JsonSchema to bleve mapping

mapper.go

func addSchemaMapper(schema *Schema) {
	ix := schema.GetIndexer()
	if ix == nil {
		println("Schema does not have an indexer")
		return
	}

	unindexedFieldMapping := bleve.NewTextFieldMapping()
	unindexedFieldMapping.Index = false
	unindexedFieldMapping.Store = false

	// a generic reusable mapping for english text
	englishTextFieldMapping := bleve.NewTextFieldMapping()
	englishTextFieldMapping.Analyzer = "en"
	englishTextFieldMapping.Store = false

	keywordFieldMapping := bleve.NewTextFieldMapping()
	keywordFieldMapping.Analyzer = "keyword"
	keywordFieldMapping.Store = true

	// emailFieldMapping := bleve.NewTextFieldMapping()

	mapping := bleve.NewDocumentMapping()
	indexed_fields := schema.GetIndexedFields()
	indexed_fields_set := mapset.NewSetFromSlice(indexed_fields)
	fields := schema.GetFields()
	for k, f := range fields {
		var field string
		if f, ok := f.(map[string]interface{})["name"].(string); ok {
			field = f
		} else {
			field = string(k)
		}
		if indexed_fields_set.Contains(field) {
			switch schema.GetPropIndexType(field) {
			case "email":
				println("Add field mapping", schema.Name, field, "email")
				mapping.AddFieldMappingsAt(field, keywordFieldMapping)
			// case "string":
			// 	println("Add field mapping", schema.Name, field)
			// 	mapping.AddFieldMappingsAt(field, keywordFieldMapping)
			default:
				println("Add field mapping", schema.Name, field)
				mapping.AddFieldMappingsAt(field, englishTextFieldMapping)
			}
		} else {
			mapping.AddFieldMappingsAt(field, unindexedFieldMapping)
		}

	}
	mapping.AddFieldMappingsAt("type", keywordFieldMapping)
	ix.AddDocumentMapping(schema.Name, mapping)
}