Batch insertion of shouldEncryptForInvitedMembers

hughns · Jan 3, 2023 · c1a8bf8 · c1a8bf8
1 parent 6f384c7
commit c1a8bf8
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 4 deletions.
diff --git a/...id/src/main/java/org/matrix/android/sdk/internal/crypto/store/db/CryptoStoreAggregator.kt b/...id/src/main/java/org/matrix/android/sdk/internal/crypto/store/db/CryptoStoreAggregator.kt
@@ -17,5 +17,6 @@
 package org.matrix.android.sdk.internal.crypto.store.db
 
 data class CryptoStoreAggregator(
-        val setShouldShareHistoryData: MutableMap<String, Boolean> = mutableMapOf()
+        val setShouldShareHistoryData: MutableMap<String, Boolean> = mutableMapOf(),
+        val setShouldEncryptForInvitedMembersData: MutableMap<String, Boolean> = mutableMapOf(),
 )
diff --git a/...android/src/main/java/org/matrix/android/sdk/internal/crypto/store/db/RealmCryptoStore.kt b/...android/src/main/java/org/matrix/android/sdk/internal/crypto/store/db/RealmCryptoStore.kt
@@ -708,9 +708,7 @@ internal class RealmCryptoStore @Inject constructor(
     }
 
     override fun setShouldEncryptForInvitedMembers(roomId: String, shouldEncryptForInvitedMembers: Boolean) {
-        doRealmTransaction(realmConfiguration) {
-            CryptoRoomEntity.getOrCreate(it, roomId).shouldEncryptForInvitedMembers = shouldEncryptForInvitedMembers
-        }
+        cryptoStoreAggregator?.setShouldEncryptForInvitedMembersData?.put(roomId, shouldEncryptForInvitedMembers)
     }
 
     override fun setShouldShareHistory(roomId: String, shouldShareHistory: Boolean) {
@@ -1832,6 +1830,10 @@ internal class RealmCryptoStore @Inject constructor(
             aggregator.setShouldShareHistoryData.map {
                 CryptoRoomEntity.getOrCreate(realm, it.key).shouldShareHistory = it.value
             }
+            // setShouldEncryptForInvitedMembers
+            aggregator.setShouldEncryptForInvitedMembersData.map {
+                CryptoRoomEntity.getOrCreate(realm, it.key).shouldEncryptForInvitedMembers = it.value
+            }
         }
         cryptoStoreAggregator = null
     }