rtc: Handle non-MXID call member event state keys

Cargo.toml

@@ -47,7 +47,7 @@ once_cell = "1.16.0"
 pin-project-lite = "0.2.9"
 rand = "0.8.5"
 reqwest = { version = "0.12.4", default-features = false }
-ruma = { git = "https://github.com/matrix-org/ruma", rev = "79289381444e886c454302e1e8f5b5f62f249a57", features = [
+ruma = { git = "https://github.com/matrix-org/ruma", rev = "e87f1d839e3821f0fb0ba20fb3164fedbc90a25c", features = [
     "client-api-c",
     "compat-upload-signatures",
     "compat-user-id",
@@ -61,7 +61,7 @@ ruma = { git = "https://github.com/matrix-org/ruma", rev = "79289381444e886c4543
     "unstable-msc4075",
     "unstable-msc4140",
 ] }
-ruma-common = { git = "https://github.com/matrix-org/ruma", rev = "79289381444e886c454302e1e8f5b5f62f249a57" }
+ruma-common = { git = "https://github.com/matrix-org/ruma", rev = "e87f1d839e3821f0fb0ba20fb3164fedbc90a25c" }
 serde = "1.0.151"
 serde_html_form = "0.2.0"
 serde_json = "1.0.91"

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

@@ -40,7 +40,7 @@ use ruma::{
         RedactedStateEventContent, StaticStateEventContent, SyncStateEvent,
     },
     room::RoomType,
-    EventId, OwnedUserId, RoomVersionId,
+    EventId, OwnedUserId, RoomVersionId, UserId,
 };
 use serde::{Deserialize, Serialize};
 
@@ -195,9 +195,12 @@ impl BaseRoomInfo {
                 let mut o_ev = o_ev.clone();
                 o_ev.content.set_created_ts_if_none(o_ev.origin_server_ts);
 
+                let Some(owned_user_id) = get_user_id_for_state_key(m.state_key()) else {
+                    return false;
+                };
+
                 // add the new event.
-                self.rtc_member
-                    .insert(m.state_key().clone(), SyncStateEvent::Original(o_ev).into());
+                self.rtc_member.insert(owned_user_id, SyncStateEvent::Original(o_ev).into());
 
                 // Remove all events that don't contain any memberships anymore.
                 self.rtc_member.retain(|_, ev| {
@@ -319,6 +322,37 @@ impl BaseRoomInfo {
     }
 }
 
+/// Extract a user ID from a state key that matches one of the following formats:
+/// - `<user ID>`
+/// - `<user ID>_<string>`
+/// - `_<user ID>_<string>`
+fn get_user_id_for_state_key(state_key: &str) -> Option<OwnedUserId> {
+    match UserId::parse(state_key) {
+        Ok(user_id) => Some(user_id),
+        Err(_) => {
+            // Ignore leading underscore if present
+            // (used for avoiding auth rules on @-prefixed state keys)
+            let state_key = state_key.strip_prefix('_').unwrap_or(state_key);
+            if state_key.starts_with('@') {
+                if let Some(colon_idx) = state_key.find(':') {
+                    let state_key_user_id = match state_key[colon_idx + 1..].find('_') {
+                        None => state_key,
+                        Some(suffix_idx) => &state_key[..colon_idx + 1 + suffix_idx],
+                    };
+                    match UserId::parse(state_key_user_id) {
+                        Ok(user_id) => Some(user_id),
+                        Err(_) => None,
+                    }
+                } else {
+                    None
+                }
+            } else {
+                None
+            }
+        }
+    }
+}
+
 bitflags! {
     /// Notable tags, i.e. subset of tags that we are more interested by.
     ///
@@ -536,9 +570,10 @@ impl RoomMemberships {
 mod tests {
     use std::ops::Not;
 
+    use assert_matches::assert_matches;
     use ruma::events::tag::{TagInfo, TagName, Tags};
 
-    use super::{BaseRoomInfo, RoomNotableTags};
+    use super::{get_user_id_for_state_key, BaseRoomInfo, RoomNotableTags};
 
     #[test]
     fn test_handle_notable_tags_favourite() {
@@ -569,4 +604,19 @@ mod tests {
         base_room_info.handle_notable_tags(&tags);
         assert!(base_room_info.notable_tags.contains(RoomNotableTags::LOW_PRIORITY).not());
     }
+
+    #[test]
+    fn test_get_user_id_from_state_key() {
+        assert_matches!(get_user_id_for_state_key(""), None);
+        assert_matches!(get_user_id_for_state_key("abc"), None);
+        assert_matches!(get_user_id_for_state_key("username:example.org"), None);
+
+        assert_matches!(get_user_id_for_state_key("@username:example.org"), Some(_));
+        assert_matches!(get_user_id_for_state_key("@username:example.org_valid_suffix"), Some(_));
+        assert_matches!(get_user_id_for_state_key("@username:example.org:invalid_suffix"), None);
+
+        assert_matches!(get_user_id_for_state_key("_@username:example.org"), Some(_));
+        assert_matches!(get_user_id_for_state_key("_@username:example.org_valid_suffix"), Some(_));
+        assert_matches!(get_user_id_for_state_key("_@username:example.org:invalid_suffix"), None);
+    }
 }

crates/matrix-sdk-base/src/rooms/normal.rs

@@ -2624,7 +2624,7 @@ mod tests {
             // we can simply use now here since this will be dropped when using a MinimalStateEvent
             // in the roomInfo
             origin_server_ts: timestamp(0),
-            state_key: user_id.to_owned(),
+            state_key: user_id.to_string(),
             unsigned: StateUnsigned::new(),
         }))
     }