Built motion from commit (unavailable).|2.5.4
[motion2.git] / server / services / routing / server / applications / strategy / rrmemory.js
index e4c46ef..961ffad 100644 (file)
@@ -15,4 +15,4 @@
 // * treaties. The SOFTWARE PRODUCT is licensed, not sold.                        *
 // *                                                                       *
 // *************************************************************************
-var _0xb05b=['writeLog','RINGING','[%s][QUEUE]\x20agent\x20skipped,\x20not\x20available\x20id\x20%s','[%s][QUEUE]\x20timeout\x20with\x20%s','hideNotification','exports','lodash','./util','../../../../../config/logger','routing','squeue','queue','realtime','push','bind','handleTimeout','timeout','drained','handleRun','prototype','handleDrained','handleCheckReject','isAgentAvailable','agents','channel','info','[%s][QUEUE]\x20available\x20again\x20%s','agentId','intervals','done','mapAgentsId','[%s][QUEUE]\x20try\x20with\x20%s','[%s][QUEUE]\x20agent\x20skipped,\x20unknown\x20id\x20%s','busy','busyQueue','name','showNotification'];(function(_0xe25e2d,_0x418926){var _0x52401d=function(_0x4bbf3f){while(--_0x4bbf3f){_0xe25e2d['push'](_0xe25e2d['shift']());}};_0x52401d(++_0x418926);}(_0xb05b,0x1e7));var _0xbb05=function(_0x53f74c,_0xd71010){_0x53f74c=_0x53f74c-0x0;var _0x467bc0=_0xb05b[_0x53f74c];return _0x467bc0;};'use strict';var rr=require('rr');var _=require(_0xbb05('0x0'));var uuid=require('uuid');var util=require(_0xbb05('0x1'));var logger=require(_0xbb05('0x2'))(_0xbb05('0x3'));var RRMemory=function(_0x386875,_0xdf40bf,_0x5834f9,_0x3004a4){this['notificationId']=uuid['v4']();this[_0xbb05('0x4')]=_0x386875;this[_0xbb05('0x5')]=_0xdf40bf;this[_0xbb05('0x6')]=_0x5834f9;this[_0xbb05('0x3')]=_0x3004a4;this['intervals']={};this['squeue'][_0xbb05('0x7')](this['handleRun'][_0xbb05('0x8')](this),this[_0xbb05('0x9')][_0xbb05('0x8')](this),this['module']);this[_0xbb05('0x4')]['on'](_0xbb05('0xa'),this['handleTimeout'][_0xbb05('0x8')](this));this[_0xbb05('0x4')]['on'](_0xbb05('0xb'),this['handleDrained']['bind'](this));};RRMemory['prototype'][_0xbb05('0x7')]=function(){this[_0xbb05('0x4')]['push'](this[_0xbb05('0xc')][_0xbb05('0x8')](this),this['handleTimeout'][_0xbb05('0x8')](this));};RRMemory[_0xbb05('0xd')][_0xbb05('0xe')]=function(_0x2c4d87){this[_0xbb05('0x9')](!![]);};RRMemory[_0xbb05('0xd')][_0xbb05('0xf')]=function(_0x47bc0d){if(util[_0xbb05('0x10')](this[_0xbb05('0x4')]['id'],this['realtime'][_0xbb05('0x11')][this['agentId']],this[_0xbb05('0x4')][_0xbb05('0x12')],!![])){logger[_0xbb05('0x13')](_0xbb05('0x14'),this['squeue']['id'],this[_0xbb05('0x15')]);clearInterval(this[_0xbb05('0x16')][this['agentId']]);_0x47bc0d[_0xbb05('0x17')]();setTimeout(this[_0xbb05('0x7')][_0xbb05('0x8')](this),0x3e8);}};RRMemory[_0xbb05('0xd')][_0xbb05('0xc')]=function(_0x47f63e){this['agentId']=rr(this[_0xbb05('0x5')][_0xbb05('0x18')]);logger['info'](_0xbb05('0x19'),this[_0xbb05('0x4')]['id'],this[_0xbb05('0x15')]);if(_['isNil'](this[_0xbb05('0x6')][_0xbb05('0x11')][this[_0xbb05('0x15')]])){logger['info'](_0xbb05('0x1a'),this[_0xbb05('0x4')]['id'],this[_0xbb05('0x15')]);_0x47f63e['done']();setTimeout(this['push'][_0xbb05('0x8')](this),0x3e8);}else{if(util[_0xbb05('0x10')](this[_0xbb05('0x4')]['id'],this[_0xbb05('0x6')][_0xbb05('0x11')][this['agentId']],this[_0xbb05('0x4')]['channel'],!![])){this[_0xbb05('0x6')][_0xbb05('0x11')][this[_0xbb05('0x15')]][_0xbb05('0x1b')]=!![];this[_0xbb05('0x6')]['agents'][this[_0xbb05('0x15')]][_0xbb05('0x1c')]=this[_0xbb05('0x5')][_0xbb05('0x1d')];util[_0xbb05('0x1e')](this['notificationId'],this[_0xbb05('0x4')]['id'],this[_0xbb05('0x6')][_0xbb05('0x11')][this[_0xbb05('0x15')]],this[_0xbb05('0x5')],this[_0xbb05('0x3')]);util[_0xbb05('0x1f')](this[_0xbb05('0x4')]['id'],this['realtime'][_0xbb05('0x11')][this['agentId']],_0xbb05('0x20'));this[_0xbb05('0x16')][this[_0xbb05('0x15')]]=setInterval(this[_0xbb05('0xf')][_0xbb05('0x8')](this,_0x47f63e),0x3e8);}else{logger[_0xbb05('0x13')](_0xbb05('0x21'),this[_0xbb05('0x4')]['id'],this[_0xbb05('0x15')]);_0x47f63e[_0xbb05('0x17')]();setTimeout(this[_0xbb05('0x7')]['bind'](this),0x3e8);}}};RRMemory[_0xbb05('0xd')][_0xbb05('0x9')]=function(_0x3a2f79){logger[_0xbb05('0x13')](_0xbb05('0x22'),this[_0xbb05('0x4')]['id'],this['agentId']);if(_['isNil'](this['realtime'][_0xbb05('0x11')][this[_0xbb05('0x15')]])){logger[_0xbb05('0x13')]('[%s][QUEUE]\x20agent\x20skipped,\x20unknown\x20id\x20%s',this['squeue']['id'],this[_0xbb05('0x15')]);}else{clearInterval(this[_0xbb05('0x16')][this[_0xbb05('0x15')]]);util[_0xbb05('0x23')](this['notificationId'],this['squeue']['id'],this[_0xbb05('0x6')][_0xbb05('0x11')][this[_0xbb05('0x15')]],this[_0xbb05('0x5')],this[_0xbb05('0x3')]);util[_0xbb05('0x1f')](this[_0xbb05('0x4')]['id'],this[_0xbb05('0x6')][_0xbb05('0x11')][this[_0xbb05('0x15')]],'TIMEOUT');this['realtime'][_0xbb05('0x11')][this['agentId']]['busy']=![];this['realtime']['agents'][this[_0xbb05('0x15')]][_0xbb05('0x1c')]=undefined;}if(!_0x3a2f79){setTimeout(this['push'][_0xbb05('0x8')](this),0x3e8);}};function rrmemory(_0x553b0c,_0x59c8fc,_0x4008d5,_0x581bd8){return new RRMemory(_0x553b0c,_0x59c8fc,_0x4008d5,_0x581bd8);}module[_0xbb05('0x24')]=rrmemory;
\ No newline at end of file
+var _0xb152=['[%s][QUEUE]\x20agent\x20skipped,\x20unknown\x20id\x20%s','busy','busyQueue','showNotification','notificationId','routing','writeLog','[%s][QUEUE]\x20agent\x20skipped,\x20not\x20available\x20id\x20%s','[%s][QUEUE]\x20timeout\x20with\x20%s','hideNotification','TIMEOUT','exports','lodash','../../../../../config/logger','queue','realtime','squeue','bind','module','timeout','handleTimeout','drained','handleDrained','prototype','push','handleRun','handleCheckReject','isAgentAvailable','agents','channel','info','[%s][QUEUE]\x20available\x20again\x20%s','agentId','intervals','done','mapAgentsId','isNil'];(function(_0x3f5cd3,_0x35d9a4){var _0x3912cd=function(_0x8d0c1a){while(--_0x8d0c1a){_0x3f5cd3['push'](_0x3f5cd3['shift']());}};_0x3912cd(++_0x35d9a4);}(_0xb152,0xc5));var _0x2b15=function(_0x26ce3e,_0x31d727){_0x26ce3e=_0x26ce3e-0x0;var _0x3a67ef=_0xb152[_0x26ce3e];return _0x3a67ef;};'use strict';var rr=require('rr');var _=require(_0x2b15('0x0'));var uuid=require('uuid');var util=require('./util');var logger=require(_0x2b15('0x1'))('routing');var RRMemory=function(_0x3e12eb,_0x1352e1,_0xcbc790,_0x53d42d){this['notificationId']=uuid['v4']();this['squeue']=_0x3e12eb;this[_0x2b15('0x2')]=_0x1352e1;this[_0x2b15('0x3')]=_0xcbc790;this['routing']=_0x53d42d;this['intervals']={};this[_0x2b15('0x4')]['push'](this['handleRun'][_0x2b15('0x5')](this),this['handleTimeout'][_0x2b15('0x5')](this),this[_0x2b15('0x6')]);this[_0x2b15('0x4')]['on'](_0x2b15('0x7'),this[_0x2b15('0x8')][_0x2b15('0x5')](this));this[_0x2b15('0x4')]['on'](_0x2b15('0x9'),this[_0x2b15('0xa')][_0x2b15('0x5')](this));};RRMemory[_0x2b15('0xb')]['push']=function(){this[_0x2b15('0x4')][_0x2b15('0xc')](this[_0x2b15('0xd')][_0x2b15('0x5')](this),this[_0x2b15('0x8')][_0x2b15('0x5')](this));};RRMemory[_0x2b15('0xb')][_0x2b15('0xa')]=function(_0x51618b){this['handleTimeout'](!![]);};RRMemory['prototype'][_0x2b15('0xe')]=function(_0x377fd7){if(util[_0x2b15('0xf')](this[_0x2b15('0x4')]['id'],this[_0x2b15('0x3')][_0x2b15('0x10')][this['agentId']],this[_0x2b15('0x4')][_0x2b15('0x11')],!![])){logger[_0x2b15('0x12')](_0x2b15('0x13'),this['squeue']['id'],this[_0x2b15('0x14')]);clearInterval(this[_0x2b15('0x15')][this[_0x2b15('0x14')]]);_0x377fd7[_0x2b15('0x16')]();setTimeout(this['push']['bind'](this),0x3e8);}};RRMemory[_0x2b15('0xb')]['handleRun']=function(_0x498961){this[_0x2b15('0x14')]=rr(this['queue'][_0x2b15('0x17')]);logger[_0x2b15('0x12')]('[%s][QUEUE]\x20try\x20with\x20%s',this[_0x2b15('0x4')]['id'],this[_0x2b15('0x14')]);if(_[_0x2b15('0x18')](this[_0x2b15('0x3')][_0x2b15('0x10')][this['agentId']])){logger[_0x2b15('0x12')](_0x2b15('0x19'),this['squeue']['id'],this['agentId']);_0x498961[_0x2b15('0x16')]();setTimeout(this[_0x2b15('0xc')][_0x2b15('0x5')](this),0x3e8);}else{if(util[_0x2b15('0xf')](this[_0x2b15('0x4')]['id'],this[_0x2b15('0x3')][_0x2b15('0x10')][this[_0x2b15('0x14')]],this[_0x2b15('0x4')]['channel'],!![])){this[_0x2b15('0x3')]['agents'][this[_0x2b15('0x14')]][_0x2b15('0x1a')]=!![];this[_0x2b15('0x3')][_0x2b15('0x10')][this['agentId']][_0x2b15('0x1b')]=this[_0x2b15('0x2')]['name'];util[_0x2b15('0x1c')](this[_0x2b15('0x1d')],this['squeue']['id'],this[_0x2b15('0x3')][_0x2b15('0x10')][this[_0x2b15('0x14')]],this[_0x2b15('0x2')],this[_0x2b15('0x1e')]);util[_0x2b15('0x1f')](this['squeue']['id'],this['realtime']['agents'][this[_0x2b15('0x14')]],'RINGING');this[_0x2b15('0x15')][this['agentId']]=setInterval(this[_0x2b15('0xe')][_0x2b15('0x5')](this,_0x498961),0x3e8);}else{logger[_0x2b15('0x12')](_0x2b15('0x20'),this[_0x2b15('0x4')]['id'],this['agentId']);_0x498961[_0x2b15('0x16')]();setTimeout(this[_0x2b15('0xc')][_0x2b15('0x5')](this),0x3e8);}}};RRMemory[_0x2b15('0xb')][_0x2b15('0x8')]=function(_0x2f58ad){logger['info'](_0x2b15('0x21'),this['squeue']['id'],this[_0x2b15('0x14')]);if(_[_0x2b15('0x18')](this['realtime'][_0x2b15('0x10')][this[_0x2b15('0x14')]])){logger[_0x2b15('0x12')](_0x2b15('0x19'),this['squeue']['id'],this[_0x2b15('0x14')]);}else{clearInterval(this[_0x2b15('0x15')][this['agentId']]);util[_0x2b15('0x22')](this[_0x2b15('0x1d')],this[_0x2b15('0x4')]['id'],this[_0x2b15('0x3')][_0x2b15('0x10')][this[_0x2b15('0x14')]],this[_0x2b15('0x2')],this['routing']);util[_0x2b15('0x1f')](this['squeue']['id'],this[_0x2b15('0x3')][_0x2b15('0x10')][this[_0x2b15('0x14')]],_0x2b15('0x23'));this[_0x2b15('0x3')][_0x2b15('0x10')][this[_0x2b15('0x14')]]['busy']=![];this[_0x2b15('0x3')][_0x2b15('0x10')][this['agentId']][_0x2b15('0x1b')]=undefined;}if(!_0x2f58ad){setTimeout(this['push'][_0x2b15('0x5')](this),0x3e8);}};function rrmemory(_0x5cfedd,_0xc5a01,_0x5bcd42,_0x30985a){return new RRMemory(_0x5cfedd,_0xc5a01,_0x5bcd42,_0x30985a);}module[_0x2b15('0x24')]=rrmemory;
\ No newline at end of file