chore: fix conversation type not used

core/conversations/src/context.rs

@@ -175,6 +175,13 @@ impl Context {
             .load_conversation(convo_id)?
             .ok_or_else(|| ChatError::NoConvo(convo_id.into()))?;
 
+        if record.convo_type != "private_v1" {
+            return Err(ChatError::BadBundleValue(format!(
+                "unsupported conversation type: {}",
+                record.convo_type
+            )));
+        }
+
         let dr_state: RatchetState = self.ratchet_storage.load(&record.local_convo_id)?;
 
         Ok(PrivateV1Convo::from_stored(

core/conversations/src/errors.rs

@@ -22,6 +22,8 @@ pub enum ChatError {
     BadParsing(&'static str),
     #[error("convo with id: {0} was not found")]
     NoConvo(String),
+    #[error("unsupported conversation type: {0}")]
+    UnsupportedConvoType(String),
     #[error("storage error: {0}")]
     Storage(#[from] StorageError),
 }

core/conversations/src/storage.rs

@@ -180,6 +180,16 @@ impl ChatStorage {
         Ok(exists)
     }
 
+    /// Removes a conversation by its local ID.
+    #[allow(dead_code)]
+    pub fn remove_conversation(&mut self, local_convo_id: &str) -> Result<(), StorageError> {
+        self.db.connection().execute(
+            "DELETE FROM conversations WHERE local_convo_id = ?1",
+            params![local_convo_id],
+        )?;
+        Ok(())
+    }
+
     /// Loads a single conversation record by its local ID.
     pub fn load_conversation(
         &self,
@@ -223,15 +233,6 @@ impl ChatStorage {
 
         Ok(records)
     }
-
-    /// Removes a conversation by its local ID.
-    pub fn remove_conversation(&mut self, local_convo_id: &str) -> Result<(), StorageError> {
-        self.db.connection().execute(
-            "DELETE FROM conversations WHERE local_convo_id = ?1",
-            params![local_convo_id],
-        )?;
-        Ok(())
-    }
 }
 
 #[cfg(test)]