Interface TaskMiddleware

An example middleware

const middleware = {
  name: 'timer',
  global: true,
  priority: 90,
  preProcessor: async function () {
    const worker = this.worker
    worker.startTime = process.hrtime()
  },
  postProcessor: async function () {
    const worker = this.worker
    const elapsed = process.hrtime(worker.startTime)
    const seconds = elapsed[0]
    const millis = elapsed[1] / 1000000
    log(worker.job.class + ' done in ' + seconds + ' s and ' + millis + ' ms.', 'info')
  },
  preEnqueue: async function () {
    return true // returning `false` will prevent the task from enqueueing
  },
  postEnqueue: async function () {
    log("Task successfully enqueued!")
  }
}
api.tasks.addMiddleware(middleware)
Copy