summaryrefslogtreecommitdiff
path: root/src/queue/processors/inbox.ts
diff options
context:
space:
mode:
authorMeiMei <30769358+mei23@users.noreply.github.com>2021-10-16 17:16:24 +0900
committerGitHub <noreply@github.com>2021-10-16 17:16:24 +0900
commit482081c41b45ab3798e73c4d11e8a7c1c1f5e8c9 (patch)
treefed02348c2fce534f8101370853eb83fbf3aa899 /src/queue/processors/inbox.ts
parentテスト用コンテナの調整 (#7838) (diff)
downloadmisskey-482081c41b45ab3798e73c4d11e8a7c1c1f5e8c9.tar.gz
misskey-482081c41b45ab3798e73c4d11e8a7c1c1f5e8c9.tar.bz2
misskey-482081c41b45ab3798e73c4d11e8a7c1c1f5e8c9.zip
Refactor request (#7814)
* status code * Test ap-request.ts https://github.com/mei23/crytest/blob/4397fc5e70536e4175fe56e974ca83b8047bef3a/test/ap-request.ts * tune
Diffstat (limited to 'src/queue/processors/inbox.ts')
-rw-r--r--src/queue/processors/inbox.ts3
1 files changed, 2 insertions, 1 deletions
diff --git a/src/queue/processors/inbox.ts b/src/queue/processors/inbox.ts
index e2c271cdf8..4032ce8653 100644
--- a/src/queue/processors/inbox.ts
+++ b/src/queue/processors/inbox.ts
@@ -14,6 +14,7 @@ import { InboxJobData } from '../types';
import DbResolver from '@/remote/activitypub/db-resolver';
import { resolvePerson } from '@/remote/activitypub/models/person';
import { LdSignature } from '@/remote/activitypub/misc/ld-signature';
+import { StatusError } from '@/misc/fetch';
const logger = new Logger('inbox');
@@ -53,7 +54,7 @@ export default async (job: Bull.Job<InboxJobData>): Promise<string> => {
authUser = await dbResolver.getAuthUserFromApId(getApId(activity.actor));
} catch (e) {
// 対象が4xxならスキップ
- if (e.statusCode >= 400 && e.statusCode < 500) {
+ if (e instanceof StatusError && e.isClientError) {
return `skip: Ignored deleted actors on both ends ${activity.actor} - ${e.statusCode}`;
}
throw `Error in actor ${activity.actor} - ${e.statusCode || e}`;