diff --git a/packages/backend/src/queue/processors/inbox.ts b/packages/backend/src/queue/processors/inbox.ts index 1985edaac..6f3a98698 100644 --- a/packages/backend/src/queue/processors/inbox.ts +++ b/packages/backend/src/queue/processors/inbox.ts @@ -194,6 +194,27 @@ export default async (job: Bull.Job): Promise => { federationChart.inbox(i.host); }); + const inbox = authUser.user.sharedInbox ?? authUser.user.inbox; + if (inbox !== null) { + const { host: inboxHost } = new URL(inbox); + + if (inboxHost !== authUser.user.host) { + registerOrFetchInstanceDoc(inboxHost).then((i) => { + Instances.update(i.id, { + latestRequestReceivedAt: new Date(), + lastCommunicatedAt: new Date(), + isNotResponding: false, + }); + + fetchInstanceMetadata(i); + + instanceChart.requestReceived(i.host); + apRequestChart.inbox(); + federationChart.inbox(i.host); + }); + } + } + // アクティビティを処理 await perform(authUser.user, activity); return "ok";