aboutsummaryrefslogtreecommitdiffstats
path: root/filamento/src/logic/online.rs
diff options
context:
space:
mode:
authorLibravatar cel 🌸 <cel@bunny.garden>2025-04-28 19:53:11 +0100
committerLibravatar cel 🌸 <cel@bunny.garden>2025-04-28 19:53:11 +0100
commit42c7423667a2d6acdebca75250ad30c5d475081b (patch)
tree65faaac42cf3f8ef83715ee7f66db1af45dd39d6 /filamento/src/logic/online.rs
parent66cd4d48142124d920e5cc57f685555d279b8c7a (diff)
downloadluz-42c7423667a2d6acdebca75250ad30c5d475081b.tar.gz
luz-42c7423667a2d6acdebca75250ad30c5d475081b.tar.bz2
luz-42c7423667a2d6acdebca75250ad30c5d475081b.zip
feat: serde
Diffstat (limited to '')
-rw-r--r--filamento/src/logic/online.rs8
1 files changed, 8 insertions, 0 deletions
diff --git a/filamento/src/logic/online.rs b/filamento/src/logic/online.rs
index c0c3a7f..3936584 100644
--- a/filamento/src/logic/online.rs
+++ b/filamento/src/logic/online.rs
@@ -23,6 +23,7 @@ use crate::{
use super::{
local_only::{
+ handle_get_message,
handle_delete_chat, handle_delete_messaage, handle_get_chat, handle_get_chats, handle_get_chats_ordered, handle_get_chats_ordered_with_latest_messages, handle_get_chats_ordered_with_latest_messages_and_users, handle_get_messages, handle_get_messages_with_users, handle_get_user
}, ClientLogic
};
@@ -583,6 +584,9 @@ pub async fn handle_send_message<Fs: FileStore + Clone>(logic: &ClientLogic<Fs>,
match result {
Ok(_) => {
info!("sent message: {:?}", message_stanza);
+ if let Err(e) = logic.db().update_message_delivery(id, Delivery::Written).await {
+ error!("updating message delivery: {}", e);
+ }
logic
.update_sender()
.send(UpdateMessage::MessageDelivery {
@@ -1107,6 +1111,10 @@ pub async fn handle_online_result<Fs: FileStore + Clone>(
let chat = handle_get_chat(logic, jid).await;
let _ = sender.send(chat);
}
+ Command::GetMessage(id, sender) => {
+ let message = handle_get_message(logic, id).await;
+ let _ = sender.send(message);
+ }
Command::GetMessages(jid, sender) => {
let messages = handle_get_messages(logic, jid).await;
let _ = sender.send(messages);