Upgrade Ruma: revert StrippedState

Handle the previous breaking change that was reverted: `StrippedState`
was removed and `AnyStrippedStateEvent` is used again.

Signed-off-by: Kévin Commaille <[email protected]>

Author: zecakeh

Cargo.lock

@@ -59,7 +59,7 @@ proptest = { version = "1.6.0", default-features = false, features = ["std"] }
 rand = "0.8.5"
 reqwest = { version = "0.12.12", default-features = false }
 rmp-serde = "1.3.0"
-ruma = { git = "https://github.com/ruma/ruma", rev = "a2fe858133ba932b4bda730dc7472c9c985739a0", features = [
+ruma = { git = "https://github.com/ruma/ruma", rev = "d879f7df16ba9928a73649f8149dabeee939691e", features = [
     "client-api-c",
     "compat-upload-signatures",
     "compat-arbitrary-length-ids",
@@ -79,7 +79,7 @@ ruma = { git = "https://github.com/ruma/ruma", rev = "a2fe858133ba932b4bda730dc7
     "unstable-msc4286",
     "unstable-msc4306"
 ] }
-ruma-common = { git = "https://github.com/ruma/ruma", rev = "a2fe858133ba932b4bda730dc7472c9c985739a0" }
+ruma-common = { git = "https://github.com/ruma/ruma", rev = "d879f7df16ba9928a73649f8149dabeee939691e" }
 sentry = "0.36.0"
 sentry-tracing = "0.36.0"
 serde = { version = "1.0.217", features = ["rc"] }

Cargo.toml

@@ -21,9 +21,8 @@ use once_cell::sync::Lazy;
 use regex::Regex;
 use ruma::{
     EventId, MilliSecondsSinceUnixEpoch, OwnedEventId, OwnedRoomId, OwnedUserId, UInt, UserId,
-    api::client::sync::sync_events::StrippedState,
     events::{
-        AnySyncStateEvent, AnySyncTimelineEvent, EventContentFromType,
+        AnyStrippedStateEvent, AnySyncStateEvent, AnySyncTimelineEvent, EventContentFromType,
         PossiblyRedactedStateEventContent, RedactContent, RedactedStateEventContent,
         StateEventContent, StaticStateEventContent, StrippedStateEvent, SyncStateEvent,
         room::{
@@ -262,7 +261,7 @@ pub enum RawAnySyncOrStrippedTimelineEvent {
     /// An event from a room in joined or left state.
     Sync(Raw<AnySyncTimelineEvent>),
     /// An event from a room in invited state.
-    Stripped(Raw<StrippedState>),
+    Stripped(Raw<AnyStrippedStateEvent>),
 }
 
 impl From<Raw<AnySyncTimelineEvent>> for RawAnySyncOrStrippedTimelineEvent {
@@ -271,8 +270,8 @@ impl From<Raw<AnySyncTimelineEvent>> for RawAnySyncOrStrippedTimelineEvent {
     }
 }
 
-impl From<Raw<StrippedState>> for RawAnySyncOrStrippedTimelineEvent {
-    fn from(event: Raw<StrippedState>) -> Self {
+impl From<Raw<AnyStrippedStateEvent>> for RawAnySyncOrStrippedTimelineEvent {
+    fn from(event: Raw<AnyStrippedStateEvent>) -> Self {
         Self::Stripped(event)
     }
 }
@@ -284,7 +283,7 @@ pub enum RawAnySyncOrStrippedState {
     /// An event from a room in joined or left state.
     Sync(Raw<AnySyncStateEvent>),
     /// An event from a room in invited state.
-    Stripped(Raw<StrippedState>),
+    Stripped(Raw<AnyStrippedStateEvent>),
 }
 
 impl RawAnySyncOrStrippedState {
@@ -324,7 +323,7 @@ pub enum AnySyncOrStrippedState {
     ///
     /// The value is `Box`ed because it is quite large. Let's keep the size of
     /// `Self` as small as possible.
-    Stripped(Box<StrippedState>),
+    Stripped(Box<AnyStrippedStateEvent>),
 }
 
 impl AnySyncOrStrippedState {
@@ -339,7 +338,7 @@ impl AnySyncOrStrippedState {
 
     /// If this is an `AnyStrippedStateEvent`, return a reference to the inner
     /// event.
-    pub fn as_stripped(&self) -> Option<&StrippedState> {
+    pub fn as_stripped(&self) -> Option<&AnyStrippedStateEvent> {
         match self {
             Self::Sync(_) => None,
             Self::Stripped(ev) => Some(ev),

crates/matrix-sdk-base/src/deserialized_responses.rs

@@ -23,7 +23,6 @@ use matrix_sdk_common::deserialized_responses::TimelineEvent;
 use ruma::{
     JsOption, OwnedRoomId, RoomId, UserId,
     api::client::sync::sync_events::{
-        StrippedState,
         v3::{InviteState, InvitedRoom, KnockState, KnockedRoom},
         v5 as http,
     },
@@ -226,7 +225,7 @@ pub async fn update_any_room(
 fn membership(
     context: &mut Context,
     state_events: &[AnySyncStateEvent],
-    invite_state_events: &Option<(Vec<Raw<StrippedState>>, Vec<AnyStrippedStateEvent>)>,
+    invite_state_events: &Option<(Vec<Raw<AnyStrippedStateEvent>>, Vec<AnyStrippedStateEvent>)>,
     store: &BaseStateStore,
     user_id: &UserId,
     room_id: &RoomId,

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

@@ -206,31 +206,20 @@ pub mod sync {
 pub mod stripped {
     use std::{collections::BTreeMap, iter};
 
-    use ruma::{
-        api::client::sync::sync_events::StrippedState, events::AnyStrippedStateEvent, push::Action,
-    };
-    use tracing::{instrument, warn};
+    use ruma::{events::AnyStrippedStateEvent, push::Action};
+    use tracing::instrument;
 
     use super::{
         super::{notification, timeline},
         Context, Raw,
     };
     use crate::{Result, Room, RoomInfo};
 
-    /// Collect [`Raw<StrippedState>`] to [`AnyStrippedStateEvent`].
+    /// Collect [`Raw<AnyStrippedStateEvent>`] to [`AnyStrippedStateEvent`].
     pub fn collect(
-        raw_events: &[Raw<StrippedState>],
-    ) -> (Vec<Raw<StrippedState>>, Vec<AnyStrippedStateEvent>) {
-        raw_events
-            .iter()
-            .filter_map(|raw_event| match raw_event.deserialize_as() {
-                Ok(event) => Some((raw_event.clone(), event)),
-                Err(e) => {
-                    warn!("Couldn't deserialize stripped state event: {e}");
-                    None
-                }
-            })
-            .unzip()
+        raw_events: &[Raw<AnyStrippedStateEvent>],
+    ) -> (Vec<Raw<AnyStrippedStateEvent>>, Vec<AnyStrippedStateEvent>) {
+        super::collect(raw_events)
     }
 
     /// Dispatch the stripped state events.
@@ -252,7 +241,7 @@ pub mod stripped {
     #[instrument(skip_all, fields(room_id = ?room_info.room_id))]
     pub(crate) async fn dispatch_invite_or_knock(
         context: &mut Context,
-        (raw_events, events): (&[Raw<StrippedState>], &[AnyStrippedStateEvent]),
+        (raw_events, events): (&[Raw<AnyStrippedStateEvent>], &[AnyStrippedStateEvent]),
         room: &Room,
         room_info: &mut RoomInfo,
         mut notification: notification::Notification<'_>,

crates/matrix-sdk-base/src/response_processors/state_events.rs

@@ -10,16 +10,13 @@ use ruma::{
     EventId, MilliSecondsSinceUnixEpoch, OwnedEventId, OwnedUserId, RoomId, TransactionId, UserId,
     api::{
         FeatureFlag, MatrixVersion,
-        client::{
-            discovery::discover_homeserver::{HomeserverInfo, RtcFocusInfo},
-            sync::sync_events::StrippedState,
-        },
+        client::discovery::discover_homeserver::{HomeserverInfo, RtcFocusInfo},
     },
     event_id,
     events::{
         AnyGlobalAccountDataEvent, AnyMessageLikeEventContent, AnyRoomAccountDataEvent,
-        AnySyncStateEvent, GlobalAccountDataEventType, RoomAccountDataEventType, StateEventType,
-        SyncStateEvent,
+        AnyStrippedStateEvent, AnySyncStateEvent, GlobalAccountDataEventType,
+        RoomAccountDataEventType, StateEventType, SyncStateEvent,
         presence::PresenceEvent,
         receipt::{ReceiptThread, ReceiptType},
         room::{
@@ -193,8 +190,8 @@ impl StateStoreIntegrationTests for DynStateStore {
 
         let stripped_name_json: &JsonValue = &test_json::NAME_STRIPPED;
         let stripped_name_raw =
-            serde_json::from_value::<Raw<StrippedState>>(stripped_name_json.clone())?;
-        let stripped_name_event = stripped_name_raw.deserialize_as()?;
+            serde_json::from_value::<Raw<AnyStrippedStateEvent>>(stripped_name_json.clone())?;
+        let stripped_name_event = stripped_name_raw.deserialize()?;
         stripped_room.handle_stripped_state_event(&stripped_name_event);
         changes.stripped_state.insert(
             stripped_room_id.to_owned(),

crates/matrix-sdk-base/src/store/integration_tests.rs

@@ -23,11 +23,10 @@ use matrix_sdk_common::{ROOM_VERSION_FALLBACK, ROOM_VERSION_RULES_FALLBACK};
 use ruma::{
     CanonicalJsonObject, EventId, MilliSecondsSinceUnixEpoch, OwnedEventId, OwnedMxcUri,
     OwnedRoomId, OwnedTransactionId, OwnedUserId, RoomId, TransactionId, UserId,
-    api::client::sync::sync_events::StrippedState,
     canonical_json::{RedactedBecause, redact},
     events::{
-        AnyGlobalAccountDataEvent, AnyRoomAccountDataEvent, AnySyncStateEvent,
-        GlobalAccountDataEventType, RoomAccountDataEventType, StateEventType,
+        AnyGlobalAccountDataEvent, AnyRoomAccountDataEvent, AnyStrippedStateEvent,
+        AnySyncStateEvent, GlobalAccountDataEventType, RoomAccountDataEventType, StateEventType,
         presence::PresenceEvent,
         receipt::{Receipt, ReceiptThread, ReceiptType},
         room::member::{MembershipState, StrippedRoomMemberEvent, SyncRoomMemberEvent},
@@ -69,7 +68,7 @@ struct MemoryStoreInner {
     room_account_data:
         HashMap<OwnedRoomId, HashMap<RoomAccountDataEventType, Raw<AnyRoomAccountDataEvent>>>,
     stripped_room_state:
-        HashMap<OwnedRoomId, HashMap<StateEventType, HashMap<String, Raw<StrippedState>>>>,
+        HashMap<OwnedRoomId, HashMap<StateEventType, HashMap<String, Raw<AnyStrippedStateEvent>>>>,
     stripped_members: HashMap<OwnedRoomId, HashMap<OwnedUserId, MembershipState>>,
     presence: HashMap<OwnedUserId, Raw<PresenceEvent>>,
     room_user_receipts: HashMap<

crates/matrix-sdk-base/src/store/memory_store.rs

@@ -47,12 +47,11 @@ pub use matrix_sdk_store_encryption::Error as StoreEncryptionError;
 use observable_map::ObservableMap;
 use ruma::{
     EventId, OwnedEventId, OwnedRoomId, OwnedUserId, RoomId, UserId,
-    api::client::sync::sync_events::StrippedState,
     events::{
-        AnyGlobalAccountDataEvent, AnyRoomAccountDataEvent, AnySyncStateEvent, EmptyStateKey,
-        GlobalAccountDataEventType, RedactContent, RedactedStateEventContent,
-        RoomAccountDataEventType, StateEventType, StaticEventContent, StaticStateEventContent,
-        StrippedStateEvent, SyncStateEvent,
+        AnyGlobalAccountDataEvent, AnyRoomAccountDataEvent, AnyStrippedStateEvent,
+        AnySyncStateEvent, EmptyStateKey, GlobalAccountDataEventType, RedactContent,
+        RedactedStateEventContent, RoomAccountDataEventType, StateEventType, StaticEventContent,
+        StaticStateEventContent, StrippedStateEvent, SyncStateEvent,
         presence::PresenceEvent,
         receipt::ReceiptEventContent,
         room::{
@@ -517,8 +516,10 @@ pub struct StateChanges {
 
     /// A mapping of `RoomId` to a map of event type to a map of state key to
     /// `StrippedState`.
-    pub stripped_state:
-        BTreeMap<OwnedRoomId, BTreeMap<StateEventType, BTreeMap<String, Raw<StrippedState>>>>,
+    pub stripped_state: BTreeMap<
+        OwnedRoomId,
+        BTreeMap<StateEventType, BTreeMap<String, Raw<AnyStrippedStateEvent>>>,
+    >,
 
     /// A map from room id to a map of a display name and a set of user ids that
     /// share that display name in the given room.

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

@@ -70,7 +70,7 @@ async fn test_notification() -> Result<()> {
     };
 
     if let Some(event_id) = invited_room.invite_state.events.iter().find_map(|event| {
-        let Ok(AnyStrippedStateEvent::RoomMember(room_member_ev)) = event.deserialize_as() else {
+        let Ok(AnyStrippedStateEvent::RoomMember(room_member_ev)) = event.deserialize() else {
             return None;
         };
 

testing/matrix-sdk-integration-testing/src/tests/sliding_sync/notification_client.rs

@@ -68,7 +68,7 @@ macro_rules! stripped_state_event {
     ($( $tt:tt )*) => {
         ::ruma::serde::Raw::new(&::serde_json::json!( $($tt)* ))
             .unwrap()
-            .cast_unchecked::<::ruma::api::client::sync::sync_events::StrippedState>()
+            .cast_unchecked::<::ruma::events::AnyStrippedStateEvent>()
     }
 }