devol
/
smalltalk-matrix
mirror of https://github.com/ouchadam/small-talk.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #208 from ouchadam/bug/importing-keys-fails-first-time 

Room key imports failing the first time
This commit is contained in:
Adam Brown 2022-10-17 23:12:11 +01:00 committed by GitHub
parent 0d9bb308cd 23ba01509c
commit 146e30193f
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
domains/store/src/main/kotlin/app/dapk/st/domain/OlmPersistence.kt
View File

@ -14,6 +14,8 @@ import com.squareup.sqldelight.TransactionWithoutReturn
import kotlinx.coroutines.CoroutineScope import kotlinx.coroutines.CoroutineScope
import kotlinx.coroutines.launch import kotlinx.coroutines.launch
import kotlinx.coroutines.withContext import kotlinx.coroutines.withContext
import kotlin.coroutines.resume
import kotlin.coroutines.suspendCoroutine
class OlmPersistence( class OlmPersistence(
private val database: DapkDb, private val database: DapkDb,
@ -83,11 +85,13 @@ class OlmPersistence(
} }
suspend fun startTransaction(action: suspend TransactionWithoutReturn.() -> Unit) { suspend fun startTransaction(action: suspend TransactionWithoutReturn.() -> Unit) {
val scope = CoroutineScope(dispatchers.io) val transaction = suspendCoroutine { continuation ->
database.cryptoQueries.transaction { database.cryptoQueries.transaction {
scope.launch { action() } continuation.resume(this)
} }
} }
action(transaction)
}
suspend fun persist(sessionId: SessionId, inboundGroupSession: SerializedObject) { suspend fun persist(sessionId: SessionId, inboundGroupSession: SerializedObject) {
withContext(dispatchers.io) { withContext(dispatchers.io) {