@@ -2,15 +2,10 @@ use assert_matches2::assert_matches;
22use matrix_sdk:: { config:: SyncSettings , sync:: Notification } ;
33use matrix_sdk_base:: deserialized_responses:: RawAnySyncOrStrippedTimelineEvent ;
44use matrix_sdk_test:: {
5- async_test, stripped_state_event , sync_state_event , sync_timeline_event , test_json,
5+ async_test, event_factory :: EventFactory , stripped_state_event , sync_state_event , test_json,
66 InvitedRoomBuilder , JoinedRoomBuilder , SyncResponseBuilder ,
77} ;
8- use ruma:: {
9- events:: { room:: message:: RoomMessageEventContent , Mentions , StateEventType } ,
10- room_id,
11- serde:: Raw ,
12- OwnedRoomId ,
13- } ;
8+ use ruma:: { event_id, events:: StateEventType , room_id, serde:: Raw , user_id, OwnedRoomId } ;
149use stream_assert:: { assert_pending, assert_ready} ;
1510use tokio:: sync:: mpsc;
1611use tokio_stream:: wrappers:: ReceiverStream ;
@@ -61,25 +56,18 @@ async fn test_notifications_joined() {
6156 assert_pending ! ( receiver_stream) ;
6257
6358 // Sync with two notifications.
64- let first_message = RoomMessageEventContent :: text_plain ( "Hello example!" )
65- . add_mentions ( Mentions :: with_user_ids ( [ client. user_id ( ) . unwrap ( ) . to_owned ( ) ] ) ) ;
66- let second_message = RoomMessageEventContent :: text_plain ( "How are you?" ) ;
67-
59+ let f = EventFactory :: new ( ) ;
6860 let joined_room = JoinedRoomBuilder :: new ( room_id) . add_timeline_bulk ( [
69- sync_timeline_event ! ( {
70- "content" : first_message,
71- "type" : "m.room.message" ,
72- "event_id" : "$aaa" ,
73- "origin_server_ts" : 2189 ,
74- "sender" : "@bob:example.com" ,
75- } ) ,
76- sync_timeline_event ! ( {
77- "content" : second_message,
78- "type" : "m.room.message" ,
79- "event_id" : "$bbb" ,
80- "origin_server_ts" : 3189 ,
81- "sender" : "@bob:example.com" ,
82- } ) ,
61+ f. text_msg ( "Hello example!" )
62+ . event_id ( event_id ! ( "$aaa" ) )
63+ . server_ts ( 2189 )
64+ . sender ( user_id ! ( "@bob:example.com" ) )
65+ . into_raw_sync ( ) ,
66+ f. text_msg ( "How are you?" )
67+ . event_id ( event_id ! ( "$bbb" ) )
68+ . server_ts ( 3189 )
69+ . sender ( user_id ! ( "@bob:example.com" ) )
70+ . into_raw_sync ( ) ,
8371 ] ) ;
8472 sync_builder. add_joined_room ( joined_room) ;
8573
0 commit comments