From e66d7babc5ae477d7a60628e5599f9c390426c81 Mon Sep 17 00:00:00 2001 From: syuilo Date: Mon, 18 Jun 2018 14:28:43 +0900 Subject: yatta --- src/queue/processors/http/process-inbox.ts | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) (limited to 'src/queue/processors/http/process-inbox.ts') diff --git a/src/queue/processors/http/process-inbox.ts b/src/queue/processors/http/process-inbox.ts index dfafe64a78..0da442aefb 100644 --- a/src/queue/processors/http/process-inbox.ts +++ b/src/queue/processors/http/process-inbox.ts @@ -10,7 +10,7 @@ import { resolvePerson } from '../../../remote/activitypub/models/person'; const log = debug('misskey:queue:inbox'); // ユーザーのinboxにアクティビティが届いた時の処理 -export default async (job: kue.Job, done): Promise => { +export default async (job: kue.Job, done: any): Promise => { const signature = job.data.signature; const activity = job.data.activity; @@ -22,7 +22,7 @@ export default async (job: kue.Job, done): Promise => { //#endregion const keyIdLower = signature.keyId.toLowerCase(); - let user; + let user: IRemoteUser; if (keyIdLower.startsWith('acct:')) { const { username, host } = parseAcct(keyIdLower.slice('acct:'.length)); @@ -36,7 +36,7 @@ export default async (job: kue.Job, done): Promise => { // アクティビティを送信してきたユーザーがまだMisskeyサーバーに登録されていなかったら登録する if (user === null) { - user = await resolvePerson(activity.actor); + user = await resolvePerson(activity.actor) as IRemoteUser; } } else { user = await User.findOne({ @@ -46,7 +46,7 @@ export default async (job: kue.Job, done): Promise => { // アクティビティを送信してきたユーザーがまだMisskeyサーバーに登録されていなかったら登録する if (user === null) { - user = await resolvePerson(signature.keyId); + user = await resolvePerson(signature.keyId) as IRemoteUser; } } -- cgit v1.2.3-freya