feat(sdk): compute_latest_events broadcasts the update to LatestEvent.

This patch updates `compute_latest_events` to broadcast a
`RoomSendQueueUpdate` onto `LatestEvent`. It introduces the new
`update_with_send_queue` method.

Author: Hywan

crates/matrix-sdk/src/latest_events/latest_event.rs

@@ -31,7 +31,7 @@ use ruma::{
 };
 use tracing::warn;
 
-use crate::{event_cache::RoomEventCache, room::WeakRoom};
+use crate::{event_cache::RoomEventCache, room::WeakRoom, send_queue::RoomSendQueueUpdate};
 
 /// The latest event of a room or a thread.
 ///
@@ -84,6 +84,12 @@ impl LatestEvent {
 
         self.value.set(new_value).await;
     }
+
+    /// Update the inner latest event value, based on the send queue
+    /// (specifically with a [`RoomSendQueueUpdate`]).
+    pub async fn update_with_send_queue(&mut self, send_queue_update: &RoomSendQueueUpdate) {
+        todo!()
+    }
 }
 
 /// A latest event value!

crates/matrix-sdk/src/latest_events/mod.rs

@@ -532,6 +532,16 @@ impl RoomLatestEvents {
             latest_event.update_with_event_cache(&self.room_event_cache, &power_levels).await;
         }
     }
+
+    /// Update the latest events for the room and its threads, based on the
+    /// send queue update.
+    async fn update_with_send_queue(&mut self, send_queue_update: &RoomSendQueueUpdate) {
+        self.for_the_room.update_with_send_queue(send_queue_update).await;
+
+        for latest_event in self.per_thread.values_mut() {
+            latest_event.update_with_send_queue(send_queue_update).await;
+        }
+    }
 }
 
 /// The task responsible to listen to the [`EventCache`] and the [`SendQueue`].
@@ -687,9 +697,15 @@ async fn compute_latest_events(
             }
 
             LatestEventQueueUpdate::SendQueue { room_id, update } => {
-                // let mut rooms = registered_rooms.rooms.write().await;
+                let mut rooms = registered_rooms.rooms.write().await;
 
-                todo!()
+                if let Some(room_latest_events) = rooms.get_mut(room_id) {
+                    room_latest_events.update_with_send_queue(update).await;
+                } else {
+                    error!(?room_id, "Failed to find the room");
+
+                    continue;
+                }
             }
         }
     }