@@ -61,8 +61,8 @@ def test_delivery_status(acfactory: ACFactory) -> None:
61
61
62
62
event = bob .wait_for_incoming_msg_event ()
63
63
msg = bob .get_message_by_id (event .msg_id )
64
- bob . _rpc . accept_chat ( bob . id , msg .get_snapshot ().chat_id )
65
- bob . mark_seen_messages ([ msg ] )
64
+ msg .get_snapshot ().chat . accept ( )
65
+ msg . mark_seen ( )
66
66
67
67
chat_item = alice ._rpc .get_chatlist_items_by_entries (alice .id , [alice_chat_bob .id ])[str (alice_chat_bob .id )]
68
68
assert chat_item ["summaryStatus" ] == const .MessageState .OUT_DELIVERED
@@ -123,7 +123,7 @@ def test_download_on_demand(acfactory: ACFactory) -> None:
123
123
event = bob .wait_for_incoming_msg_event ()
124
124
msg = bob .get_message_by_id (event .msg_id )
125
125
chat_id = msg .get_snapshot ().chat_id
126
- bob . _rpc . accept_chat ( bob . id , msg .get_snapshot ().chat_id )
126
+ msg .get_snapshot ().chat . accept ( )
127
127
bob .get_chat_by_id (chat_id ).send_message (
128
128
"Hello World, this message is bigger than 5 bytes" ,
129
129
html = base64 .b64encode (os .urandom (300000 )).decode ("utf-8" ),
@@ -174,7 +174,7 @@ def test_imap_sync_seen_msgs(acfactory: ACFactory) -> None:
174
174
event = bob .wait_for_incoming_msg_event ()
175
175
msg = bob .get_message_by_id (event .msg_id )
176
176
bob_chat_id = msg .get_snapshot ().chat_id
177
- bob . _rpc . accept_chat ( bob . id , bob_chat_id )
177
+ msg . get_snapshot (). chat . accept ( )
178
178
179
179
alice .clear_all_events ()
180
180
alice_second_device .clear_all_events ()
@@ -186,7 +186,7 @@ def test_imap_sync_seen_msgs(acfactory: ACFactory) -> None:
186
186
event = alice .wait_for_incoming_msg_event ()
187
187
msg = alice .get_message_by_id (event .msg_id )
188
188
alice_second_device .clear_all_events ()
189
- alice . mark_seen_messages ([ msg ] )
189
+ msg . mark_seen ( )
190
190
191
191
wait_for_chatlist_specific_item (bob , bob_chat_id )
192
192
wait_for_chatlist_specific_item (alice , alice_chat_bob .id )
0 commit comments