feat: add tests to connection binding on gateway objects

Author: bruno-martins-mx

gateway/src/test/groovy/com/mx/path/gateway/configuration/ConnectionBinderTest.groovy

@@ -0,0 +1,110 @@
+package com.mx.path.gateway.configuration
+
+import com.mx.path.core.common.accessor.PathResponseStatus
+import com.mx.path.core.common.collection.ObjectMap
+import com.mx.path.core.common.gateway.GatewayException
+import com.mx.testing.binding.ConnectionWithBoundConfiguration
+
+import spock.lang.Specification
+
+class ConnectionBinderTest extends Specification {
+
+  ObjectMap configuration
+  ConnectionBinder subject
+
+  def setup() {
+    subject = new ConnectionBinder()
+    configuration = new ObjectMap()
+  }
+
+  def "build connection"() {
+    given:
+    def configuration = new ObjectMap().tap {
+      createMap("TestConnection").tap {
+        createMap("configurations").tap {
+          put("clientId", "clientId")
+        }
+        put("baseUrl", "url")
+        put("certificateAlias", "alias")
+        put("keystorePath", "path")
+        put("keystorePassword", "password")
+      }
+    }
+
+    when:
+    def connection = (ConnectionWithBoundConfiguration) subject.build(ConnectionWithBoundConfiguration.class, configuration, "TestConnection")
+
+    then:
+    verifyAll (connection) {
+      baseUrl == "url"
+      certificateAlias == "alias"
+      keystorePath == "path"
+      keystorePassword.toString() == "password"
+    }
+  }
+
+  def "build connection throw on missing client id"() {
+    given:
+    def configuration = new ObjectMap().tap {
+      createMap("TestConnection").tap {
+        createMap("configurations").tap {
+          put("clientId", null)
+        }
+        put("baseUrl", "url")
+        put("certificateAlias", "alias")
+        put("keystorePath", "path")
+        put("keystorePassword", "password")
+      }
+    }
+
+    when:
+    subject.build(ConnectionWithBoundConfiguration.class, configuration, "TestConnection")
+
+    then:
+    def e = thrown(ConfigurationError)
+    e.message == "Client ID not provided for connection TestConnection at connections.TestConnection"
+  }
+
+  def "build connection settings"() {
+    given:
+    def configuration = new ObjectMap().tap {
+      createMap("TestConnection").tap {
+        put("baseUrl", "url")
+        put("certificateAlias", "alias")
+        put("keystorePath", "path")
+        put("keystorePassword", "password")
+      }
+    }
+
+    when:
+    def connection = subject.buildConnection(configuration, "TestConnection")
+
+    then:
+    verifyAll (connection) {
+      baseUrl == "url"
+      certificateAlias == "alias"
+      keystorePath == "path"
+      keystorePassword.toString() == "password"
+    }
+  }
+
+  def "build connection and fail validation"() {
+    given:
+    def configuration = new ObjectMap().tap {
+      createMap("TestConnection").tap {
+        put("baseUrl", "url")
+        put("certificateAlias", "")
+        put("keystorePath", "path")
+        put("keystorePassword", "password")
+      }
+    }
+
+    when:
+    subject.buildConnection(configuration, "TestConnection")
+
+    then:
+    def e = thrown(GatewayException)
+    e.status == PathResponseStatus.INTERNAL_ERROR
+    e.message == "Invalid connection details. Missing certificateAlias"
+  }
+}

gateway/src/test/groovy/com/mx/path/gateway/configuration/GatewayObjectConfiguratorTest.groovy

@@ -6,6 +6,7 @@ import com.mx.path.gateway.behavior.GatewayBehavior
 import com.mx.path.gateway.service.GatewayService
 import com.mx.testing.MessageBrokerImpl
 import com.mx.testing.binding.BehaviorWithConfiguration
+import com.mx.testing.binding.BehaviorWithConfigurationAndConnection
 import com.mx.testing.binding.BindedConfigGatewayService
 
 import spock.lang.Specification
@@ -64,6 +65,45 @@ class GatewayObjectConfiguratorTest extends Specification {
     }
   }
 
+  def "builds and binds a GatewayBehavior with Connection"() {
+    given:
+    def node = new ObjectMap().tap {
+      put("class", BehaviorWithConfigurationAndConnection.getCanonicalName())
+      put("configurations", new ObjectMap().tap {
+        put("active", true)
+        put("actionFilter", "put")
+      })
+      createMap("connections").tap {
+        createMap("connection").tap {
+          createMap("configurations").tap {
+            put("clientId", "clientId")
+          }
+          put("baseUrl", "url")
+          put("certificateAlias", "alias")
+          put("keystorePath", "path")
+          put("keystorePassword", "password")
+        }
+      }
+    }
+
+    when:
+    def result = subject.buildFromNode(node, "client1", GatewayBehavior)
+
+    then:
+    result instanceof BehaviorWithConfigurationAndConnection
+    verifyAll((BehaviorWithConfigurationAndConnection) result) {
+      connectionWithBoundConfiguration
+      behaviorConfiguration.active
+      initialized
+      verifyAll (connectionWithBoundConfiguration) {
+        baseUrl == "url"
+        certificateAlias == "alias"
+        keystorePath == "path"
+        keystorePassword.toString() == "password"
+      }
+    }
+  }
+
   def "builds and binds a Facility"() {
     given:
     def node = new ObjectMap().tap {

gateway/src/test/java/com/mx/testing/binding/BehaviorWithConfigurationAndConnection.java

@@ -0,0 +1,49 @@
+package com.mx.testing.binding;
+
+import lombok.Getter;
+
+import com.mx.path.core.common.collection.ObjectMap;
+import com.mx.path.core.common.configuration.Configuration;
+import com.mx.path.core.common.configuration.ConfigurationField;
+import com.mx.path.gateway.accessor.AccessorResponse;
+import com.mx.path.gateway.behavior.GatewayBehavior;
+import com.mx.path.gateway.configuration.Configurable;
+import com.mx.path.gateway.configuration.annotations.Connection;
+import com.mx.path.gateway.context.GatewayRequestContext;
+
+public class BehaviorWithConfigurationAndConnection extends GatewayBehavior implements Configurable {
+  @Getter
+  private final BehaviorConfiguration behaviorConfiguration;
+
+  @Getter
+  private final ConnectionWithBoundConfiguration connectionWithBoundConfiguration;
+
+  @Getter
+  boolean initialized = false;
+
+  public static class BehaviorConfiguration {
+    @Getter
+    @ConfigurationField("active")
+    private boolean active;
+
+    @Getter
+    @ConfigurationField("actionFilter")
+    private String actionFilter;
+  }
+
+  public BehaviorWithConfigurationAndConnection(ObjectMap configurations, @Configuration BehaviorConfiguration behaviorConfiguration, @Connection("connection") ConnectionWithBoundConfiguration connection) {
+    super(configurations);
+    this.connectionWithBoundConfiguration = connection;
+    this.behaviorConfiguration = behaviorConfiguration;
+  }
+
+  @Override
+  protected <T> AccessorResponse<T> call(Class<T> resultType, GatewayRequestContext request, GatewayBehavior terminatingBehavior) {
+    return null;
+  }
+
+  @Override
+  public void initialize() {
+    this.initialized = true;
+  }
+}