From be0924d4636e7d84828e18e54962eef468fe8ecc Mon Sep 17 00:00:00 2001
From: Gabriel Kaszewski <gabrielkaszewski@gmail.com>
Date: Sun, 17 May 2026 12:02:13 +0200
Subject: [PATCH] fix: promote worker event logs from debug to info

---
 crates/worker/src/main.rs         | 4 +++-
 crates/worker/src/outbox_relay.rs | 2 +-
 2 files changed, 4 insertions(+), 2 deletions(-)

diff --git a/crates/worker/src/main.rs b/crates/worker/src/main.rs
index c5caa91..8d64b3f 100644
--- a/crates/worker/src/main.rs
+++ b/crates/worker/src/main.rs
@@ -43,13 +43,15 @@ async fn main() {
         match result {
             Ok(envelope) => {
                 let event = &envelope.event;
-                tracing::debug!(?event, "received event");
+                let event_type = event_payload::EventPayload::from(event).subject();
+                tracing::info!(event_type, delivery = envelope.delivery_count, "received event");
 
                 let n = infra.handlers.notification.handle(event).await;
                 let f = infra.handlers.federation.handle(event).await;
 
                 if n.is_ok() && f.is_ok() {
                     (envelope.ack)();
+                    tracing::info!(event_type, "event handled ok");
                 } else {
                     if let Err(e) = &n {
                         tracing::error!("notification handler: {e}");
diff --git a/crates/worker/src/outbox_relay.rs b/crates/worker/src/outbox_relay.rs
index d8fd0ff..6631891 100644
--- a/crates/worker/src/outbox_relay.rs
+++ b/crates/worker/src/outbox_relay.rs
@@ -100,7 +100,7 @@ impl OutboxRelay {
                     .execute(&mut *tx)
                     .await?;
                     tx.commit().await?;
-                    tracing::debug!(seq = row.seq, event_type = row.event_type, "outbox: delivered");
+                    tracing::info!(seq = row.seq, event_type = row.event_type, "outbox: delivered");
                 }
                 Err(e) => {
                     tracing::warn!(seq = row.seq, "outbox: publish failed (will retry): {e}");