remove old tests elastic#135942

Author: slobodanadamovic

x-pack/plugin/security/src/test/java/org/elasticsearch/xpack/security/transport/CrossClusterAccessTransportInterceptorTests.java

@@ -404,107 +404,6 @@ public <T extends TransportResponse> void sendRequest(
         assertThat(securityContext.getThreadContext().getHeader(CROSS_CLUSTER_ACCESS_CREDENTIALS_HEADER_KEY), nullValue());
     }
 
-    public void testSendWithCrossClusterAccessHeadersThrowsOnOldConnection() throws Exception {
-        final Authentication authentication = AuthenticationTestHelper.builder()
-            .user(new User(randomAlphaOfLengthBetween(3, 10), randomArray(0, 4, String[]::new, () -> randomAlphaOfLengthBetween(1, 20))))
-            .realm()
-            .build();
-        authentication.writeToContext(threadContext);
-        final String remoteClusterAlias = randomAlphaOfLengthBetween(5, 10);
-        final String encodedApiKey = randomAlphaOfLengthBetween(10, 42);
-        final String remoteClusterCredential = ApiKeyService.withApiKeyPrefix(encodedApiKey);
-
-        final SecurityServerTransportInterceptor interceptor = new SecurityServerTransportInterceptor(
-            settings,
-            threadPool,
-            mock(AuthenticationService.class),
-            mock(AuthorizationService.class),
-            mockSslService(),
-            securityContext,
-            destructiveOperations,
-            new CrossClusterAccessTransportInterceptor(
-                settings,
-                threadPool,
-                mock(AuthenticationService.class),
-                mock(AuthorizationService.class),
-                securityContext,
-                mock(CrossClusterAccessAuthenticationService.class),
-                crossClusterApiKeySignatureManager,
-                mockLicenseState,
-                ignored -> Optional.of(
-                    new RemoteConnectionManager.RemoteClusterAliasWithCredentials(
-                        remoteClusterAlias,
-                        new SecureString(encodedApiKey.toCharArray())
-                    )
-                )
-            )
-        );
-
-        final TransportInterceptor.AsyncSender sender = interceptor.interceptSender(new TransportInterceptor.AsyncSender() {
-            @Override
-            public <T extends TransportResponse> void sendRequest(
-                Transport.Connection connection,
-                String action,
-                TransportRequest request,
-                TransportRequestOptions options,
-                TransportResponseHandler<T> handler
-            ) {
-                fail("sender should not be called");
-            }
-        });
-        final Transport.Connection connection = mock(Transport.Connection.class);
-        final TransportVersion versionBeforeCrossClusterAccessRealm = TransportVersionUtils.getPreviousVersion(
-            RemoteClusterPortSettings.TRANSPORT_VERSION_ADVANCED_REMOTE_CLUSTER_SECURITY
-        );
-        final TransportVersion version = TransportVersionUtils.randomVersionBetween(
-            random(),
-            TransportVersions.V_8_0_0,
-            versionBeforeCrossClusterAccessRealm
-        );
-        when(connection.getTransportVersion()).thenReturn(version);
-        final AtomicBoolean calledHandleException = new AtomicBoolean(false);
-        final AtomicReference<TransportException> actualException = new AtomicReference<>();
-        sender.sendRequest(connection, "action", mock(TransportRequest.class), null, new TransportResponseHandler<>() {
-            @Override
-            public Executor executor() {
-                return TransportResponseHandler.TRANSPORT_WORKER;
-            }
-
-            @Override
-            public void handleResponse(TransportResponse response) {
-                fail("should not receive a response");
-            }
-
-            @Override
-            public void handleException(TransportException exp) {
-                if (calledHandleException.compareAndSet(false, true) == false) {
-                    fail("handle exception called more than once");
-                }
-                actualException.set(exp);
-            }
-
-            @Override
-            public TransportResponse read(StreamInput in) {
-                fail("should not receive a response");
-                return null;
-            }
-        });
-        assertThat(actualException.get(), instanceOf(SendRequestTransportException.class));
-        assertThat(actualException.get().getCause(), instanceOf(IllegalArgumentException.class));
-        assertThat(
-            actualException.get().getCause().getMessage(),
-            equalTo(
-                "Settings for remote cluster ["
-                    + remoteClusterAlias
-                    + "] indicate cross cluster access headers should be sent but target cluster version ["
-                    + connection.getTransportVersion().toReleaseVersion()
-                    + "] does not support receiving them"
-            )
-        );
-        assertThat(securityContext.getThreadContext().getHeader(CROSS_CLUSTER_ACCESS_SUBJECT_INFO_HEADER_KEY), nullValue());
-        assertThat(securityContext.getThreadContext().getHeader(CROSS_CLUSTER_ACCESS_CREDENTIALS_HEADER_KEY), nullValue());
-    }
-
     public void testSendRemoteRequestFailsIfUserHasNoRemoteIndicesPrivileges() throws Exception {
         final Authentication authentication = AuthenticationTestHelper.builder()
             .user(new User(randomAlphaOfLengthBetween(3, 10), randomRoles()))