wip

bindings/prose-sdk-ffi/src/client.rs

@@ -62,7 +62,7 @@ impl Client {
 
     pub async fn connect(&self, password: String) -> Result<(), ConnectionError> {
         self.client
-            .connect(&self.jid.to_bare().unwrap(), password)
+            .connect(&self.jid.to_bare().unwrap().into(), password)
             .await?;
         Ok(())
     }
@@ -81,7 +81,7 @@ impl Client {
         let profile = self
             .client
             .user_data
-            .load_user_profile(&from.to_bare().unwrap())
+            .load_user_profile(&from.to_bare().unwrap().into())
             .await?;
         Ok(profile)
     }
@@ -100,7 +100,7 @@ impl Client {
         let path = self
             .client
             .user_data
-            .load_avatar(&from.to_bare().unwrap())
+            .load_avatar(&from.to_bare().unwrap().into())
             .await?;
         Ok(path)
     }

bindings/prose-sdk-ffi/src/prose_sdk_ffi.udl

@@ -133,7 +133,7 @@ enum Group {
     "Other",
 };
 
-dictionary UserActivity {
+dictionary UserStatus {
     string emoji;
     string? status;
 };
@@ -142,7 +142,7 @@ dictionary Contact {
     JID jid;
     string name;
     Availability availability;
-    UserActivity? activity;
+    UserStatus? status;
     Group group;
 };
 

bindings/prose-sdk-ffi/src/types/contact.rs

@@ -20,17 +20,17 @@ pub struct Contact {
     pub jid: JID,
     pub name: String,
     pub availability: Availability,
-    pub activity: Option<UserStatus>,
+    pub status: Option<UserStatus>,
     pub group: Group,
 }
 
 impl From<CoreContact> for Contact {
     fn from(value: CoreContact) -> Self {
         Contact {
-            jid: value.id.into(),
+            jid: value.id.into_inner().into(),
             name: value.name,
             availability: value.availability,
-            activity: value.activity,
+            status: value.status,
             group: value.group.into(),
         }
     }

bindings/prose-sdk-ffi/src/types/message.rs

@@ -50,7 +50,11 @@ impl From<ProseReaction> for Reaction {
     fn from(value: ProseReaction) -> Self {
         Reaction {
             emoji: value.emoji,
-            from: value.from.into_iter().map(Into::into).collect(),
+            from: value
+                .from
+                .into_iter()
+                .map(|id| id.into_inner().into())
+                .collect(),
         }
     }
 }

bindings/prose-sdk-js/src/client.rs

@@ -13,7 +13,7 @@ use prose_core_client::{open_store, Client as ProseClient, IndexedDBDriver, Stor
 use crate::connector::{Connector, ProseConnectionProvider};
 use crate::delegate::{Delegate, JSDelegate};
 use crate::types::{
-    try_jid_vec_from_string_array, Availability, BareJid, Channel, ChannelsArray, Contact,
+    try_user_id_vec_from_string_array, Availability, BareJid, Channel, ChannelsArray, Contact,
     ContactsArray, IntoJSArray, SidebarItem, SidebarItemsArray, UserMetadata, UserProfile,
 };
 
@@ -187,7 +187,7 @@ impl Client {
     /// Pass a String[] as participants where each string is a valid BareJid.
     #[wasm_bindgen(js_name = "startConversation")]
     pub async fn start_conversation(&self, participants: Array) -> Result<BareJid> {
-        let participants = try_jid_vec_from_string_array(participants)?;
+        let participants = try_user_id_vec_from_string_array(participants)?;
 
         Ok(self
             .client
@@ -204,7 +204,7 @@ impl Client {
     /// Pass a String[] as participants where each string is a valid BareJid.
     #[wasm_bindgen(js_name = "createGroup")]
     pub async fn create_group(&self, participants: Array) -> Result<BareJid> {
-        let participants = try_jid_vec_from_string_array(participants)?;
+        let participants = try_user_id_vec_from_string_array(participants)?;
 
         Ok(self
             .client
@@ -264,15 +264,14 @@ impl Client {
         icon: Option<String>,
         text: Option<String>,
     ) -> Result<()> {
-        let user_activity =
-            if let Some(icon) = &icon {
-                Some(UserStatus {
-                    emoji: icon.clone(),
-                    status: text.clone(),
-                })
-            } else {
-                None
-            };
+        let user_activity = if let Some(icon) = &icon {
+            Some(UserStatus {
+                emoji: icon.clone(),
+                status: text.clone(),
+            })
+        } else {
+            None
+        };
 
         self.client
             .account

bindings/prose-sdk-js/src/delegate.rs

@@ -119,6 +119,13 @@ extern "C" {
         client: Client,
         room: JsValue,
     ) -> Result<(), JsValue>;
+
+    #[wasm_bindgen(method, catch, js_name = "roomParticipantsChanged")]
+    fn room_participants_changed(
+        this: &JSDelegate,
+        client: Client,
+        room: JsValue,
+    ) -> Result<(), JsValue>;
 }
 
 #[wasm_bindgen(getter_with_clone)]
@@ -134,12 +141,10 @@ impl From<ConnectionError> for JSConnectionError {
                 code: "timed_out".to_string(),
                 message: None,
             },
-            ConnectionError::InvalidCredentials => {
-                JSConnectionError {
-                    code: "invalid_credentials".to_string(),
-                    message: None,
-                }
-            }
+            ConnectionError::InvalidCredentials => JSConnectionError {
+                code: "invalid_credentials".to_string(),
+                message: None,
+            },
             ConnectionError::Generic { msg } => JSConnectionError {
                 code: "generic".to_string(),
                 message: Some(msg),
@@ -200,11 +205,11 @@ impl Delegate {
                 .inner
                 .client_disconnected(client, error.map(Into::into))?,
             ClientEvent::SidebarChanged => self.inner.sidebar_changed(client)?,
-            ClientEvent::ContactChanged { id: jid } => {
-                self.inner.contact_changed(client, jid.into())?
-            }
+            ClientEvent::ContactChanged { id: jid } => self
+                .inner
+                .contact_changed(client, jid.into_inner().into())?,
             ClientEvent::AvatarChanged { id: jid } => {
-                self.inner.avatar_changed(client, jid.into())?
+                self.inner.avatar_changed(client, jid.into_inner().into())?
             }
             ClientEvent::RoomChanged { room, r#type } => match r#type {
                 ClientRoomEventType::MessagesAppended { message_ids } => self
@@ -222,6 +227,9 @@ impl Delegate {
                 ClientRoomEventType::AttributesChanged => self
                     .inner
                     .room_attributes_changed(client, room.into_js_value())?,
+                ClientRoomEventType::ParticipantsChanged => self
+                    .inner
+                    .room_participants_changed(client, room.into_js_value())?,
             },
         }
         Ok(())

bindings/prose-sdk-js/src/types/contact.rs

@@ -5,7 +5,7 @@
 
 use prose_core_client::dtos::{
     Availability as CoreAvailability, Contact as CoreContact, Group as CoreGroup,
-    UserStatus as CoreUserActivity,
+    UserStatus as CoreUserStatus,
 };
 use wasm_bindgen::prelude::*;
 
@@ -48,13 +48,13 @@ impl From<Availability> for CoreAvailability {
 }
 
 #[wasm_bindgen]
-pub struct UserActivity(CoreUserActivity);
+pub struct UserStatus(CoreUserStatus);
 
 #[wasm_bindgen]
 impl Contact {
     #[wasm_bindgen(getter)]
     pub fn jid(&self) -> BareJid {
-        self.0.id.clone().into()
+        self.0.id.clone().into_inner().into()
     }
 
     #[wasm_bindgen(getter)]
@@ -68,11 +68,11 @@ impl Contact {
     }
 
     #[wasm_bindgen(getter)]
-    pub fn activity(&self) -> Option<UserActivity> {
+    pub fn status(&self) -> Option<UserStatus> {
         self.0
-            .activity
+            .status
             .as_ref()
-            .map(|activity| UserActivity(activity.clone()))
+            .map(|activity| UserStatus(activity.clone()))
     }
 
     #[wasm_bindgen(getter)]
@@ -84,10 +84,10 @@ impl Contact {
 }
 
 #[wasm_bindgen]
-impl UserActivity {
+impl UserStatus {
     #[wasm_bindgen(constructor)]
     pub fn new(icon: &str, status: Option<String>) -> Self {
-        UserActivity(CoreUserActivity {
+        UserStatus(CoreUserStatus {
             emoji: icon.to_string(),
             status: status.clone(),
         })

bindings/prose-sdk-js/src/types/jid.rs

@@ -6,9 +6,10 @@
 use core::fmt::{Debug, Display, Formatter};
 use core::str::FromStr;
 
-use prose_core_client::dtos::RoomId;
 use wasm_bindgen::prelude::*;
 
+use prose_core_client::dtos::{RoomId, UserId};
+
 #[derive(Debug, PartialEq, Clone)]
 #[wasm_bindgen(js_name = "JID")]
 pub struct BareJid(jid::BareJid);
@@ -95,3 +96,15 @@ impl From<BareJid> for RoomId {
         RoomId::from(value.0)
     }
 }
+
+impl From<BareJid> for UserId {
+    fn from(value: BareJid) -> Self {
+        UserId::from(value.0)
+    }
+}
+
+impl From<&BareJid> for UserId {
+    fn from(value: &BareJid) -> Self {
+        UserId::from(value.0.clone())
+    }
+}

bindings/prose-sdk-js/src/types/js_array.rs

@@ -3,12 +3,13 @@
 // Copyright: 2023, Marc Bauer <[email protected]>
 // License: Mozilla Public License v2.0 (MPL v2.0)
 
-use crate::client::WasmError;
 use anyhow::anyhow;
-use core::str::FromStr;
 use js_sys::Array;
 use wasm_bindgen::prelude::*;
 
+use prose_core_client::dtos::UserId;
+
+use crate::client::WasmError;
 use crate::types::Message;
 
 #[wasm_bindgen]
@@ -97,15 +98,15 @@ impl TryFrom<&StringArray> for Vec<String> {
     }
 }
 
-pub fn try_jid_vec_from_string_array(arr: Array) -> Result<Vec<jid::BareJid>, WasmError> {
+pub fn try_user_id_vec_from_string_array(arr: Array) -> Result<Vec<UserId>, WasmError> {
     arr.into_iter()
         .map(|value| {
             value
                 .as_string()
                 .ok_or(anyhow::format_err!(
                     "Could not read String from supposed String Array"
                 ))
-                .and_then(|str| jid::BareJid::from_str(&str).map_err(Into::into))
+                .and_then(|str| str.parse::<UserId>().map_err(Into::into))
         })
         .collect::<Result<Vec<_>, _>>()
         .map_err(WasmError::from)

bindings/prose-sdk-js/src/types/message.rs

@@ -133,7 +133,11 @@ impl From<dtos::Reaction> for Reaction {
     fn from(value: dtos::Reaction) -> Self {
         Reaction {
             emoji: value.emoji.into_inner(),
-            from: value.from.into_iter().map(Into::into).collect(),
+            from: value
+                .from
+                .into_iter()
+                .map(|id| id.into_inner().into())
+                .collect(),
         }
     }
 }

bindings/prose-sdk-js/src/types/mod.rs

@@ -10,7 +10,10 @@ pub use js_array::*;
 pub use message::Message;
 pub use room::RoomEnvelopeExt;
 pub use sidebar_item::{SidebarItem, SidebarItemsArray};
-pub use user_info::{UserBasicInfo, UserBasicInfoArray, UserPresenceInfo, UserPresenceInfoArray};
+pub use user_info::{
+    ParticipantInfo, ParticipantInfoArray, UserBasicInfo, UserBasicInfoArray, UserPresenceInfo,
+    UserPresenceInfoArray,
+};
 pub use user_metadata::UserMetadata;
 pub use user_profile::UserProfile;