From a59a94492d9541ad18f1a7dfdcfe4b09cb5a484e Mon Sep 17 00:00:00 2001
From: phiresky <phireskyde+git@gmail.com>
Date: Wed, 20 Sep 2023 12:29:09 +0000
Subject: [PATCH] more debug log

---
 crates/apub/src/activities/mod.rs |  2 +-
 crates/federate/src/worker.rs     | 13 +++++++++++++
 2 files changed, 14 insertions(+), 1 deletion(-)

diff --git a/crates/apub/src/activities/mod.rs b/crates/apub/src/activities/mod.rs
index 2e26e0678..fcb90b13a 100644
--- a/crates/apub/src/activities/mod.rs
+++ b/crates/apub/src/activities/mod.rs
@@ -194,7 +194,7 @@ fn generate_announce_activity_id(
     "{}/activities/{}/{}/{}",
     protocol_and_hostname,
     AnnounceType::Announce.to_string().to_lowercase(),
-    inner_kind,
+    inner_kind.to_lowercase(),
     Uuid::new_v4()
   );
   Url::parse(&id)
diff --git a/crates/federate/src/worker.rs b/crates/federate/src/worker.rs
index b6e174c04..249fc100e 100644
--- a/crates/federate/src/worker.rs
+++ b/crates/federate/src/worker.rs
@@ -168,6 +168,12 @@ impl InstanceWorker {
         self.state.last_successful_id = id;
         continue;
       };
+      tracing::info!(
+        "processing send of {} {} for {}",
+        ele.0.id,
+        ele.0.ap_id,
+        self.instance.domain
+      );
       if let Err(e) = self.send_retry_loop(pool, &ele.0, &ele.1).await {
         tracing::warn!(
           "sending {} errored internally, skipping activity: {:?}",
@@ -197,6 +203,13 @@ impl InstanceWorker {
       .get_inbox_urls(pool, activity)
       .await
       .context("failed figuring out inbox urls")?;
+    tracing::info!(
+      "inboxes of {} for {} {}: {:?}",
+      self.instance.domain,
+      activity.id,
+      activity.ap_id,
+      inbox_urls
+    );
     if inbox_urls.is_empty() {
       self.state.last_successful_id = activity.id;
       return Ok(());