mirror/matrix-rust-sdk
1
0
Fork 0
mirror of https://github.com/matrix-org/matrix-rust-sdk.git synced 2026-05-19 06:04:31 -04:00
Code Issues Packages Projects Releases Wiki Activity

refactor(timeline): Split finding retry indices into its own function

Browse Source
This commit is contained in:
Andy Balaam
2025-02-24 16:13:56 +00:00
committed by Andy Balaam
parent c74ecff3f0
commit d447342cbd
1 changed files with 11 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
crates/matrix-sdk-ui/src/timeline/controller/decryption_retry_task.rs
View File

@@ -47,6 +47,15 @@ impl<P: RoomDataProvider> DecryptionRetryTask<P> {
decryptor: impl Decryptor,
session_ids: Option<BTreeSet<String>>,
) {
let retry_indices = self.retry_indices(&session_ids).await;
if !retry_indices.is_empty() {
debug!("Retrying decryption");
self.decrypt_by_index(decryptor, session_ids, retry_indices).await;
}
}
async fn retry_indices(&self, session_ids: &Option<BTreeSet<String>>) -> Vec<usize> {
let state = self.state.clone().read_owned().await;
let should_retry = |session_id: &str| {
@@ -57,7 +66,7 @@ impl<P: RoomDataProvider> DecryptionRetryTask<P> {
}
};
let retry_indices: Vec<_> = state
state
.items
.iter()
.enumerate()
@@ -71,17 +80,7 @@ impl<P: RoomDataProvider> DecryptionRetryTask<P> {
| EncryptedMessage::OlmV1Curve25519AesSha2 { .. }
| EncryptedMessage::Unknown => None,
})
.collect();
if retry_indices.is_empty() {
return;
}
drop(state);
debug!("Retrying decryption");
self.decrypt_by_index(decryptor, session_ids, retry_indices).await;
.collect()
}
async fn decrypt_by_index(