src/queue/processors/index.ts


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

import deliver from './http/deliver';
import processInbox from './http/process-inbox';
import { exportNotes } from './export-notes';
import { queueLogger } from '../logger';

const handlers: any = {
	deliver,
	processInbox,
	exportNotes,
};

export default (job: any, done: any) => {
	const handler = handlers[job.data.type];

	if (handler) {
		handler(job, done);
	} else {
		queueLogger.error(`Unknown job: ${job.data.type}`);
		done();
	}
};