graphite/Sharkey
1
0
Fork 0
mirror of https://git.joinsharkey.org/Sharkey/Sharkey.git synced 2024-12-24 15:43:18 +02:00
Code Issues Projects Releases Packages Wiki Activity

Log

Browse source
This commit is contained in:
syuilo 2018-04-06 22:40:06 +09:00
parent 2b02655a3f
commit 3cf6eab119
1 changed files with 10 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
src/queue/processors/http/process-inbox.ts
View file

@ -1,4 +1,5 @@
import * as kue from 'kue'; import * as kue from 'kue';
import * as debug from 'debug';
import { verifySignature } from 'http-signature'; import { verifySignature } from 'http-signature';
import parseAcct from '../../../acct/parse'; import parseAcct from '../../../acct/parse';
@ -6,11 +7,20 @@ import User, { IRemoteUser } from '../../../models/user';
import act from '../../../remote/activitypub/act'; import act from '../../../remote/activitypub/act';
import resolvePerson from '../../../remote/activitypub/resolve-person'; import resolvePerson from '../../../remote/activitypub/resolve-person';
const log = debug('misskey:queue:inbox');
// ユーザーのinboxにアクティビティが届いた時の処理 // ユーザーのinboxにアクティビティが届いた時の処理
export default async (job: kue.Job, done): Promise<void> => { export default async (job: kue.Job, done): Promise<void> => {
const signature = job.data.signature; const signature = job.data.signature;
const activity = job.data.activity; 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(); const keyIdLower = signature.keyId.toLowerCase();
let user; let user;