Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 2 additions & 2 deletions build.sbt
Original file line number Diff line number Diff line change
Expand Up @@ -10,8 +10,8 @@ name := "docker-testkit-munit"
testFrameworks += new TestFramework("munit.Framework")
fork in Test := true

val munit = "org.scalameta" %% "munit" % "[0.2.0,)" % Provided // scala-steward:off
val testKitVersion = "0.9.9"
val munit = "org.scalameta" %% "munit" % "1.0.0-M1" % Provided // scala-steward:off
val testKitVersion = "0.11.0-beta1"

libraryDependencies += munit

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -80,16 +80,16 @@ class DependencyGraphReadyCheckSpec extends FunSuite with DockerKitSpotify {
} catch {
case e: RuntimeException => log.error("Test failed during readychecks", e)
} finally {
Await.ready(containerManager.stopRmAll(), StopContainersTimeout)
Await.ready(containerManager.stopRmAll(StopContainersTimeout), StopContainersTimeout)
()
}
}

override def startAllOrFail(): Unit = {
Await.result(containerManager.pullImages(), PullImagesTimeout)
Await.result(containerManager.pullImages(PullImagesTimeout), PullImagesTimeout)
containerManager.initReadyAll(StartContainersTimeout).map(_.map(_._2).forall(identity))
sys.addShutdownHook {
containerManager.stopRmAll()
containerManager.stopRmAll(StopContainersTimeout)
()
}
()
Expand Down
6 changes: 6 additions & 0 deletions src/test/scala/docker/munit/DockerContainerLinkingSpec.scala
Original file line number Diff line number Diff line change
Expand Up @@ -21,6 +21,9 @@ import com.whisk.docker.impl.dockerjava._
import com.whisk.docker.impl.spotify._
import _root_.munit.FunSuite

import scala.concurrent.duration._
import scala.language.postfixOps

abstract class DockerContainerLinkingSpec extends FunSuite with DockerTestKit {

lazy val cmdExecutor = implicitly[DockerCommandExecutor]
Expand All @@ -37,6 +40,9 @@ abstract class DockerContainerLinkingSpec extends FunSuite with DockerTestKit {
override def dockerContainers = pingService :: pongService :: super.dockerContainers

test("A DockerContainer should be linked to the specified containers upon start") {

implicit val InspectTimeout = 3 seconds

val ping = cmdExecutor.inspectContainer(pingName)
val pongPing = cmdExecutor.inspectContainer(s"$pongName/$pingAlias")

Expand Down
5 changes: 5 additions & 0 deletions src/test/scala/docker/munit/ElasticsearchServiceSpec.scala
Original file line number Diff line number Diff line change
Expand Up @@ -20,13 +20,18 @@ import com.whisk.docker._
import com.whisk.docker.impl.dockerjava.DockerKitDockerJava
import _root_.munit.FunSuite

import scala.concurrent.duration._
import scala.language.postfixOps

class ElasticsearchServiceSpec
extends FunSuite
with DockerElasticsearchService
with DockerTestKit
with DockerKitDockerJava {

test("elasticsearch container should be ready") {
implicit val ContainerReadyTimeout = 3 seconds

isContainerReady(elasticsearchContainer).map(assert(_))
elasticsearchContainer.getPorts().map(m => assert(m.get(9300).nonEmpty))
elasticsearchContainer.getIpAddresses().map(s => assert(s.nonEmpty))
Expand Down
5 changes: 5 additions & 0 deletions src/test/scala/docker/munit/MongodbServiceSpec.scala
Original file line number Diff line number Diff line change
Expand Up @@ -20,13 +20,18 @@ import com.whisk.docker._
import com.whisk.docker.impl.spotify.DockerKitSpotify
import _root_.munit.FunSuite

import scala.concurrent.duration._
import scala.language.postfixOps

class MongodbServiceSpec
extends FunSuite
with DockerTestKit
with DockerKitSpotify
with DockerMongodbService {

test("mongodb node should be ready with log line checker") {
implicit val ContainerReadyTimeout = 3 seconds

isContainerReady(mongodbContainer).map(assert(_))
mongodbContainer.getPorts().map(m => assert(m.get(27017).nonEmpty))
mongodbContainer.getIpAddresses().map(s => assert(s.nonEmpty))
Expand Down