summaryrefslogtreecommitdiff
path: root/packages/backend/src/queue/processors/InboxProcessorService.ts
diff options
context:
space:
mode:
authorHazelnoot <acomputerdog@gmail.com>2025-03-03 00:51:46 -0500
committerHazelnoot <acomputerdog@gmail.com>2025-06-06 22:19:49 -0400
commita10885ae95c3495e9822ab2853b2f3364a45668a (patch)
tree621417fec478d32ef7aec45ab49f8897db2ccf5c /packages/backend/src/queue/processors/InboxProcessorService.ts
parentensure that permanent errors always terminate the inbox job (diff)
downloadsharkey-a10885ae95c3495e9822ab2853b2f3364a45668a.tar.gz
sharkey-a10885ae95c3495e9822ab2853b2f3364a45668a.tar.bz2
sharkey-a10885ae95c3495e9822ab2853b2f3364a45668a.zip
recognize more retryable errors when resolving actor for signature verification
Diffstat (limited to 'packages/backend/src/queue/processors/InboxProcessorService.ts')
-rw-r--r--packages/backend/src/queue/processors/InboxProcessorService.ts9
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;
}
}