test(sdk): Add integration test for search

Author: dragonfly1033

crates/matrix-sdk/src/client/mod.rs

@@ -2921,6 +2921,28 @@ impl Client {
         }
     }
 
+    /// Commit a [`Room`]'s [`RoomIndex`]
+    #[cfg(feature = "experimental-search")]
+    pub async fn commit(&self, room_id: &RoomId) {
+        let mut hash_map = self.inner.room_indexes.lock().await;
+        if let Some(index) = hash_map.get_mut(room_id) {
+            let _ = index.commit().inspect_err(|err| {
+                error!("error occured while committing: {err:?}");
+            });
+        }
+    }
+
+    /// Commit a [`Room`]'s [`RoomIndex`] and reload searchers
+    #[cfg(feature = "experimental-search")]
+    pub async fn commit_and_reload(&self, room_id: &RoomId) {
+        let mut hash_map = self.inner.room_indexes.lock().await;
+        if let Some(index) = hash_map.get_mut(room_id) {
+            let _ = index.commit_and_reload().inspect_err(|err| {
+                error!("error occured while committing: {err:?}");
+            });
+        }
+    }
+
     /// Whether the client is configured to take thread subscriptions (MSC4306
     /// and MSC4308) into account.
     ///

crates/matrix-sdk/src/room/mod.rs

@@ -3695,6 +3695,18 @@ impl Room {
         self.client.search_index(query, max_number_of_results, self.room_id()).await
     }
 
+    /// Commit a [`Room`]'s [`RoomIndex`]
+    #[cfg(feature = "experimental-search")]
+    pub async fn commit(&self) {
+        self.client.commit(self.room_id()).await;
+    }
+
+    /// Commit a [`Room`]'s [`RoomIndex`] and reload searchers
+    #[cfg(feature = "experimental-search")]
+    pub async fn commit_and_reload(&self) {
+        self.client.commit_and_reload(self.room_id()).await;
+    }
+
     /// Subscribe to a given thread in this room.
     ///
     /// This will subscribe the user to the thread, so that they will receive

crates/matrix-sdk/tests/integration/room/joined.rs

@@ -740,6 +740,40 @@ async fn test_room_message_send() {
     assert_eq!(event_id!("$h29iv0s8:example.com"), response.event_id)
 }
 
+#[cfg(feature = "experimental-search")]
+#[async_test]
+async fn test_sending_message_indexes_message() {
+    let mock_server = MatrixMockServer::new().await;
+    let client = mock_server.client_builder().build().await;
+
+    client.event_cache().subscribe().unwrap();
+
+    let room_id = room_id!("!room_id:localhost");
+    let event_id = event_id!("$event_id:localost");
+    let user_id = user_id!("@user_id:localost");
+
+    let event_factory = EventFactory::new();
+    mock_server
+        .sync_room(
+            &client,
+            JoinedRoomBuilder::new(room_id).add_timeline_bulk(vec![event_factory
+                .text_msg("this is a sentence")
+                .event_id(event_id)
+                .sender(user_id)
+                .into_raw_sync()]),
+        )
+        .await;
+
+    let room = client.get_room(room_id).unwrap();
+
+    room.commit_and_reload().await;
+
+    let response = room.search_index("this", 5).await.expect("search should have 1 result");
+
+    assert!(!response.is_empty(), "no results found {response:?}");
+    assert_eq!(response[0], event_id, "event id doesn't match: {response:?}");
+}
+
 #[async_test]
 async fn test_room_redact() {
     let server = MatrixMockServer::new().await;