Refactor to use TransportLocalProjectMetadataAction

Author: PeteGillinElastic

x-pack/plugin/ilm/src/main/java/org/elasticsearch/xpack/ilm/action/TransportExplainLifecycleAction.java

@@ -11,8 +11,8 @@
 import org.elasticsearch.action.ActionListener;
 import org.elasticsearch.action.support.ActionFilters;
 import org.elasticsearch.action.support.ChannelActionListener;
-import org.elasticsearch.action.support.local.TransportLocalClusterStateAction;
-import org.elasticsearch.cluster.ClusterState;
+import org.elasticsearch.action.support.local.TransportLocalProjectMetadataAction;
+import org.elasticsearch.cluster.ProjectState;
 import org.elasticsearch.cluster.block.ClusterBlockException;
 import org.elasticsearch.cluster.block.ClusterBlockLevel;
 import org.elasticsearch.cluster.metadata.IndexMetadata;
@@ -52,11 +52,12 @@
 import static org.elasticsearch.index.IndexSettings.LIFECYCLE_ORIGINATION_DATE;
 import static org.elasticsearch.xpack.core.ilm.WaitForRolloverReadyStep.applyDefaultConditions;
 
-public class TransportExplainLifecycleAction extends TransportLocalClusterStateAction<ExplainLifecycleRequest, ExplainLifecycleResponse> {
+public class TransportExplainLifecycleAction extends TransportLocalProjectMetadataAction<
+    ExplainLifecycleRequest,
+    ExplainLifecycleResponse> {
 
     private final NamedXContentRegistry xContentRegistry;
     private final IndexNameExpressionResolver indexNameExpressionResolver;
-    private final ProjectResolver projectResolver;
 
     /**
      * NB prior to 9.0 this was a TransportMasterNodeReadAction so for BwC it must be registered with the TransportService until
@@ -79,11 +80,11 @@ public TransportExplainLifecycleAction(
             actionFilters,
             transportService.getTaskManager(),
             clusterService,
-            threadPool.executor(ThreadPool.Names.MANAGEMENT)
+            threadPool.executor(ThreadPool.Names.MANAGEMENT),
+            projectResolver
         );
         this.xContentRegistry = xContentRegistry;
         this.indexNameExpressionResolver = indexNameExpressionResolver;
-        this.projectResolver = projectResolver;
 
         transportService.registerRequestHandler(
             actionName,
@@ -97,33 +98,33 @@ public TransportExplainLifecycleAction(
     }
 
     @Override
-    protected ClusterBlockException checkBlock(ExplainLifecycleRequest request, ClusterState state) {
-        return state.blocks()
+    protected ClusterBlockException checkBlock(ExplainLifecycleRequest request, ProjectState project) {
+        return project.blocks()
             .indicesBlockedException(
-                projectResolver.getProjectId(),
+                project.projectId(),
                 ClusterBlockLevel.METADATA_READ,
-                indexNameExpressionResolver.concreteIndexNames(state, request)
+                indexNameExpressionResolver.concreteIndexNames(project.metadata(), request)
             );
     }
 
     @Override
     protected void localClusterStateOperation(
         Task task,
         ExplainLifecycleRequest request,
-        final ClusterState state,
+        ProjectState project,
         ActionListener<ExplainLifecycleResponse> listener
     ) {
-        String[] concreteIndices = indexNameExpressionResolver.concreteIndexNames(state, request);
+        String[] concreteIndices = indexNameExpressionResolver.concreteIndexNames(project.metadata(), request);
         boolean rolloverOnlyIfHasDocuments = LifecycleSettings.LIFECYCLE_ROLLOVER_ONLY_IF_HAS_DOCUMENTS_SETTING.get(
-            state.metadata().settings()
+            project.cluster().metadata().settings()
         );
         Map<String, IndexLifecycleExplainResponse> indexResponses = new TreeMap<>();
         for (String index : concreteIndices) {
             final IndexLifecycleExplainResponse indexResponse;
             try {
                 indexResponse = getIndexLifecycleExplainResponse(
                     index,
-                    projectResolver.getProjectMetadata(state.metadata()),
+                    project.metadata(),
                     request.onlyErrors(),
                     request.onlyManaged(),
                     xContentRegistry,