feat: #261 Adding GooglePubSub support

Signed-off-by: Laurent Broudoux <laurent.broudoux@gmail.com>

Author: lbroudoux

pom.xml

@@ -158,6 +158,19 @@
       <scope>test</scope>
     </dependency>
 
+    <dependency>
+      <groupId>org.testcontainers</groupId>
+      <artifactId>gcloud</artifactId>
+      <version>${testcontainers.version}</version>
+      <scope>test</scope>
+    </dependency>
+    <dependency>
+      <groupId>com.google.cloud</groupId>
+      <artifactId>google-cloud-pubsub</artifactId>
+      <version>1.134.1</version>
+      <scope>test</scope>
+    </dependency>
+
     <dependency>
       <groupId>com.github.dasniko</groupId>
       <artifactId>testcontainers-keycloak</artifactId>

src/main/java/io/github/microcks/testcontainers/MicrocksAsyncMinionContainer.java

@@ -17,6 +17,7 @@
 
 import io.github.microcks.testcontainers.connection.AmazonServiceConnection;
 import io.github.microcks.testcontainers.connection.GenericConnection;
+import io.github.microcks.testcontainers.connection.GooglePubSubConnection;
 import io.github.microcks.testcontainers.connection.KafkaConnection;
 
 import org.testcontainers.containers.GenericContainer;
@@ -187,6 +188,23 @@ public MicrocksAsyncMinionContainer withAmazonSNSConnection(AmazonServiceConnect
       return this;
    }
 
+   /**
+    * Connect the MicrocksAsyncMinionContainer to a Google Pub/Sub service to allow Pub/Sub messages mocking.
+    * @param connection Connection details to a Google Pub/Sub service.
+    * @return self
+    */
+   public MicrocksAsyncMinionContainer withGooglePubSubConnection(GooglePubSubConnection connection) {
+      if (!extraProtocols.contains(",GOOGLEPUBSUB")) {
+         extraProtocols += ",GOOGLEPUBSUB";
+      }
+      withEnv(ASYNC_PROTOCOLS_ENV_VAR, extraProtocols);
+      withEnv("GOOGLEPUBSUB_PROJECT", connection.getProjectId());
+      if (connection.getEmulatorHost() != null) {
+         withEnv("PUBSUB_EMULATOR_HOST", connection.getEmulatorHost());
+      }
+      return this;
+   }
+
    /**
     * Get the Http endpoint where Microcks can be accessed (you'd have to append '/api' to access APIs)
     * @return The Http endpoint for talking to container.
@@ -289,6 +307,24 @@ public String getAmazonSNSMockTopic(String service, String version, String opera
       return getAmazonServiceMockDestination(service, version, operationName);
    }
 
+   /**
+    * Get the exposed mock topic for a Google Pub/Sub Service.
+    * @param service The name of Service/API
+    * @param version The version of Service/API
+    * @param operationName The name of operation to get the topic for
+    * @return A usable topic to interact with Microcks mocks.
+    */
+   public String getGooglePubSubMockTopic(String service, String version, String operationName) {
+      // operationName may start with SUBSCRIBE or PUBLISH.
+      if (operationName.contains(" ")) {
+         operationName = operationName.split(" ")[1];
+      }
+      return String.format(DESTINATION_PATTERN,
+            service.replace(" ", "").replace("-", ""),
+            version.replace(" ", ""),
+            operationName.replace("/", "-"));
+   }
+
    private String getAmazonServiceMockDestination(String service, String version, String operationName) {
       // operationName may start with SUBSCRIBE or PUBLISH.
       if (operationName.contains(" ")) {

src/main/java/io/github/microcks/testcontainers/MicrocksContainersEnsemble.java

@@ -17,6 +17,7 @@
 
 import io.github.microcks.testcontainers.connection.AmazonServiceConnection;
 import io.github.microcks.testcontainers.connection.GenericConnection;
+import io.github.microcks.testcontainers.connection.GooglePubSubConnection;
 import io.github.microcks.testcontainers.connection.KafkaConnection;
 import io.github.microcks.testcontainers.model.Secret;
 
@@ -266,6 +267,17 @@ public MicrocksContainersEnsemble withAmazonSNSConnection(AmazonServiceConnectio
       return this;
    }
 
+   /**
+    * Once the Async Feature is enabled, connects to a Google Pub/Sub service.
+    * @param connection Connection details to a Google Pub/Sub service.
+    * @return self
+    */
+   public MicrocksContainersEnsemble withGooglePubSubConnection(GooglePubSubConnection connection) {
+      ensureAsyncFeatureIsEnabled();
+      this.asyncMinion.withGooglePubSubConnection(connection);
+      return this;
+   }
+
    /**
     * Set host accessibility on ensemble containers.
     * @param hostAccessible Host accessibility flag

src/main/java/io/github/microcks/testcontainers/connection/GooglePubSubConnection.java

@@ -0,0 +1,44 @@
+/*
+ * Copyright The Microcks Authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *  http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package io.github.microcks.testcontainers.connection;
+
+/**
+ * A simple bean representing a Google Pub/Sub connection settings.
+ * @author laurent
+ */
+public class GooglePubSubConnection {
+
+   private final String projectId;
+   private final String emulatorHost;
+
+   /**
+    * Create a GooglePubSubConnection.
+    * @param projectId The GCP Project ID
+    * @param emulatorHost The Pub/Sub emulator host (including port)
+    */
+   public GooglePubSubConnection(String projectId, String emulatorHost) {
+      this.projectId = projectId;
+      this.emulatorHost = emulatorHost;
+   }
+
+   public String getProjectId() {
+      return projectId;
+   }
+
+   public String getEmulatorHost() {
+      return emulatorHost;
+   }
+}