base: Remember the direct target for rooms.

matrix_sdk_base/src/client.rs

@@ -644,6 +644,38 @@ impl BaseClient {
         AccountData { events }
     }
 
+    async fn handle_account_data(
+        &self,
+        events: Vec<Raw<AnyBasicEvent>>,
+        changes: &mut StateChanges,
+    ) {
+        let events: Vec<AnyBasicEvent> =
+            events.iter().filter_map(|e| e.deserialize().ok()).collect();
+
+        for event in &events {
+            if let AnyBasicEvent::Direct(e) = event {
+                for (user_id, rooms) in e.content.iter() {
+                    for room_id in rooms {
+                        if let Some(room) = changes.room_infos.get_mut(room_id) {
+                            room.base_info.dm_target = Some(user_id.clone());
+                        } else if let Some(room) = self.store.get_bare_room(room_id) {
+                            let mut info = room.clone_info();
+                            info.base_info.dm_target = Some(user_id.clone());
+                            changes.add_room(info);
+                        }
+                    }
+                }
+            }
+        }
+
+        let account_data: BTreeMap<String, AnyBasicEvent> = events
+            .into_iter()
+            .map(|e| (e.content().event_type().to_owned(), e))
+            .collect();
+
+        changes.account_data = account_data;
+    }
+
     /// Receive a response from a sync call.
     ///
     /// # Arguments
@@ -826,17 +858,8 @@ impl BaseClient {
 
         changes.presence = presence;
 
-        let account_data: BTreeMap<String, AnyBasicEvent> = response
+        self.handle_account_data(response.account_data.events, &mut changes)
-            .account_data
+            .await;
-            .events
-            .into_iter()
-            .filter_map(|e| {
-                let event = e.deserialize().ok()?;
-                Some((event.content().event_type().to_owned(), event))
-            })
-            .collect();
-
-        changes.account_data = account_data;
 
         self.store.save_changes(&changes).await;
         *self.sync_token.write().await = Some(response.next_batch.clone());

matrix_sdk_base/src/rooms/mod.rs

@@ -2,6 +2,7 @@ mod members;
 mod normal;
 mod stripped;
 
+use matrix_sdk_common::identifiers::UserId;
 pub use normal::{Room, RoomInfo, RoomType};
 pub use stripped::{StrippedRoom, StrippedRoomInfo};
 
@@ -119,6 +120,7 @@ impl Deref for InvitedRoom {
 pub struct BaseRoomInfo {
     pub name: Option<String>,
     pub canonical_alias: Option<RoomAliasId>,
+    pub dm_target: Option<UserId>,
     pub avatar_url: Option<String>,
     pub topic: Option<String>,
     pub encryption: Option<EncryptionEventContent>,
@@ -171,6 +173,7 @@ impl Default for BaseRoomInfo {
         Self {
             name: None,
             canonical_alias: None,
+            dm_target: None,
             avatar_url: None,
             topic: None,
             encryption: None,

matrix_sdk_base/src/rooms/normal.rs

@@ -92,6 +92,14 @@ impl Room {
         self.inner.read().unwrap().room_type
     }
 
+    pub fn is_direct(&self) -> bool {
+        self.inner.read().unwrap().base_info.dm_target.is_some()
+    }
+
+    pub fn direct_target(&self) -> Option<UserId> {
+        self.inner.read().unwrap().base_info.dm_target.clone()
+    }
+
     fn max_power_level(&self) -> i64 {
         self.inner.read().unwrap().base_info.max_power_level
     }