fix: add a workaround for testcontainers/testcontainers-java#6441

monosoul · Oct 20, 2023 · 6a792be · 6a792be
1 parent 3146995
commit 6a792be
Showing 1 changed file with 28 additions and 4 deletions.
diff --git a/src/main/kotlin/dev/monosoul/jooq/container/GenericDatabaseContainer.kt b/src/main/kotlin/dev/monosoul/jooq/container/GenericDatabaseContainer.kt
@@ -6,16 +6,26 @@ import org.slf4j.LoggerFactory
 import org.testcontainers.containers.JdbcDatabaseContainer
 import org.testcontainers.containers.output.Slf4jLogConsumer
 import org.testcontainers.containers.wait.strategy.HostPortWaitStrategy
+import org.testcontainers.dockerclient.DockerClientProviderStrategy
 import org.testcontainers.utility.DockerImageName
 import java.sql.Driver
+import java.util.concurrent.atomic.AtomicBoolean
 import java.util.concurrent.locks.ReentrantLock
 import kotlin.concurrent.withLock
+import kotlin.reflect.KCallable
+import kotlin.reflect.full.declaredMembers
+import kotlin.reflect.jvm.isAccessible
 
 class GenericDatabaseContainer(
-    private val image: Image,
-    private val database: Database.Internal,
-    private val jdbcAwareClassLoader: ClassLoader,
-) : JdbcDatabaseContainer<GenericDatabaseContainer>(DockerImageName.parse(image.name)) {
+        private val image: Image,
+        private val database: Database.Internal,
+        private val jdbcAwareClassLoader: ClassLoader,
+) : JdbcDatabaseContainer<GenericDatabaseContainer>(
+        image.let {
+            failFastAlways.set(false)
+            DockerImageName.parse(it.name)
+        }
+) {
 
     private val driverLoadLock = ReentrantLock()
     private var driver: Driver? = null
@@ -67,4 +77,18 @@ class GenericDatabaseContainer(
             else -> throw e
         }
     }
+
+    private companion object {
+        /**
+         * Workaround for https://github.com/testcontainers/testcontainers-java/issues/6441
+         */
+        val failFastAlways = DockerClientProviderStrategy::class.declaredMembers
+                .single { it.name == "FAIL_FAST_ALWAYS" }
+                .apply { isAccessible = true }
+                .let {
+                    @Suppress("UNCHECKED_CAST")
+                    it as KCallable<AtomicBoolean>
+                }
+                .call()
+    }
 }