Add consent & user preference streaming to WASM bindings

bindings_wasm/README.md

@@ -8,3 +8,8 @@
 - `yarn`: Installs all dependencies (required before building)
 - `yarn build`: Build a release version of the WASM bindings for the current platform
 - `yarn lint`: Run cargo clippy and fmt checks
+- `yarn check:macos`: Run cargo check for macOS (requires Homebrew and `llvm` to be installed)
+
+# Publishing
+
+To release a new version of the bindings, update the version in `package.json` with the appropriate semver value and add an entry to the CHANGELOG.md file. Once merged, manually trigger the `Release WASM Bindings` workflow to build and publish the bindings.

bindings_wasm/package.json

@@ -27,6 +27,7 @@
     "build": "yarn clean && yarn build:web && yarn build:copy && yarn clean:release",
     "build:web": "cargo xtask build BindingsWasm --out-dir ./dist --plain -- --release",
     "build:copy": "node scripts/copyFiles.js",
+    "check:macos": "CC_wasm32_unknown_unknown=/opt/homebrew/opt/llvm/bin/clang cargo check --target wasm32-unknown-unknown",
     "clean:release": "rm -f ./dist/package.json",
     "clean": "rm -rf ./dist",
     "lint": "yarn lint:clippy && yarn lint:fmt",

bindings_wasm/src/consent_state.rs

@@ -81,6 +81,20 @@ impl From<Consent> for StoredConsentRecord {
   }
 }
 
+impl From<StoredConsentRecord> for Consent {
+  fn from(value: StoredConsentRecord) -> Self {
+    Self {
+      entity: value.entity,
+      entity_type: match value.entity_type {
+        XmtpConsentType::Address => ConsentEntityType::Address,
+        XmtpConsentType::ConversationId => ConsentEntityType::GroupId,
+        XmtpConsentType::InboxId => ConsentEntityType::InboxId,
+      },
+      state: value.state.into(),
+    }
+  }
+}
+
 #[wasm_bindgen]
 impl Client {
   #[wasm_bindgen(js_name = setConsentStates)]

bindings_wasm/src/conversations.rs

@@ -641,4 +641,16 @@ impl Conversations {
     );
     Ok(StreamCloser::new(stream_closer))
   }
+
+  #[wasm_bindgen(js_name = "streamConsent")]
+  pub fn stream_consent(&self, callback: StreamCallback) -> Result<StreamCloser, JsError> {
+    let stream_closer =
+      RustXmtpClient::stream_consent_with_callback(self.inner_client.clone(), move |message| {
+        match message {
+          Ok(m) => callback.on_consent_update(m.into_iter().map(Into::into).collect()),
+          Err(e) => callback.on_error(JsError::from(e)),
+        }
+      });
+    Ok(StreamCloser::new(stream_closer))
+  }
 }

bindings_wasm/src/streams.rs

@@ -1,3 +1,4 @@
+use crate::consent_state::Consent;
 use crate::conversation::Conversation;
 use crate::messages::Message;
 use std::{cell::RefCell, rc::Rc};
@@ -18,6 +19,9 @@ extern "C" {
   #[wasm_bindgen(structural, method)]
   pub fn on_message(this: &StreamCallback, item: Message);
 
+  #[wasm_bindgen(structural, method)]
+  pub fn on_consent_update(this: &StreamCallback, item: Consent);
+
   #[wasm_bindgen(structural, method)]
   pub fn on_conversation(this: &StreamCallback, item: Conversation);