Remove docker-engine dependency

Author: gesellix

client-groovy4/build.gradle.kts

@@ -81,7 +81,6 @@ dependencies {
   api("de.gesellix:docker-remote-api-client:2025-11-09T15-40-00")
   implementation("de.gesellix:docker-filesocket:2025-10-31T17-48-00")
   api("de.gesellix:docker-remote-api-model-1-41:2025-10-31T17-49-00")
-  api("de.gesellix:docker-engine:2025-10-31T18-10-00")
   api("de.gesellix:docker-compose:2025-10-31T17-47-00")
 
   implementation(libs.groovy4)

client/build.gradle.kts

@@ -81,7 +81,6 @@ dependencies {
   api("de.gesellix:docker-remote-api-client:2025-11-09T15-40-00")
   implementation("de.gesellix:docker-filesocket:2025-10-31T17-48-00")
   api("de.gesellix:docker-remote-api-model-1-41:2025-10-31T17-49-00")
-  api("de.gesellix:docker-engine:2025-10-31T18-10-00")
   api("de.gesellix:docker-compose:2025-10-31T17-47-00")
 
   implementation(libs.groovy3)

client/src/main/groovy/de/gesellix/docker/client/container/ArchiveUtil.java

@@ -1,9 +1,8 @@
 package de.gesellix.docker.client.container;
 
-import de.gesellix.util.IOUtils;
+import okio.BufferedSink;
+import okio.BufferedSource;
 import okio.Okio;
-import okio.Sink;
-import okio.Source;
 import org.apache.commons.compress.archivers.tar.TarArchiveEntry;
 import org.apache.commons.compress.archivers.tar.TarArchiveInputStream;
 import org.slf4j.Logger;
@@ -54,26 +53,16 @@ public long copySingleTarEntry(InputStream tarContent, String filename, OutputSt
     final byte[] content = new byte[(int) entry.getSize()];
     log.debug("going to read {} bytes", content.length);
 
-    final Source source = Okio.source(stream);
-    final Sink sink = Okio.sink(target);
     try {
-      IOUtils.copy(source, sink);
+      try (BufferedSink sink = Okio.buffer(Okio.sink(target));
+           BufferedSource source = Okio.buffer(Okio.source(stream))) {
+        long read = source.readAll(sink);
+        sink.flush();
+//        return read;
+      }
       return entry.getSize();
     } catch (Exception e) {
       throw new RuntimeException("failed to write TarArchiveEntry to target OutputStream", e);
-    } finally {
-      silently(() -> {
-        sink.flush();
-        return null;
-      });
-      silently(() -> {
-        sink.close();
-        return null;
-      });
-      silently(() -> {
-        source.close();
-        return null;
-      });
     }
   }
 

client/src/main/groovy/de/gesellix/docker/client/container/DockerResponseHandler.java

@@ -41,14 +41,12 @@ class ManageContainerClient implements ManageContainer {
   private final Logger log = LoggerFactory.getLogger(ManageContainerClient)
 
   private EngineApiClient client
-  private DockerResponseHandler responseHandler
   private QueryParameterEncoder queryParameterEncoder
   private ArchiveUtil archiveUtil
   private RepositoryTagParser repositoryTagParser
 
   ManageContainerClient(EngineApiClient client) {
     this.client = client
-    this.responseHandler = new DockerResponseHandler()
     this.repositoryTagParser = new RepositoryTagParser()
     this.queryParameterEncoder = new QueryParameterEncoder()
     this.archiveUtil = new ArchiveUtil()

client/src/main/groovy/de/gesellix/docker/client/container/ManageContainerClient.groovy

@@ -1,85 +1,25 @@
 package de.gesellix.docker.client;
 
-import de.gesellix.docker.engine.EngineResponse;
-import de.gesellix.docker.engine.EngineResponseStatus;
+public class EngineResponseContent<R> {
 
-import java.io.InputStream;
-import java.util.concurrent.Future;
-
-public class EngineResponseContent<R> extends EngineResponse<R> {
+  private R content;
 
   public EngineResponseContent(R content) {
-    super();
-    setContent(content);
-  }
-
-  @Override
-  public EngineResponseStatus getStatus() {
-    throw new UnsupportedOperationException("deprecated");
-  }
-
-  @Override
-  public void setStatus(EngineResponseStatus status) {
-    throw new UnsupportedOperationException("deprecated");
-  }
-
-  @Override
-  public Object getHeaders() {
-    throw new UnsupportedOperationException("deprecated");
-  }
-
-  @Override
-  public void setHeaders(Object headers) {
-    throw new UnsupportedOperationException("deprecated");
-  }
-
-  @Override
-  public String getContentType() {
-    throw new UnsupportedOperationException("deprecated");
-  }
-
-  @Override
-  public void setContentType(String contentType) {
-    throw new UnsupportedOperationException("deprecated");
-  }
-
-  @Override
-  public String getMimeType() {
-    throw new UnsupportedOperationException("deprecated");
-  }
-
-  @Override
-  public void setMimeType(String mimeType) {
-    throw new UnsupportedOperationException("deprecated");
-  }
-
-  @Override
-  public String getContentLength() {
-    throw new UnsupportedOperationException("deprecated");
+    this.content = content;
   }
 
-  @Override
-  public void setContentLength(String contentLength) {
-    throw new UnsupportedOperationException("deprecated");
-  }
-
-  @Override
-  public InputStream getStream() {
-    throw new UnsupportedOperationException("deprecated");
+  public R getContent() {
+    return content;
   }
 
-  @Override
-  public void setStream(InputStream stream) {
-    throw new UnsupportedOperationException("deprecated");
-  }
-
-  @Override
-  public Future<?> getTaskFuture() {
-    throw new UnsupportedOperationException("deprecated");
+  public void setContent(R content) {
+    this.content = content;
   }
 
   @Override
-  public void setTaskFuture(Future<?> taskFuture) {
-    throw new UnsupportedOperationException("deprecated");
+  public String toString() {
+    return "EngineResponse{" +
+        ", content=" + content +
+        '}';
   }
 }