Built motion from commit (unavailable).|2.5.31
[motion2.git] / server / services / routing / server / applications / strategy / rrmemory.js
index 283e11e..08d101c 100644 (file)
@@ -15,4 +15,4 @@
 // * treaties. The SOFTWARE PRODUCT is licensed, not sold.                        *
 // *                                                                       *
 // *************************************************************************
-var _0x967e=['channel','info','[%s][QUEUE]\x20available\x20again\x20%s','done','mapAgentsId','agents','[%s][QUEUE]\x20agent\x20skipped,\x20unknown\x20id\x20%s','busy','busyQueue','name','RINGING','[%s][QUEUE]\x20agent\x20skipped,\x20not\x20available\x20id\x20%s','[%s][QUEUE]\x20timeout\x20with\x20%s','isNil','hideNotification','TIMEOUT','exports','lodash','uuid','./util','../../../../../config/logger','routing','notificationId','queue','realtime','intervals','squeue','push','handleRun','handleTimeout','timeout','bind','prototype','isAgentAvailable','agentId'];(function(_0x572944,_0xd5c0df){var _0x2f457a=function(_0x5ba3bf){while(--_0x5ba3bf){_0x572944['push'](_0x572944['shift']());}};_0x2f457a(++_0xd5c0df);}(_0x967e,0x7a));var _0xe967=function(_0x312f1f,_0xac5232){_0x312f1f=_0x312f1f-0x0;var _0x2623bf=_0x967e[_0x312f1f];return _0x2623bf;};'use strict';var rr=require('rr');var _=require(_0xe967('0x0'));var uuid=require(_0xe967('0x1'));var util=require(_0xe967('0x2'));var logger=require(_0xe967('0x3'))(_0xe967('0x4'));var RRMemory=function(_0x3c1113,_0x5bb5cd,_0x5e60ac,_0x28af9c){this[_0xe967('0x5')]=uuid['v4']();this['squeue']=_0x3c1113;this[_0xe967('0x6')]=_0x5bb5cd;this[_0xe967('0x7')]=_0x5e60ac;this[_0xe967('0x4')]=_0x28af9c;this[_0xe967('0x8')]={};this[_0xe967('0x9')][_0xe967('0xa')](this[_0xe967('0xb')]['bind'](this),this[_0xe967('0xc')]['bind'](this),this['module']);this[_0xe967('0x9')]['on'](_0xe967('0xd'),this[_0xe967('0xc')][_0xe967('0xe')](this));this[_0xe967('0x9')]['on']('drained',this['handleDrained'][_0xe967('0xe')](this));};RRMemory[_0xe967('0xf')][_0xe967('0xa')]=function(){this[_0xe967('0x9')][_0xe967('0xa')](this[_0xe967('0xb')]['bind'](this),this[_0xe967('0xc')][_0xe967('0xe')](this));};RRMemory['prototype']['handleDrained']=function(_0xf3570a){this[_0xe967('0xc')](!![]);};RRMemory[_0xe967('0xf')]['handleCheckReject']=function(_0xc1db01){if(util[_0xe967('0x10')](this[_0xe967('0x9')]['id'],this[_0xe967('0x7')]['agents'][this[_0xe967('0x11')]],this[_0xe967('0x9')][_0xe967('0x12')],!![])){logger[_0xe967('0x13')](_0xe967('0x14'),this[_0xe967('0x9')]['id'],this['agentId']);clearInterval(this['intervals'][this[_0xe967('0x11')]]);_0xc1db01[_0xe967('0x15')]();setTimeout(this['push'][_0xe967('0xe')](this),0x3e8);}};RRMemory[_0xe967('0xf')][_0xe967('0xb')]=function(_0x533294){this['agentId']=rr(this[_0xe967('0x6')][_0xe967('0x16')]);logger[_0xe967('0x13')]('[%s][QUEUE]\x20try\x20with\x20%s',this[_0xe967('0x9')]['id'],this['agentId']);if(_['isNil'](this[_0xe967('0x7')][_0xe967('0x17')][this['agentId']])){logger[_0xe967('0x13')](_0xe967('0x18'),this[_0xe967('0x9')]['id'],this[_0xe967('0x11')]);_0x533294[_0xe967('0x15')]();setTimeout(this[_0xe967('0xa')][_0xe967('0xe')](this),0x3e8);}else{if(util[_0xe967('0x10')](this[_0xe967('0x9')]['id'],this['realtime'][_0xe967('0x17')][this[_0xe967('0x11')]],this['squeue'][_0xe967('0x12')],!![])){this[_0xe967('0x7')][_0xe967('0x17')][this[_0xe967('0x11')]][_0xe967('0x19')]=!![];this[_0xe967('0x7')]['agents'][this[_0xe967('0x11')]][_0xe967('0x1a')]=this['queue'][_0xe967('0x1b')];util['showNotification'](this[_0xe967('0x5')],this['squeue']['id'],this['realtime'][_0xe967('0x17')][this[_0xe967('0x11')]],this[_0xe967('0x6')],this[_0xe967('0x4')]);util['writeLog'](this[_0xe967('0x9')]['id'],this['realtime'][_0xe967('0x17')][this[_0xe967('0x11')]],_0xe967('0x1c'));this[_0xe967('0x8')][this['agentId']]=setInterval(this['handleCheckReject']['bind'](this,_0x533294),0x3e8);}else{logger['info'](_0xe967('0x1d'),this[_0xe967('0x9')]['id'],this[_0xe967('0x11')]);_0x533294['done']();setTimeout(this[_0xe967('0xa')]['bind'](this),0x3e8);}}};RRMemory[_0xe967('0xf')]['handleTimeout']=function(_0x490efb){logger[_0xe967('0x13')](_0xe967('0x1e'),this['squeue']['id'],this[_0xe967('0x11')]);if(_[_0xe967('0x1f')](this[_0xe967('0x7')][_0xe967('0x17')][this[_0xe967('0x11')]])){logger[_0xe967('0x13')]('[%s][QUEUE]\x20agent\x20skipped,\x20unknown\x20id\x20%s',this[_0xe967('0x9')]['id'],this['agentId']);}else{clearInterval(this[_0xe967('0x8')][this[_0xe967('0x11')]]);util[_0xe967('0x20')](this[_0xe967('0x5')],this['squeue']['id'],this[_0xe967('0x7')][_0xe967('0x17')][this[_0xe967('0x11')]],this[_0xe967('0x6')],this[_0xe967('0x4')]);util['writeLog'](this['squeue']['id'],this[_0xe967('0x7')][_0xe967('0x17')][this[_0xe967('0x11')]],_0xe967('0x21'));this[_0xe967('0x7')]['agents'][this[_0xe967('0x11')]]['busy']=![];this[_0xe967('0x7')][_0xe967('0x17')][this[_0xe967('0x11')]][_0xe967('0x1a')]=undefined;}if(!_0x490efb){setTimeout(this[_0xe967('0xa')][_0xe967('0xe')](this),0x3e8);}};function rrmemory(_0x3fdd15,_0x3ca662,_0x506085,_0xea1d88){return new RRMemory(_0x3fdd15,_0x3ca662,_0x506085,_0xea1d88);}module[_0xe967('0x22')]=rrmemory;
\ No newline at end of file
+var _0x351b=['routing','intervals','push','bind','handleTimeout','timeout','drained','handleDrained','prototype','handleRun','handleCheckReject','realtime','agents','agentId','channel','info','[%s][QUEUE]\x20available\x20again\x20%s','done','mapAgentsId','[%s][QUEUE]\x20try\x20with\x20%s','busyQueue','showNotification','writeLog','RINGING','[%s][QUEUE]\x20agent\x20skipped,\x20not\x20available\x20id\x20%s','isNil','hideNotification','TIMEOUT','busy','uuid','./util','../../../../../config/logger','notificationId','squeue','queue'];(function(_0x3dd15e,_0x1f0015){var _0x231fd0=function(_0x4f680a){while(--_0x4f680a){_0x3dd15e['push'](_0x3dd15e['shift']());}};_0x231fd0(++_0x1f0015);}(_0x351b,0x17b));var _0xb351=function(_0x1d9d79,_0x351091){_0x1d9d79=_0x1d9d79-0x0;var _0x471f17=_0x351b[_0x1d9d79];return _0x471f17;};'use strict';var rr=require('rr');var _=require('lodash');var uuid=require(_0xb351('0x0'));var util=require(_0xb351('0x1'));var logger=require(_0xb351('0x2'))('routing');var RRMemory=function(_0x263672,_0x1e82b3,_0x3a36ad,_0x315659){this[_0xb351('0x3')]=uuid['v4']();this[_0xb351('0x4')]=_0x263672;this[_0xb351('0x5')]=_0x1e82b3;this['realtime']=_0x3a36ad;this[_0xb351('0x6')]=_0x315659;this[_0xb351('0x7')]={};this[_0xb351('0x4')][_0xb351('0x8')](this['handleRun'][_0xb351('0x9')](this),this[_0xb351('0xa')]['bind'](this),this['module']);this[_0xb351('0x4')]['on'](_0xb351('0xb'),this[_0xb351('0xa')][_0xb351('0x9')](this));this[_0xb351('0x4')]['on'](_0xb351('0xc'),this[_0xb351('0xd')]['bind'](this));};RRMemory[_0xb351('0xe')][_0xb351('0x8')]=function(){this['squeue']['push'](this[_0xb351('0xf')][_0xb351('0x9')](this),this[_0xb351('0xa')][_0xb351('0x9')](this));};RRMemory[_0xb351('0xe')]['handleDrained']=function(_0x374efa){this[_0xb351('0xa')](!![]);};RRMemory[_0xb351('0xe')][_0xb351('0x10')]=function(_0x3131ed){if(util['isAgentAvailable'](this[_0xb351('0x4')]['id'],this[_0xb351('0x11')][_0xb351('0x12')][this[_0xb351('0x13')]],this['squeue'][_0xb351('0x14')],!![])){logger[_0xb351('0x15')](_0xb351('0x16'),this['squeue']['id'],this['agentId']);clearInterval(this['intervals'][this['agentId']]);_0x3131ed[_0xb351('0x17')]();setTimeout(this[_0xb351('0x8')]['bind'](this),0x3e8);}};RRMemory[_0xb351('0xe')][_0xb351('0xf')]=function(_0x46caec){this['agentId']=rr(this[_0xb351('0x5')][_0xb351('0x18')]);logger[_0xb351('0x15')](_0xb351('0x19'),this[_0xb351('0x4')]['id'],this[_0xb351('0x13')]);if(_['isNil'](this[_0xb351('0x11')]['agents'][this[_0xb351('0x13')]])){logger['info']('[%s][QUEUE]\x20agent\x20skipped,\x20unknown\x20id\x20%s',this[_0xb351('0x4')]['id'],this[_0xb351('0x13')]);_0x46caec['done']();setTimeout(this[_0xb351('0x8')][_0xb351('0x9')](this),0x3e8);}else{if(util['isAgentAvailable'](this['squeue']['id'],this[_0xb351('0x11')][_0xb351('0x12')][this[_0xb351('0x13')]],this[_0xb351('0x4')][_0xb351('0x14')],!![])){this[_0xb351('0x11')][_0xb351('0x12')][this[_0xb351('0x13')]]['busy']=!![];this[_0xb351('0x11')][_0xb351('0x12')][this[_0xb351('0x13')]][_0xb351('0x1a')]=this[_0xb351('0x5')]['name'];util[_0xb351('0x1b')](this[_0xb351('0x3')],this['squeue']['id'],this[_0xb351('0x11')][_0xb351('0x12')][this[_0xb351('0x13')]],this['queue'],this[_0xb351('0x6')]);util[_0xb351('0x1c')](this[_0xb351('0x4')]['id'],this[_0xb351('0x11')][_0xb351('0x12')][this['agentId']],_0xb351('0x1d'));this[_0xb351('0x7')][this[_0xb351('0x13')]]=setInterval(this[_0xb351('0x10')][_0xb351('0x9')](this,_0x46caec),0x3e8);}else{logger[_0xb351('0x15')](_0xb351('0x1e'),this[_0xb351('0x4')]['id'],this['agentId']);_0x46caec[_0xb351('0x17')]();setTimeout(this[_0xb351('0x8')][_0xb351('0x9')](this),0x3e8);}}};RRMemory[_0xb351('0xe')]['handleTimeout']=function(_0x4b52a8){logger[_0xb351('0x15')]('[%s][QUEUE]\x20timeout\x20with\x20%s',this[_0xb351('0x4')]['id'],this[_0xb351('0x13')]);if(_[_0xb351('0x1f')](this[_0xb351('0x11')][_0xb351('0x12')][this[_0xb351('0x13')]])){logger[_0xb351('0x15')]('[%s][QUEUE]\x20agent\x20skipped,\x20unknown\x20id\x20%s',this[_0xb351('0x4')]['id'],this[_0xb351('0x13')]);}else{clearInterval(this[_0xb351('0x7')][this['agentId']]);util[_0xb351('0x20')](this[_0xb351('0x3')],this[_0xb351('0x4')]['id'],this[_0xb351('0x11')]['agents'][this[_0xb351('0x13')]],this[_0xb351('0x5')],this[_0xb351('0x6')]);util[_0xb351('0x1c')](this[_0xb351('0x4')]['id'],this[_0xb351('0x11')][_0xb351('0x12')][this['agentId']],_0xb351('0x21'));this[_0xb351('0x11')][_0xb351('0x12')][this[_0xb351('0x13')]][_0xb351('0x22')]=![];this['realtime']['agents'][this[_0xb351('0x13')]][_0xb351('0x1a')]=undefined;}if(!_0x4b52a8){setTimeout(this[_0xb351('0x8')][_0xb351('0x9')](this),0x3e8);}};function rrmemory(_0x30c216,_0x34db5a,_0x5134dc,_0x1ccb6f){return new RRMemory(_0x30c216,_0x34db5a,_0x5134dc,_0x1ccb6f);}module['exports']=rrmemory;
\ No newline at end of file