fix: remove GcpPubSubEmulatorAutoConfiguration and update test configuration for PubSub transport channel

Author: admitrov

embedded-google-pubsub/src/main/java/com/playtika/testcontainer/pubsub/EmbeddedPubsubDependenciesAutoConfiguration.java

@@ -2,7 +2,6 @@
 
 import com.google.cloud.spring.autoconfigure.core.GcpContextAutoConfiguration;
 import com.google.cloud.spring.autoconfigure.pubsub.GcpPubSubAutoConfiguration;
-import com.google.cloud.spring.autoconfigure.pubsub.GcpPubSubEmulatorAutoConfiguration;
 import com.google.cloud.spring.pubsub.core.PubSubTemplate;
 import com.playtika.testcontainer.common.spring.DependsOnPostProcessor;
 import org.springframework.beans.factory.config.BeanFactoryPostProcessor;
@@ -18,7 +17,7 @@
 
 @AutoConfiguration
 @AutoConfigureOrder
-@ImportAutoConfiguration(classes = {GcpContextAutoConfiguration.class, GcpPubSubEmulatorAutoConfiguration.class, GcpPubSubAutoConfiguration.class})
+@ImportAutoConfiguration(classes = {GcpContextAutoConfiguration.class, GcpPubSubAutoConfiguration.class})
 @ConditionalOnExpression("${embedded.containers.enabled:true}")
 @ConditionalOnClass(PubSubTemplate.class)
 @ConditionalOnProperty(name = "embedded.google.pubsub.enabled", matchIfMissing = true)

embedded-google-pubsub/src/test/java/com/playtika/testcontainer/pubsub/EmbeddedPubsubBootstrapConfigurationTest.java

@@ -1,20 +1,32 @@
 package com.playtika.testcontainer.pubsub;
 
+import com.google.api.gax.core.CredentialsProvider;
+import com.google.api.gax.core.FixedCredentialsProvider;
+import com.google.api.gax.grpc.GrpcTransportChannel;
+import com.google.api.gax.rpc.FixedTransportChannelProvider;
+import com.google.api.gax.rpc.TransportChannelProvider;
+import com.google.cloud.NoCredentials;
 import com.google.cloud.spring.pubsub.core.PubSubTemplate;
 import com.google.cloud.spring.pubsub.support.AcknowledgeablePubsubMessage;
 import com.google.pubsub.v1.DeadLetterPolicy;
 import com.google.pubsub.v1.ProjectSubscriptionName;
 import com.google.pubsub.v1.Subscription;
 import com.google.pubsub.v1.TopicName;
+import io.grpc.ManagedChannel;
+import io.grpc.ManagedChannelBuilder;
 import lombok.extern.slf4j.Slf4j;
 import org.junit.jupiter.api.Test;
 import org.springframework.beans.factory.BeanFactoryUtils;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.beans.factory.config.ConfigurableListableBeanFactory;
 import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
 import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Primary;
 import org.springframework.core.env.ConfigurableEnvironment;
 import org.springframework.test.context.ActiveProfiles;
 import org.testcontainers.containers.GenericContainer;
@@ -48,6 +60,25 @@ class EmbeddedPubsubBootstrapConfigurationTest {
     @EnableAutoConfiguration
     @Configuration
     static class TestConfiguration {
+
+        @Bean
+        @Primary
+        @ConditionalOnProperty(name = "embedded.google.pubsub.enabled", matchIfMissing = true)
+        public TransportChannelProvider pubsubTransportChannelProvider(@Qualifier(BEAN_NAME_EMBEDDED_GOOGLE_PUBSUB) GenericContainer<?> container,
+                                                                        PubsubProperties properties) {
+            String host = container.getHost();
+            Integer port = container.getMappedPort(properties.getPort());
+            ManagedChannel channel = ManagedChannelBuilder.forAddress(host, port)
+                    .usePlaintext()
+                    .build();
+            return FixedTransportChannelProvider.create(GrpcTransportChannel.create(channel));
+        }
+
+        @Bean
+        @Primary
+        public CredentialsProvider googleCredentials() {
+            return FixedCredentialsProvider.create(NoCredentials.getInstance());
+        }
     }
 
     @Test

embedded-google-pubsub/src/test/resources/application-enabled.yaml

@@ -1,3 +1,2 @@
 spring.cloud.gcp:
-  project-id: ${embedded.google.pubsub.project-id}
-  pubsub.emulatorHost: ${embedded.google.pubsub.host}:${embedded.google.pubsub.port}
+  project-id: my-project-id