Adopt to the updated api-model

See 3594851 (PR #562)
gesellix · Oct 3, 2023 · f831b2b · f831b2b
1 parent 2e3c856
commit f831b2b
Show file tree

Hide file tree

Showing 4 changed files with 19 additions and 15 deletions.
diff --git a/client/src/main/groovy/de/gesellix/docker/client/container/ManageContainerClient.groovy b/client/src/main/groovy/de/gesellix/docker/client/container/ManageContainerClient.groovy
@@ -265,6 +265,7 @@ class ManageContainerClient implements ManageContainer {
         true,
         true,
         null,
+        null,
         (execConfig.Tty ?: false) as Boolean,
         null,
         command,
@@ -276,7 +277,8 @@ class ManageContainerClient implements ManageContainer {
     String execId = execCreateResult.content.id
     ExecStartConfig execStartConfig = new ExecStartConfig(
         (execConfig.Detach ?: false) as Boolean,
-        actualExecConfig.tty)
+        actualExecConfig.tty,
+        null)
     startExec(execId, execStartConfig, callback, timeout)
     return execCreateResult
   }
@@ -333,14 +335,14 @@ class ManageContainerClient implements ManageContainer {
 //    def multiplexStreams = !inspectContainer(container).content.config.tty
 
     client.containerApi.containerLogs(container,
-                                      actualQuery.follow as Boolean,
-                                      actualQuery.stdout as Boolean,
-                                      actualQuery.stderr as Boolean,
-                                      actualQuery.since as Integer,
-                                      actualQuery.until as Integer,
-                                      actualQuery.timestamps as Boolean,
-                                      actualQuery.tail as String,
-                                      callback, timeout.toMillis())
+        actualQuery.follow as Boolean,
+        actualQuery.stdout as Boolean,
+        actualQuery.stderr as Boolean,
+        actualQuery.since as Integer,
+        actualQuery.until as Integer,
+        actualQuery.timestamps as Boolean,
+        actualQuery.tail as String,
+        callback, timeout.toMillis())
   }
 
   @Override

diff --git a/client/src/main/groovy/de/gesellix/docker/client/volume/ManageVolumeClient.java b/client/src/main/groovy/de/gesellix/docker/client/volume/ManageVolumeClient.java
@@ -1,6 +1,7 @@
 package de.gesellix.docker.client.volume;
 
 import de.gesellix.docker.client.EngineResponseContent;
+import de.gesellix.docker.remote.api.ClusterVolumeSpec;
 import de.gesellix.docker.remote.api.EngineApiClient;
 import de.gesellix.docker.remote.api.Volume;
 import de.gesellix.docker.remote.api.VolumeCreateOptions;
@@ -72,7 +73,8 @@ public EngineResponseContent<Volume> createVolume(Map<String, Object> config) {
         config == null ? null : (String) config.get("Name"),
         config == null ? null : (String) config.get("Driver"),
         config == null ? null : (Map) config.get("DriverOpts"),
-        config == null ? null : (Map) config.get("Labels")));
+        config == null ? null : (Map) config.get("Labels"),
+        config == null ? null : (ClusterVolumeSpec) config.get("ClusterVolumeSpec")));
   }
 
   @Override

diff --git a/client/src/test/groovy/de/gesellix/docker/client/container/ManageContainerClientTest.groovy b/client/src/test/groovy/de/gesellix/docker/client/container/ManageContainerClientTest.groovy
@@ -213,7 +213,7 @@ class ManageContainerClientTest extends Specification {
     given:
     def execApi = Mock(ExecApi)
     client.execApi >> execApi
-    def execStartConfig = new ExecStartConfig(true, false)
+    def execStartConfig = new ExecStartConfig(true, false, null)
     def callback = Mock(StreamCallback)
 
     when:
@@ -251,12 +251,12 @@ class ManageContainerClientTest extends Specification {
     then:
     1 * execApi.containerExec("container-id",
                               new ExecConfig(false, true, true,
-                                             null, false,
+                                             null, null, false,
                                              null, ["command", "line"],
                                              null, null, null)) >> idResponse
     then:
     1 * execApi.execStart("exec-id",
-                          new ExecStartConfig(false, false),
+                          new ExecStartConfig(false, false, null),
                           callback, 1000)
     and:
     exec.content == idResponse

diff --git a/client/src/test/groovy/de/gesellix/docker/client/volume/ManageVolumeClientTest.groovy b/client/src/test/groovy/de/gesellix/docker/client/volume/ManageVolumeClientTest.groovy
@@ -79,7 +79,7 @@ class ManageVolumeClientTest extends Specification {
         DriverOpts: [:]])
 
     then:
-    1 * volumeApi.volumeCreate(new VolumeCreateOptions("my-fancy-volume", "local", [:], null)) >> volumeResponse
+    1 * volumeApi.volumeCreate(new VolumeCreateOptions("my-fancy-volume", "local", [:], null, null)) >> volumeResponse
     volume.content == volumeResponse
   }
 
@@ -88,7 +88,7 @@ class ManageVolumeClientTest extends Specification {
     def volumeApi = Mock(VolumeApi)
     client.volumeApi >> volumeApi
     def volumeResponse = Mock(Volume)
-    def volumeConfig = new VolumeCreateOptions("my-volume", "local", [:], [:])
+    def volumeConfig = new VolumeCreateOptions("my-volume", "local", [:], [:], null)
 
     when:
     def volume = service.createVolume(volumeConfig)