Skip to content

Commit c3fb01d

Browse files
committed
fix(redecryptor): Early return if we don't have any events to process
1 parent f3dde16 commit c3fb01d

File tree

1 file changed

+12
-0
lines changed

1 file changed

+12
-0
lines changed

crates/matrix-sdk/src/event_cache/redecryptor.rs

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -391,6 +391,11 @@ impl EventCache {
391391
// Get all the relevant UTDs.
392392
let events = self.get_utds(room_id, session_id).await?;
393393

394+
if events.is_empty() {
395+
trace!("No relevant events found.");
396+
return Ok(());
397+
}
398+
394399
let room = self.inner.client().ok().and_then(|client| client.get_room(room_id));
395400
let push_context =
396401
if let Some(room) = &room { room.push_context().await.ok().flatten() } else { None };
@@ -434,6 +439,8 @@ impl EventCache {
434439
room_id: &RoomId,
435440
session_id: SessionId<'_>,
436441
) -> Result<(), EventCacheError> {
442+
trace!("Updating encryption info");
443+
437444
let Ok(client) = self.inner.client() else {
438445
return Ok(());
439446
};
@@ -445,6 +452,11 @@ impl EventCache {
445452
// Get all the relevant events.
446453
let events = self.get_decrypted_events(room_id, session_id).await?;
447454

455+
if events.is_empty() {
456+
trace!("No relevant events found.");
457+
return Ok(());
458+
}
459+
448460
// Let's attempt to update their encryption info.
449461
let mut updated_events = Vec::with_capacity(events.len());
450462

0 commit comments

Comments
 (0)