diff options
Diffstat (limited to 'src/queue/processors')
| -rw-r--r-- | src/queue/processors/inbox.ts | 10 |
1 files changed, 9 insertions, 1 deletions
diff --git a/src/queue/processors/inbox.ts b/src/queue/processors/inbox.ts index 8a292107ba..1d35079e9d 100644 --- a/src/queue/processors/inbox.ts +++ b/src/queue/processors/inbox.ts @@ -47,7 +47,15 @@ export default async (job: Bull.Job<InboxJobData>): Promise<string> => { // keyIdでわからなければ、activity.actorを元にDBから取得 || activity.actorを元にリモートから取得 if (authUser == null) { - authUser = await dbResolver.getAuthUserFromApId(getApId(activity.actor)); + try { + authUser = await dbResolver.getAuthUserFromApId(getApId(activity.actor)); + } catch (e) { + // 対象が4xxならスキップ + if (e.statusCode >= 400 && e.statusCode < 500) { + return `skip: Ignored deleted actors on both ends ${activity.actor} - ${e.statusCode}`; + } + throw `Error in actor ${activity.actor} - ${e.statusCode || e}`; + } } // それでもわからなければ終了 |