Built motion from commit (unavailable).|2.5.21
[motion2.git] / server / services / routing / server / applications / strategy / rrmemory.js
index 1033848..8158344 100644 (file)
@@ -15,4 +15,4 @@
 // * treaties. The SOFTWARE PRODUCT is licensed, not sold.                        *
 // *                                                                       *
 // *************************************************************************
-var _0xe806=['handleCheckReject','agents','agentId','info','[%s][QUEUE]\x20available\x20again\x20%s','done','[%s][QUEUE]\x20try\x20with\x20%s','isNil','[%s][QUEUE]\x20agent\x20skipped,\x20unknown\x20id\x20%s','isAgentAvailable','busy','busyQueue','name','showNotification','RINGING','[%s][QUEUE]\x20agent\x20skipped,\x20not\x20available\x20id\x20%s','[%s][QUEUE]\x20timeout\x20with\x20%s','hideNotification','writeLog','TIMEOUT','lodash','uuid','routing','notificationId','squeue','queue','realtime','intervals','push','handleRun','bind','module','handleTimeout','drained','handleDrained','prototype'];(function(_0x239536,_0x38b078){var _0x11ebf9=function(_0x503d1f){while(--_0x503d1f){_0x239536['push'](_0x239536['shift']());}};_0x11ebf9(++_0x38b078);}(_0xe806,0x134));var _0x6e80=function(_0x541a8b,_0x55407c){_0x541a8b=_0x541a8b-0x0;var _0x5b4d10=_0xe806[_0x541a8b];return _0x5b4d10;};'use strict';var rr=require('rr');var _=require(_0x6e80('0x0'));var uuid=require(_0x6e80('0x1'));var util=require('./util');var logger=require('../../../../../config/logger')(_0x6e80('0x2'));var RRMemory=function(_0x1bee55,_0x5a9044,_0x3c0ebe,_0x29b8bd){this[_0x6e80('0x3')]=uuid['v4']();this[_0x6e80('0x4')]=_0x1bee55;this[_0x6e80('0x5')]=_0x5a9044;this[_0x6e80('0x6')]=_0x3c0ebe;this[_0x6e80('0x2')]=_0x29b8bd;this[_0x6e80('0x7')]={};this['squeue'][_0x6e80('0x8')](this[_0x6e80('0x9')][_0x6e80('0xa')](this),this['handleTimeout'][_0x6e80('0xa')](this),this[_0x6e80('0xb')]);this[_0x6e80('0x4')]['on']('timeout',this[_0x6e80('0xc')][_0x6e80('0xa')](this));this[_0x6e80('0x4')]['on'](_0x6e80('0xd'),this[_0x6e80('0xe')][_0x6e80('0xa')](this));};RRMemory[_0x6e80('0xf')][_0x6e80('0x8')]=function(){this[_0x6e80('0x4')][_0x6e80('0x8')](this[_0x6e80('0x9')][_0x6e80('0xa')](this),this['handleTimeout'][_0x6e80('0xa')](this));};RRMemory[_0x6e80('0xf')][_0x6e80('0xe')]=function(_0x25a953){this['handleTimeout'](!![]);};RRMemory[_0x6e80('0xf')][_0x6e80('0x10')]=function(_0x581ace){if(util['isAgentAvailable'](this[_0x6e80('0x4')]['id'],this[_0x6e80('0x6')][_0x6e80('0x11')][this[_0x6e80('0x12')]],this['squeue']['channel'],!![])){logger[_0x6e80('0x13')](_0x6e80('0x14'),this['squeue']['id'],this[_0x6e80('0x12')]);clearInterval(this[_0x6e80('0x7')][this[_0x6e80('0x12')]]);_0x581ace[_0x6e80('0x15')]();setTimeout(this['push'][_0x6e80('0xa')](this),0x3e8);}};RRMemory[_0x6e80('0xf')][_0x6e80('0x9')]=function(_0x127152){this[_0x6e80('0x12')]=rr(this[_0x6e80('0x5')]['mapAgentsId']);logger[_0x6e80('0x13')](_0x6e80('0x16'),this[_0x6e80('0x4')]['id'],this[_0x6e80('0x12')]);if(_[_0x6e80('0x17')](this[_0x6e80('0x6')]['agents'][this[_0x6e80('0x12')]])){logger['info'](_0x6e80('0x18'),this[_0x6e80('0x4')]['id'],this[_0x6e80('0x12')]);_0x127152[_0x6e80('0x15')]();setTimeout(this['push'][_0x6e80('0xa')](this),0x3e8);}else{if(util[_0x6e80('0x19')](this[_0x6e80('0x4')]['id'],this[_0x6e80('0x6')]['agents'][this[_0x6e80('0x12')]],this[_0x6e80('0x4')]['channel'],!![])){this[_0x6e80('0x6')][_0x6e80('0x11')][this[_0x6e80('0x12')]][_0x6e80('0x1a')]=!![];this['realtime'][_0x6e80('0x11')][this[_0x6e80('0x12')]][_0x6e80('0x1b')]=this[_0x6e80('0x5')][_0x6e80('0x1c')];util[_0x6e80('0x1d')](this[_0x6e80('0x3')],this[_0x6e80('0x4')]['id'],this[_0x6e80('0x6')]['agents'][this['agentId']],this[_0x6e80('0x5')],this[_0x6e80('0x2')]);util['writeLog'](this[_0x6e80('0x4')]['id'],this[_0x6e80('0x6')][_0x6e80('0x11')][this[_0x6e80('0x12')]],_0x6e80('0x1e'));this[_0x6e80('0x7')][this['agentId']]=setInterval(this[_0x6e80('0x10')][_0x6e80('0xa')](this,_0x127152),0x3e8);}else{logger['info'](_0x6e80('0x1f'),this[_0x6e80('0x4')]['id'],this['agentId']);_0x127152[_0x6e80('0x15')]();setTimeout(this[_0x6e80('0x8')][_0x6e80('0xa')](this),0x3e8);}}};RRMemory['prototype'][_0x6e80('0xc')]=function(_0x55d417){logger[_0x6e80('0x13')](_0x6e80('0x20'),this['squeue']['id'],this[_0x6e80('0x12')]);if(_[_0x6e80('0x17')](this[_0x6e80('0x6')][_0x6e80('0x11')][this[_0x6e80('0x12')]])){logger[_0x6e80('0x13')](_0x6e80('0x18'),this[_0x6e80('0x4')]['id'],this[_0x6e80('0x12')]);}else{clearInterval(this[_0x6e80('0x7')][this['agentId']]);util[_0x6e80('0x21')](this[_0x6e80('0x3')],this['squeue']['id'],this[_0x6e80('0x6')][_0x6e80('0x11')][this['agentId']],this[_0x6e80('0x5')],this[_0x6e80('0x2')]);util[_0x6e80('0x22')](this[_0x6e80('0x4')]['id'],this[_0x6e80('0x6')][_0x6e80('0x11')][this[_0x6e80('0x12')]],_0x6e80('0x23'));this[_0x6e80('0x6')][_0x6e80('0x11')][this[_0x6e80('0x12')]][_0x6e80('0x1a')]=![];this[_0x6e80('0x6')][_0x6e80('0x11')][this[_0x6e80('0x12')]]['busyQueue']=undefined;}if(!_0x55d417){setTimeout(this['push'][_0x6e80('0xa')](this),0x3e8);}};function rrmemory(_0xfeb131,_0x481b28,_0x3a5982,_0x1d5a06){return new RRMemory(_0xfeb131,_0x481b28,_0x3a5982,_0x1d5a06);}module['exports']=rrmemory;
\ No newline at end of file
+var _0x06e2=['TIMEOUT','exports','lodash','./util','routing','notificationId','squeue','queue','realtime','intervals','push','handleRun','handleTimeout','bind','module','drained','handleDrained','prototype','handleCheckReject','agents','agentId','channel','info','[%s][QUEUE]\x20available\x20again\x20%s','done','mapAgentsId','[%s][QUEUE]\x20try\x20with\x20%s','[%s][QUEUE]\x20agent\x20skipped,\x20unknown\x20id\x20%s','isAgentAvailable','busy','busyQueue','name','writeLog','RINGING','hideNotification'];(function(_0x5f0089,_0x227e2c){var _0x193892=function(_0x24051f){while(--_0x24051f){_0x5f0089['push'](_0x5f0089['shift']());}};_0x193892(++_0x227e2c);}(_0x06e2,0x6b));var _0x206e=function(_0x483633,_0x28b955){_0x483633=_0x483633-0x0;var _0x5218c1=_0x06e2[_0x483633];return _0x5218c1;};'use strict';var rr=require('rr');var _=require(_0x206e('0x0'));var uuid=require('uuid');var util=require(_0x206e('0x1'));var logger=require('../../../../../config/logger')(_0x206e('0x2'));var RRMemory=function(_0x3be434,_0x35391f,_0x20f20b,_0x364712){this[_0x206e('0x3')]=uuid['v4']();this[_0x206e('0x4')]=_0x3be434;this[_0x206e('0x5')]=_0x35391f;this[_0x206e('0x6')]=_0x20f20b;this[_0x206e('0x2')]=_0x364712;this[_0x206e('0x7')]={};this[_0x206e('0x4')][_0x206e('0x8')](this[_0x206e('0x9')]['bind'](this),this[_0x206e('0xa')][_0x206e('0xb')](this),this[_0x206e('0xc')]);this['squeue']['on']('timeout',this['handleTimeout'][_0x206e('0xb')](this));this['squeue']['on'](_0x206e('0xd'),this[_0x206e('0xe')][_0x206e('0xb')](this));};RRMemory[_0x206e('0xf')][_0x206e('0x8')]=function(){this['squeue'][_0x206e('0x8')](this[_0x206e('0x9')][_0x206e('0xb')](this),this['handleTimeout'][_0x206e('0xb')](this));};RRMemory['prototype'][_0x206e('0xe')]=function(_0x84f742){this[_0x206e('0xa')](!![]);};RRMemory['prototype'][_0x206e('0x10')]=function(_0x5e9158){if(util['isAgentAvailable'](this[_0x206e('0x4')]['id'],this['realtime'][_0x206e('0x11')][this[_0x206e('0x12')]],this[_0x206e('0x4')][_0x206e('0x13')],!![])){logger[_0x206e('0x14')](_0x206e('0x15'),this[_0x206e('0x4')]['id'],this[_0x206e('0x12')]);clearInterval(this[_0x206e('0x7')][this[_0x206e('0x12')]]);_0x5e9158[_0x206e('0x16')]();setTimeout(this[_0x206e('0x8')][_0x206e('0xb')](this),0x3e8);}};RRMemory[_0x206e('0xf')][_0x206e('0x9')]=function(_0x329517){this[_0x206e('0x12')]=rr(this[_0x206e('0x5')][_0x206e('0x17')]);logger[_0x206e('0x14')](_0x206e('0x18'),this[_0x206e('0x4')]['id'],this[_0x206e('0x12')]);if(_['isNil'](this[_0x206e('0x6')][_0x206e('0x11')][this[_0x206e('0x12')]])){logger[_0x206e('0x14')](_0x206e('0x19'),this[_0x206e('0x4')]['id'],this[_0x206e('0x12')]);_0x329517[_0x206e('0x16')]();setTimeout(this[_0x206e('0x8')][_0x206e('0xb')](this),0x3e8);}else{if(util[_0x206e('0x1a')](this[_0x206e('0x4')]['id'],this[_0x206e('0x6')][_0x206e('0x11')][this[_0x206e('0x12')]],this[_0x206e('0x4')][_0x206e('0x13')],!![])){this[_0x206e('0x6')][_0x206e('0x11')][this[_0x206e('0x12')]][_0x206e('0x1b')]=!![];this['realtime'][_0x206e('0x11')][this[_0x206e('0x12')]][_0x206e('0x1c')]=this[_0x206e('0x5')][_0x206e('0x1d')];util['showNotification'](this[_0x206e('0x3')],this[_0x206e('0x4')]['id'],this[_0x206e('0x6')][_0x206e('0x11')][this[_0x206e('0x12')]],this[_0x206e('0x5')],this[_0x206e('0x2')]);util[_0x206e('0x1e')](this[_0x206e('0x4')]['id'],this[_0x206e('0x6')][_0x206e('0x11')][this[_0x206e('0x12')]],_0x206e('0x1f'));this[_0x206e('0x7')][this['agentId']]=setInterval(this[_0x206e('0x10')]['bind'](this,_0x329517),0x3e8);}else{logger[_0x206e('0x14')]('[%s][QUEUE]\x20agent\x20skipped,\x20not\x20available\x20id\x20%s',this[_0x206e('0x4')]['id'],this[_0x206e('0x12')]);_0x329517['done']();setTimeout(this['push'][_0x206e('0xb')](this),0x3e8);}}};RRMemory['prototype'][_0x206e('0xa')]=function(_0xac29c7){logger[_0x206e('0x14')]('[%s][QUEUE]\x20timeout\x20with\x20%s',this[_0x206e('0x4')]['id'],this[_0x206e('0x12')]);if(_['isNil'](this['realtime'][_0x206e('0x11')][this[_0x206e('0x12')]])){logger[_0x206e('0x14')](_0x206e('0x19'),this['squeue']['id'],this[_0x206e('0x12')]);}else{clearInterval(this[_0x206e('0x7')][this[_0x206e('0x12')]]);util[_0x206e('0x20')](this['notificationId'],this['squeue']['id'],this[_0x206e('0x6')][_0x206e('0x11')][this[_0x206e('0x12')]],this[_0x206e('0x5')],this[_0x206e('0x2')]);util[_0x206e('0x1e')](this[_0x206e('0x4')]['id'],this[_0x206e('0x6')]['agents'][this['agentId']],_0x206e('0x21'));this[_0x206e('0x6')][_0x206e('0x11')][this[_0x206e('0x12')]]['busy']=![];this[_0x206e('0x6')][_0x206e('0x11')][this['agentId']][_0x206e('0x1c')]=undefined;}if(!_0xac29c7){setTimeout(this[_0x206e('0x8')]['bind'](this),0x3e8);}};function rrmemory(_0x4c60c0,_0x5c5541,_0x19eefd,_0x85ace5){return new RRMemory(_0x4c60c0,_0x5c5541,_0x19eefd,_0x85ace5);}module[_0x206e('0x22')]=rrmemory;
\ No newline at end of file