mirrors/barkey
1
0
Fork 0
mirror of https://codeberg.org/yeentown/barkey.git synced 2025-07-07 12:36:57 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

recognize more retryable errors when resolving actor for signature verification

Browse source
This commit is contained in:
Hazelnoot 2025-03-03 00:51:46 -05:00
parent 1c48d3eef9
commit a10885ae95
1 changed files with 4 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
packages/backend/src/queue/processors/InboxProcessorService.ts
View file

@ -146,12 +146,11 @@ export class InboxProcessorService implements OnApplicationShutdown {
authUser = await this.apDbResolverService.getAuthUserFromApId(actorId); authUser = await this.apDbResolverService.getAuthUserFromApId(actorId);
} catch (err) { } catch (err) {
// 対象が4xxならスキップ // 対象が4xxならスキップ
if (err instanceof StatusError) { if (!isRetryableError(err)) {
if (!err.isRetryable) { throw new Bull.UnrecoverableError(`skip: Ignored deleted actors on both ends ${actorId}`);
throw new Bull.UnrecoverableError(`skip: Ignored deleted actors on both ends ${actorId} - ${err.statusCode}`);
}
throw new Error(`Error in actor ${actorId} - ${err.statusCode}`);
} }
throw err;
} }
} }