diff --git a/crates/apub/src/activities/mod.rs b/crates/apub/src/activities/mod.rs index 54a96014..958065ff 100644 --- a/crates/apub/src/activities/mod.rs +++ b/crates/apub/src/activities/mod.rs @@ -230,8 +230,7 @@ where actor_type: actor.actor_type(), actor_apub_id: actor.id().into(), }; - let created = SentActivity::create(&mut data.pool(), form).await?; - info!("Queued for send: {:?}", created); + SentActivity::create(&mut data.pool(), form).await?; Ok(()) } diff --git a/crates/federate/src/worker.rs b/crates/federate/src/worker.rs index 14c86a7d..b6e174c0 100644 --- a/crates/federate/src/worker.rs +++ b/crates/federate/src/worker.rs @@ -161,21 +161,13 @@ impl InstanceWorker { { id += 1; processed_activities += 1; - tracing::info!("looking at activity {id}, proc={processed_activities}, latest={latest_id}"); let Some(ele) = get_activity_cached(pool, id) .await .context("failed reading activity from db")? else { - tracing::info!("activity {id} empty, marking latest"); 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: {:?}", @@ -205,13 +197,6 @@ 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(());