worker.js

'use strict';

/**
 * @name worker
 * @description job worker process for open311 API
 *
 * Alert!: Please ensure your have installed Redis Server
 *
 * Alert!: Run worker in the separate process from main process
 *
 * Recommendation!: It also adviced to run each worker per process or per machine
 * with any number of concurrency(10 is sufficient max worker so far)
 */
const { getNumber } = require('@lykmapipo/env');
const { worker, listen } = require('@lykmapipo/postman');
const mkdir = require('mkdir-p');


/* constants */
const KUE_HTTP_PORT = getNumber('KUE_HTTP_PORT');


//build logs directory if does not exists
const logPath = './logs';
mkdir.sync(logPath);


/* setup models */
require('./app/initializers/mongoose');


/* run work */
worker.start();


/* open web interface to monitor jobs */
if (KUE_HTTP_PORT) {
  listen();
}