From e9b472eb0b7e4f832d9df96b674dc8da73b34b94 Mon Sep 17 00:00:00 2001 From: cel 🌸 Date: Sun, 17 Aug 2025 09:15:53 +0100 Subject: feat: new db schema --- filamento/src/logic/online.rs | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) (limited to 'filamento/src/logic/online.rs') diff --git a/filamento/src/logic/online.rs b/filamento/src/logic/online.rs index b36f9a9..2368eff 100644 --- a/filamento/src/logic/online.rs +++ b/filamento/src/logic/online.rs @@ -520,13 +520,15 @@ pub async fn handle_send_message(logic: &ClientLogic, body: body.clone(), timestamp, delivery: Some(Delivery::Sending), + // TODO: raw stanza logging + source: Vec::new(), }; // try to store in message history that there is a new message that is sending. if client is quit mid-send then can mark as failed and re-send // TODO: mark these as potentially failed upon client launch if let Err(e) = logic .db() - .create_message_with_user_resource(message.clone(), jid.clone(), connection.jid().clone()) + .create_message(message.clone(), jid.clone(), connection.jid().to_bare()) .await { // TODO: should these really be handle_error or just the error macro? @@ -586,6 +588,7 @@ pub async fn handle_send_message(logic: &ClientLogic, match result { Ok(_) => { info!("sent message: {:?}", message_stanza); + // TODO: raw stanza if let Err(e) = logic.db().update_message_delivery(id, Delivery::Written).await { error!("updating message delivery: {}", e); } -- cgit