summaryrefslogtreecommitdiff
path: root/src/queue/processors/http
diff options
context:
space:
mode:
authorsyuilo <Syuilotan@yahoo.co.jp>2019-02-05 19:50:14 +0900
committerGitHub <noreply@github.com>2019-02-05 19:50:14 +0900
commit5db5bbd1cd25f83640d4dd01de14e7774d9370db (patch)
tree701c27744ca0e4d6e16d5f2fb568481c1bf4baf0 /src/queue/processors/http
parentAdd ffmpeg package for the runner container (#4145) (diff)
downloadsharkey-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.ts2
-rw-r--r--src/queue/processors/http/index.ts19
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();
- }
-};