Remove cartridge-java from dependencies

- Update executeScript and executeCommand methods to execute code viva execInContainer
  (now it returns yaml string in Container.ExecResult not CompletableFuture).
- Remove TarantoolContainer containers with TarantoolClientBuilder parameter.
- Remove getClient method from TarantoolContainerClientHelper.
- Remove io.tarantool.cartridge-driver dependency.
  because cartridge-java client was also removed.
- Add executeScriptDecoded and executeCommandDecoded methods to return parsed yaml not string.
- Add withSsl and withKeyAndCertFiles methods to TarantoolContainer and TarantoolCartridgeContainer.
- Rewrite tests and add new cases to support new API.
- Update org.yaml.snakeyaml to 2.0 version.

Closes #69

Author: iDneprov

CHANGELOG.md

@@ -2,6 +2,16 @@
 
 ## [Unreleased]
 - Fix problem if topology isn't applied correctly
+- **[breaking change]** Update executeScript and executeCommand methods to execute code viva execInContainer  
+  (now it returns yaml string in Container.ExecResult not CompletableFuture).
+- **[breaking change]** Remove TarantoolContainer containers with TarantoolClientBuilder parameter.
+- **[breaking change]** Remove getClient method from TarantoolContainerClientHelper.
+- **[breaking change]** Remove io.tarantool.cartridge-driver dependency.
+  because cartridge-java client was also removed.
+- Add executeScriptDecoded and executeCommandDecoded methods to return parsed yaml not string.
+- Add withSsl and withKeyAndCertFiles methods to TarantoolContainer and TarantoolCartridgeContainer.
+- Rewrite tests and add new cases to support new API.
+- Update org.yaml.snakeyaml to 2.0 version.
 
 ## [0.5.4] - 2023-03-31
 - Use tarantool image as base instead of centos in cartridge container

README.md

@@ -14,7 +14,7 @@ Add the Maven dependency:
 <dependency>
   <groupId>io.tarantool</groupId>
   <artifactId>testcontainers-java-tarantool</artifactId>
