diff options
Diffstat (limited to 'src/queue/processors/db/index.ts')
| -rw-r--r-- | src/queue/processors/db/index.ts | 20 |
1 files changed, 20 insertions, 0 deletions
diff --git a/src/queue/processors/db/index.ts b/src/queue/processors/db/index.ts new file mode 100644 index 0000000000..91d7f06a4b --- /dev/null +++ b/src/queue/processors/db/index.ts @@ -0,0 +1,20 @@ +import * as Bull from 'bull'; +import { deleteNotes } from './delete-notes'; +import { deleteDriveFiles } from './delete-drive-files'; +import { exportNotes } from './export-notes'; +import { exportFollowing } from './export-following'; +import { exportMute } from './export-mute'; +import { exportBlocking } from './export-blocking'; + +const jobs = { + deleteNotes, + deleteDriveFiles, + exportNotes, + exportFollowing, + exportMute, + exportBlocking, +} as any; + +export default function(job: Bull.Job, done: any) { + jobs[job.data.type](job, done); +} |