Adding user context.

Signed-off-by: AWSHurneyt <[email protected]>
AWSHurneyt · Jan 25, 2024 · 2ec34d0 · 2ec34d0
1 parent b284919
commit 2ec34d0
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/...ting/src/main/kotlin/org/opensearch/alerting/transport/TransportGetRemoteIndexesAction.kt b/...ting/src/main/kotlin/org/opensearch/alerting/transport/TransportGetRemoteIndexesAction.kt
@@ -33,6 +33,7 @@ import org.opensearch.cluster.service.ClusterService
 import org.opensearch.common.inject.Inject
 import org.opensearch.common.settings.Settings
 import org.opensearch.common.xcontent.XContentType
+import org.opensearch.commons.ConfigConstants
 import org.opensearch.commons.alerting.util.string
 import org.opensearch.core.xcontent.NamedXContentRegistry
 import org.opensearch.core.xcontent.ToXContent
@@ -81,6 +82,9 @@ class TransportGetRemoteIndexesAction @Inject constructor(
         }
 
         client.threadPool().threadContext.stashContext().use {
+            val userStr = client.threadPool().threadContext
+                .getTransient<String>(ConfigConstants.OPENSEARCH_SECURITY_USER_INFO_THREAD_CONTEXT)
+            client.threadPool().threadContext.putTransient(ConfigConstants.OPENSEARCH_SECURITY_USER_INFO_THREAD_CONTEXT, userStr)
             scope.launch {
                 val clusterIndexesList = mutableListOf<ClusterIndexes>()