src/queue/processors/http/index.ts


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17

import deliverPost from './deliver-post';
import follow from './follow';
import performActivityPub from './perform-activitypub';
import processInbox from './process-inbox';
import reportGitHubFailure from './report-github-failure';
import unfollow from './unfollow';

const handlers = {
  deliverPost,
  follow,
  performActivityPub,
  processInbox,
  reportGitHubFailure,
  unfollow
};

export default (job, done) => handlers[job.data.type](job).then(() => done(), done);