From dabe5bf7e97adaf9ad6af1854bbacf2c3e7025e8 Mon Sep 17 00:00:00 2001
From: syuilo <Syuilotan@yahoo.co.jp>
Date: Sat, 24 Sep 2022 14:45:44 +0900
Subject: fix type errors

---
 .../backend/src/queue/SystemQueueProcessorsService.ts  | 18 ++++++------------
 1 file changed, 6 insertions(+), 12 deletions(-)

(limited to 'packages/backend/src/queue/SystemQueueProcessorsService.ts')

diff --git a/packages/backend/src/queue/SystemQueueProcessorsService.ts b/packages/backend/src/queue/SystemQueueProcessorsService.ts
index ccb040fae5..a8af92b9ba 100644
--- a/packages/backend/src/queue/SystemQueueProcessorsService.ts
+++ b/packages/backend/src/queue/SystemQueueProcessorsService.ts
@@ -22,17 +22,11 @@ export class SystemQueueProcessorsService {
 	) {
 	}
 
-	public start(dbQueue: Bull.Queue<Record<string, unknown>>) {
-		const jobs = {
-			tickCharts: (job, done) => this.tickChartsProcessorService.process(job, done),
-			resyncCharts: (job, done) => this.resyncChartsProcessorService.process(job, done),
-			cleanCharts: (job, done) => this.cleanChartsProcessorService.process(job, done),
-			checkExpiredMutings: (job, done) => this.checkExpiredMutingsProcessorService.process(job, done),
-			clean: (job, done) => this.cleanProcessorService.process(job, done),
-		} as Record<string, Bull.ProcessCallbackFunction<Record<string, unknown>> | Bull.ProcessPromiseFunction<Record<string, unknown>>>;
-		
-		for (const [k, v] of Object.entries(jobs)) {
-			dbQueue.process(k, v);
-		}
+	public start(q: Bull.Queue): void {
+		q.process('tickCharts', (job, done) => this.tickChartsProcessorService.process(job, done));
+		q.process('resyncCharts', (job, done) => this.resyncChartsProcessorService.process(job, done));
+		q.process('cleanCharts', (job, done) => this.cleanChartsProcessorService.process(job, done));
+		q.process('checkExpiredMutings', (job, done) => this.checkExpiredMutingsProcessorService.process(job, done));
+		q.process('clean', (job, done) => this.cleanProcessorService.process(job, done));
 	}
 }
-- 
cgit v1.2.3-freya