From 5db5bbd1cd25f83640d4dd01de14e7774d9370db Mon Sep 17 00:00:00 2001 From: syuilo Date: Tue, 5 Feb 2019 19:50:14 +0900 Subject: 自分の投稿情報をエクスポートできるように (#4144) MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit * wip * 正しいJSONを生成するように * データを整形 --- src/queue/processors/http/deliver.ts | 2 +- src/queue/processors/http/index.ts | 19 ------------------- 2 files changed, 1 insertion(+), 20 deletions(-) delete mode 100644 src/queue/processors/http/index.ts (limited to 'src/queue/processors/http') diff --git a/src/queue/processors/http/deliver.ts b/src/queue/processors/http/deliver.ts index d8d90a2773..d1dad55cd7 100644 --- a/src/queue/processors/http/deliver.ts +++ b/src/queue/processors/http/deliver.ts @@ -1,7 +1,7 @@ import * as bq from 'bee-queue'; import request from '../../../remote/activitypub/request'; -import { queueLogger } from '../..'; +import { queueLogger } from '../../logger'; export default async (job: bq.Job, done: any): Promise => { try { diff --git a/src/queue/processors/http/index.ts b/src/queue/processors/http/index.ts deleted file mode 100644 index 74ed723bd3..0000000000 --- a/src/queue/processors/http/index.ts +++ /dev/null @@ -1,19 +0,0 @@ -import deliver from './deliver'; -import processInbox from './process-inbox'; -import { queueLogger } from '../..'; - -const handlers: any = { - deliver, - processInbox, -}; - -export default (job: any, done: any) => { - const handler = handlers[job.data.type]; - - if (handler) { - handler(job, done); - } else { - queueLogger.error(`Unknown job: ${job.data.type}`); - done(); - } -}; -- cgit v1.2.3-freya