package eventDemo.configuration.injection

import com.zaxxer.hikari.HikariConfig
import com.zaxxer.hikari.HikariDataSource
import eventDemo.adapter.infrastructureLayer.event.GameEventBusInMemory
import eventDemo.adapter.infrastructureLayer.event.GameEventStoreInPostgresql
import eventDemo.adapter.infrastructureLayer.event.projection.GameListRepositoryInMemory
import eventDemo.adapter.infrastructureLayer.event.projection.GameProjectionBusInMemory
import eventDemo.adapter.infrastructureLayer.event.projection.GameStateRepositoryInRedis
import eventDemo.business.event.GameEventBus
import eventDemo.business.event.GameEventStore
import eventDemo.business.event.projection.GameProjectionBus
import eventDemo.business.event.projection.gameList.GameListRepository
import eventDemo.business.event.projection.gameState.GameStateRepository
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.JedisPooled
import redis.clients.jedis.UnifiedJedis
import javax.sql.DataSource

fun Module.configureDIInfrastructure(config: Configuration) {
  factory {
    JedisPooled(config.redisUrl)
  } bind UnifiedJedis::class

  single {
    HikariConfig()
      .apply {
        jdbcUrl = config.postgresql.url
        username = config.postgresql.username
        password = config.postgresql.password
        maximumPoolSize = 10
        minimumIdle = 10
      }.let {
        HikariDataSource(it)
      }
  } bind DataSource::class

  singleOf(::GameEventBusInMemory) bind GameEventBus::class
  singleOf(::GameEventStoreInPostgresql) bind GameEventStore::class
  singleOf(::GameProjectionBusInMemory) bind GameProjectionBus::class

  single {
    GameStateRepositoryInRedis(get(), get(), get(), get(), snapshotConfig = SnapshotConfig())
  } bind GameStateRepository::class

  single {
    GameListRepositoryInMemory(get(), get(), get(), snapshotConfig = SnapshotConfig())
  } bind GameListRepository::class
}