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

fixup! state store: change schema for send_queue_events table

Browse Source
This commit is contained in:
Benjamin Bouvier
2024-06-26 11:48:08 +02:00
parent 29ac3e0dda
commit 8e8d793f0d
1 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
crates/matrix-sdk-indexeddb/src/state_store/mod.rs
View File

@@ -1495,10 +1495,11 @@ impl_state_store!({
.get_all()?
.await?
.into_iter()
.map(|item| {
self.deserialize_value(&item).map(|event: PersistedQueuedEvent| event.room_id)
})
.collect::<Result<HashSet<OwnedRoomId>, _>>()?;
.map(|item| self.deserialize_value::<Vec<PersistedQueuedEvent>>(&item))
.collect::<Result<Vec<Vec<PersistedQueuedEvent>>, _>>()?
.into_iter()
.flat_map(|vec| vec.into_iter().map(|item| item.room_id))
.collect::<BTreeSet<_>>();
Ok(all_entries.into_iter().collect())
}