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/index.ts | 21 +++++++++++++++++++++ 1 file changed, 21 insertions(+) create mode 100644 src/queue/processors/index.ts (limited to 'src/queue/processors/index.ts') diff --git a/src/queue/processors/index.ts b/src/queue/processors/index.ts new file mode 100644 index 0000000000..3f08fe29fb --- /dev/null +++ b/src/queue/processors/index.ts @@ -0,0 +1,21 @@ +import deliver from './http/deliver'; +import processInbox from './http/process-inbox'; +import { exportNotes } from './export-notes'; +import { queueLogger } from '../logger'; + +const handlers: any = { + deliver, + processInbox, + exportNotes, +}; + +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