replace id with topic

xmtp · Oct 17, 2024 · 585d6aa · 585d6aa
1 parent c7fe699
commit 585d6aa
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/xmtp_mls/src/storage/encrypted_store/v2_conversation.rs b/xmtp_mls/src/storage/encrypted_store/v2_conversation.rs
@@ -74,24 +74,24 @@ impl DbConnection {
                 .optional()?;
 
             if maybe_inserted_conversation.is_none() {
-                let existing_conversation: StoredV2Conversation = dsl::v2_conversations.find(v2_conversation.id).first(conn)?;
-                if existing_conversation.welcome_id == v2_conversation.welcome_id {
+                let existing_conversation: StoredV2Conversation = dsl::v2_conversations.find(v2_conversation.topic).first(conn)?;
+                if existing_conversation.topic == v2_conversation.topic {
                     tracing::info!("V2 Conversation invite already exists");
                     // Error so OpenMLS db transaction are rolled back on duplicate welcomes
                     return Err(StorageError::Duplicate(DuplicateItem::WelcomeId(
-                        existing_group.welcome_id,
+                        existing_conversation.topic,
                     )));
                 } else {
                     tracing::info!("V2 Conversation already exists");
-                    return Ok(existing_group);
+                    return Ok(existing_conversation);
                 }
             } else {
                 tracing::info!("V2 Conversation is inserted");
             }
 
             match maybe_inserted_conversation {
                 Some(v2_conversation) => Ok(v2_conversation),
-                None => Ok(dsl::v2_conversations.find(v2_conversation.id).first(conn)?),
+                None => Ok(dsl::v2_conversations.find(v2_conversation.topic).first(conn)?),
             }
         })?;