|
|
|
@ -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(());
|
|
|
|
|