summaryrefslogtreecommitdiff
path: root/src/queue
diff options
context:
space:
mode:
authorsyuilo <Syuilotan@yahoo.co.jp>2021-07-20 12:11:07 +0900
committersyuilo <Syuilotan@yahoo.co.jp>2021-07-20 12:11:07 +0900
commitacb92442058fa2458967425efb7324ab0646a335 (patch)
treeafc2ac62a7bbddce5756fc49f1caba9f7cba5407 /src/queue
parentMerge branch 'develop' (diff)
parent12.84.0 (diff)
downloadmisskey-acb92442058fa2458967425efb7324ab0646a335.tar.gz
misskey-acb92442058fa2458967425efb7324ab0646a335.tar.bz2
misskey-acb92442058fa2458967425efb7324ab0646a335.zip
Merge branch 'develop'
Diffstat (limited to 'src/queue')
-rw-r--r--src/queue/processors/db/import-following.ts2
-rw-r--r--src/queue/processors/db/import-user-lists.ts2
-rw-r--r--src/queue/processors/inbox.ts9
3 files changed, 11 insertions, 2 deletions
diff --git a/src/queue/processors/db/import-following.ts b/src/queue/processors/db/import-following.ts
index 55c0aaa9f9..1156b5cafa 100644
--- a/src/queue/processors/db/import-following.ts
+++ b/src/queue/processors/db/import-following.ts
@@ -2,7 +2,7 @@ import * as Bull from 'bull';
import { queueLogger } from '../../logger';
import follow from '../../../services/following/create';
-import parseAcct from '@/misc/acct/parse';
+import { parseAcct } from '@/misc/acct';
import { resolveUser } from '../../../remote/resolve-user';
import { downloadTextFile } from '@/misc/download-text-file';
import { isSelfHost, toPuny } from '@/misc/convert-host';
diff --git a/src/queue/processors/db/import-user-lists.ts b/src/queue/processors/db/import-user-lists.ts
index d316b95ff0..d04ead869a 100644
--- a/src/queue/processors/db/import-user-lists.ts
+++ b/src/queue/processors/db/import-user-lists.ts
@@ -1,7 +1,7 @@
import * as Bull from 'bull';
import { queueLogger } from '../../logger';
-import parseAcct from '@/misc/acct/parse';
+import { parseAcct } from '@/misc/acct';
import { resolveUser } from '../../../remote/resolve-user';
import { pushUserToUserList } from '../../../services/user-list/push';
import { downloadTextFile } from '@/misc/download-text-file';
diff --git a/src/queue/processors/inbox.ts b/src/queue/processors/inbox.ts
index 2ef19777f1..5922c4c560 100644
--- a/src/queue/processors/inbox.ts
+++ b/src/queue/processors/inbox.ts
@@ -65,6 +65,11 @@ export default async (job: Bull.Job<InboxJobData>): Promise<string> => {
return `skip: failed to resolve user`;
}
+ // publicKey がなくても終了
+ if (authUser.key == null) {
+ return `skip: failed to resolve user publicKey`;
+ }
+
// HTTP-Signatureの検証
const httpSignatureValidated = httpSignature.verifySignature(signature, authUser.key.keyPem);
@@ -89,6 +94,10 @@ export default async (job: Bull.Job<InboxJobData>): Promise<string> => {
return `skip: LD-Signatureのユーザーが取得できませんでした`;
}
+ if (authUser.key == null) {
+ return `skip: LD-SignatureのユーザーはpublicKeyを持っていませんでした`;
+ }
+
// LD-Signature検証
const ldSignature = new LdSignature();
const verified = await ldSignature.verifyRsaSignature2017(activity, authUser.key.keyPem).catch(() => false);