Update deleteAllTopNIndices

Signed-off-by: David Zane <davizane@amazon.com>

Author: dzane17

src/main/java/org/opensearch/plugin/insights/core/service/QueryInsightsService.java

@@ -632,13 +632,22 @@ void deleteExpiredTopNIndices() {
      * @param localIndexExporter the exporter to handle the local index operations
      */
     void deleteAllTopNIndices(final Client client, final LocalIndexExporter localIndexExporter) {
-        clusterService.state()
-            .metadata()
-            .indices()
-            .entrySet()
-            .stream()
-            .filter(entry -> isTopQueriesIndex(entry.getKey(), entry.getValue()))
-            .forEach(entry -> localIndexExporter.deleteSingleIndex(entry.getKey(), client));
+        final ClusterStateRequest clusterStateRequest = new ClusterStateRequest().clear()
+            .indices(TOP_QUERIES_INDEX_PATTERN_GLOB)
+            .metadata(true)
+            .local(true)
+            .indicesOptions(IndicesOptions.strictExpand());
+
+        client.admin().cluster().state(clusterStateRequest, ActionListener.wrap(clusterStateResponse -> {
+            logger.error(clusterStateResponse.getState().metadata().indices());
+            clusterStateResponse.getState()
+                .metadata()
+                .indices()
+                .entrySet()
+                .stream()
+                .filter(entry -> isTopQueriesIndex(entry.getKey(), entry.getValue()))
+                .forEach(entry -> localIndexExporter.deleteSingleIndex(entry.getKey(), client));
+        }, exception -> { logger.error("Error while deleting expired top_queries-* indices: ", exception); }));
     }
 
     /**

src/test/java/org/opensearch/plugin/insights/core/service/QueryInsightsServiceTests.java

@@ -33,8 +33,8 @@
 
 import java.io.IOException;
 import java.time.Instant;
+import java.time.LocalDate;
 import java.time.ZoneId;
-import java.time.ZoneOffset;
 import java.time.ZonedDateTime;
 import java.time.format.DateTimeFormatter;
 import java.time.temporal.ChronoUnit;
@@ -358,10 +358,8 @@ public void testDeleteExpiredTopNIndices() throws InterruptedException, IOExcept
         // Create 9 top_queries-* indices with creation dates older than the retention period
         Map<String, IndexMetadata> indexMetadataMap = new HashMap<>();
         for (int i = 1; i < 10; i++) {
-            String indexName = "top_queries-2023.01.0"
-                + i
-                + "-"
-                + generateLocalIndexDateHash(ZonedDateTime.now(ZoneOffset.UTC).toLocalDate());
+            LocalDate date = LocalDate.of(2023, 1, i);
+            String indexName = "top_queries-" + date.format(format) + "-" + generateLocalIndexDateHash(date);
             long creationTime = Instant.now().minus(i + 100, ChronoUnit.DAYS).toEpochMilli(); // Ensure indices are expired
             IndexMetadata indexMetadata = IndexMetadata.builder(indexName)
                 .settings(