diff options
| author | syuilo <Syuilotan@yahoo.co.jp> | 2022-09-24 14:45:44 +0900 |
|---|---|---|
| committer | syuilo <Syuilotan@yahoo.co.jp> | 2022-09-24 14:45:44 +0900 |
| commit | dabe5bf7e97adaf9ad6af1854bbacf2c3e7025e8 (patch) | |
| tree | 404a262838da93e74e3070c12caa5301554a17bf /packages/backend/src/queue/DbQueueProcessorsService.ts | |
| parent | fix type (diff) | |
| download | sharkey-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.ts | 34 |
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)); } } |