diff --git a/kordophoned/src/daemon/mod.rs b/kordophoned/src/daemon/mod.rs index f4eeda0..399df4d 100644 --- a/kordophoned/src/daemon/mod.rs +++ b/kordophoned/src/daemon/mod.rs @@ -240,7 +240,7 @@ impl Daemon { let guid = outgoing_message.guid.clone(); self.post_office_sink.send(PostOfficeEvent::EnqueueOutgoingMessage(outgoing_message)).await.unwrap(); - + guid } @@ -264,7 +264,7 @@ impl Daemon { // Send conversations updated signal signal_sender.send(Signal::ConversationsUpdated).await?; - log::info!(target: target::SYNC, "Synchronized {} conversations", num_conversations); + log::info!(target: target::SYNC, "List synchronized: {} conversations", num_conversations); Ok(()) } @@ -294,7 +294,7 @@ impl Daemon { // Send conversations updated signal. signal_sender.send(Signal::ConversationsUpdated).await?; - log::info!(target: target::SYNC, "Synchronized {} conversations", num_conversations); + log::info!(target: target::SYNC, "Full sync complete, {} conversations processed", num_conversations); Ok(()) } @@ -307,6 +307,7 @@ impl Daemon { let conversation = database.with_repository(|r| r.get_conversation_by_guid(&conversation_id)).await?; if conversation.is_none() { // If the conversation doesn't exist, first do a conversation list sync. + log::warn!(target: target::SYNC, "Conversation {} not found, performing list sync", conversation_id); Self::sync_conversation_list(database, signal_sender).await?; } diff --git a/kordophoned/src/daemon/update_monitor.rs b/kordophoned/src/daemon/update_monitor.rs index 57ed1ca..06edec7 100644 --- a/kordophoned/src/daemon/update_monitor.rs +++ b/kordophoned/src/daemon/update_monitor.rs @@ -42,8 +42,8 @@ impl UpdateMonitor { match update { UpdateEvent::ConversationChanged(conversation) => { log::info!(target: target::UPDATES, "Conversation changed: {:?}", conversation); - log::info!(target: target::UPDATES, "Triggering conversation list sync"); - self.send_event(Event::SyncConversationList).await + log::info!(target: target::UPDATES, "Syncing new messages for conversation id: {}", conversation.guid); + self.send_event(|r| Event::SyncConversation(conversation.guid, r)).await .unwrap_or_else(|e| { log::error!("Failed to send daemon event: {}", e); });