oops
This commit is contained in:
parent
2259747072
commit
c77013ab3e
|
@ -1,17 +1,20 @@
|
||||||
import deliverPost from './deliver-post';
|
import deliver from './deliver';
|
||||||
import follow from './follow';
|
|
||||||
import performActivityPub from './perform-activitypub';
|
|
||||||
import processInbox from './process-inbox';
|
import processInbox from './process-inbox';
|
||||||
import reportGitHubFailure from './report-github-failure';
|
import reportGitHubFailure from './report-github-failure';
|
||||||
import unfollow from './unfollow';
|
|
||||||
|
|
||||||
const handlers = {
|
const handlers = {
|
||||||
deliverPost,
|
deliver,
|
||||||
follow,
|
processInbox,
|
||||||
performActivityPub,
|
reportGitHubFailure
|
||||||
processInbox,
|
|
||||||
reportGitHubFailure,
|
|
||||||
unfollow
|
|
||||||
};
|
};
|
||||||
|
|
||||||
export default (job, done) => handlers[job.data.type](job, done);
|
export default (job, done) => {
|
||||||
|
const handler = handlers[job.data.type];
|
||||||
|
|
||||||
|
if (handler) {
|
||||||
|
handler(job, done);
|
||||||
|
} else {
|
||||||
|
console.error(`Unknown job: ${job.data.type}`);
|
||||||
|
done();
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
Loading…
Reference in a new issue