From 0d08ed0758057fd46cf6ecbbde2a7c279e9253c6 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Damir=20Jeli=C4=87?= Date: Wed, 12 Nov 2025 11:25:24 +0100 Subject: [PATCH] refactor(redecryptor): Add some type aliases for the event ID/event tuples --- crates/matrix-sdk/src/event_cache/redecryptor.rs | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) diff --git a/crates/matrix-sdk/src/event_cache/redecryptor.rs b/crates/matrix-sdk/src/event_cache/redecryptor.rs index fc121760d..9debfa6de 100644 --- a/crates/matrix-sdk/src/event_cache/redecryptor.rs +++ b/crates/matrix-sdk/src/event_cache/redecryptor.rs @@ -146,6 +146,10 @@ use crate::{Room, room::PushContext}; type SessionId<'a> = &'a str; type OwnedSessionId = String; +type EventIdAndUtd = (OwnedEventId, Raw); +type EventIdAndEvent = (OwnedEventId, DecryptedRoomEvent); +type ResolvedUtd = (OwnedEventId, DecryptedRoomEvent, Option>); + /// The information sent across the channel to the long-running task requesting /// that the supplied set of sessions be retried. #[derive(Debug, Clone)] @@ -206,7 +210,7 @@ impl EventCache { &self, room_id: &RoomId, session_id: SessionId<'_>, - ) -> Result)>, EventCacheError> { + ) -> Result, EventCacheError> { let filter = |event: TimelineEvent| { let event_id = event.event_id(); @@ -231,7 +235,7 @@ impl EventCache { &self, room_id: &RoomId, session_id: SessionId<'_>, - ) -> Result, EventCacheError> { + ) -> Result, EventCacheError> { let filter = |event: TimelineEvent| { let event_id = event.event_id(); @@ -264,7 +268,7 @@ impl EventCache { async fn on_resolved_utds( &self, room_id: &RoomId, - events: Vec<(OwnedEventId, DecryptedRoomEvent, Option>)>, + events: Vec, ) -> Result<(), EventCacheError> { if events.is_empty() { trace!("No events were redecrypted or updated, nothing to replace");