From 20ec0d52cc3ddb0b31917667ec47e39e4517a518 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E8=A8=BE=E6=98=8E=E5=8D=8E?= <zmh01@digibird.com.cn>
Date: Wed, 10 Nov 2021 21:24:47 +0800
Subject: [PATCH 1/2] add `until` param with LogContainerCmd

---
 .../dockerjava/api/command/LogContainerCmd.java   |  7 +++++++
 .../core/command/LogContainerCmdImpl.java         | 15 ++++++++++++++-
 .../dockerjava/core/exec/LogContainerCmdExec.java |  4 ++++
 .../github/dockerjava/cmd/LogContainerCmdIT.java  |  1 +
 4 files changed, 26 insertions(+), 1 deletion(-)

diff --git a/docker-java-api/src/main/java/com/github/dockerjava/api/command/LogContainerCmd.java b/docker-java-api/src/main/java/com/github/dockerjava/api/command/LogContainerCmd.java
index 53674cbaa..29c4516cd 100644
--- a/docker-java-api/src/main/java/com/github/dockerjava/api/command/LogContainerCmd.java
+++ b/docker-java-api/src/main/java/com/github/dockerjava/api/command/LogContainerCmd.java
@@ -25,6 +25,8 @@
  * @param since
  *            - UNIX timestamp (integer) to filter logs. Specifying a timestamp will only output log-entries since that timestamp. Default:
  *            0 (unfiltered)
+ * @param until
+ *            - Only return logs before this time, as a UNIX timestamp. Default: 0
  */
 public interface LogContainerCmd extends AsyncDockerCmd<LogContainerCmd, Frame> {
 
@@ -49,6 +51,9 @@ public interface LogContainerCmd extends AsyncDockerCmd<LogContainerCmd, Frame>
     @CheckForNull
     Integer getSince();
 
+    @CheckForNull
+    Integer getUntil();
+
     LogContainerCmd withContainerId(@Nonnull String containerId);
 
     /**
@@ -69,6 +74,8 @@ public interface LogContainerCmd extends AsyncDockerCmd<LogContainerCmd, Frame>
 
     LogContainerCmd withSince(Integer since);
 
+    LogContainerCmd withUntil(Integer until);
+
     /**
      * @throws com.github.dockerjava.api.NotFoundException
      *             No such container
diff --git a/docker-java-core/src/main/java/com/github/dockerjava/core/command/LogContainerCmdImpl.java b/docker-java-core/src/main/java/com/github/dockerjava/core/command/LogContainerCmdImpl.java
index aa267fc8f..5113bdf4f 100644
--- a/docker-java-core/src/main/java/com/github/dockerjava/core/command/LogContainerCmdImpl.java
+++ b/docker-java-core/src/main/java/com/github/dockerjava/core/command/LogContainerCmdImpl.java
@@ -24,6 +24,8 @@
  * @param since
  *            - UNIX timestamp (integer) to filter logs. Specifying a timestamp will only output log-entries since that timestamp. Default:
  *            0 (unfiltered)
+ * @param until
+ *            - Only return logs before this time, as a UNIX timestamp. Default: 0
  */
 public class LogContainerCmdImpl extends AbstrAsyncDockerCmd<LogContainerCmd, Frame> implements LogContainerCmd {
 
@@ -31,7 +33,7 @@ public class LogContainerCmdImpl extends AbstrAsyncDockerCmd<LogContainerCmd, Fr
 
     private Boolean followStream, timestamps, stdout, stderr;
 
-    private Integer tail, since;
+    private Integer tail, since, until;
 
     public LogContainerCmdImpl(LogContainerCmd.Exec exec, String containerId) {
         super(exec);
@@ -73,6 +75,11 @@ public Integer getSince() {
         return since;
     }
 
+    @Override
+    public Integer getUntil() {
+        return until;
+    }
+
     @Override
     public LogContainerCmd withContainerId(String containerId) {
         checkNotNull(containerId, "containerId was not specified");
@@ -122,6 +129,12 @@ public LogContainerCmd withSince(Integer since) {
         return this;
     }
 
+    @Override
+    public LogContainerCmd withUntil(Integer until) {
+        this.until = until;
+        return this;
+    }
+
     @Override
     public String toString() {
         return ReflectionToStringBuilder.toString(this, ToStringStyle.SHORT_PREFIX_STYLE);
diff --git a/docker-java-core/src/main/java/com/github/dockerjava/core/exec/LogContainerCmdExec.java b/docker-java-core/src/main/java/com/github/dockerjava/core/exec/LogContainerCmdExec.java
index 54168bb5e..357af6d0e 100644
--- a/docker-java-core/src/main/java/com/github/dockerjava/core/exec/LogContainerCmdExec.java
+++ b/docker-java-core/src/main/java/com/github/dockerjava/core/exec/LogContainerCmdExec.java
@@ -32,6 +32,10 @@ protected Void execute0(LogContainerCmd command, ResultCallback<Frame> resultCal
             webTarget = webTarget.queryParam("since", command.getSince());
         }
 
+        if (command.getUntil() != null) {
+            webTarget = webTarget.queryParam("until", command.getUntil());
+        }
+
         webTarget = booleanQueryParam(webTarget, "timestamps", command.hasTimestampsEnabled());
         webTarget = booleanQueryParam(webTarget, "stdout", command.hasStdoutEnabled());
         webTarget = booleanQueryParam(webTarget, "stderr", command.hasStderrEnabled());
diff --git a/docker-java/src/test/java/com/github/dockerjava/cmd/LogContainerCmdIT.java b/docker-java/src/test/java/com/github/dockerjava/cmd/LogContainerCmdIT.java
index b0de380db..008cab325 100644
--- a/docker-java/src/test/java/com/github/dockerjava/cmd/LogContainerCmdIT.java
+++ b/docker-java/src/test/java/com/github/dockerjava/cmd/LogContainerCmdIT.java
@@ -206,6 +206,7 @@ public void asyncLogContainerWithSince() throws Exception {
                 .withStdErr(true)
                 .withStdOut(true)
                 .withSince(timestamp)
+                .withUntil(timestamp +  1000)
                 .exec(loggingCallback);
 
         loggingCallback.awaitCompletion();

From d1d83e4d029657ca3e77ac8adb86c68cc3a133fe Mon Sep 17 00:00:00 2001
From: Sergei Egorov <bsideup@gmail.com>
Date: Fri, 17 Dec 2021 06:55:04 -0500
Subject: [PATCH 2/2] Update LogContainerCmdIT.java

---
 .../test/java/com/github/dockerjava/cmd/LogContainerCmdIT.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/docker-java/src/test/java/com/github/dockerjava/cmd/LogContainerCmdIT.java b/docker-java/src/test/java/com/github/dockerjava/cmd/LogContainerCmdIT.java
index 008cab325..6ab68abff 100644
--- a/docker-java/src/test/java/com/github/dockerjava/cmd/LogContainerCmdIT.java
+++ b/docker-java/src/test/java/com/github/dockerjava/cmd/LogContainerCmdIT.java
@@ -206,7 +206,7 @@ public void asyncLogContainerWithSince() throws Exception {
                 .withStdErr(true)
                 .withStdOut(true)
                 .withSince(timestamp)
-                .withUntil(timestamp +  1000)
+                .withUntil(timestamp + 1000)
                 .exec(loggingCallback);
 
         loggingCallback.awaitCompletion();