From 1a3ce2a4710f0a71994b47e05494f739e37f37fb Mon Sep 17 00:00:00 2001
From: "anjali.agarwal" <anjali.aggarwal@gojek.com>
Date: Wed, 4 Oct 2023 17:03:29 +0530
Subject: [PATCH] add test case

---
 internal/store/elasticsearch/es_test.go | 44 +++++++++++++++++++++++++
 1 file changed, 44 insertions(+)

diff --git a/internal/store/elasticsearch/es_test.go b/internal/store/elasticsearch/es_test.go
index ab7bb6e7..955f7c75 100644
--- a/internal/store/elasticsearch/es_test.go
+++ b/internal/store/elasticsearch/es_test.go
@@ -122,6 +122,50 @@ func TestElasticsearch(t *testing.T) {
 						analyzedTokens = append(analyzedTokens, tok.Token)
 					}
 
+					if reflect.DeepEqual(expectTokens, analyzedTokens) == false {
+						return fmt.Errorf("expected analyzer to tokenize %q as %v, was %v", textToAnalyze, expectTokens, analyzedTokens)
+					}
+					return nil
+				},
+			},
+			{
+				Title:   "created index should be able to correctly tokenize CamelCase text",
+				Service: daggerService,
+				Validate: func(esClient *store.Client, cli *elasticsearch.Client, indexName string) error {
+					textToAnalyze := "walking"
+					analyzerPath := fmt.Sprintf("/%s/_analyze", indexName)
+					analyzerPayload := fmt.Sprintf(`{"analyzer": "my_analyzer", "text": %q}`, textToAnalyze)
+
+					//nolint:noctx
+					req, err := http.NewRequest("POST", analyzerPath, strings.NewReader(analyzerPayload))
+					if err != nil {
+						return fmt.Errorf("error creating analyzer request: %w", err)
+					}
+					req.Header.Add("content-type", "application/json")
+
+					res, err := cli.Perform(req)
+					if err != nil {
+						return fmt.Errorf("invoke analyzer: %w", err)
+					}
+					defer res.Body.Close()
+					if res.StatusCode != http.StatusOK {
+						return fmt.Errorf("elasticsearch returned non-200 response: %d", res.StatusCode)
+					}
+					var response struct {
+						Tokens []struct {
+							Token string `json:"token"`
+						} `json:"tokens"`
+					}
+					err = json.NewDecoder(res.Body).Decode(&response)
+					if err != nil {
+						return fmt.Errorf("error decoding response: %w", err)
+					}
+					expectTokens := []string{"walk"}
+					analyzedTokens := []string{}
+					for _, tok := range response.Tokens {
+						analyzedTokens = append(analyzedTokens, tok.Token)
+					}
+
 					if reflect.DeepEqual(expectTokens, analyzedTokens) == false {
 						return fmt.Errorf("expected analyzer to tokenize %q as %v, was %v", textToAnalyze, expectTokens, analyzedTokens)
 					}