Configure redis for ktor/koin

src/main/kotlin/eventDemo/configuration/injection/ConfigureDI.kt

@@ -2,10 +2,14 @@ package eventDemo.configuration.injection
 
 import org.koin.dsl.module
 
-val appKoinModule =
+fun appKoinModule(config: Configuration) =
   module {
     configureDIBusiness()
-    configureDIInfrastructure()
+    configureDIInfrastructure(config.redisUrl)
     configureDILibs()
     configureDICommandActions()
   }
+
+data class Configuration(
+  val redisUrl: String,
+)

src/main/kotlin/eventDemo/configuration/injection/ConfigureDIInfrastructure.kt

@@ -14,8 +14,13 @@ import eventDemo.libs.event.projection.SnapshotConfig
 import org.koin.core.module.Module
 import org.koin.core.module.dsl.singleOf
 import org.koin.dsl.bind
+import redis.clients.jedis.JedisPool
+
+fun Module.configureDIInfrastructure(redisUrl: String) {
+  single {
+    JedisPool(redisUrl)
+  }
 
-fun Module.configureDIInfrastructure() {
   singleOf(::GameEventBusInMemory) bind GameEventBus::class
   singleOf(::GameEventStoreInMemory) bind GameEventStore::class
   singleOf(::GameProjectionBusInMemory) bind GameProjectionBus::class

src/main/kotlin/eventDemo/configuration/ktor/ConfigureKoin.kt

@@ -1,5 +1,6 @@
 package eventDemo.configuration.ktor
 
+import eventDemo.configuration.injection.Configuration
 import eventDemo.configuration.injection.appKoinModule
 import io.ktor.server.application.Application
 import io.ktor.server.application.install
@@ -9,6 +10,8 @@ import org.koin.logger.slf4jLogger
 fun Application.configureKoin() {
   install(Koin) {
     slf4jLogger()
-    modules(appKoinModule)
+
+    val redisUrl = environment.config.propertyOrNull("redis.url")?.getString() ?: error("You must set the redis.url")
+    modules(appKoinModule(Configuration(redisUrl)))
   }
 }

src/main/resources/application.conf

@@ -2,3 +2,8 @@ jwt {
     secret = "secret"
     secret = ${?JWT_SECRET}
 }
+
+redis {
+    url = "redis://localhost:6379"
+    url = ${?REDIS_URL}
+}

src/test/kotlin/eventDemo/adapter/interfaceLayer/query/GameSimulationTest.kt

@@ -27,6 +27,7 @@ import eventDemo.libs.event.projection.ProjectionSnapshotRepositoryInMemory
 import io.kotest.core.spec.style.FunSpec
 import io.kotest.matchers.collections.shouldHaveSize
 import io.kotest.matchers.equals.shouldBeEqual
+import io.mockk.mockk
 import kotlinx.coroutines.DelicateCoroutinesApi
 import kotlinx.coroutines.Dispatchers
 import kotlinx.coroutines.GlobalScope
@@ -170,7 +171,7 @@ class GameSimulationTest :
             }
           }
 
-        koinApplication { modules(appKoinModule) }.koin.apply {
+        koinApplication { modules(appKoinModule(mockk(relaxed = true))) }.koin.apply {
           val commandHandler by inject<GameCommandHandler>()
           val eventStore by inject<GameEventStore>()
           val playerNotificationListener by inject<PlayerNotificationListener>()

src/test/kotlin/eventDemo/business/command/GameCommandHandlerTest.kt

@@ -13,6 +13,7 @@ import eventDemo.configuration.injection.appKoinModule
 import io.kotest.core.spec.style.FunSpec
 import io.kotest.matchers.collections.shouldContain
 import io.kotest.matchers.equals.shouldBeEqual
+import io.mockk.mockk
 import kotlinx.coroutines.DelicateCoroutinesApi
 import kotlinx.coroutines.GlobalScope
 import kotlinx.coroutines.channels.Channel
@@ -25,7 +26,7 @@ import kotlin.test.assertIs
 class GameCommandHandlerTest :
   FunSpec({
     test("handle a command should execute the command") {
-      koinApplication { modules(appKoinModule) }.koin.apply {
+      koinApplication { modules(appKoinModule(mockk(relaxed = true))) }.koin.apply {
         val commandHandler by inject<GameCommandHandler>()
         val notificationListener by inject<PlayerNotificationListener>()
         val gameId = GameId()

src/test/kotlin/eventDemo/business/event/projection/GameStateRepositoryTest.kt

@@ -9,6 +9,7 @@ import eventDemo.configuration.injection.appKoinModule
 import io.kotest.core.spec.style.FunSpec
 import io.kotest.matchers.collections.shouldHaveSize
 import io.kotest.matchers.equals.shouldBeEqual
+import io.mockk.mockk
 import kotlinx.coroutines.DelicateCoroutinesApi
 import kotlinx.coroutines.GlobalScope
 import kotlinx.coroutines.joinAll
@@ -25,7 +26,7 @@ class GameStateRepositoryTest :
 
     test("GameStateRepository should build the projection when a new event occurs") {
       val aggregateId = GameId()
-      koinApplication { modules(appKoinModule) }.koin.apply {
+      koinApplication { modules(appKoinModule(mockk(relaxed = true))) }.koin.apply {
         val repo = get<GameStateRepository>()
         val eventHandler = get<GameEventHandler>()
         eventHandler
@@ -44,7 +45,7 @@ class GameStateRepositoryTest :
 
     test("get should build the last version of the state") {
       val aggregateId = GameId()
-      koinApplication { modules(appKoinModule) }.koin.apply {
+      koinApplication { modules(appKoinModule(mockk(relaxed = true))) }.koin.apply {
         val repo = get<GameStateRepository>()
         val eventHandler = get<GameEventHandler>()
 
@@ -69,7 +70,7 @@ class GameStateRepositoryTest :
     test("getUntil should build the state until the event") {
       repeat(10) {
         val aggregateId = GameId()
-        koinApplication { modules(appKoinModule) }.koin.apply {
+        koinApplication { modules(appKoinModule(mockk(relaxed = true))) }.koin.apply {
           val repo = get<GameStateRepository>()
           val eventHandler = get<GameEventHandler>()
 
@@ -98,7 +99,7 @@ class GameStateRepositoryTest :
 
     test("getUntil should be concurrently secure") {
       val aggregateId = GameId()
-      koinApplication { modules(appKoinModule) }.koin.apply {
+      koinApplication { modules(appKoinModule(mockk(relaxed = true))) }.koin.apply {
         val repo = get<GameStateRepository>()
         val eventHandler = get<GameEventHandler>()