From 7592e9d9a7a7801013654fe338ead8030b5d38eb Mon Sep 17 00:00:00 2001 From: Rahul Bhardwaj Date: Wed, 21 Aug 2024 15:46:30 +0530 Subject: [PATCH] Add testcases for opensearch index crud --- databases_test.go | 82 +++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 82 insertions(+) diff --git a/databases_test.go b/databases_test.go index 395d58be..737f63b0 100644 --- a/databases_test.go +++ b/databases_test.go @@ -3225,3 +3225,85 @@ func TestDatabases_ListDatabaseEvents(t *testing.T) { require.NoError(t, err) require.Equal(t, want, got) } + +func TestDatabases_ListIndexes(t *testing.T) { + setup() + defer teardown() + + dbID := "deadbeef-dead-4aa5-beef-deadbeef347d" + + path := fmt.Sprintf("/v2/databases/%s/indexes", dbID) + + want := []DatabaseIndex{ + { + IndexName: "sample_index", + NumberofShards: uint64(1), + NumberofReplicas: uint64(0), + CreateTime: "2020-10-29T15:57:38Z", + Health: "green", + Size: int64(5314), + Status: "open", + Docs: int64(64811), + }, + { + IndexName: "sample_index_2", + NumberofShards: uint64(1), + NumberofReplicas: uint64(0), + CreateTime: "2020-10-30T15:57:38Z", + Health: "red", + Size: int64(6105247), + Status: "close", + Docs: int64(64801), + }, + } + + body := `{ + "indexes": [ + { + "create_time": "2020-10-29T15:57:38Z", + "docs": 64811, + "health": "green", + "index_name": "sample_index", + "number_of_replica": 0, + "number_of_shards": 1, + "size": 5314, + "status": "open" + }, + { + "create_time": "2020-10-30T15:57:38Z", + "docs": 64801, + "health": "red", + "index_name": "sample_index_2", + "number_of_replica": 0, + "number_of_shards": 1, + "size": 6105247, + "status": "close" + }] + } ` + + mux.HandleFunc(path, func(w http.ResponseWriter, r *http.Request) { + testMethod(t, r, http.MethodGet) + fmt.Fprint(w, body) + }) + + got, _, err := client.Databases.ListIndexes(ctx, dbID, &ListOptions{}) + require.NoError(t, err) + require.Equal(t, want, got) +} + +func TestDatabases_DeleteIndexes(t *testing.T) { + setup() + defer teardown() + + dbID := "deadbeef-dead-4aa5-beef-deadbeef347d" + indexName := "sample_index" + + path := fmt.Sprintf("/v2/databases/%s/indexes/%s", dbID, indexName) + + mux.HandleFunc(path, func(w http.ResponseWriter, r *http.Request) { + testMethod(t, r, http.MethodDelete) + }) + + _, err := client.Databases.DeleteIndex(ctx, dbID, indexName) + require.NoError(t, err) +}