[FIX] Fix dispatcher for cachedFlow

Author: makeevrserg

gradle.properties

@@ -13,7 +13,7 @@ klibs.java.ktarget=21
 # Project
 klibs.project.name=MessageBridge
 klibs.project.group=ru.astrainteractive.messagebridge
-klibs.project.version.string=0.22.1
+klibs.project.version.string=0.22.2
 klibs.project.description=Bridge for TG and Discord
 klibs.project.developers=makeevrserg|Makeev Roman|makeevrserg@gmail.com
 klibs.project.url=https://empireprojekt.ru

modules/link/src/main/kotlin/ru/astrainteractive/messagebridge/link/database/di/LinkDatabaseModule.kt

@@ -12,6 +12,7 @@ import org.jetbrains.exposed.v1.jdbc.transactions.TransactionManager
 import org.jetbrains.exposed.v1.jdbc.transactions.transaction
 import ru.astrainteractive.astralibs.lifecycle.Lifecycle
 import ru.astrainteractive.klibs.mikro.core.coroutines.mapCached
+import ru.astrainteractive.klibs.mikro.core.dispatchers.KotlinDispatchers
 import ru.astrainteractive.klibs.mikro.exposed.model.DatabaseConfiguration
 import ru.astrainteractive.klibs.mikro.exposed.util.connect
 import ru.astrainteractive.messagebridge.link.database.table.LinkedPlayerTable
@@ -23,11 +24,12 @@ interface LinkDatabaseModule {
 
     class Default(
         ioScope: CoroutineScope,
-        dataFolder: File
+        dataFolder: File,
+        dispatchers: KotlinDispatchers
     ) : LinkDatabaseModule {
         override val databaseFlow: Flow<Database> = flowOf(
             value = DatabaseConfiguration.H2(dataFolder.resolve("linking").absolutePath)
-        ).mapCached(ioScope) { dbConfig, previous ->
+        ).mapCached(ioScope, dispatcher = dispatchers.IO) { dbConfig, previous ->
             previous?.connector?.invoke()?.close()
             previous?.run(TransactionManager::closeAndUnregister)
             val database = dbConfig.connect()

modules/link/src/main/kotlin/ru/astrainteractive/messagebridge/link/di/LinkModule.kt

@@ -29,7 +29,8 @@ interface LinkModule {
 
         private val linkDatabaseModule = LinkDatabaseModule.Default(
             ioScope = coreModule.ioScope,
-            dataFolder = coreModule.dataFolder
+            dataFolder = coreModule.dataFolder,
+            dispatchers = coreModule.dispatchers
         )
 
         override val linkingDao: LinkingDao = LinkingDaoImpl(linkDatabaseModule.databaseFlow)

modules/messenger/discord/src/main/kotlin/ru/astrainteractive/messagebridge/messenger/discord/di/JdaMessengerModule.kt

@@ -93,7 +93,10 @@ class JdaMessengerModule(
 
     private val webhookClient = jdaFlow
         .filterNotNull()
-        .mapCached<JDA, WebhookClient>(coreModule.ioScope) { jda, old ->
+        .mapCached<JDA, WebhookClient>(
+            coreModule.ioScope,
+            dispatcher = coreModule.dispatchers.IO
+        ) { jda, old ->
             old?.close()
             val channel = coreModule.configKrate.cachedValue.jdaConfig.channelId
             WebHookClientFactory(jda).create(channel).first()