@knetik/micro-queue/dist/job_base.js

const Queue = require("bull");
const _ = require("lodash");

/**
 * Base class for all Jobs
 *
 * Generate a new job
 *
 * ```
 * $ yarn run micro-queue generate {job_name}
 * ```
 *
 * Creates a job inside the /app/jobs/{job_name}.job.js
 *
 * @name JobBase
*/
class JobBase {
  /**
   * Job concurrency limit
   */
  constructor(App) {
    this.app = App;
  }

  /**
   * The perform function is the target for all job processing. It should be
   * re-implemented in the JobBase subclass and will be called each time a job
   * instance is processed
   * */


  /**
   * Job options defaults
   */
  static perform(App, params, progress) {
    throw new Error('Must be implemented in a subclass');
  }

  /**
   * Called to queue a job instance
   *
   * @param params data that will be passed into the perform function
   * @param options Bull Queue JobOpts: https://github.com/OptimalBits/bull/blob/master/REFERENCE.md#queueadd
   */
  perform_later(params, options) {
    const { app_id, token, request_id } = this.app;
    const data = { app: { app_id, token, request_id }, params };

    const { queue, name, job_default_options } = this.constructor;
    const job_options = _.merge(job_default_options, options);

    return queue.add(name, data, job_options);
  }
}

module.exports = JobBase;
module.exports.concurrency = 5;
module.exports.job_default_options = {};