Sharkey/src/queue/processors/index.ts

28 lines
643 B
TypeScript
Raw Normal View History

import deliver from './http/deliver';
import processInbox from './http/process-inbox';
import { exportNotes } from './export-notes';
2019-02-06 13:56:48 +02:00
import { exportFollowing } from './export-following';
import { exportMute } from './export-mute';
import { exportBlocking } from './export-blocking';
import { queueLogger } from '../logger';
2018-03-31 13:55:00 +03:00
2018-06-18 08:28:43 +03:00
const handlers: any = {
2018-04-07 09:45:03 +03:00
deliver,
processInbox,
exportNotes,
2019-02-06 13:56:48 +02:00
exportFollowing,
exportMute,
exportBlocking,
2018-03-31 13:55:00 +03:00
};
2018-06-18 08:28:43 +03:00
export default (job: any, done: any) => {
2018-04-07 09:45:03 +03:00
const handler = handlers[job.data.type];
if (handler) {
handler(job, done);
} else {
queueLogger.error(`Unknown job: ${job.data.type}`);
2018-04-07 09:45:03 +03:00
done();
}
};