Implement TransactionProvider

tgkotbot/src/main/kotlin/io/heapy/kotbot/infra/jdbc/JdbcModule.kt

@@ -35,6 +35,12 @@ open class JdbcModule(
         )
     }
 
+    open val transactionProvider: TransactionProvider by lazy {
+        TransactionProvider(
+            dslContext = dslContext,
+        )
+    }
+
     open val hikariConfig by lazy {
         HikariConfig().apply {
             poolName = "kotbot-hikari-pool"

tgkotbot/src/main/kotlin/io/heapy/kotbot/infra/jdbc/TransactionContext.kt

@@ -8,13 +8,16 @@ internal data class JooqTransactionContext(
     internal val dslContext: DSLContext,
 ) : TransactionContext
 
+data object MockTransactionContext : TransactionContext
+
 suspend fun <T> TransactionContext.useTx(
     block: suspend DSLContext.() -> T,
 ): T {
     return when (val context = this) {
         is JooqTransactionContext -> block(context.dslContext)
+        MockTransactionContext -> error("useTx shouldn't be called with mock transaction")
     }
 }
 
-val DSLContext.dslContext: DSLContext
+inline val DSLContext.dslContext: DSLContext
     get() = this

tgkotbot/src/main/kotlin/io/heapy/kotbot/infra/jdbc/TransactionProvider.kt

@@ -0,0 +1,21 @@
+package io.heapy.kotbot.infra.jdbc
+
+import io.heapy.kotbot.infra.Loom
+import kotlinx.coroutines.*
+import org.jooq.DSLContext
+
+class TransactionProvider(
+    private val dslContext: DSLContext,
+) {
+    suspend fun <R> transaction(
+        body: suspend TransactionContext.() -> R,
+    ): R {
+        return withContext(Dispatchers.Loom) {
+            dslContext.transactionResult { configuration ->
+                runBlocking {
+                    JooqTransactionContext(configuration.dsl()).body()
+                }
+            }
+        }
+    }
+}