feat(mls): add getMLSSelfConversationGroupId to ConversationDao

wireapp · Oct 18, 2023 · 3945b26 · 3945b26
1 parent c82d8aa
commit 3945b26
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 0 deletions.
diff --git a/persistence/src/commonMain/db_user/com/wire/kalium/persistence/Conversations.sq b/persistence/src/commonMain/db_user/com/wire/kalium/persistence/Conversations.sq
@@ -354,6 +354,9 @@ SELECT changes();
 selfConversationId:
 SELECT qualified_id FROM Conversation WHERE type = 'SELF' AND protocol = ? LIMIT 1;
 
+selfMLSGroupId:
+SELECT mls_group_id FROM Conversation WHERE type = 'SELF' AND protocol = 'MLS' LIMIT 1;
+
 updateConversationReceiptMode:
 UPDATE Conversation
 SET receipt_mode = ?

diff --git a/...nce/src/commonMain/kotlin/com/wire/kalium/persistence/dao/conversation/ConversationDAO.kt b/...nce/src/commonMain/kotlin/com/wire/kalium/persistence/dao/conversation/ConversationDAO.kt
@@ -31,6 +31,7 @@ data class ProposalTimerEntity(
 
 interface ConversationDAO {
     suspend fun getSelfConversationId(protocol: ConversationEntity.Protocol): QualifiedIDEntity?
+    suspend fun getMLSSelfConversationGroupId(): String?
     suspend fun insertConversation(conversationEntity: ConversationEntity)
     suspend fun insertConversations(conversationEntities: List<ConversationEntity>)
     suspend fun updateConversation(conversationEntity: ConversationEntity)

diff --git a/...src/commonMain/kotlin/com/wire/kalium/persistence/dao/conversation/ConversationDAOImpl.kt b/...src/commonMain/kotlin/com/wire/kalium/persistence/dao/conversation/ConversationDAOImpl.kt
@@ -58,6 +58,10 @@ internal class ConversationDAOImpl internal constructor(
         conversationQueries.selfConversationId(protocol).executeAsOneOrNull()
     }
 
+    override suspend fun getMLSSelfConversationGroupId(): String? = withContext(coroutineContext) {
+        conversationQueries.selfMLSGroupId().executeAsOneOrNull()?.mls_group_id
+    }
+
     override suspend fun insertConversation(conversationEntity: ConversationEntity) = withContext(coroutineContext) {
         nonSuspendingInsertConversation(conversationEntity)
     }