Prevent ghost containers after retries

ReportLeakedContainers adapted from
https://github.com/trinodb/trino/blob/master/testing/trino-testing-containers/src/main/java/io/trino/testing/containers/junit/ReportLeakedContainers.java

Co-authored-by: Piotr Findeisen <[email protected]>
Co-authored-by: Jan Waś <[email protected]>

Author: 3 people

core/src/main/java/org/testcontainers/containers/GenericContainer.java

@@ -550,6 +550,7 @@ private void tryStart() {
                 } else {
                     logger().error("There are no stdout/stderr logs available for the failed container");
                 }
+                stop();
             }
 
             throw new ContainerLaunchException("Could not create/start container", e);

core/src/test/java/org/testcontainers/containers/GenericContainerTest.java

@@ -28,6 +28,7 @@
 import org.testcontainers.utility.DockerImageName;
 import org.testcontainers.utility.MountableFile;
 
+import java.time.Duration;
 import java.util.Arrays;
 import java.util.List;
 import java.util.Map;
@@ -39,9 +40,27 @@
 import static org.assertj.core.api.Assertions.assertThatThrownBy;
 import static org.assertj.core.api.Assertions.catchThrowable;
 import static org.assertj.core.api.Assumptions.assumeThat;
+import static org.testcontainers.containers.ReportLeakedContainers.reportLeakedContainers;
+import static org.testcontainers.containers.wait.strategy.Wait.forLogMessage;
 
 public class GenericContainerTest {
 
+    @Test
+    public void testStartupTimeout()
+    {
+        try (
+            GenericContainer<?> container = new GenericContainer<>(TestImages.TINY_IMAGE)
+                .withStartupAttempts(3)
+                .waitingFor(forLogMessage("this text does not exist in logs", 1)
+                    .withStartupTimeout(Duration.ofMillis(1)))
+                .withCommand("tail", "-f", "/dev/null");
+        ) {
+            assertThatThrownBy(container::start)
+                .hasStackTraceContaining("Retry limit hit with exception");
+        }
+        assertThat(reportLeakedContainers()).isEmpty();
+    }
+
     @Test
     public void shouldReportOOMAfterWait() {
         Info info = DockerClientFactory.instance().client().infoCmd().exec();

core/src/test/java/org/testcontainers/containers/ReportLeakedContainers.java

@@ -0,0 +1,44 @@
+package org.testcontainers.containers;
+
+import com.github.dockerjava.api.DockerClient;
+import com.github.dockerjava.api.model.Container;
+import org.testcontainers.DockerClientFactory;
+
+import java.util.List;
+import java.util.Optional;
+
+import static com.google.common.base.MoreObjects.toStringHelper;
+import static com.google.common.collect.ImmutableList.toImmutableList;
+import static java.lang.String.format;
+import static java.util.Arrays.asList;
+import static java.util.Collections.singletonMap;
+import static java.util.stream.Collectors.joining;
+
+public class ReportLeakedContainers
+{
+    public static Optional<String> reportLeakedContainers()
+    {
+        @SuppressWarnings("resource") // Throws when close is attempted, as this is a global instance.
+        DockerClient dockerClient = DockerClientFactory.lazyClient();
+
+        List<Container> containers = dockerClient.listContainersCmd()
+            .withLabelFilter(singletonMap(DockerClientFactory.TESTCONTAINERS_SESSION_ID_LABEL, DockerClientFactory.SESSION_ID))
+            // ignore status "exited" - for example, failed containers after using `withStartupAttempts()`
+            .withStatusFilter(asList("created", "restarting", "running", "paused"))
+            .exec()
+            .stream()
+            .collect(toImmutableList());
+
+        if (containers.isEmpty()) {
+            return Optional.empty();
+        }
+
+        return Optional.of(format("Leaked containers: %s", containers.stream()
+            .map(container -> toStringHelper("container")
+                .add("id", container.getId())
+                .add("image", container.getImage())
+                .add("imageId", container.getImageId())
+                .toString())
+            .collect(joining(", ", "[", "]"))));
+    }
+}