Function parseSourceNamesFromIndexDefs

rest_backup_restore.go:581–623

(indexDef *cbgt.IndexDef)

}

func parseSourceNamesFromIndexDefs(indexDef *cbgt.IndexDef) []string {
	if len(indexDef.Params) > 0 {
		bleveParamBytes := []byte(indexDef.Params)
		docConfig, _, _, err := jsonparser.Get(bleveParamBytes, "doc_config")
		if err != nil {
			return []string{indexDef.SourceName + "." + defaultScopeName +
				"." + defaultCollName}
		}

		docConfigMode, _, _, _ := jsonparser.Get(docConfig, "mode")
		if strings.HasPrefix(string(docConfigMode), "scope.collection") {
			bmapping, _, _, err := jsonparser.Get(bleveParamBytes, "mapping")
			if err != nil {
				return nil
			}

			mapping := bleve.NewIndexMapping()
			err = json.Unmarshal(bmapping, mapping)
			if err != nil {
				return nil
			}

			sname, colNames, _, err := getScopeCollTypeMappings(mapping, true)
			if err != nil {
				return nil
			}

			var rv []string
			for _, cname := range colNames {
				rv = append(rv, indexDef.SourceName+"."+sname+"."+cname)
			}
			sort.Strings(rv)
			return rv
		}
	}

	if indexDef.SourceName != "" {
		return []string{indexDef.SourceName + "." + defaultScopeName +
			"." + defaultCollName}
	}

	return nil
}