Add origin for post write refresh (elastic#95506)

Which sends unpromotable refresh actions internally

Relates ES-5884

Author: kingherc

server/src/main/java/org/elasticsearch/action/support/replication/PostWriteRefresh.java

@@ -15,6 +15,7 @@
 import org.elasticsearch.action.admin.indices.refresh.TransportUnpromotableShardRefreshAction;
 import org.elasticsearch.action.admin.indices.refresh.UnpromotableShardRefreshRequest;
 import org.elasticsearch.action.support.WriteRequest;
+import org.elasticsearch.common.util.concurrent.ThreadContext;
 import org.elasticsearch.core.Nullable;
 import org.elasticsearch.core.TimeValue;
 import org.elasticsearch.index.engine.Engine;
@@ -26,6 +27,7 @@
 
 public class PostWriteRefresh {
 
+    public static final String POST_WRITE_REFRESH_ORIGIN = "post_write_refresh";
     public static final String FORCED_REFRESH_AFTER_INDEX = "refresh_flag_index";
     private final TransportService transportService;
 
@@ -119,7 +121,13 @@ private void refreshUnpromotables(
         engineOrNull.addFlushListener(location, ActionListener.wrap(new ActionListener<>() {
             @Override
             public void onResponse(Long generation) {
-                sendUnpromotableRequests(indexShard, generation, forced, listener, postWriteRefreshTimeout);
+                try (
+                    ThreadContext.StoredContext ignore = transportService.getThreadPool()
+                        .getThreadContext()
+                        .stashWithOrigin(POST_WRITE_REFRESH_ORIGIN)
+                ) {
+                    sendUnpromotableRequests(indexShard, generation, forced, listener, postWriteRefreshTimeout);
+                }
             }
 
             @Override

x-pack/plugin/security/src/main/java/org/elasticsearch/xpack/security/authz/AuthorizationUtils.java

@@ -16,13 +16,15 @@
 import org.elasticsearch.xpack.core.security.support.Automatons;
 import org.elasticsearch.xpack.core.security.user.AsyncSearchUser;
 import org.elasticsearch.xpack.core.security.user.SecurityProfileUser;
+import org.elasticsearch.xpack.core.security.user.StorageInternalUser;
 import org.elasticsearch.xpack.core.security.user.XPackSecurityUser;
 import org.elasticsearch.xpack.core.security.user.XPackUser;
 
 import java.util.function.Consumer;
 import java.util.function.Predicate;
 
 import static org.elasticsearch.action.admin.cluster.node.tasks.get.GetTaskAction.TASKS_ORIGIN;
+import static org.elasticsearch.action.support.replication.PostWriteRefresh.POST_WRITE_REFRESH_ORIGIN;
 import static org.elasticsearch.cluster.metadata.DataLifecycle.DLM_ORIGIN;
 import static org.elasticsearch.ingest.IngestService.INGEST_ORIGIN;
 import static org.elasticsearch.persistent.PersistentTasksService.PERSISTENT_TASK_ORIGIN;
@@ -125,6 +127,9 @@ public static void switchUserBasedOnActionOriginAndExecute(
             case SECURITY_PROFILE_ORIGIN:
                 securityContext.executeAsInternalUser(SecurityProfileUser.INSTANCE, version, consumer);
                 break;
+            case POST_WRITE_REFRESH_ORIGIN:
+                securityContext.executeAsInternalUser(StorageInternalUser.INSTANCE, version, consumer);
+                break;
             case WATCHER_ORIGIN:
             case ML_ORIGIN:
             case MONITORING_ORIGIN: