diff options
| author | Hazelnoot <acomputerdog@gmail.com> | 2025-03-03 00:51:46 -0500 |
|---|---|---|
| committer | Hazelnoot <acomputerdog@gmail.com> | 2025-06-06 22:19:49 -0400 |
| commit | a10885ae95c3495e9822ab2853b2f3364a45668a (patch) | |
| tree | 621417fec478d32ef7aec45ab49f8897db2ccf5c | |
| parent | ensure that permanent errors always terminate the inbox job (diff) | |
| download | sharkey-a10885ae95c3495e9822ab2853b2f3364a45668a.tar.gz sharkey-a10885ae95c3495e9822ab2853b2f3364a45668a.tar.bz2 sharkey-a10885ae95c3495e9822ab2853b2f3364a45668a.zip | |
recognize more retryable errors when resolving actor for signature verification
| -rw-r--r-- | packages/backend/src/queue/processors/InboxProcessorService.ts | 9 |
1 files changed, 4 insertions, 5 deletions
diff --git a/packages/backend/src/queue/processors/InboxProcessorService.ts b/packages/backend/src/queue/processors/InboxProcessorService.ts index 1257467cfe..93d0a08003 100644 --- a/packages/backend/src/queue/processors/InboxProcessorService.ts +++ b/packages/backend/src/queue/processors/InboxProcessorService.ts @@ -146,12 +146,11 @@ export class InboxProcessorService implements OnApplicationShutdown { authUser = await this.apDbResolverService.getAuthUserFromApId(actorId); } catch (err) { // 対象が4xxならスキップ - if (err instanceof StatusError) { - if (!err.isRetryable) { - throw new Bull.UnrecoverableError(`skip: Ignored deleted actors on both ends ${actorId} - ${err.statusCode}`); - } - throw new Error(`Error in actor ${actorId} - ${err.statusCode}`); + if (!isRetryableError(err)) { + throw new Bull.UnrecoverableError(`skip: Ignored deleted actors on both ends ${actorId}`); } + + throw err; } } |