diff options
| author | syuilo <Syuilotan@yahoo.co.jp> | 2019-02-05 19:50:14 +0900 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2019-02-05 19:50:14 +0900 |
| commit | 5db5bbd1cd25f83640d4dd01de14e7774d9370db (patch) | |
| tree | 701c27744ca0e4d6e16d5f2fb568481c1bf4baf0 /src/queue/processors/http | |
| parent | Add ffmpeg package for the runner container (#4145) (diff) | |
| download | sharkey-5db5bbd1cd25f83640d4dd01de14e7774d9370db.tar.gz sharkey-5db5bbd1cd25f83640d4dd01de14e7774d9370db.tar.bz2 sharkey-5db5bbd1cd25f83640d4dd01de14e7774d9370db.zip | |
自分の投稿情報をエクスポートできるように (#4144)
* wip
* 正しいJSONを生成するように
* データを整形
Diffstat (limited to 'src/queue/processors/http')
| -rw-r--r-- | src/queue/processors/http/deliver.ts | 2 | ||||
| -rw-r--r-- | src/queue/processors/http/index.ts | 19 |
2 files changed, 1 insertions, 20 deletions
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<void> => { 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(); - } -}; |