Extract ImageId utils to extension functions/static methods

Author: gesellix

api-client/src/main/kotlin/de/gesellix/docker/remote/api/client/BuildInfoExtensions.kt

@@ -0,0 +1,29 @@
+package de.gesellix.docker.remote.api.client
+
+import de.gesellix.docker.remote.api.BuildInfo
+import de.gesellix.docker.remote.api.ImageID
+
+fun List<BuildInfo>.getImageId(): ImageID? {
+  val reversedInfos = this.reversed()
+  val firstAux = reversedInfos.stream()
+    .filter { (_, _, _, _, _, _, _, aux): BuildInfo -> aux != null }
+    .findFirst()
+  if (firstAux.isPresent) {
+    return firstAux.get().aux
+  } else {
+    val idFromStream = reversedInfos.stream()
+      .filter { (_, stream): BuildInfo -> stream?.contains("Successfully built ")!! }
+      .findFirst()
+    return if (idFromStream.isPresent) {
+      ImageID(idFromStream.get().stream!!.removePrefix("Successfully built ").replaceAfter('\n', "").trim())
+    } else {
+      val tagFromStream = reversedInfos.stream()
+        .filter { (_, stream): BuildInfo -> stream?.contains("Successfully tagged ")!! }
+        .findFirst()
+      tagFromStream.map { (_, stream): BuildInfo ->
+        ImageID(stream!!.removePrefix("Successfully tagged ").replaceAfter('\n', "").trim())
+      }
+        .orElse(null)
+    }
+  }
+}

api-client/src/main/kotlin/de/gesellix/docker/remote/api/client/CreateImageInfoExtensions.kt

@@ -0,0 +1,15 @@
+package de.gesellix.docker.remote.api.client
+
+import de.gesellix.docker.remote.api.CreateImageInfo
+
+fun List<CreateImageInfo>.getImageId(): String? {
+  val reversedInfos = this.reversed()
+  val firstStatus = reversedInfos.stream()
+    .filter { (_, _, status, _, _): CreateImageInfo -> status != null }
+    .findFirst()
+  if (firstStatus.isPresent) {
+    return firstStatus.get().status
+  } else {
+    return null
+  }
+}

api-client/src/main/kotlin/de/gesellix/docker/remote/api/client/ImageApi.kt

@@ -23,7 +23,6 @@ import de.gesellix.docker.remote.api.HistoryResponseItem
 import de.gesellix.docker.remote.api.IdResponse
 import de.gesellix.docker.remote.api.Image
 import de.gesellix.docker.remote.api.ImageDeleteResponseItem
-import de.gesellix.docker.remote.api.ImageID
 import de.gesellix.docker.remote.api.ImagePruneResponse
 import de.gesellix.docker.remote.api.ImageSearchResponseItem
 import de.gesellix.docker.remote.api.ImageSummary
@@ -270,31 +269,6 @@ class ImageApi(dockerClientConfig: DockerClientConfig = defaultClientConfig, pro
     }
   }
 
