feat(indexeddb): add IndexedDB-backed impl for EventCacheStore::filter_duplicated_events

Signed-off-by: Michael Goldenberg <[email protected]>

Author: mgoldenberg

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

@@ -748,6 +748,13 @@ macro_rules! event_cache_store_integration_tests {
                     get_event_cache_store().await.unwrap().into_event_cache_store();
                 event_cache_store.test_remove_room().await;
             }
+
+            #[async_test]
+            async fn test_filter_duplicated_events() {
+                let event_cache_store =
+                    get_event_cache_store().await.unwrap().into_event_cache_store();
+                event_cache_store.test_filter_duplicated_events().await;
+            }
         }
     };
 }

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

@@ -435,10 +435,24 @@ impl_event_cache_store! {
         events: Vec<OwnedEventId>,
     ) -> Result<Vec<(OwnedEventId, Position)>, IndexeddbEventCacheStoreError> {
         let _timer = timer!("method");
-        self.memory_store
-            .filter_duplicated_events(linked_chunk_id, events)
-            .await
-            .map_err(IndexeddbEventCacheStoreError::MemoryStore)
+
+        if events.is_empty() {
+            return Ok(Vec::new());
+        }
+
+        let linked_chunk_id = linked_chunk_id.to_owned();
+        let room_id = linked_chunk_id.room_id();
+        let transaction =
+            self.transaction(&[keys::EVENTS], IdbTransactionMode::Readonly)?;
+        let mut duplicated = Vec::new();
+        for event_id in events {
+            if let Some(types::Event::InBand(event)) =
+                transaction.get_event_by_id(room_id, &event_id).await?
+            {
+                duplicated.push((event_id, event.position.into()));
+            }
+        }
+        Ok(duplicated)
     }
 
     #[instrument(skip(self, event_id))]

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

@@ -570,6 +570,17 @@ impl<'a> IndexeddbEventCacheStoreTransaction<'a> {
         self.delete_items_in_room::<Chunk, IndexedChunkIdKey>(room_id).await
     }
 
+    /// Query IndexedDB for events that match the given event id in the given
+    /// room. If more than one item is found, an error is returned.
+    pub async fn get_event_by_id(
+        &self,
+        room_id: &RoomId,
+        event_id: &OwnedEventId,
+    ) -> Result<Option<Event>, IndexeddbEventCacheStoreTransactionError> {
+        let key = self.serializer.encode_key(room_id, event_id);
+        self.get_item_by_key::<Event, IndexedEventIdKey>(room_id, key).await
+    }
+
     /// Query IndexedDB for events in the given position range in the given
     /// room.
     pub async fn get_events_by_position(