Built motion from commit (unavailable).|2.5.4
[motion2.git] / server / services / routing / server / applications / strategy / rrmemory.js
index df1781d..dd5df7b 100644 (file)
@@ -15,4 +15,4 @@
 // * treaties. The SOFTWARE PRODUCT is licensed, not sold.                        *
 // *                                                                       *
 // *************************************************************************
-var _0x8998=['lodash','./util','notificationId','squeue','realtime','routing','intervals','push','handleRun','bind','handleTimeout','module','timeout','drained','prototype','handleDrained','handleCheckReject','agents','agentId','channel','info','[%s][QUEUE]\x20available\x20again\x20%s','done','mapAgentsId','[%s][QUEUE]\x20try\x20with\x20%s','isAgentAvailable','busyQueue','showNotification','queue','RINGING','[%s][QUEUE]\x20agent\x20skipped,\x20not\x20available\x20id\x20%s','[%s][QUEUE]\x20timeout\x20with\x20%s','isNil','[%s][QUEUE]\x20agent\x20skipped,\x20unknown\x20id\x20%s','hideNotification','writeLog','TIMEOUT','busy','exports'];(function(_0x58bb99,_0x5cd41a){var _0x27f0b9=function(_0x1b8268){while(--_0x1b8268){_0x58bb99['push'](_0x58bb99['shift']());}};_0x27f0b9(++_0x5cd41a);}(_0x8998,0x138));var _0x8899=function(_0x18aed1,_0x5f5598){_0x18aed1=_0x18aed1-0x0;var _0x44bace=_0x8998[_0x18aed1];return _0x44bace;};'use strict';var rr=require('rr');var _=require(_0x8899('0x0'));var uuid=require('uuid');var util=require(_0x8899('0x1'));var logger=require('../../../../../config/logger')('routing');var RRMemory=function(_0x126782,_0x554ca8,_0x4e0f41,_0xfcdd8c){this[_0x8899('0x2')]=uuid['v4']();this[_0x8899('0x3')]=_0x126782;this['queue']=_0x554ca8;this[_0x8899('0x4')]=_0x4e0f41;this[_0x8899('0x5')]=_0xfcdd8c;this[_0x8899('0x6')]={};this[_0x8899('0x3')][_0x8899('0x7')](this[_0x8899('0x8')][_0x8899('0x9')](this),this[_0x8899('0xa')][_0x8899('0x9')](this),this[_0x8899('0xb')]);this[_0x8899('0x3')]['on'](_0x8899('0xc'),this[_0x8899('0xa')][_0x8899('0x9')](this));this[_0x8899('0x3')]['on'](_0x8899('0xd'),this['handleDrained'][_0x8899('0x9')](this));};RRMemory[_0x8899('0xe')][_0x8899('0x7')]=function(){this['squeue'][_0x8899('0x7')](this['handleRun'][_0x8899('0x9')](this),this[_0x8899('0xa')][_0x8899('0x9')](this));};RRMemory[_0x8899('0xe')][_0x8899('0xf')]=function(_0x1c3c4d){this[_0x8899('0xa')](!![]);};RRMemory[_0x8899('0xe')][_0x8899('0x10')]=function(_0x1288e9){if(util['isAgentAvailable'](this[_0x8899('0x3')]['id'],this[_0x8899('0x4')][_0x8899('0x11')][this[_0x8899('0x12')]],this[_0x8899('0x3')][_0x8899('0x13')],!![])){logger[_0x8899('0x14')](_0x8899('0x15'),this[_0x8899('0x3')]['id'],this[_0x8899('0x12')]);clearInterval(this[_0x8899('0x6')][this[_0x8899('0x12')]]);_0x1288e9[_0x8899('0x16')]();setTimeout(this[_0x8899('0x7')][_0x8899('0x9')](this),0x3e8);}};RRMemory['prototype']['handleRun']=function(_0x26648a){this[_0x8899('0x12')]=rr(this['queue'][_0x8899('0x17')]);logger[_0x8899('0x14')](_0x8899('0x18'),this[_0x8899('0x3')]['id'],this[_0x8899('0x12')]);if(_['isNil'](this['realtime'][_0x8899('0x11')][this[_0x8899('0x12')]])){logger[_0x8899('0x14')]('[%s][QUEUE]\x20agent\x20skipped,\x20unknown\x20id\x20%s',this[_0x8899('0x3')]['id'],this['agentId']);_0x26648a[_0x8899('0x16')]();setTimeout(this[_0x8899('0x7')]['bind'](this),0x3e8);}else{if(util[_0x8899('0x19')](this[_0x8899('0x3')]['id'],this[_0x8899('0x4')][_0x8899('0x11')][this['agentId']],this[_0x8899('0x3')][_0x8899('0x13')],!![])){this['realtime'][_0x8899('0x11')][this[_0x8899('0x12')]]['busy']=!![];this[_0x8899('0x4')][_0x8899('0x11')][this[_0x8899('0x12')]][_0x8899('0x1a')]=this['queue']['name'];util[_0x8899('0x1b')](this[_0x8899('0x2')],this['squeue']['id'],this['realtime'][_0x8899('0x11')][this[_0x8899('0x12')]],this[_0x8899('0x1c')],this[_0x8899('0x5')]);util['writeLog'](this[_0x8899('0x3')]['id'],this[_0x8899('0x4')][_0x8899('0x11')][this[_0x8899('0x12')]],_0x8899('0x1d'));this[_0x8899('0x6')][this[_0x8899('0x12')]]=setInterval(this['handleCheckReject'][_0x8899('0x9')](this,_0x26648a),0x3e8);}else{logger[_0x8899('0x14')](_0x8899('0x1e'),this[_0x8899('0x3')]['id'],this[_0x8899('0x12')]);_0x26648a[_0x8899('0x16')]();setTimeout(this[_0x8899('0x7')][_0x8899('0x9')](this),0x3e8);}}};RRMemory[_0x8899('0xe')][_0x8899('0xa')]=function(_0x166a3c){logger['info'](_0x8899('0x1f'),this[_0x8899('0x3')]['id'],this[_0x8899('0x12')]);if(_[_0x8899('0x20')](this[_0x8899('0x4')][_0x8899('0x11')][this['agentId']])){logger[_0x8899('0x14')](_0x8899('0x21'),this['squeue']['id'],this[_0x8899('0x12')]);}else{clearInterval(this[_0x8899('0x6')][this['agentId']]);util[_0x8899('0x22')](this['notificationId'],this[_0x8899('0x3')]['id'],this[_0x8899('0x4')]['agents'][this['agentId']],this[_0x8899('0x1c')],this[_0x8899('0x5')]);util[_0x8899('0x23')](this[_0x8899('0x3')]['id'],this['realtime'][_0x8899('0x11')][this[_0x8899('0x12')]],_0x8899('0x24'));this[_0x8899('0x4')][_0x8899('0x11')][this['agentId']][_0x8899('0x25')]=![];this[_0x8899('0x4')][_0x8899('0x11')][this[_0x8899('0x12')]][_0x8899('0x1a')]=undefined;}if(!_0x166a3c){setTimeout(this[_0x8899('0x7')][_0x8899('0x9')](this),0x3e8);}};function rrmemory(_0x1f0180,_0xdf1a77,_0x52c624,_0x2a3fca){return new RRMemory(_0x1f0180,_0xdf1a77,_0x52c624,_0x2a3fca);}module[_0x8899('0x26')]=rrmemory;
\ No newline at end of file
+var _0x5769=['handleRun','bind','timeout','handleTimeout','drained','prototype','handleDrained','handleCheckReject','isAgentAvailable','agents','agentId','channel','info','[%s][QUEUE]\x20available\x20again\x20%s','done','mapAgentsId','[%s][QUEUE]\x20try\x20with\x20%s','isNil','[%s][QUEUE]\x20agent\x20skipped,\x20unknown\x20id\x20%s','busyQueue','writeLog','RINGING','[%s][QUEUE]\x20agent\x20skipped,\x20not\x20available\x20id\x20%s','[%s][QUEUE]\x20timeout\x20with\x20%s','hideNotification','TIMEOUT','busy','exports','uuid','./util','../../../../../config/logger','routing','notificationId','squeue','queue','realtime','intervals','push'];(function(_0x2af23d,_0x2ae292){var _0x15f9f5=function(_0x3c5cf3){while(--_0x3c5cf3){_0x2af23d['push'](_0x2af23d['shift']());}};_0x15f9f5(++_0x2ae292);}(_0x5769,0x1be));var _0x9576=function(_0xe89179,_0x36e096){_0xe89179=_0xe89179-0x0;var _0x4bb0c3=_0x5769[_0xe89179];return _0x4bb0c3;};'use strict';var rr=require('rr');var _=require('lodash');var uuid=require(_0x9576('0x0'));var util=require(_0x9576('0x1'));var logger=require(_0x9576('0x2'))(_0x9576('0x3'));var RRMemory=function(_0x1bacb1,_0x2fafa2,_0x340bbb,_0x264f8f){this[_0x9576('0x4')]=uuid['v4']();this[_0x9576('0x5')]=_0x1bacb1;this[_0x9576('0x6')]=_0x2fafa2;this[_0x9576('0x7')]=_0x340bbb;this['routing']=_0x264f8f;this[_0x9576('0x8')]={};this[_0x9576('0x5')][_0x9576('0x9')](this[_0x9576('0xa')][_0x9576('0xb')](this),this['handleTimeout']['bind'](this),this['module']);this[_0x9576('0x5')]['on'](_0x9576('0xc'),this[_0x9576('0xd')][_0x9576('0xb')](this));this[_0x9576('0x5')]['on'](_0x9576('0xe'),this['handleDrained'][_0x9576('0xb')](this));};RRMemory[_0x9576('0xf')][_0x9576('0x9')]=function(){this[_0x9576('0x5')][_0x9576('0x9')](this[_0x9576('0xa')][_0x9576('0xb')](this),this[_0x9576('0xd')]['bind'](this));};RRMemory[_0x9576('0xf')][_0x9576('0x10')]=function(_0x7f6c6e){this['handleTimeout'](!![]);};RRMemory[_0x9576('0xf')][_0x9576('0x11')]=function(_0x551967){if(util[_0x9576('0x12')](this[_0x9576('0x5')]['id'],this[_0x9576('0x7')][_0x9576('0x13')][this[_0x9576('0x14')]],this[_0x9576('0x5')][_0x9576('0x15')],!![])){logger[_0x9576('0x16')](_0x9576('0x17'),this[_0x9576('0x5')]['id'],this['agentId']);clearInterval(this['intervals'][this[_0x9576('0x14')]]);_0x551967[_0x9576('0x18')]();setTimeout(this['push'][_0x9576('0xb')](this),0x3e8);}};RRMemory[_0x9576('0xf')][_0x9576('0xa')]=function(_0x42a798){this[_0x9576('0x14')]=rr(this[_0x9576('0x6')][_0x9576('0x19')]);logger[_0x9576('0x16')](_0x9576('0x1a'),this[_0x9576('0x5')]['id'],this['agentId']);if(_[_0x9576('0x1b')](this[_0x9576('0x7')][_0x9576('0x13')][this[_0x9576('0x14')]])){logger[_0x9576('0x16')](_0x9576('0x1c'),this[_0x9576('0x5')]['id'],this['agentId']);_0x42a798[_0x9576('0x18')]();setTimeout(this['push'][_0x9576('0xb')](this),0x3e8);}else{if(util[_0x9576('0x12')](this[_0x9576('0x5')]['id'],this['realtime'][_0x9576('0x13')][this[_0x9576('0x14')]],this['squeue'][_0x9576('0x15')],!![])){this[_0x9576('0x7')][_0x9576('0x13')][this[_0x9576('0x14')]]['busy']=!![];this['realtime'][_0x9576('0x13')][this[_0x9576('0x14')]][_0x9576('0x1d')]=this[_0x9576('0x6')]['name'];util['showNotification'](this['notificationId'],this['squeue']['id'],this[_0x9576('0x7')][_0x9576('0x13')][this[_0x9576('0x14')]],this[_0x9576('0x6')],this[_0x9576('0x3')]);util[_0x9576('0x1e')](this['squeue']['id'],this['realtime'][_0x9576('0x13')][this[_0x9576('0x14')]],_0x9576('0x1f'));this[_0x9576('0x8')][this[_0x9576('0x14')]]=setInterval(this[_0x9576('0x11')][_0x9576('0xb')](this,_0x42a798),0x3e8);}else{logger['info'](_0x9576('0x20'),this['squeue']['id'],this[_0x9576('0x14')]);_0x42a798['done']();setTimeout(this[_0x9576('0x9')][_0x9576('0xb')](this),0x3e8);}}};RRMemory[_0x9576('0xf')][_0x9576('0xd')]=function(_0x516a92){logger[_0x9576('0x16')](_0x9576('0x21'),this[_0x9576('0x5')]['id'],this[_0x9576('0x14')]);if(_[_0x9576('0x1b')](this[_0x9576('0x7')][_0x9576('0x13')][this[_0x9576('0x14')]])){logger[_0x9576('0x16')](_0x9576('0x1c'),this[_0x9576('0x5')]['id'],this[_0x9576('0x14')]);}else{clearInterval(this[_0x9576('0x8')][this['agentId']]);util[_0x9576('0x22')](this[_0x9576('0x4')],this[_0x9576('0x5')]['id'],this['realtime'][_0x9576('0x13')][this['agentId']],this[_0x9576('0x6')],this[_0x9576('0x3')]);util['writeLog'](this[_0x9576('0x5')]['id'],this['realtime'][_0x9576('0x13')][this[_0x9576('0x14')]],_0x9576('0x23'));this[_0x9576('0x7')][_0x9576('0x13')][this[_0x9576('0x14')]][_0x9576('0x24')]=![];this[_0x9576('0x7')][_0x9576('0x13')][this['agentId']][_0x9576('0x1d')]=undefined;}if(!_0x516a92){setTimeout(this[_0x9576('0x9')][_0x9576('0xb')](this),0x3e8);}};function rrmemory(_0x3c2a16,_0x37fd8e,_0x15e0bf,_0x27f5be){return new RRMemory(_0x3c2a16,_0x37fd8e,_0x15e0bf,_0x27f5be);}module[_0x9576('0x25')]=rrmemory;
\ No newline at end of file