Fix elasticsearch mapping comparison for healthcheck

Financial-Times · Jul 6, 2020 · 785fb02 · 785fb02
1 parent 54a73cd
commit 785fb02
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/pkg/es/service.go b/pkg/es/service.go
@@ -57,12 +57,13 @@ func (s *ElasticsearchService) GetSchemaHealth() (string, error) {
 			return "", err
 		}
 
-		fullReferenceJSON := []byte(fmt.Sprintf(`{"ft": %s}`, string(referenceJSON)))
+		fullReferenceJSON := []byte(fmt.Sprintf(`{"%s": %s}`, s.IndexName, string(referenceJSON)))
 		err = json.Unmarshal(fullReferenceJSON, &referenceIndex.index)
 		if err != nil {
 			return "", err
 		}
 	}
+
 	if referenceIndex.index[s.IndexName] == nil || referenceIndex.index[s.IndexName].Settings == nil || referenceIndex.index[s.IndexName].Mappings == nil {
 		return "not ok, wrong referenceIndex", nil
 	}