cancel.js

const moment = require('moment')
const logger = require('@pubsweet/logger')
const { Team, Collection } = require('pubsweet-component-helper-service')
const {
  Team: TeamModel,
  User: UserModel,
  Fragment: FragmentModel,
  Collection: CollectionModel,
} = require('pubsweet-server')

const { jobs: { connectToJobQueue } } = require('pubsweet-server/src')

const cancelJob = async ({ name }) => {
  const queue = `reviewer-removal`

  const jobQueue = await connectToJobQueue()

  // Subscribe to the job queue with an async handler
  await jobQueue.subscribe(queue, jobHandler)

  await jobQueue.onComplete(queue, job => {
    console.log(job.data.response.value)
    logger.info(job.data.response.value)
  })
}