@@ -16,7 +16,7 @@ use matrix_sdk::{
16
16
} ,
17
17
test_utils:: {
18
18
assert_event_matches_msg,
19
- mocks:: { MatrixMockServer , RoomMessagesResponse } ,
19
+ mocks:: { MatrixMockServer , RoomMessagesResponseTemplate } ,
20
20
} ,
21
21
} ;
22
22
use matrix_sdk_test:: {
@@ -261,7 +261,7 @@ async fn test_backpaginate_once() {
261
261
server
262
262
. mock_room_messages ( )
263
263
. from ( "prev_batch" )
264
- . ok ( RoomMessagesResponse :: default ( ) . events ( vec ! [
264
+ . ok ( RoomMessagesResponseTemplate :: default ( ) . events ( vec ! [
265
265
f. text_msg( "world" ) . event_id( event_id!( "$2" ) ) ,
266
266
f. text_msg( "hello" ) . event_id( event_id!( "$3" ) ) ,
267
267
] ) )
@@ -349,7 +349,7 @@ async fn test_backpaginate_many_times_with_many_iterations() {
349
349
server
350
350
. mock_room_messages ( )
351
351
. from ( "prev_batch" )
352
- . ok ( RoomMessagesResponse :: default ( ) . end_token ( "prev_batch2" ) . events ( vec ! [
352
+ . ok ( RoomMessagesResponseTemplate :: default ( ) . end_token ( "prev_batch2" ) . events ( vec ! [
353
353
f. text_msg( "world" ) . event_id( event_id!( "$2" ) ) ,
354
354
f. text_msg( "hello" ) . event_id( event_id!( "$3" ) ) ,
355
355
] ) )
@@ -361,7 +361,7 @@ async fn test_backpaginate_many_times_with_many_iterations() {
361
361
server
362
362
. mock_room_messages ( )
363
363
. from ( "prev_batch2" )
364
- . ok ( RoomMessagesResponse :: default ( )
364
+ . ok ( RoomMessagesResponseTemplate :: default ( )
365
365
. events ( vec ! [ f. text_msg( "oh well" ) . event_id( event_id!( "$4" ) ) ] ) )
366
366
. mock_once ( )
367
367
. mount ( )
@@ -487,7 +487,7 @@ async fn test_backpaginate_many_times_with_one_iteration() {
487
487
server
488
488
. mock_room_messages ( )
489
489
. from ( "prev_batch" )
490
- . ok ( RoomMessagesResponse :: default ( ) . end_token ( "prev_batch2" ) . events ( vec ! [
490
+ . ok ( RoomMessagesResponseTemplate :: default ( ) . end_token ( "prev_batch2" ) . events ( vec ! [
491
491
f. text_msg( "world" ) . event_id( event_id!( "$2" ) ) ,
492
492
f. text_msg( "hello" ) . event_id( event_id!( "$3" ) ) ,
493
493
] ) )
@@ -499,7 +499,7 @@ async fn test_backpaginate_many_times_with_one_iteration() {
499
499
server
500
500
. mock_room_messages ( )
501
501
. from ( "prev_batch2" )
502
- . ok ( RoomMessagesResponse :: default ( )
502
+ . ok ( RoomMessagesResponseTemplate :: default ( )
503
503
. events ( vec ! [ f. text_msg( "oh well" ) . event_id( event_id!( "$4" ) ) ] ) )
504
504
. mock_once ( )
505
505
. mount ( )
@@ -641,7 +641,7 @@ async fn test_reset_while_backpaginating() {
641
641
server
642
642
. mock_room_messages ( )
643
643
. from ( "first_backpagination" )
644
- . ok ( RoomMessagesResponse :: default ( )
644
+ . ok ( RoomMessagesResponseTemplate :: default ( )
645
645
. events ( vec ! [ f. text_msg( "lalala" ) . into_raw_timeline( ) ] )
646
646
. delayed ( Duration :: from_millis ( 500 ) ) )
647
647
. mock_once ( )
@@ -653,7 +653,7 @@ async fn test_reset_while_backpaginating() {
653
653
server
654
654
. mock_room_messages ( )
655
655
. from ( "second_backpagination" )
656
- . ok ( RoomMessagesResponse :: default ( )
656
+ . ok ( RoomMessagesResponseTemplate :: default ( )
657
657
. end_token ( "third_backpagination" )
658
658
. events ( vec ! [ f. text_msg( "finally!" ) . into_raw_timeline( ) ] ) )
659
659
. mock_once ( )
@@ -764,7 +764,7 @@ async fn test_backpaginating_without_token() {
764
764
765
765
server
766
766
. mock_room_messages ( )
767
- . ok ( RoomMessagesResponse :: default ( )
767
+ . ok ( RoomMessagesResponseTemplate :: default ( )
768
768
. events ( vec ! [ f. text_msg( "hi" ) . event_id( event_id!( "$2" ) ) . into_raw_timeline( ) ] ) )
769
769
. mock_once ( )
770
770
. mount ( )
@@ -822,7 +822,7 @@ async fn test_limited_timeline_resets_pagination() {
822
822
823
823
server
824
824
. mock_room_messages ( )
825
- . ok ( RoomMessagesResponse :: default ( )
825
+ . ok ( RoomMessagesResponseTemplate :: default ( )
826
826
. events ( vec ! [ f. text_msg( "hi" ) . event_id( event_id!( "$2" ) ) . into_raw_timeline( ) ] ) )
827
827
. mock_once ( )
828
828
. mount ( )
@@ -992,7 +992,7 @@ async fn test_limited_timeline_without_storage() {
992
992
server
993
993
. mock_room_messages ( )
994
994
. from ( "prev-batch" )
995
- . ok ( RoomMessagesResponse :: default ( )
995
+ . ok ( RoomMessagesResponseTemplate :: default ( )
996
996
. events ( vec ! [ f. text_msg( "oh well" ) . event_id( event_id!( "$1" ) ) ] ) )
997
997
. mock_once ( )
998
998
. mount ( )
@@ -1058,7 +1058,7 @@ async fn test_backpaginate_with_no_initial_events() {
1058
1058
let wait_time = Duration :: from_millis ( 500 ) ;
1059
1059
server
1060
1060
. mock_room_messages ( )
1061
- . ok ( RoomMessagesResponse :: default ( )
1061
+ . ok ( RoomMessagesResponseTemplate :: default ( )
1062
1062
. end_token ( "prev_batch" )
1063
1063
. events ( vec ! [
1064
1064
f. text_msg( "world" ) . event_id( event_id!( "$2" ) ) . into_raw_timeline( ) ,
@@ -1073,7 +1073,7 @@ async fn test_backpaginate_with_no_initial_events() {
1073
1073
server
1074
1074
. mock_room_messages ( )
1075
1075
. from ( "prev_batch" )
1076
- . ok ( RoomMessagesResponse :: default ( )
1076
+ . ok ( RoomMessagesResponseTemplate :: default ( )
1077
1077
. events ( vec ! [ f. text_msg( "oh well" ) . event_id( event_id!( "$1" ) ) ] ) )
1078
1078
. mock_once ( )
1079
1079
. mount ( )
@@ -1146,7 +1146,7 @@ async fn test_backpaginate_replace_empty_gap() {
1146
1146
// The first back-pagination will return a previous-batch token, but no events.
1147
1147
server
1148
1148
. mock_room_messages ( )
1149
- . ok ( RoomMessagesResponse :: default ( ) . end_token ( "prev_batch" ) )
1149
+ . ok ( RoomMessagesResponseTemplate :: default ( ) . end_token ( "prev_batch" ) )
1150
1150
. mock_once ( )
1151
1151
. mount ( )
1152
1152
. await ;
@@ -1155,7 +1155,7 @@ async fn test_backpaginate_replace_empty_gap() {
1155
1155
server
1156
1156
. mock_room_messages ( )
1157
1157
. from ( "prev_batch" )
1158
- . ok ( RoomMessagesResponse :: default ( )
1158
+ . ok ( RoomMessagesResponseTemplate :: default ( )
1159
1159
. events ( vec ! [ f. text_msg( "hello" ) . event_id( event_id!( "$1" ) ) ] ) )
1160
1160
. mock_once ( )
1161
1161
. mount ( )
@@ -1218,7 +1218,12 @@ async fn test_no_gap_stored_after_deduplicated_sync() {
1218
1218
drop ( events) ;
1219
1219
1220
1220
// Backpagination will return nothing.
1221
- server. mock_room_messages ( ) . ok ( RoomMessagesResponse :: default ( ) ) . mock_once ( ) . mount ( ) . await ;
1221
+ server
1222
+ . mock_room_messages ( )
1223
+ . ok ( RoomMessagesResponseTemplate :: default ( ) )
1224
+ . mock_once ( )
1225
+ . mount ( )
1226
+ . await ;
1222
1227
1223
1228
let pagination = room_event_cache. pagination ( ) ;
1224
1229
@@ -1328,7 +1333,7 @@ async fn test_no_gap_stored_after_deduplicated_backpagination() {
1328
1333
server
1329
1334
. mock_room_messages ( )
1330
1335
. from ( "prev-batch2" )
1331
- . ok ( RoomMessagesResponse :: default ( ) )
1336
+ . ok ( RoomMessagesResponseTemplate :: default ( ) )
1332
1337
. mock_once ( )
1333
1338
. mount ( )
1334
1339
. await ;
@@ -1338,7 +1343,7 @@ async fn test_no_gap_stored_after_deduplicated_backpagination() {
1338
1343
server
1339
1344
. mock_room_messages ( )
1340
1345
. from ( "prev-batch" )
1341
- . ok ( RoomMessagesResponse :: default ( ) . end_token ( "prev-batch3" ) . events ( vec ! [
1346
+ . ok ( RoomMessagesResponseTemplate :: default ( ) . end_token ( "prev-batch3" ) . events ( vec ! [
1342
1347
// Items in reverse order, since this is back-pagination.
1343
1348
f. text_msg( "world" ) . event_id( event_id!( "$2" ) ) . into_raw_timeline( ) ,
1344
1349
f. text_msg( "hello" ) . event_id( event_id!( "$1" ) ) . into_raw_timeline( ) ,
@@ -1424,7 +1429,7 @@ async fn test_dont_delete_gap_that_wasnt_inserted() {
1424
1429
server
1425
1430
. mock_room_messages ( )
1426
1431
. from ( "prev-batch" )
1427
- . ok ( RoomMessagesResponse :: default ( ) )
1432
+ . ok ( RoomMessagesResponseTemplate :: default ( ) )
1428
1433
. mock_once ( )
1429
1434
. mount ( )
1430
1435
. await ;
0 commit comments