Add ElasticsearchServer for testing

Author: debop

jasync/jasync-mysql-example/src/test/kotlin/io/github/debop/examples/BasicConnectionExample.kt

@@ -70,7 +70,7 @@ class BasicConnectionExample: AbstractJasyncTest() {
 
         withContext(Dispatchers.IO) {
             val result1 = conn.sendPreparedStatement("SELECT 1")
-            val result2 = conn.sendPreparedStatement("SELECT 1")
+            val result2 = conn.sendPreparedStatement("SELECT 2")
 
             val rowData1 = result1.await().rows[0] as ArrayRowData
             val rowData2 = result2.await().rows[0] as ArrayRowData

kotlin-koin-example/build.gradle.kts

@@ -3,6 +3,7 @@ dependencies {
     api(project(":kotlin-basic"))
     testImplementation(project(":kotlin-tests"))
 
+    api(Libraries.koin_core)
     api(Libraries.koin_core_ext)
     testImplementation(Libraries.koin_test)
 

kotlin-koin-example/src/main/kotlin/io/github/debop/koin/example/coffeemaker/CoffeeAppModule.kt

@@ -1,9 +1,14 @@
 package io.github.debop.koin.example.coffeemaker
 
 import org.koin.dsl.module
+import org.koin.experimental.builder.singleBy
 
 val coffeeAppModule = module {
-    single<CoffeeMaker> { CoffeeMaker(get(), get()) }
-    single<Pump>(createdAtStart = false, override = true) { Thermosiphon(get()) }
-    single<Heater>(createdAtStart = false, override = false) { ElectricHeater() }
+    single { CoffeeMaker(get(), get()) }
+    //    single<Pump>(createdAtStart = false, override = true) { Thermosiphon(get()) }
+    //    single<Heater>(createdAtStart = false, override = false) { ElectricHeater() }
+
+    // koin-core-ext 의 extension method 를 사용할 수 있다 
+    singleBy<Pump, Thermosiphon>(createOnStart = false, override = true)
+    singleBy<Heater, ElectricHeater>(createOnStart = false, override = false)
 }

kotlin-tests/build.gradle.kts

@@ -9,7 +9,8 @@ dependencies {
     api(Libraries.testcontainers_mariadb)
     api(Libraries.testcontainers_mysql)
     api(Libraries.testcontainers_postgresql)
-    api(Libraries.testcontainers_kafka)
+    implementation(Libraries.testcontainers_kafka)
+    implementation(Libraries.testcontainers_elasticsearch)
 
     api(Libraries.hikaricp)
     api(Libraries.mysql_connector_java)

kotlin-tests/src/main/kotlin/io/github/debop/kotlin/tests/containers/ElasticsearchServer.kt

@@ -0,0 +1,65 @@
+package io.github.debop.kotlin.tests.containers
+
+import com.github.dockerjava.api.model.ExposedPort
+import com.github.dockerjava.api.model.PortBinding
+import com.github.dockerjava.api.model.Ports.Binding
+import mu.KLogging
+import org.testcontainers.containers.output.Slf4jLogConsumer
+import org.testcontainers.containers.wait.strategy.Wait
+import org.testcontainers.elasticsearch.ElasticsearchContainer
+
+/**
+ * ElasticSearchServer
+ * @author debop (Sunghyouk Bae)
+ */
+class ElasticsearchServer(tag: String = ELASTICSEARCH_DEFAULT_VERSION,
+                          private val useDefaultPort: Boolean = false)
+    : ElasticsearchContainer("$IMAGE:$tag") {
+
+    companion object: KLogging() {
+        const val IMAGE = "docker.elastic.co/elasticsearch/elasticsearch"
+        const val NAME = "elasticsearch"
+        const val ELASTICSEARCH_PORT = 9200
+        const val ELASTICSEARCH_TCP_PORT = 9300
+    }
+
+    init {
+        withExposedPorts(ELASTICSEARCH_PORT, ELASTICSEARCH_TCP_PORT)
+        withLogConsumer(Slf4jLogConsumer(logger))
+        setWaitStrategy(Wait.forListeningPort())
+
+        // BUG: 왜 기본 Port 매핑이 안되는지???
+        if (useDefaultPort) {
+            withCreateContainerCmdModifier {
+                it.withPortBindings(PortBinding(Binding.bindPort(ELASTICSEARCH_PORT), ExposedPort(ELASTICSEARCH_PORT)))
+                it.withPortBindings(PortBinding(Binding.bindPort(ELASTICSEARCH_TCP_PORT), ExposedPort(ELASTICSEARCH_TCP_PORT)))
+            }
+        }
+    }
+
+    val host: String get() = containerIpAddress
+    val port: Int by lazy { getMappedPort(ELASTICSEARCH_PORT) }
+    val tcpPort: Int by lazy { getMappedPort(ELASTICSEARCH_TCP_PORT) }
+    val url: String get() = "http://$host:$port"
+
+    override fun start() {
+        super.start()
+
+        val name = "$CONTAINER_PREFIX.$NAME"
+
+        System.setProperty("$name.host", host)
+        System.setProperty("$name.port", port.toString())
+        System.setProperty("$name.tcp-port", tcpPort.toString())
+        System.setProperty("$name.url", url)
+
+        RedisServer.logger.info {
+            """
+            |Start TestContainer Elasticsearch:
+            |    $name.host=$host
+            |    $name.port=$port
+            |    $name.tcp-port=$tcpPort
+            |    $name.url=$url
+            """.trimMargin()
+        }
+    }
+}

kotlin-tests/src/test/kotlin/io/github/debop/kotlin/tests/containers/ElasticsearchServerTest.kt

@@ -0,0 +1,34 @@
+package io.github.debop.kotlin.tests.containers
+
+import mu.KLogging
+import org.amshove.kluent.shouldBeTrue
+import org.amshove.kluent.shouldEqualTo
+import org.junit.jupiter.api.AfterAll
+import org.junit.jupiter.api.BeforeAll
+import org.junit.jupiter.api.Test
+
+class ElasticsearchServerTest {
+
+    companion object: KLogging() {
+        val elasticsearchServer = ElasticsearchServer(useDefaultPort = true)
+    }
+
+    @BeforeAll
+    fun beforeAll() {
+        elasticsearchServer.start()
+    }
+
+    @AfterAll
+    fun afterAll() {
+        elasticsearchServer.stop()
+    }
+
+    @Test
+    fun `run elasticsearch server`() {
+        elasticsearchServer.isRunning.shouldBeTrue()
+
+        // BUG: 왜 기본 Port 매핑이 안되는지???
+        elasticsearchServer.port shouldEqualTo ElasticsearchServer.ELASTICSEARCH_PORT
+        elasticsearchServer.tcpPort shouldEqualTo ElasticsearchServer.ELASTICSEARCH_TCP_PORT
+    }
+}