-  fun getImageId(buildInfos: List<BuildInfo>): ImageID? {
-    val reversedInfos = buildInfos.reversed()
-    val firstAux = reversedInfos.stream()
-      .filter { (_, _, _, _, _, _, _, aux): BuildInfo -> aux != null }
-      .findFirst()
-    if (firstAux.isPresent) {
-      return firstAux.get().aux
-    } else {
-      val idFromStream = reversedInfos.stream()
-        .filter { (_, stream): BuildInfo -> stream?.contains("Successfully built ")!! }
-        .findFirst()
-      return if (idFromStream.isPresent) {
-        ImageID(idFromStream.get().stream!!.removePrefix("Successfully built ").replaceAfter('\n', "").trim())
-      } else {
-        val tagFromStream = reversedInfos.stream()
-          .filter { (_, stream): BuildInfo -> stream?.contains("Successfully tagged ")!! }
-          .findFirst()
-        tagFromStream.map { (_, stream): BuildInfo ->
-          ImageID(stream!!.removePrefix("Successfully tagged ").replaceAfter('\n', "").trim())
-        }
-          .orElse(null)
-      }
-    }
-  }
-
   /**
    * To obtain the request config of the operation imageBuild
    *

api-client/src/test/java/de/gesellix/docker/remote/api/client/ImageApiTest.java renamed to api-client/src/test/java/de/gesellix/docker/remote/api/client/BuildInfoExtensionsTest.java

@@ -1,24 +1,15 @@
 package de.gesellix.docker.remote.api.client;
 
-import de.gesellix.docker.engine.DockerClientConfig;
 import de.gesellix.docker.remote.api.BuildInfo;
 import de.gesellix.docker.remote.api.ImageID;
-import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
 
 import java.util.ArrayList;
 import java.util.List;
 
 import static org.junit.jupiter.api.Assertions.assertEquals;
 
-class ImageApiTest {
-
-  private ImageApi imageApi;
-
-  @BeforeEach
-  public void setup() {
-    imageApi = new ImageApi(new DockerClientConfig());
-  }
+class BuildInfoExtensionsTest {
 
   @Test
   public void getImageIdFromAux() {
@@ -28,7 +19,7 @@ public void getImageIdFromAux() {
     infos.add(new BuildInfo(null, "Successfully built f9d5f290d048\nfoo bar", null, null, null, null, null, null));
     infos.add(new BuildInfo(null, "Successfully tagged image:tag\nbar baz", null, null, null, null, null, null));
 
-    ImageID imageId = imageApi.getImageId(infos);
+    ImageID imageId = BuildInfoExtensionsKt.getImageId(infos);
 
     assertEquals("sha256:expected-id", imageId.getID());
   }
@@ -40,7 +31,7 @@ public void getImageIdFromStreamWithBuildMessage() {
     infos.add(new BuildInfo(null, "Successfully built f9d5f290d048\nfoo bar", null, null, null, null, null, null));
     infos.add(new BuildInfo(null, "Successfully tagged image:tag\nbar baz", null, null, null, null, null, null));
 
-    ImageID imageId = imageApi.getImageId(infos);
+    ImageID imageId = BuildInfoExtensionsKt.getImageId(infos);
 
     assertEquals("f9d5f290d048", imageId.getID());
   }
@@ -50,7 +41,7 @@ public void getImageIdFromStreamWithTagMessage() {
     List<BuildInfo> infos = new ArrayList<>();
     infos.add(new BuildInfo(null, "Successfully tagged image:tag\nbar baz", null, null, null, null, null, null));
 
-    ImageID imageId = imageApi.getImageId(infos);
+    ImageID imageId = BuildInfoExtensionsKt.getImageId(infos);
 
     assertEquals("image:tag", imageId.getID());
   }

api-client/src/test/java/de/gesellix/docker/remote/api/client/CreateImageInfoExtensionsTest.java

@@ -0,0 +1,25 @@
+package de.gesellix.docker.remote.api.client;
+
+import de.gesellix.docker.remote.api.CreateImageInfo;
+import org.junit.jupiter.api.Test;
+
+import java.util.ArrayList;
+import java.util.List;
+
+import static org.junit.jupiter.api.Assertions.assertEquals;
+
+class CreateImageInfoExtensionsTest {
+
+  @Test
+  public void getImageIdFromStatus() {
+    List<CreateImageInfo> infos = new ArrayList<>();
+    infos.add(new CreateImageInfo("os-linux", null, "Pulling from gesellix/echo-server", null, null));
+    infos.add(new CreateImageInfo(null, null, "Digest: sha256:04c0275878dc243b2f92193467cb33cdb9ee2262be64b627ed476de73e399244", null, null));
+    infos.add(new CreateImageInfo(null, null, "Status: Image is up to date for gesellix/echo-server:os-linux", null, null));
+    infos.add(new CreateImageInfo(null, null, "sha256:87f5e747ad067f91a7c4adf154deea20cebc3a749be5c2864a0c65cf70ddd8c4", null, null));
+
+    String imageId = CreateImageInfoExtensionsKt.getImageId(infos);
+
+    assertEquals("sha256:87f5e747ad067f91a7c4adf154deea20cebc3a749be5c2864a0c65cf70ddd8c4", imageId);
+  }
+}

api-client/src/test/java/de/gesellix/docker/remote/api/client/ImageApiIntegrationTest.java

@@ -127,7 +127,7 @@ public void onFinished() {
       log.error("Wait interrupted", e);
     }
 
-    ImageID imageId = imageApi.getImageId(infos);
+    ImageID imageId = BuildInfoExtensionsKt.getImageId(infos);
     assertNotNull(imageId);
     assertNotNull(imageId.getID());
     assertTrue(imageId.getID().matches(".+"));