Function processRemapRequest

rest_backup_restore.go:140–171

(req *http.Request, bucketName string)

}

func processRemapRequest(req *http.Request, bucketName string) (
	*cbgt.IndexDefs, error) {
	requestBody, err := ioutil.ReadAll(req.Body)
	if err != nil {
		return nil, fmt.Errorf("failed to read request body, err: %v", err)
	}

	indexDefs := &cbgt.IndexDefs{}
	if len(requestBody) > 0 {
		err := json.Unmarshal(requestBody, indexDefs)
		if err != nil {
			return nil, fmt.Errorf("requestBody: %s, json unmarshal err: %v", requestBody, err)
		}
	}

	if len(indexDefs.IndexDefs) == 0 {
		return nil, fmt.Errorf("requestBody: no index definitions parsed")
	}

	queryParams := req.URL.Query()
	params := queryParams.Get("remap")
	mapingRules, err := parseMappingParams(params)
	if err != nil {
		return nil, err
	}
	indexDefs, err = remapIndexDefinitions(indexDefs, mapingRules, bucketName)
	if err != nil {
		return nil, fmt.Errorf("index remapping error: %v", err)
	}

	return indexDefs, nil
}

func parseMappingParams(params string) (map[string]string, error) {
	rv := make(map[string]string)