bench: fix pinned events benchmark

Author: jmartinesp

benchmarks/benches/room_bench.rs

@@ -10,7 +10,7 @@ use matrix_sdk_base::{
     store::StoreConfig, BaseClient, RoomInfo, RoomState, SessionMeta, StateChanges, StateStore,
 };
 use matrix_sdk_sqlite::SqliteStateStore;
-use matrix_sdk_test::{EventBuilder, JoinedRoomBuilder, StateTestEvent, SyncResponseBuilder};
+use matrix_sdk_test::{EventBuilder, JoinedRoomBuilder, StateTestEvent, SyncResponseBuilder, ALICE};
 use matrix_sdk_ui::{timeline::TimelineFocus, Timeline};
 use ruma::{
     api::client::membership::get_member_events,
@@ -20,6 +20,8 @@ use ruma::{
     serde::Raw,
     user_id, EventId, MilliSecondsSinceUnixEpoch, OwnedEventId, OwnedUserId,
 };
+use ruma::events::AnyStateEvent;
+use ruma::events::room::member::MembershipState;
 use serde::Serialize;
 use serde_json::json;
 use tokio::runtime::Builder;
@@ -153,11 +155,10 @@ pub fn load_pinned_events_benchmark(c: &mut Criterion) {
 
     runtime.block_on(
         Mock::given(method("GET"))
-            .and(path_regex(r"/_matrix/client/r0/rooms/.*/event/.*"))
+            .and(path_regex(r"/_matrix/client/r0/rooms/.*/context/.*"))
             .respond_with(move |r: &Request| {
                 let segments: Vec<&str> = r.url.path_segments().expect("Invalid path").collect();
                 let event_id_str = segments[6];
-                // let f = EventFactory::new().room(&room_id)
                 let event_id = EventId::parse(event_id_str).expect("Invalid event id in response");
                 let event = f
                     .text_msg(format!("Message {event_id_str}"))
@@ -166,13 +167,16 @@ pub fn load_pinned_events_benchmark(c: &mut Criterion) {
                     .into_raw_sync();
                 ResponseTemplate::new(200)
                     .set_delay(Duration::from_millis(50))
-                    .set_body_json(event.json())
+                    .set_body_json(json!({
+                            "events_before": [],
+                            "event": event.json(),
+                            "events_after": [],
+                            "state": [],
+                        })
+                    )
             })
             .mount(&server),
     );
-    // runtime.block_on(server.reset());
-
-    client.event_cache().subscribe().unwrap();
 
     let room = client.get_room(&room_id).expect("Room not found");
     assert!(!room.pinned_event_ids().is_empty());
@@ -186,6 +190,8 @@ pub fn load_pinned_events_benchmark(c: &mut Criterion) {
 
     group.bench_function(BenchmarkId::new("load_pinned_events", name), |b| {
         b.to_async(&runtime).iter(|| async {
+            client.event_cache().subscribe().unwrap();
+
             assert!(!room.pinned_event_ids().is_empty());
             assert_eq!(room.pinned_event_ids().len(), PINNED_EVENTS_COUNT);