diff --git a/crates/core/database/src/models/messages/ops/mongodb.rs b/crates/core/database/src/models/messages/ops/mongodb.rs index a518d5b8..0eceaab4 100644 --- a/crates/core/database/src/models/messages/ops/mongodb.rs +++ b/crates/core/database/src/models/messages/ops/mongodb.rs @@ -416,7 +416,7 @@ impl AbstractMessages for MongoDb { Ok(deleted_messages) } - + async fn fetch_all_messages(&self) -> Result> { let mut session = self .start_session() diff --git a/crates/core/database/src/models/messages/ops/reference.rs b/crates/core/database/src/models/messages/ops/reference.rs index 1c4c8e2e..5426fe8e 100644 --- a/crates/core/database/src/models/messages/ops/reference.rs +++ b/crates/core/database/src/models/messages/ops/reference.rs @@ -353,7 +353,7 @@ impl AbstractMessages for ReferenceDb { Ok(deleted_messages) } - + async fn fetch_all_messages(&self) -> Result> { Ok(ChunkedDatabaseGenerator::new_reference( self.messages.lock().await.values().cloned().collect(),