WIP

Author: jmartinesp

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

@@ -2223,7 +2223,7 @@ async fn notification_handler(
             .map(ToString::to_string)
             .collect(),
         active_service_members_count: room
-            .active_service_members()
+            .update_active_service_members()
             .await
             .ok()
             .flatten()
@@ -2232,6 +2232,7 @@ async fn notification_handler(
         is_encrypted: Some(room.encryption_state().is_encrypted()),
         is_direct,
         is_space: room.is_space(),
+        is_dm: room.compute_is_dm().await.ok().unwrap_or_default(),
     };
 
     listener.on_notification(

bindings/matrix-sdk-ffi/src/notification.rs

@@ -54,6 +54,7 @@ pub struct NotificationRoomInfo {
     pub is_encrypted: Option<bool>,
     pub is_direct: bool,
     pub is_space: bool,
+    pub is_dm: bool,
 }
 
 #[derive(uniffi::Record)]
@@ -113,6 +114,7 @@ impl NotificationItem {
                 is_encrypted: item.is_room_encrypted,
                 is_direct: item.is_direct_message_room,
                 is_space: item.is_space,
+                is_dm: item.is_dm,
             },
             is_noisy: item.is_noisy,
             has_mention: item.has_mention,

bindings/matrix-sdk-ffi/src/room/room_info.rs

@@ -147,9 +147,6 @@ impl RoomInfo {
             .ok()
             .map(|p| RoomPowerLevels::new(p, room.own_user_id().to_owned()));
 
-        let active_service_members_count =
-            room.active_service_members().await?.unwrap_or_default().len() as u64;
-
         Ok(Self {
             id: room.room_id().to_string(),
             encryption_state: room.encryption_state(),
@@ -161,7 +158,7 @@ impl RoomInfo {
             topic: room.topic(),
             avatar_url: room.avatar_url().map(Into::into),
             is_direct: room.is_direct().await?,
-            is_dm: room.is_dm().await?,
+            is_dm: room.compute_is_dm().await?,
             is_public: room.is_public(),
             is_space: room.is_space(),
             successor_room: room.successor_room().map(Into::into),
@@ -186,7 +183,7 @@ impl RoomInfo {
             active_members_count: room.active_members_count(),
             invited_members_count: room.invited_members_count(),
             joined_members_count: room.joined_members_count(),
-            active_service_members_count,
+            active_service_members_count: room.active_service_members_count().unwrap_or_default(),
             service_members: room
                 .service_members()
                 .iter()

bindings/matrix-sdk-ffi/src/spaces.rs

@@ -359,6 +359,10 @@ pub struct SpaceRoom {
     pub heroes: Option<Vec<RoomHero>>,
     /// The via parameters of the room.
     pub via: Vec<String>,
+    /// Whether this room is a DM, if known.
+    /// Note this value can be calculated following some assumptions and is not
+    /// guaranteed to be accurate.
+    pub is_dm: Option<bool>,
 }
 
 impl From<UISpaceRoom> for SpaceRoom {
@@ -380,6 +384,7 @@ impl From<UISpaceRoom> for SpaceRoom {
             state: room.state.map(Into::into),
             heroes: room.heroes.map(|heroes| heroes.into_iter().map(Into::into).collect()),
             via: room.via.into_iter().map(Into::into).collect(),
+            is_dm: room.is_dm,
         }
     }
 }

crates/matrix-sdk-base/src/room/display_name.rs

@@ -378,6 +378,10 @@ pub(crate) struct RoomSummary {
     pub joined_member_count: u64,
     /// The number of members that are considered to be invited to the room.
     pub invited_member_count: u64,
+    /// The number of active (joined/invited) service members in the room, if
+    /// known.
+    #[serde(default, skip_serializing_if = "Option::is_none")]
+    pub active_service_members: Option<u64>,
 }
 
 #[cfg(test)]

crates/matrix-sdk-base/src/room/mod.rs

@@ -66,7 +66,7 @@ pub use state::{RoomState, RoomStateFilter};
 pub(crate) use tags::RoomNotableTags;
 use tokio::sync::broadcast;
 pub use tombstone::{PredecessorRoom, SuccessorRoom};
-use tracing::{info, instrument, warn};
+use tracing::{info, instrument, trace, warn};
 
 use crate::{
     DmRoomDefinition, Error,
@@ -304,9 +304,9 @@ impl Room {
         }
     }
 
-    /// Checks if the current room is a DM based on the rules from the
-    /// [`DmRoomDefinition`].
-    pub async fn is_dm(&self, dm_room_definition: &DmRoomDefinition) -> StoreResult<bool> {
+    /// Computes if the current room is a DM based on the rules from the
+    /// [`DmRoomDefinition`], updating the active service members.
+    pub async fn compute_is_dm(&self, dm_room_definition: &DmRoomDefinition) -> StoreResult<bool> {
         let is_direct = self.is_direct().await?;
 
         match *dm_room_definition {
@@ -316,7 +316,7 @@ impl Room {
                     return Ok(false);
                 }
                 let active_service_member_count =
-                    self.active_service_members().await?.unwrap_or_default().len() as u64;
+                    self.update_active_service_members().await?.unwrap_or_default().len() as u64;
                 let has_at_most_two_members =
                     self.active_members_count().saturating_sub(active_service_member_count) <= 2;
                 Ok(has_at_most_two_members)
@@ -534,7 +534,7 @@ impl Room {
     /// Returns the list of service members that are either in a joined or
     /// invited state in this room, checking the service member list against the
     /// locally available room members.
-    pub async fn active_service_members(&self) -> StoreResult<Option<Vec<RoomMember>>> {
+    pub async fn update_active_service_members(&self) -> StoreResult<Option<Vec<RoomMember>>> {
         if let Some(service_members) = self.service_members() {
             let mut found = Vec::new();
             for user_id in service_members {
@@ -553,11 +553,44 @@ impl Room {
                 }
             }
 
+            trace!(
+                "Updating active service members ({}) in room {:?}",
+                found.len(),
+                self.room_id()
+            );
+
+            let new_active_service_member_count = found.len() as u64;
+            let current_active_service_member_count =
+                self.info.read().summary.active_service_members.unwrap_or_default();
+            if new_active_service_member_count != current_active_service_member_count {
+                let mut new_room_info = self.clone_info();
+                new_room_info
+                    .update_active_service_member_count(Some(new_active_service_member_count));
+                self.set_room_info(
+                    new_room_info,
+                    RoomInfoNotableUpdateReasons::ACTIVE_SERVICE_MEMBERS,
+                );
+            }
+
             Ok(Some(found))
         } else {
+            if self.info.read().summary.active_service_members.is_some() {
+                let mut new_room_info = self.clone_info();
+                new_room_info.update_active_service_member_count(None);
+                self.set_room_info(
+                    new_room_info,
+                    RoomInfoNotableUpdateReasons::ACTIVE_SERVICE_MEMBERS,
+                );
+            }
             Ok(None)
         }
     }
+
+    /// Returns a cached value containing the active (joined/invited) service
+    /// member count, if known.
+    pub fn active_service_members_count(&self) -> Option<u64> {
+        self.info.read().summary.active_service_members
+    }
 }
 
 // See https://github.com/matrix-org/matrix-rust-sdk/pull/3749#issuecomment-2312939823.

crates/matrix-sdk-base/src/room/room_info.rs

@@ -872,6 +872,10 @@ impl RoomInfo {
             }
         }
 
+        if changed {
+            self.summary.active_service_members = None;
+        }
+
         changed
     }
 
@@ -1233,6 +1237,18 @@ impl RoomInfo {
 
         migrated
     }
+
+    /// Returns the number of active (joined/invited) service members in the
+    /// room, if known.
+    pub fn active_service_member_count(&self) -> Option<u64> {
+        self.summary.active_service_members
+    }
+
+    /// Updates the cached value for the number of active service members in the
+    /// room.
+    pub fn update_active_service_member_count(&mut self, count: Option<u64>) {
+        self.summary.active_service_members = count;
+    }
 }
 
 /// Type to represent a `RoomInfo::recency_stamp`.
@@ -1346,6 +1362,9 @@ bitflags! {
         /// The display name has changed.
         const DISPLAY_NAME = 0b0010_0000;
 
+        /// The active service members have changed.
+        const ACTIVE_SERVICE_MEMBERS = 0b0100_0000;
+
         /// This is a temporary hack.
         ///
         /// So here is the thing. Ideally, we DO NOT want to emit this reason. It does not
@@ -1416,6 +1435,7 @@ mod tests {
                 }],
                 joined_member_count: 5,
                 invited_member_count: 0,
+                active_service_members: None,
             },
             members_synced: true,
             last_prev_batch: Some("pb".to_owned()),

crates/matrix-sdk-ui/src/notification_client.rs

@@ -955,6 +955,8 @@ pub struct NotificationItem {
 
     /// The push actions for this notification (notify, sound, highlight, etc.).
     pub actions: Option<Vec<Action>>,
+
+    pub is_dm: bool,
 }
 
 impl NotificationItem {
@@ -1034,7 +1036,7 @@ impl NotificationItem {
             .collect_vec();
 
         let active_service_members_count =
-            room.active_service_members().await?.unwrap_or_default().len() as u64;
+            room.update_active_service_members().await?.unwrap_or_default().len() as u64;
 
         let item = NotificationItem {
             event,
@@ -1061,6 +1063,7 @@ impl NotificationItem {
             has_mention,
             thread_id,
             actions: push_actions.map(|actions| actions.to_vec()),
+            is_dm: room.compute_is_dm().await?,
         };
 
         Ok(item)