whisklabs/docker-it-scala

I encountered a similar problem while connecting to container using modified example DockerPostgresService. I receive connection error, but after that everything is set up and all tests pass. Here's the snippet from logs:

PG [f387ecb6533263922aa7619d8c719a044df627a360ba18bfb0cfbac815f67a5f] ok
running bootstrap script ... 
Jul 05, 2019 11:16:00 AM org.postgresql.Driver connect
SEVERE: Connection error: 
org.postgresql.util.PSQLException: The connection attempt failed.
    at org.postgresql.core.v3.ConnectionFactoryImpl.openConnectionImpl(ConnectionFactoryImpl.java:275)
    at org.postgresql.core.ConnectionFactory.openConnection(ConnectionFactory.java:49)
    at org.postgresql.jdbc.PgConnection.<init>(PgConnection.java:194)
    at org.postgresql.Driver.makeConnection(Driver.java:450)
    at org.postgresql.Driver.connect(Driver.java:252)
    at java.sql.DriverManager.getConnection(DriverManager.java:664)
    at java.sql.DriverManager.getConnection(DriverManager.java:247)
    at docker.services.PostgresReadyChecker.$anonfun$apply$2(DockerPostgresService.scala:52)
    at scala.runtime.java8.JFunction0$mcZ$sp.apply(JFunction0$mcZ$sp.scala:17)
    at scala.util.Try$.apply(Try.scala:212)
    at docker.services.PostgresReadyChecker.$anonfun$apply$1(DockerPostgresService.scala:48)
    at docker.services.PostgresReadyChecker.$anonfun$apply$1$adapted(DockerPostgresService.scala:47)
    at scala.concurrent.impl.Promise$Transformation.run(Promise.scala:430)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
    at java.lang.Thread.run(Thread.java:748)
Caused by: java.io.EOFException
    at org.postgresql.core.PGStream.receiveChar(PGStream.java:290)
    at org.postgresql.core.v3.ConnectionFactoryImpl.doAuthentication(ConnectionFactoryImpl.java:418)
    at org.postgresql.core.v3.ConnectionFactoryImpl.openConnectionImpl(ConnectionFactoryImpl.java:222)
    ... 15 more

PG [f387ecb6533263922aa7619d8c719a044df627a360ba18bfb0cfbac815f67a5f] ok

And my DockerPostgresService implementation:

package docker.services

import java.sql.DriverManager

import com.whisk.docker._
import com.whisk.docker.impl.spotify.DockerKitSpotify
import com.typesafe.config.{Config, ConfigFactory}

import scala.concurrent.{ExecutionContext, Future}
import scala.util.Try

trait DockerPostgresService extends DockerKitSpotify {

  import scala.concurrent.duration._

  lazy val config: Config = ConfigFactory.load()
  lazy val dockerConfig: Config = config.getConfig("docker.postgres")

  val ImageName: String = dockerConfig.getString("image-name")
  val PostgresAdvertisedPort: Int = dockerConfig.getInt("port-maps.default-postgres-port.internal")
  val PostgresExposedPort: Int = dockerConfig.getInt("port-maps.default-postgres-port.external")

  val PostgresUser = "postgres"
  val PostgresPassword = "postgres"

  val postgresContainer: DockerContainer = DockerContainer(ImageName)
    .withPorts((PostgresAdvertisedPort, Some(PostgresExposedPort)))
    .withEnv(s"POSTGRES_USER=$PostgresUser", s"POSTGRES_PASSWORD=$PostgresPassword")
    .withReadyChecker(
      new PostgresReadyChecker(PostgresUser, PostgresPassword, Some(PostgresExposedPort))
        .looped(15, 1.second)
    )
    .withLogLineReceiver(LogLineReceiver(withErr = true, s => println(s"PG $s")))

  override def dockerContainers: List[DockerContainer] =
    postgresContainer :: super.dockerContainers
}

class PostgresReadyChecker(user: String, password: String, port: Option[Int] = None)
  extends DockerReadyChecker {

  override def apply(container: DockerContainerState)(
    implicit docker: DockerCommandExecutor,
    ec: ExecutionContext): Future[Boolean] =
    container
      .getPorts()
      .map(ports =>
        Try {
          Class.forName("org.postgresql.Driver")
          val url = s"jdbc:postgresql://${docker.host}:${port.getOrElse(ports.values.head)}/postgres"
          Option(
            DriverManager.getConnection(url, user, password)
          ).map(_.close).isDefined
        }.getOrElse(false))
}