Skip to content

Commit e862ded

Browse files
mgoldenbergbnjbvr
authored andcommitted
feat(indexeddb): add IndexedDB-backed impl for EventCacheStore::find_event
Signed-off-by: Michael Goldenberg <[email protected]>
1 parent 5cb033a commit e862ded

File tree

2 files changed

+14
-3
lines changed

2 files changed

+14
-3
lines changed

crates/matrix-sdk-indexeddb/src/event_cache_store/integration_tests.rs

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -755,6 +755,13 @@ macro_rules! event_cache_store_integration_tests {
755755
get_event_cache_store().await.unwrap().into_event_cache_store();
756756
event_cache_store.test_filter_duplicated_events().await;
757757
}
758+
759+
#[async_test]
760+
async fn test_find_event() {
761+
let event_cache_store =
762+
get_event_cache_store().await.unwrap().into_event_cache_store();
763+
event_cache_store.test_find_event().await;
764+
}
758765
}
759766
};
760767
}

crates/matrix-sdk-indexeddb/src/event_cache_store/mod.rs

Lines changed: 7 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -462,10 +462,14 @@ impl_event_cache_store! {
462462
event_id: &EventId,
463463
) -> Result<Option<Event>, IndexeddbEventCacheStoreError> {
464464
let _timer = timer!("method");
465-
self.memory_store
466-
.find_event(room_id, event_id)
465+
466+
let transaction =
467+
self.transaction(&[keys::EVENTS], IdbTransactionMode::Readonly)?;
468+
transaction
469+
.get_event_by_id(room_id, &event_id.to_owned())
467470
.await
468-
.map_err(IndexeddbEventCacheStoreError::MemoryStore)
471+
.map(|ok| ok.map(Into::into))
472+
.map_err(Into::into)
469473
}
470474

471475
#[instrument(skip(self, event_id, filters))]

0 commit comments

Comments
 (0)