Pass MockNode LinkedProjectConfigService to MockTransportService (#136004)

NodeConstruction creates a LinkedProjectConfigService via SPI.
This instance is passed to MockNode, but currently it is not
forwarded on to the MockTransportService, which results in a
new ClusterSettingsLinkedProjectConfigService being created.
This change plumbs the instance passed into MockNode down into
the MockTransportService.  In serverless tests we'll be using
an implementation based on the new ProjectCustom so we must
be able to get this new implementation created via SPI and
passed through the MockNode and into the MockTransportService
so it can be used in RemoteClusterService.

Relates: ES-12270

Author: JeremyDahlgren

test/framework/src/main/java/org/elasticsearch/node/MockNode.java

@@ -49,6 +49,7 @@
 import org.elasticsearch.test.ESTestCase;
 import org.elasticsearch.test.MockHttpTransport;
 import org.elasticsearch.test.transport.MockTransportService;
+import org.elasticsearch.test.transport.StubbableTransport;
 import org.elasticsearch.threadpool.ThreadPool;
 import org.elasticsearch.transport.LinkedProjectConfigService;
 import org.elasticsearch.transport.Transport;
@@ -201,13 +202,14 @@ protected TransportService newTransportService(
             } else {
                 return new MockTransportService(
                     settings,
-                    transport,
+                    new StubbableTransport(transport),
                     threadPool,
                     interceptor,
                     localNodeFactory,
                     clusterSettings,
-                    taskManager.getTaskHeaders(),
-                    nodeId
+                    MockTransportService.createTaskManager(settings, threadPool, taskManager.getTaskHeaders(), Tracer.NOOP, nodeId),
+                    linkedProjectConfigService,
+                    projectResolver
                 );
             }
         }

test/framework/src/main/java/org/elasticsearch/test/transport/MockTransportService.java

@@ -18,6 +18,8 @@
 import org.elasticsearch.cluster.node.DiscoveryNode;
 import org.elasticsearch.cluster.node.DiscoveryNodeUtils;
 import org.elasticsearch.cluster.node.VersionInformation;
+import org.elasticsearch.cluster.project.DefaultProjectResolver;
+import org.elasticsearch.cluster.project.ProjectResolver;
 import org.elasticsearch.common.UUIDs;
 import org.elasticsearch.common.io.stream.BytesStreamOutput;
 import org.elasticsearch.common.io.stream.NamedWriteableRegistry;
@@ -51,8 +53,10 @@
 import org.elasticsearch.test.tasks.MockTaskManager;
 import org.elasticsearch.threadpool.ThreadPool;
 import org.elasticsearch.transport.ClusterConnectionManager;
+import org.elasticsearch.transport.ClusterSettingsLinkedProjectConfigService;
 import org.elasticsearch.transport.ConnectTransportException;
 import org.elasticsearch.transport.ConnectionProfile;
+import org.elasticsearch.transport.LinkedProjectConfigService;
 import org.elasticsearch.transport.NodeNotConnectedException;
 import org.elasticsearch.transport.RequestHandlerRegistry;
 import org.elasticsearch.transport.TcpTransport;
@@ -192,7 +196,7 @@ public static MockTransportService createNewService(
         String nodeId = UUIDs.randomBase64UUID();
         return new MockTransportService(
             settings,
-            new StubbableTransport(transport),
+            transport,
             threadPool,
             interceptor,
             boundAddress -> DiscoveryNodeUtils.builder(nodeId)
@@ -203,7 +207,8 @@ public static MockTransportService createNewService(
                 .version(version)
                 .build(),
             clusterSettings,
-            createTaskManager(settings, threadPool, taskHeaders, Tracer.NOOP, nodeId)
+            taskHeaders,
+            nodeId
         );
     }
 
@@ -223,12 +228,13 @@ public static MockTransportService createMockTransportService(Transport transpor
         String nodeId = UUIDs.randomBase64UUID();
         return new MockTransportService(
             Settings.EMPTY,
-            new StubbableTransport(transport),
+            transport,
             threadPool,
             TransportService.NOOP_TRANSPORT_INTERCEPTOR,
             (boundAddress) -> DiscoveryNodeUtils.builder(nodeId).address(boundAddress.publishAddress()).build(),
             null, // clusterSettings
-            createTaskManager(Settings.EMPTY, threadPool, Set.of(), Tracer.NOOP, nodeId)
+            Set.of(),
+            nodeId
         );
     }
 
@@ -256,38 +262,22 @@ public MockTransportService(
             interceptor,
             localNodeFactory,
             clusterSettings,
-            createTaskManager(settings, threadPool, taskHeaders, Tracer.NOOP, nodeId)
+            createTaskManager(settings, threadPool, taskHeaders, Tracer.NOOP, nodeId),
+            new ClusterSettingsLinkedProjectConfigService(settings, clusterSettings, DefaultProjectResolver.INSTANCE),
+            DefaultProjectResolver.INSTANCE
         );
     }
 
     public MockTransportService(
-        Settings settings,
-        Transport transport,
-        ThreadPool threadPool,
-        TransportInterceptor interceptor,
-        Function<BoundTransportAddress, DiscoveryNode> localNodeFactory,
-        @Nullable ClusterSettings clusterSettings,
-        String nodeId
-    ) {
-        this(
-            settings,
-            new StubbableTransport(transport),
-            threadPool,
-            interceptor,
-            localNodeFactory,
-            clusterSettings,
-            createTaskManager(settings, threadPool, Set.of(), Tracer.NOOP, nodeId)
-        );
-    }
-
-    private MockTransportService(
         Settings settings,
         StubbableTransport transport,
         ThreadPool threadPool,
         TransportInterceptor interceptor,
         Function<BoundTransportAddress, DiscoveryNode> localNodeFactory,
         @Nullable ClusterSettings clusterSettings,
-        TaskManager taskManager
+        TaskManager taskManager,
+        LinkedProjectConfigService linkedProjectConfigService,
+        ProjectResolver projectResolver
     ) {
         super(
             settings,
@@ -297,7 +287,9 @@ private MockTransportService(
             localNodeFactory,
             clusterSettings,
             new StubbableConnectionManager(new ClusterConnectionManager(settings, transport, threadPool.getThreadContext())),
-            taskManager
+            taskManager,
+            linkedProjectConfigService,
+            projectResolver
         );
         this.original = transport.getDelegate();
         this.testExecutor = EsExecutors.newScaling(