17 lines
391 B
JavaScript
17 lines
391 B
JavaScript
const { processEvent } = require("./utils")
|
|
const { queue } = require("./bullboard")
|
|
|
|
/**
|
|
* This module is built purely to kick off the worker farm and manage the inputs/outputs
|
|
*/
|
|
exports.init = function () {
|
|
// this promise will not complete
|
|
return queue.process(async job => {
|
|
await processEvent(job)
|
|
})
|
|
}
|
|
|
|
exports.getQueues = () => {
|
|
return [queue]
|
|
}
|
|
exports.queue = queue
|