parent
b663a47331
commit
0a4499fd03
1 changed files with 9 additions and 1 deletions
|
@ -47,7 +47,15 @@ export default async (job: Bull.Job<InboxJobData>): Promise<string> => {
|
||||||
|
|
||||||
// keyIdでわからなければ、activity.actorを元にDBから取得 || activity.actorを元にリモートから取得
|
// keyIdでわからなければ、activity.actorを元にDBから取得 || activity.actorを元にリモートから取得
|
||||||
if (authUser == null) {
|
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}`;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// それでもわからなければ終了
|
// それでもわからなければ終了
|
||||||
|
|
Loading…
Reference in a new issue