-  <version>0.5.4</version>
+  <version>0.6.0</version>
 </dependency>
 ```
 
@@ -52,9 +52,9 @@ public class SomeTest {
     @BeforeAll
     public void setUp() {
         // Run some setup commands
-        container.executeCommand("return 1, 2").get();
+        container.executeCommand("return 1, 2");
         // Or execute a script
-        container.executeScript("org/testcontainers/containers/test.lua").get();
+        container.executeScript("org/testcontainers/containers/test.lua");
     }
 
     @Test
@@ -72,7 +72,7 @@ public class SomeTest {
             ...
 
             // Execute some commands in Tarantool instance for verification
-            List<Object> result = container.executeCommand("return 1, 2").get();
+            List<Object> result = container.executeCommand("return 1, 2");
             ...
         }
     ...
@@ -181,7 +181,7 @@ public class SomeOtherTest {
     // Use the created container in tests
     public void testFoo() {
         // Execute Lua commands in the router instance
-        List<Object> result = container.executeCommand("return profile_get(...)", 1).get();
+        List<Object> result = container.executeCommand("return profile_get(1)");
 
         // Instantiate a client connected to the router node
         TarantoolCredentials credentials = new SimpleTarantoolCredentials(getRouterUsername(), getRouterPassword());

pom.xml

@@ -81,15 +81,10 @@
             <artifactId>testcontainers</artifactId>
             <version>${testcontainers.version}</version>
         </dependency>
-        <dependency>
-            <groupId>io.tarantool</groupId>
-            <artifactId>cartridge-driver</artifactId>
-            <version>0.9.1</version>
-        </dependency>
         <dependency>
             <groupId>org.yaml</groupId>
             <artifactId>snakeyaml</artifactId>
-            <version>1.33</version>
+            <version>2.0</version>
         </dependency>
         <dependency>
             <groupId>org.slf4j</groupId>

src/main/java/org/testcontainers/containers/TarantoolCartridgeContainer.java

@@ -1,18 +1,12 @@
 package org.testcontainers.containers;
 
 import com.github.dockerjava.api.command.InspectContainerResponse;
-import io.tarantool.driver.exceptions.TarantoolConnectionException;
 
 import org.testcontainers.containers.exceptions.CartridgeTopologyException;
 import org.testcontainers.images.builder.ImageFromDockerfile;
 
 import java.net.URL;
-import java.util.Arrays;
-import java.util.Collections;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-import java.util.concurrent.CompletableFuture;
+import java.util.*;
 import java.util.concurrent.ExecutionException;
 import java.util.concurrent.TimeoutException;
 import java.util.function.Supplier;
@@ -82,6 +76,9 @@
  * specified in the http_port options, will be exposed.
  *
  * @author Alexey Kuzin
+ * @authorm Artyom Dubinin
+ * @author Ivan Dneprov
+ *
  */
 public class TarantoolCartridgeContainer extends GenericContainer<TarantoolCartridgeContainer>
         implements TarantoolContainerOperations<TarantoolCartridgeContainer> {
@@ -119,6 +116,9 @@ public class TarantoolCartridgeContainer extends GenericContainer<TarantoolCartr
     private String directoryResourcePath = SCRIPT_RESOURCE_DIRECTORY;
     private String instanceDir = INSTANCE_DIR;
     private String topologyConfigurationFile;
+    private Boolean sslIsActive = false;
+    private String keyFile = "";
+    private String certFile = "";
 
     /**
      * Create a container with default image and specified instances file from the classpath resources. Assumes that
@@ -246,6 +246,33 @@ private static ImageFromDockerfile buildImage(String dockerFile, String buildIma
         return new ImageFromDockerfile().withFileFromClasspath("Dockerfile", dockerFile);
     }
 
+    /**
+     * Specify SSL as connection transport.
+     * Warning! SSL must be set as default transport on your tarantool cluster.
+     * Supported only in Tarantool Enterprise
+     *
+     * @return this container instance
+     */
+    public TarantoolCartridgeContainer withSsl() {
+        checkNotRunning();
+        this.sslIsActive = true;
+        return this;
+    }
+
+    /**
+     * Specify path to key and cert files inside your container for SSL connection.
+     * Warning! SSL must be set as default transport on your tarantool cluster.
+     * Supported only in Tarantool Enterprise
+     *
+     * @return this container instance
+     */
+    public TarantoolCartridgeContainer withKeyAndCertFiles(String keyFile, String certFile) {
+        checkNotRunning();
+        this.keyFile = keyFile;
+        this.certFile = certFile;
+        return this;
+    }
+
     /**
      * Get the router host
      *
@@ -328,6 +355,11 @@ public String getInstanceDir() {
         return instanceDir;
     }
 
+    @Override
+    public int getInternalPort() {
+        return routerPort;
+    }
+
     /**
      * Get Cartridge router HTTP API hostname
      *
@@ -489,7 +521,7 @@ private boolean setupTopology() {
 
         } else {
             try {
-                List<?> res = executeScript(topologyConfigurationFile).get();
+                ArrayList<?> res = executeScriptDecoded(topologyConfigurationFile);
                 if (res.size() >= 2 && res.get(1) != null && res.get(1) instanceof Map) {
                     HashMap<?, ?> error = ((HashMap<?, ?>) res.get(1));
                     // that means topology already exists
@@ -501,10 +533,6 @@ private boolean setupTopology() {
                     if (e.getCause() instanceof TimeoutException) {
                         return true;
                         // Do nothing, the cluster is reloading
-                    } else if (e.getCause() instanceof TarantoolConnectionException) {
-                        // Probably cluster is not ready
-                        logger().error("Failed to setup topology: {}", e.getMessage());
-                        return false;
                     }
                 } else {
                     throw new CartridgeTopologyException(e);
@@ -530,7 +558,7 @@ private void retryingSetupTopology() {
 
     private void bootstrapVshard() {
         try {
-            executeCommand(VSHARD_BOOTSTRAP_COMMAND).get();
+            executeCommand(VSHARD_BOOTSTRAP_COMMAND);
         } catch (Exception e) {
             logger().error("Failed to bootstrap vshard cluster", e);
             throw new RuntimeException(e);
@@ -580,8 +608,8 @@ private boolean routerIsUp() {
         String healthyCmd = " local cartridge = package.loaded['cartridge']" +
                 " return assert(cartridge ~= nil)";
         try {
-            List<?> result = executeCommand(healthyCmd).get();
-            return (Boolean) result.get(0);
+            Container.ExecResult result = executeCommand(healthyCmd);
+            return result.getStdout().equals("---\n- true\n...\n\n");
         } catch (Exception e) {
             logger().warn("Error while waiting for router instance to be up: " + e.getMessage());
             return false;
@@ -592,21 +620,31 @@ private boolean isCartridgeHealthy() {
         String healthyCmd = " local cartridge = package.loaded['cartridge']" +
                 " return assert(cartridge) and assert(cartridge.is_healthy())";
         try {
-            List<?> result = executeCommand(healthyCmd).get();
-            return (Boolean) result.get(0);
+            Container.ExecResult result = executeCommand(healthyCmd);
+            return result.getStdout().equals("---\n- true\n...\n\n");
         } catch (Exception e) {
             logger().warn("Error while waiting for cartridge healthy state: " + e.getMessage());
             return false;
         }
     }
 
     @Override
-    public CompletableFuture<List<?>> executeScript(String scriptResourcePath) throws Exception {
-        return clientHelper.executeScript(scriptResourcePath);
+    public Container.ExecResult executeScript(String scriptResourcePath) throws Exception {
+        return clientHelper.executeScript(scriptResourcePath, this.sslIsActive, this.keyFile, this.certFile);
+    }
+
+    @Override
+    public <T> T executeScriptDecoded(String scriptResourcePath) throws Exception {
+        return clientHelper.executeScriptDecoded(scriptResourcePath, this.sslIsActive, this.keyFile, this.certFile);
+    }
+
+    @Override
+    public Container.ExecResult executeCommand(String command) throws Exception {
+        return clientHelper.executeCommand(command, this.sslIsActive, this.keyFile, this.certFile);
     }
 
     @Override
-    public CompletableFuture<List<?>> executeCommand(String command, Object... arguments) throws Exception {
-        return clientHelper.executeCommand(command, arguments);
+    public <T> T executeCommandDecoded(String command) throws Exception {
+        return clientHelper.executeCommandDecoded(command, this.sslIsActive, this.keyFile, this.certFile);
     }
 }