Resolve #4444

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);
+}