From b8d07d0ad5bc6016a33325acef1bd374cb4f1c7c Mon Sep 17 00:00:00 2001 From: Akulij Date: Sat, 31 May 2025 13:45:45 +0500 Subject: [PATCH] create MessageForward.store_db to store by DB type reason: easier to use with RwLock --- src/db/message_forward.rs | 10 ++++++++++ 1 file changed, 10 insertions(+) diff --git a/src/db/message_forward.rs b/src/db/message_forward.rs index acf7f01..31e168b 100644 --- a/src/db/message_forward.rs +++ b/src/db/message_forward.rs @@ -2,6 +2,7 @@ use bson::doc; use serde::{Deserialize, Serialize}; use super::DbResult; +use super::DB; use crate::query_call_consume; use crate::CallDB; @@ -42,6 +43,15 @@ impl MessageForward { Ok(self) }); + pub async fn store_db(self, db: &mut DB) -> DbResult { + let db = db.get_database().await; + let ci = db.collection::("message_forward"); + + ci.insert_one(&self).await?; + + Ok(self) + } + pub async fn get( db: &mut D, chat_id: i64,