From 8ac9c6bb0997b63893405c666fb59b87bf9e6d32 Mon Sep 17 00:00:00 2001 From: link2xt Date: Wed, 25 Mar 2026 23:02:57 +0100 Subject: [PATCH] more debug logging --- src/imap.rs | 24 ++++++++++++++++++++++++ 1 file changed, 24 insertions(+) diff --git a/src/imap.rs b/src/imap.rs index ac4af4ad1..4f8b14985 100644 --- a/src/imap.rs +++ b/src/imap.rs @@ -546,10 +546,21 @@ impl Imap { bail!("IMAP operation attempted while it is torn down"); } + let transport_id = session.transport_id(); + info!( + context, + "Transport {transport_id}: fetch_move_delete start." + ); + let msgs_fetched = self .fetch_new_messages(context, session, watch_folder, folder_meaning) .await .context("fetch_new_messages")?; + + info!( + context, + "Transport {transport_id}: fetch_move_delete finished fetch_new_messages." + ); if msgs_fetched && context.get_config_delete_device_after().await?.is_some() { // New messages were fetched and shall be deleted later, restart ephemeral loop. // Note that the `Config::DeleteDeviceAfter` timer starts as soon as the messages are @@ -588,10 +599,18 @@ impl Imap { return Ok(false); } + info!( + context, + "Transport {transport_id}: fetch_new_messages selects folder {folder:?}." + ); let folder_exists = session .select_with_uidvalidity(context, folder) .await .with_context(|| format!("Failed to select folder {folder:?}"))?; + info!( + context, + "Transport {transport_id}: fetch_new_messages selected folder {folder:?}." + ); if !session.new_mail { info!( @@ -1125,6 +1144,7 @@ impl Session { } let transport_id = self.transport_id(); + info!(context, "Transport {transport_id}: Storing seen flags."); let rows = context .sql .query_map_vec( @@ -1182,6 +1202,10 @@ impl Session { .await .context("Cannot remove messages marked as seen from imap_markseen table")?; } + info!( + context, + "Transport {transport_id}: Finished storing seen flags." + ); Ok(()) }