fix: add transactionWithResult when updateUser and return select changes

wireapp · Feb 2, 2024 · ec37231 · ec37231
1 parent c487237
commit ec37231
Showing 1 changed file with 13 additions and 10 deletions.
diff --git a/persistence/src/commonMain/kotlin/com/wire/kalium/persistence/dao/UserDAOImpl.kt b/persistence/src/commonMain/kotlin/com/wire/kalium/persistence/dao/UserDAOImpl.kt
@@ -193,16 +193,19 @@ class UserDAOImpl internal constructor(
     }
 
     override suspend fun updateUser(update: PartialUserEntity) = withContext(queriesContext) {
-        userQueries.updateUser(
-            name = update.name,
-            handle = update.handle,
-            email = update.email,
-            accent_id = update.accentId?.toLong(),
-            preview_asset_id = update.previewAssetId,
-            complete_asset_id = update.completeAssetId,
-            supported_protocols = update.supportedProtocols,
-            update.id
-        ).executeAsOne() > 0
+        userQueries.transactionWithResult {
+            userQueries.updateUser(
+                name = update.name,
+                handle = update.handle,
+                email = update.email,
+                accent_id = update.accentId?.toLong(),
+                preview_asset_id = update.previewAssetId,
+                complete_asset_id = update.completeAssetId,
+                supported_protocols = update.supportedProtocols,
+                update.id
+            )
+            userQueries.selectChanges().executeAsOne() > 0
+        }
     }
 
     override suspend fun updateUser(users: List<PartialUserEntity>) = withContext(queriesContext) {