summaryrefslogtreecommitdiff
path: root/src/queue
diff options
context:
space:
mode:
authorsyuilo <syuilotan@yahoo.co.jp>2019-04-18 00:57:06 +0900
committersyuilo <syuilotan@yahoo.co.jp>2019-04-18 00:57:06 +0900
commit9b05b6ef285b2205ae8ab6b6c4c29f24a3a196ee (patch)
tree0e3ebb90fd4c4709adedac2aadd32fb3c6313617 /src/queue
parentRemove unused imports (diff)
downloadsharkey-9b05b6ef285b2205ae8ab6b6c4c29f24a3a196ee.tar.gz
sharkey-9b05b6ef285b2205ae8ab6b6c4c29f24a3a196ee.tar.bz2
sharkey-9b05b6ef285b2205ae8ab6b6c4c29f24a3a196ee.zip
Improve readability
Diffstat (limited to 'src/queue')
-rw-r--r--src/queue/processors/inbox.ts60
1 files changed, 30 insertions, 30 deletions
diff --git a/src/queue/processors/inbox.ts b/src/queue/processors/inbox.ts
index 08101f11ec..e657859507 100644
--- a/src/queue/processors/inbox.ts
+++ b/src/queue/processors/inbox.ts
@@ -36,41 +36,41 @@ export default async (job: Bull.Job): Promise<void> => {
if (keyIdLower.startsWith('acct:')) {
logger.warn(`Old keyId is no longer supported. ${keyIdLower}`);
return;
- } else {
- // アクティビティ内のホストの検証
- const host = toPuny(new URL(signature.keyId).hostname);
- try {
- ValidateActivity(activity, host);
- } catch (e) {
- logger.warn(e.message);
- return;
- }
+ }
- // ブロックしてたら中断
- // TODO: いちいちデータベースにアクセスするのはコスト高そうなのでどっかにキャッシュしておく
- const meta = await fetchMeta();
- if (meta.blockedHosts.includes(host)) {
- logger.info(`Blocked request: ${host}`);
- return;
- }
+ // アクティビティ内のホストの検証
+ const host = toPuny(new URL(signature.keyId).hostname);
+ try {
+ ValidateActivity(activity, host);
+ } catch (e) {
+ logger.warn(e.message);
+ return;
+ }
- const _key = await UserPublickeys.findOne({
- keyId: signature.keyId
- });
+ // ブロックしてたら中断
+ // TODO: いちいちデータベースにアクセスするのはコスト高そうなのでどっかにキャッシュしておく
+ const meta = await fetchMeta();
+ if (meta.blockedHosts.includes(host)) {
+ logger.info(`Blocked request: ${host}`);
+ return;
+ }
- if (_key) {
- // 登録済みユーザー
- user = await Users.findOne(_key.userId) as IRemoteUser;
- key = _key;
- } else {
- // 未登録ユーザーの場合はリモート解決
- user = await resolvePerson(activity.actor) as IRemoteUser;
- if (user == null) {
- throw new Error('failed to resolve user');
- }
+ const _key = await UserPublickeys.findOne({
+ keyId: signature.keyId
+ });
- key = await UserPublickeys.findOne(user.id).then(ensure);
+ if (_key) {
+ // 登録済みユーザー
+ user = await Users.findOne(_key.userId) as IRemoteUser;
+ key = _key;
+ } else {
+ // 未登録ユーザーの場合はリモート解決
+ user = await resolvePerson(activity.actor) as IRemoteUser;
+ if (user == null) {
+ throw new Error('failed to resolve user');
}
+
+ key = await UserPublickeys.findOne(user.id).then(ensure);
}
// Update Person activityの場合は、ここで署名検証/更新処理まで実施して終了