summaryrefslogtreecommitdiff
path: root/packages/backend/src/queue/DbQueueProcessorsService.ts
diff options
context:
space:
mode:
authorsyuilo <Syuilotan@yahoo.co.jp>2022-09-24 14:45:44 +0900
committersyuilo <Syuilotan@yahoo.co.jp>2022-09-24 14:45:44 +0900
commitdabe5bf7e97adaf9ad6af1854bbacf2c3e7025e8 (patch)
tree404a262838da93e74e3070c12caa5301554a17bf /packages/backend/src/queue/DbQueueProcessorsService.ts
parentfix type (diff)
downloadsharkey-dabe5bf7e97adaf9ad6af1854bbacf2c3e7025e8.tar.gz
sharkey-dabe5bf7e97adaf9ad6af1854bbacf2c3e7025e8.tar.bz2
sharkey-dabe5bf7e97adaf9ad6af1854bbacf2c3e7025e8.zip
fix type errors
Diffstat (limited to 'packages/backend/src/queue/DbQueueProcessorsService.ts')
-rw-r--r--packages/backend/src/queue/DbQueueProcessorsService.ts34
1 files changed, 14 insertions, 20 deletions
diff --git a/packages/backend/src/queue/DbQueueProcessorsService.ts b/packages/backend/src/queue/DbQueueProcessorsService.ts
index f79100e6ce..58384c4d1b 100644
--- a/packages/backend/src/queue/DbQueueProcessorsService.ts
+++ b/packages/backend/src/queue/DbQueueProcessorsService.ts
@@ -39,25 +39,19 @@ export class DbQueueProcessorsService {
) {
}
- public start(dbQueue: Bull.Queue<DbJobData>) {
- const jobs = {
- deleteDriveFiles: (job, done) => this.deleteDriveFilesProcessorService.process(job, done),
- exportCustomEmojis: (job, done) => this.exportCustomEmojisProcessorService.process(job, done),
- exportNotes: (job, done) => this.exportNotesProcessorService.process(job, done),
- exportFollowing: (job, done) => this.exportFollowingProcessorService.process(job, done),
- exportMuting: (job, done) => this.exportMutingProcessorService.process(job, done),
- exportBlocking: (job, done) => this.exportBlockingProcessorService.process(job, done),
- exportUserLists: (job, done) => this.exportUserListsProcessorService.process(job, done),
- importFollowing: (job, done) => this.importFollowingProcessorService.process(job, done),
- importMuting: (job, done) => this.importMutingProcessorService.process(job, done),
- importBlocking: (job, done) => this.importBlockingProcessorService.process(job, done),
- importUserLists: (job, done) => this.importUserListsProcessorService.process(job, done),
- importCustomEmojis: (job, done) => this.importCustomEmojisProcessorService.process(job, done),
- deleteAccount: (job) => this.deleteAccountProcessorService.process(job),
- } as Record<string, Bull.ProcessCallbackFunction<DbJobData | Bull.ProcessPromiseFunction<DbJobData>>>;
-
- for (const [k, v] of Object.entries(jobs)) {
- dbQueue.process(k, v);
- }
+ public start(q: Bull.Queue): void {
+ q.process('deleteDriveFiles', (job, done) => this.deleteDriveFilesProcessorService.process(job, done));
+ q.process('exportCustomEmojis', (job, done) => this.exportCustomEmojisProcessorService.process(job, done));
+ q.process('exportNotes', (job, done) => this.exportNotesProcessorService.process(job, done));
+ q.process('exportFollowing', (job, done) => this.exportFollowingProcessorService.process(job, done));
+ q.process('exportMuting', (job, done) => this.exportMutingProcessorService.process(job, done));
+ q.process('exportBlocking', (job, done) => this.exportBlockingProcessorService.process(job, done));
+ q.process('exportUserLists', (job, done) => this.exportUserListsProcessorService.process(job, done));
+ q.process('importFollowing', (job, done) => this.importFollowingProcessorService.process(job, done));
+ q.process('importMuting', (job, done) => this.importMutingProcessorService.process(job, done));
+ q.process('importBlocking', (job, done) => this.importBlockingProcessorService.process(job, done));
+ q.process('importUserLists', (job, done) => this.importUserListsProcessorService.process(job, done));
+ q.process('importCustomEmojis', (job, done) => this.importCustomEmojisProcessorService.process(job, done));
+ q.process('deleteAccount', (job) => this.deleteAccountProcessorService.process(job));
}
}