jmug/stoatchat
1
0
Fork 1
Code Issues Packages Projects Releases Wiki Activity

Merge remote-tracking branch 'origin/feat/elasticsearch' into feat/elasticsearch

Browse Source 
Signed-off-by: Zomatree <me@zomatree.live>

# Conflicts:
#	Cargo.lock
#	compose.yml
#	crates/core/config/src/lib.rs
#	crates/core/database/src/models/messages/ops.rs
#	crates/core/database/src/models/messages/ops/mongodb.rs
#	crates/core/database/src/models/messages/ops/reference.rs
#	crates/delta/src/routes/servers/server_delete.rs
This commit is contained in:
Zomatree
2026-03-29 06:07:10 +01:00
parent fb487130c8 d568b4369e
commit 7ec3b07f6c
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
crates/core/database/src/models/messages/ops/mongodb.rs
View File

@@ -416,7 +416,7 @@ impl AbstractMessages for MongoDb {
Ok(deleted_messages) Ok(deleted_messages)
} }
async fn fetch_all_messages(&self) -> Result<ChunkedDatabaseGenerator<Message>> { async fn fetch_all_messages(&self) -> Result<ChunkedDatabaseGenerator<Message>> {
let mut session = self let mut session = self
.start_session() .start_session()

2
crates/core/database/src/models/messages/ops/reference.rs
View File

@@ -353,7 +353,7 @@ impl AbstractMessages for ReferenceDb {
Ok(deleted_messages) Ok(deleted_messages)
} }
async fn fetch_all_messages(&self) -> Result<ChunkedDatabaseGenerator<Message>> { async fn fetch_all_messages(&self) -> Result<ChunkedDatabaseGenerator<Message>> {
Ok(ChunkedDatabaseGenerator::new_reference( Ok(ChunkedDatabaseGenerator::new_reference(
self.messages.lock().await.values().cloned().collect(), self.messages.lock().await.values().cloned().collect(),