summaryrefslogtreecommitdiff
path: root/src/queue
diff options
context:
space:
mode:
authorsyuilo <syuilotan@yahoo.co.jp>2018-04-06 22:40:06 +0900
committersyuilo <syuilotan@yahoo.co.jp>2018-04-06 22:40:06 +0900
commit3cf6eab11945e5b2577ef67117a51a210529e456 (patch)
tree379f358db2d67af78368405427510e34db5fc837 /src/queue
parentFix bug (diff)
downloadsharkey-3cf6eab11945e5b2577ef67117a51a210529e456.tar.gz
sharkey-3cf6eab11945e5b2577ef67117a51a210529e456.tar.bz2
sharkey-3cf6eab11945e5b2577ef67117a51a210529e456.zip
Log
Diffstat (limited to 'src/queue')
-rw-r--r--src/queue/processors/http/process-inbox.ts10
1 files changed, 10 insertions, 0 deletions
diff --git a/src/queue/processors/http/process-inbox.ts b/src/queue/processors/http/process-inbox.ts
index 4666e7f373..eb4b62d37f 100644
--- a/src/queue/processors/http/process-inbox.ts
+++ b/src/queue/processors/http/process-inbox.ts
@@ -1,4 +1,5 @@
import * as kue from 'kue';
+import * as debug from 'debug';
import { verifySignature } from 'http-signature';
import parseAcct from '../../../acct/parse';
@@ -6,11 +7,20 @@ import User, { IRemoteUser } from '../../../models/user';
import act from '../../../remote/activitypub/act';
import resolvePerson from '../../../remote/activitypub/resolve-person';
+const log = debug('misskey:queue:inbox');
+
// ユーザーのinboxにアクティビティが届いた時の処理
export default async (job: kue.Job, done): Promise<void> => {
const signature = job.data.signature;
const activity = job.data.activity;
+ //#region Log
+ const info = Object.assign({}, activity);
+ delete info['@context'];
+ delete info['signature'];
+ log(info);
+ //#endregion
+
const keyIdLower = signature.keyId.toLowerCase();
let user;