priorityworker.js

/**
 * Created by mox on 21/03/16.
 *
 * Fatus worker with priority (on other workers)
 *
 */


'use strict';
const MODULE_NAME = 'FatusPriorityWorker';
const FatusWorker = require('./worker');
const moment = require('moment');

/** the worker for the fatus */
class FatusPriorityWorker extends FatusWorker {

    /**
     * get a new job from the queue NOT FAILED
     * @param th
     * @param wfcallback
     * @override
     */
    fetchNewJob(th, wfcallback) {
        let NOW = moment();
        th.fetchIteration = th.fetchIteration +1;
        if(th.fetchIteration<(th.STACK_PROTECTION_THRSD*2)) {
            th.fatus.getQueueTop(function onGet(err, msg) {
                if (!err && msg && msg[0] && msg[0].messageText) {
                    let reservedCondition = th.isMsgReserved(msg,NOW,th);
                    let notfailedCondition = msg[0].messageText.fail;
                    if (reservedCondition || notfailedCondition){
                        return th.fetchNewJob(th, wfcallback);
                    }else{
                        wfcallback(err, msg);
                    }
                }else{
                    wfcallback(err, null);
                }
            });
        }else{
            wfcallback(null,null);
        }
    }
}


/** Exports */
module.exports = FatusPriorityWorker;