bar

Author: Hywan

testing/matrix-sdk-integration-testing/src/tests/timeline.rs

@@ -63,7 +63,7 @@ use tokio::{
     task::JoinHandle,
     time::{sleep, timeout},
 };
-use tracing::{debug, trace, warn};
+use tracing::{debug, warn};
 
 use crate::helpers::TestClientBuilder;
 
@@ -193,7 +193,7 @@ async fn test_toggling_reaction() -> Result<()> {
         sleep(Duration::from_secs(1)).await;
 
         assert_let!(Some(timeline_updates) = stream.next().await);
-        assert_eq!(timeline_updates.len(), 2);
+        assert_eq!(timeline_updates.len(), 3);
 
         // Local echo is added.
         {
@@ -204,9 +204,11 @@ async fn test_toggling_reaction() -> Result<()> {
             assert_matches!(reaction.status, ReactionStatus::LocalToRemote(..));
         }
 
-        // Remote echo is added.
-        {
-            let event = assert_event_is_updated!(timeline_updates[1], event_id, message_position);
+        // Remote echo is added twice: one from the Send Queue because the event is sent
+        // and inserted in the Event Cache and one from the Event Cache via the sync.
+        // The difference is it gets a read receipt, that's why we get a second update.
+        for i in 1..3 {
+            let event = assert_event_is_updated!(timeline_updates[i], event_id, message_position);
 
             let reactions = event.content().reactions().cloned().unwrap_or_default();
             let reactions = reactions.get(&reaction_key).unwrap();
@@ -219,9 +221,10 @@ async fn test_toggling_reaction() -> Result<()> {
             // Note: this can actually be equal because if the timestamp from
             // server is not available, it might be created with a local call to `now()`
             assert!(reaction.timestamp <= MilliSecondsSinceUnixEpoch::now());
-            assert!(stream.next().now_or_never().is_none());
         }
 
+        assert_pending!(stream);
+
         // Redact the reaction.
         timeline
             .toggle_reaction(&item_id, &reaction_key)