From 46310faaf386846d124aea54fd3437561fda8489 Mon Sep 17 00:00:00 2001
From: Megha Goyal <goyamegh@amazon.com>
Date: Fri, 15 Mar 2024 10:36:53 -0700
Subject: [PATCH] Merge conflicts

Signed-off-by: Megha Goyal <goyamegh@amazon.com>
---
 .../alerting/DocumentLevelMonitorRunner.kt    | 64 +++++++++----------
 1 file changed, 30 insertions(+), 34 deletions(-)

diff --git a/alerting/src/main/kotlin/org/opensearch/alerting/DocumentLevelMonitorRunner.kt b/alerting/src/main/kotlin/org/opensearch/alerting/DocumentLevelMonitorRunner.kt
index 6af9db83a..f7a4e7a5c 100644
--- a/alerting/src/main/kotlin/org/opensearch/alerting/DocumentLevelMonitorRunner.kt
+++ b/alerting/src/main/kotlin/org/opensearch/alerting/DocumentLevelMonitorRunner.kt
@@ -140,32 +140,29 @@ object DocumentLevelMonitorRunner : MonitorRunner() {
                 }
             }
 
-            indices.forEach { indexName ->
-                // Prepare lastRunContext for each index
-                val indexLastRunContext = lastRunContext.getOrPut(indexName) {
-                    val isIndexCreatedRecently = createdRecently(
-                        monitor,
-                        periodStart,
-                        periodEnd,
-                        monitorCtx.clusterService!!.state().metadata.index(indexName)
-                    )
-                    val updatedIndexName = indexName.replace("*", "_")
-                    val conflictingFields = monitorCtx.docLevelMonitorQueries!!.getAllConflictingFields(
-                        monitorCtx.clusterService!!.state(),
-                        concreteIndices
-                    )
+            docLevelMonitorInput.indices.forEach { indexName ->
+                val concreteIndices = IndexUtils.resolveAllIndices(
+                    listOf(indexName),
+                    monitorCtx.clusterService!!,
+                    monitorCtx.indexNameExpressionResolver!!
+                )
+                val updatedIndexName = indexName.replace("*", "_")
+                val conflictingFields = monitorCtx.docLevelMonitorQueries!!.getAllConflictingFields(
+                    monitorCtx.clusterService!!.state(),
+                    concreteIndices
+                )
 
-                    concreteIndices.forEach { concreteIndexName ->
-                        // Prepare lastRunContext for each index
-                        val indexLastRunContext = lastRunContext.getOrPut(concreteIndexName) {
-                            val isIndexCreatedRecently = createdRecently(
-                                monitor,
-                                periodStart,
-                                periodEnd,
-                                monitorCtx.clusterService!!.state().metadata.index(concreteIndexName)
-                            )
-                            MonitorMetadataService.createRunContextForIndex(concreteIndexName, isIndexCreatedRecently)
-                        }
+                concreteIndices.forEach { concreteIndexName ->
+                    // Prepare lastRunContext for each index
+                    val indexLastRunContext = lastRunContext.getOrPut(concreteIndexName) {
+                        val isIndexCreatedRecently = createdRecently(
+                            monitor,
+                            periodStart,
+                            periodEnd,
+                            monitorCtx.clusterService!!.state().metadata.index(concreteIndexName)
+                        )
+                        MonitorMetadataService.createRunContextForIndex(concreteIndexName, isIndexCreatedRecently)
+                    }
 
                     // Prepare updatedLastRunContext for each index
                     val indexUpdatedRunContext = updateLastRunContext(
@@ -189,15 +186,14 @@ object DocumentLevelMonitorRunner : MonitorRunner() {
                     // Prepare DocumentExecutionContext for each index
                     val docExecutionContext = DocumentExecutionContext(queries, indexLastRunContext, indexUpdatedRunContext)
 
-                val matchingDocs = getMatchingDocs(
-                    monitor,
-                    monitorCtx,
-                    docExecutionContext,
-                    indexName,
-                    updatedIndexName,
-                    concreteIndexName,
-                    conflictingFields.toList()
-                )
+                    val matchingDocs = getMatchingDocs(
+                        monitor,
+                        monitorCtx,
+                        docExecutionContext,
+                        updatedIndexName,
+                        concreteIndexName,
+                        conflictingFields.toList()
+                    )
 
                     if (matchingDocs.isNotEmpty()) {
                         val matchedQueriesForDocs = getMatchedQueries(