Function getSourceNamesFromIndexDef

rest_auth.go:212–259

(indexDef *cbgt.IndexDef)

}

func getSourceNamesFromIndexDef(indexDef *cbgt.IndexDef) ([]string, error) {
	if len(indexDef.Params) > 0 {
		bleveParamBytes := []byte(indexDef.Params)
		docConfig, _, _, err := jsonparser.Get(bleveParamBytes, "doc_config")
		if err != nil {
			// couldn't find doc_config to detect the mode
			return []string{indexDef.SourceName}, nil
		}

		docConfigMode, _, _, _ := jsonparser.Get(docConfig, "mode")
		if strings.HasPrefix(string(docConfigMode), ConfigModeCollPrefix) {
			// look up the scope/collection details from the cache.
			scopeName, collectionNames := metaFieldValCache.getScopeCollectionNames(indexDef.Name)
			if len(scopeName) > 0 && len(collectionNames) > 0 {
				sourceNames := make([]string, len(collectionNames))
				for i := range collectionNames {
					sourceNames[i] = indexDef.SourceName + ":" + scopeName + ":" + collectionNames[i]
				}
				return sourceNames, nil
			}

			// parse it again if the cache is empty like that in a unit test.
			bmapping, _, _, err := jsonparser.Get(bleveParamBytes, "mapping")
			if err != nil {
				return nil, err
			}

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

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

			sourceNames := make([]string, len(colNames))
			for i, colName := range colNames {
				sourceNames[i] = indexDef.SourceName + ":" + sName + ":" + colName
			}
			return sourceNames, nil
		}
	}

	return []string{indexDef.SourceName}, nil
}

// an interface to abstract the bare minimum aspect of a cbgt.Manager
// that we need, so that we can stub the interface for testing