summaryrefslogtreecommitdiff
path: root/src/queue/processors/db/index.ts
diff options
context:
space:
mode:
authorAkihiko Odaki <nekomanma@pixiv.co.jp>2018-04-04 22:45:55 +0900
committerAkihiko Odaki <nekomanma@pixiv.co.jp>2018-04-04 22:45:55 +0900
commitd7c13b975f55c85b695b72a3ded3d5de97227414 (patch)
treee197f64e6b977c1f8199b3b2a93815a5529e704d /src/queue/processors/db/index.ts
parentMake HTTP request first in unfollow job (diff)
downloadsharkey-d7c13b975f55c85b695b72a3ded3d5de97227414.tar.gz
sharkey-d7c13b975f55c85b695b72a3ded3d5de97227414.tar.bz2
sharkey-d7c13b975f55c85b695b72a3ded3d5de97227414.zip
Retry HTTP requests
Diffstat (limited to 'src/queue/processors/db/index.ts')
-rw-r--r--src/queue/processors/db/index.ts7
1 files changed, 7 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..75838c099b
--- /dev/null
+++ b/src/queue/processors/db/index.ts
@@ -0,0 +1,7 @@
+import deletePostDependents from './delete-post-dependents';
+
+const handlers = {
+ deletePostDependents
+};
+
+export default (job, done) => handlers[job.data.type](job).then(() => done(), done);