From d283ec69f7282440bb5f9f44a69ac7eb6ab3459e Mon Sep 17 00:00:00 2001
From: syuilo <syuilotan@yahoo.co.jp>
Date: Thu, 7 Mar 2019 23:27:38 +0900
Subject: Refactor

---
 src/queue/processors/db/index.ts | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

(limited to 'src/queue/processors')

diff --git a/src/queue/processors/db/index.ts b/src/queue/processors/db/index.ts
index 91d7f06a4b..31a176cdae 100644
--- a/src/queue/processors/db/index.ts
+++ b/src/queue/processors/db/index.ts
@@ -15,6 +15,8 @@ const jobs = {
 	exportBlocking,
 } as any;
 
-export default function(job: Bull.Job, done: any) {
-	jobs[job.data.type](job, done);
+export default function(dbQueue: Bull.Queue) {
+	for (const [k, v] of Object.entries(jobs)) {
+		dbQueue.process(k, v as any);
+	}
 }
-- 
cgit v1.2.3-freya