add purpose field to mls group

xmtp · Oct 29, 2024 · ee9567c · ee9567c
1 parent a59284a
commit ee9567c
Show file tree

Hide file tree

Showing 10 changed files with 163 additions and 22 deletions.
diff --git a/bindings_ffi/src/mls.rs b/bindings_ffi/src/mls.rs
@@ -1376,6 +1376,7 @@ impl FfiConversation {
             self.inner.client.clone(),
             self.id(),
             self.inner.created_at_ns,
+            self.inner.purpose,
             move |message| match message {
                 Ok(m) => message_callback.on_message(m.into()),
                 Err(e) => message_callback.on_error(e.into()),

diff --git a/bindings_node/src/groups.rs b/bindings_node/src/groups.rs
@@ -12,7 +12,7 @@ use xmtp_mls::{
     members::PermissionLevel,
     MlsGroup, UpdateAdminListType,
   },
-  storage::group_message::MsgQueryArgs,
+  storage::{group::Purpose, group_message::MsgQueryArgs},
 };
 use xmtp_proto::xmtp::mls::message_contents::EncodedContent;
 
@@ -73,6 +73,7 @@ pub struct NapiGroup {
   inner_client: Arc<RustXmtpClient>,
   group_id: Vec<u8>,
   created_at_ns: i64,
+  purpose: Purpose,
 }
 
 impl From<MlsGroup<RustXmtpClient>> for NapiGroup {
@@ -81,17 +82,24 @@ impl From<MlsGroup<RustXmtpClient>> for NapiGroup {
       group_id: mls_group.group_id,
       created_at_ns: mls_group.created_at_ns,
       inner_client: mls_group.client,
+      purpose: mls_group.purpose,
     }
   }
 }
 
 #[napi]
 impl NapiGroup {
-  pub fn new(inner_client: Arc<RustXmtpClient>, group_id: Vec<u8>, created_at_ns: i64) -> Self {
+  pub fn new(
+    inner_client: Arc<RustXmtpClient>,
+    group_id: Vec<u8>,
+    created_at_ns: i64,
+    purpose: Purpose,
+  ) -> Self {
     Self {
       inner_client,
       group_id,
       created_at_ns,
+      purpose,
     }
   }
 
@@ -107,6 +115,7 @@ impl NapiGroup {
       self.inner_client.clone(),
       self.group_id.clone(),
       self.created_at_ns,
+      self.purpose,
     );
 
     let message_id = group
@@ -124,6 +133,7 @@ impl NapiGroup {
       self.inner_client.clone(),
       self.group_id.clone(),
       self.created_at_ns,
+      self.purpose,
     );
 
     let id = group
@@ -140,6 +150,7 @@ impl NapiGroup {
       self.inner_client.clone(),
       self.group_id.clone(),
       self.created_at_ns,
+      self.purpose,
     );
     group.publish_messages().await.map_err(ErrorWrapper::from)?;
     Ok(())
@@ -151,6 +162,7 @@ impl NapiGroup {
       self.inner_client.clone(),
       self.group_id.clone(),
       self.created_at_ns,
+      self.purpose,
     );
 
     group.sync().await.map_err(ErrorWrapper::from)?;
@@ -174,6 +186,7 @@ impl NapiGroup {
       self.inner_client.clone(),
       self.group_id.clone(),
       self.created_at_ns,
+      self.purpose,
     );
 
     let delivery_status = opts.delivery_status.map(|status| status.into());
@@ -203,6 +216,7 @@ impl NapiGroup {
       self.inner_client.clone(),
       self.group_id.clone(),
       self.created_at_ns,
+      self.purpose,
     );
     let envelope_bytes: Vec<u8> = envelope_bytes.deref().to_vec();
     let message = group
@@ -219,6 +233,7 @@ impl NapiGroup {
       self.inner_client.clone(),
       self.group_id.clone(),
       self.created_at_ns,
+      self.purpose,
     );
 
     let members: Vec<NapiGroupMember> = group
@@ -252,6 +267,7 @@ impl NapiGroup {
       self.inner_client.clone(),
       self.group_id.clone(),
       self.created_at_ns,
+      self.purpose,
     );
 
     let admin_list = group
@@ -267,6 +283,7 @@ impl NapiGroup {
       self.inner_client.clone(),
       self.group_id.clone(),
       self.created_at_ns,
+      self.purpose,
     );
 
     let super_admin_list = group
@@ -294,6 +311,7 @@ impl NapiGroup {
       self.inner_client.clone(),
       self.group_id.clone(),
       self.created_at_ns,
+      self.purpose,
     );
 
     group
@@ -310,6 +328,7 @@ impl NapiGroup {
       self.inner_client.clone(),
       self.group_id.clone(),
       self.created_at_ns,
+      self.purpose,
     );
     group
       .update_admin_list(UpdateAdminListType::Add, inbox_id)
@@ -325,6 +344,7 @@ impl NapiGroup {
       self.inner_client.clone(),
       self.group_id.clone(),
       self.created_at_ns,
+      self.purpose,
     );
     group
       .update_admin_list(UpdateAdminListType::Remove, inbox_id)
@@ -340,6 +360,7 @@ impl NapiGroup {
       self.inner_client.clone(),
       self.group_id.clone(),
       self.created_at_ns,
+      self.purpose,
     );
     group
       .update_admin_list(UpdateAdminListType::AddSuper, inbox_id)
@@ -355,6 +376,7 @@ impl NapiGroup {
       self.inner_client.clone(),
       self.group_id.clone(),
       self.created_at_ns,
+      self.purpose,
     );
     group
       .update_admin_list(UpdateAdminListType::RemoveSuper, inbox_id)
@@ -370,6 +392,7 @@ impl NapiGroup {
       self.inner_client.clone(),
       self.group_id.clone(),
       self.created_at_ns,
+      self.purpose,
     );
 
     let permissions = group.permissions().map_err(ErrorWrapper::from)?;
@@ -383,6 +406,7 @@ impl NapiGroup {
       self.inner_client.clone(),
       self.group_id.clone(),
       self.created_at_ns,
+      self.purpose,
     );
 
     group
@@ -399,6 +423,7 @@ impl NapiGroup {
       self.inner_client.clone(),
       self.group_id.clone(),
       self.created_at_ns,
+      self.purpose,
     );
 
     group
@@ -415,6 +440,7 @@ impl NapiGroup {
       self.inner_client.clone(),
       self.group_id.clone(),
       self.created_at_ns,
+      self.purpose,
     );
 
     group
@@ -431,6 +457,7 @@ impl NapiGroup {
       self.inner_client.clone(),
       self.group_id.clone(),
       self.created_at_ns,
+      self.purpose,
     );
 
     group
@@ -447,6 +474,7 @@ impl NapiGroup {
       self.inner_client.clone(),
       self.group_id.clone(),
       self.created_at_ns,
+      self.purpose,
     );
 
     let group_name = group
@@ -462,6 +490,7 @@ impl NapiGroup {
       self.inner_client.clone(),
       self.group_id.clone(),
       self.created_at_ns,
+      self.purpose,
     );
 
     group
@@ -478,6 +507,7 @@ impl NapiGroup {
       self.inner_client.clone(),
       self.group_id.clone(),
       self.created_at_ns,
+      self.purpose,
     );
 
     let group_image_url_square = group
@@ -493,6 +523,7 @@ impl NapiGroup {
       self.inner_client.clone(),
       self.group_id.clone(),
       self.created_at_ns,
+      self.purpose,
     );
 
     group
@@ -509,6 +540,7 @@ impl NapiGroup {
       self.inner_client.clone(),
       self.group_id.clone(),
       self.created_at_ns,
+      self.purpose,
     );
 
     let group_description = group
@@ -524,6 +556,7 @@ impl NapiGroup {
       self.inner_client.clone(),
       self.group_id.clone(),
       self.created_at_ns,
+      self.purpose,
     );
 
     group
@@ -540,6 +573,7 @@ impl NapiGroup {
       self.inner_client.clone(),
       self.group_id.clone(),
       self.created_at_ns,
+      self.purpose,
     );
 
     let group_pinned_frame_url = group
@@ -557,6 +591,7 @@ impl NapiGroup {
       self.inner_client.clone(),
       self.group_id.clone(),
       self.created_at_ns,
+      self.purpose,
       move |message| {
         tsfn.call(
           message
@@ -582,6 +617,7 @@ impl NapiGroup {
       self.inner_client.clone(),
       self.group_id.clone(),
       self.created_at_ns,
+      self.purpose,
     );
 
     Ok(
@@ -597,6 +633,7 @@ impl NapiGroup {
       self.inner_client.clone(),
       self.group_id.clone(),
       self.created_at_ns,
+      self.purpose,
     );
 
     Ok(group.added_by_inbox_id().map_err(ErrorWrapper::from)?)
@@ -608,6 +645,7 @@ impl NapiGroup {
       self.inner_client.clone(),
       self.group_id.clone(),
       self.created_at_ns,
+      self.purpose,
     );
 
     let metadata = group
@@ -623,6 +661,7 @@ impl NapiGroup {
       self.inner_client.clone(),
       self.group_id.clone(),
       self.created_at_ns,
+      self.purpose,
     );
 
     let state = group.consent_state().map_err(ErrorWrapper::from)?;
@@ -636,6 +675,7 @@ impl NapiGroup {
       self.inner_client.clone(),
       self.group_id.clone(),
       self.created_at_ns,
+      self.purpose,
     );
 
     group

diff --git a/bindings_wasm/src/conversations.rs b/bindings_wasm/src/conversations.rs
@@ -131,6 +131,7 @@ impl WasmConversations {
       self.inner_client.clone(),
       convo.group_id,
       convo.created_at_ns,
+      convo.purpose,
     );
 
     Ok(out)
@@ -149,6 +150,7 @@ impl WasmConversations {
       self.inner_client.clone(),
       group.group_id,
       group.created_at_ns,
+      group.purpose,
     ))
   }
 
@@ -203,6 +205,7 @@ impl WasmConversations {
           self.inner_client.clone(),
           group.group_id,
           group.created_at_ns,
+          group.purpose,
         ))
       })
       .collect();