Built motion from commit ded33658aad58fc8de845a8299a9db59a88cc353. Version 3.0.0...
[motion-next.git] / server / services / routing / server / applications / strategy / rrmemory.js
index eba6317..703af0c 100644 (file)
@@ -1 +1 @@
-const a1212_0x2671=['routing','channel','done','busy','[%s][QUEUE]\x20agent\x20skipped,\x20unknown\x20id\x20%s','./util','prototype','timeout','isNil','info','[%s][QUEUE]\x20try\x20with\x20%s','notificationId','handleRun','handleDrained','push','showNotification','bind','mapAgentsId','TIMEOUT','handleTimeout','busyQueue','writeLog','uuid','squeue','[%s][QUEUE]\x20timeout\x20with\x20%s','name','module','lodash','agentId','queue','handleCheckReject','agents','RINGING','[%s][QUEUE]\x20available\x20again\x20%s','realtime','../../../../../config/logger','intervals'];(function(_0x368b22,_0x2671ac){const _0x4c9452=function(_0x1f417a){while(--_0x1f417a){_0x368b22['push'](_0x368b22['shift']());}};_0x4c9452(++_0x2671ac);}(a1212_0x2671,0x1f0));const a1212_0x4c94=function(_0x368b22,_0x2671ac){_0x368b22=_0x368b22-0x0;let _0x4c9452=a1212_0x2671[_0x368b22];return _0x4c9452;};const _0x3bdd9c=a1212_0x4c94;'use strict';const rr=require('rr'),_=require(_0x3bdd9c('0xc')),uuid=require(_0x3bdd9c('0x7')),util=require(_0x3bdd9c('0x1b')),logger=require(_0x3bdd9c('0x14'))('routing'),RRMemory=function(_0x1f417a,_0x4f60be,_0x1a4c68,_0x8e353c){const _0x36ca96=_0x3bdd9c;this[_0x36ca96('0x21')]=uuid['v4'](),this['squeue']=_0x1f417a,this[_0x36ca96('0xe')]=_0x4f60be,this[_0x36ca96('0x13')]=_0x1a4c68,this[_0x36ca96('0x16')]=_0x8e353c,this[_0x36ca96('0x15')]={},this['squeue']['push'](this[_0x36ca96('0x22')][_0x36ca96('0x1')](this),this[_0x36ca96('0x4')]['bind'](this),this[_0x36ca96('0xb')]),this[_0x36ca96('0x8')]['on'](_0x36ca96('0x1d'),this['handleTimeout'][_0x36ca96('0x1')](this)),this[_0x36ca96('0x8')]['on']('drained',this[_0x36ca96('0x23')][_0x36ca96('0x1')](this));};RRMemory[_0x3bdd9c('0x1c')][_0x3bdd9c('0x24')]=function(){const _0x4f0377=_0x3bdd9c;this[_0x4f0377('0x8')][_0x4f0377('0x24')](this['handleRun'][_0x4f0377('0x1')](this),this[_0x4f0377('0x4')][_0x4f0377('0x1')](this));},RRMemory[_0x3bdd9c('0x1c')]['handleDrained']=function(){const _0x30e14a=_0x3bdd9c;this[_0x30e14a('0x4')](!![]);},RRMemory[_0x3bdd9c('0x1c')][_0x3bdd9c('0xf')]=function(_0x4abe14){const _0x17bda5=_0x3bdd9c;util['isAgentAvailable'](this[_0x17bda5('0x8')]['id'],this[_0x17bda5('0x13')][_0x17bda5('0x10')][this[_0x17bda5('0xd')]],this['squeue'][_0x17bda5('0x17')],!![])&&(logger[_0x17bda5('0x1f')](_0x17bda5('0x12'),this[_0x17bda5('0x8')]['id'],this[_0x17bda5('0xd')]),clearInterval(this[_0x17bda5('0x15')][this[_0x17bda5('0xd')]]),_0x4abe14[_0x17bda5('0x18')](),setTimeout(this['push'][_0x17bda5('0x1')](this),0x3e8));},RRMemory[_0x3bdd9c('0x1c')]['handleRun']=function(_0x7c9ee3){const _0x25cf8f=_0x3bdd9c;this[_0x25cf8f('0xd')]=rr(this[_0x25cf8f('0xe')][_0x25cf8f('0x2')]),logger[_0x25cf8f('0x1f')](_0x25cf8f('0x20'),this[_0x25cf8f('0x8')]['id'],this[_0x25cf8f('0xd')]),_[_0x25cf8f('0x1e')](this[_0x25cf8f('0x13')][_0x25cf8f('0x10')][this[_0x25cf8f('0xd')]])?(logger[_0x25cf8f('0x1f')](_0x25cf8f('0x1a'),this[_0x25cf8f('0x8')]['id'],this[_0x25cf8f('0xd')]),_0x7c9ee3[_0x25cf8f('0x18')](),setTimeout(this['push'][_0x25cf8f('0x1')](this),0x3e8)):util['isAgentAvailable'](this[_0x25cf8f('0x8')]['id'],this[_0x25cf8f('0x13')][_0x25cf8f('0x10')][this[_0x25cf8f('0xd')]],this['squeue'][_0x25cf8f('0x17')],!![])?(this[_0x25cf8f('0x13')][_0x25cf8f('0x10')][this[_0x25cf8f('0xd')]][_0x25cf8f('0x19')]=!![],this['realtime'][_0x25cf8f('0x10')][this[_0x25cf8f('0xd')]][_0x25cf8f('0x5')]=this[_0x25cf8f('0xe')][_0x25cf8f('0xa')],util[_0x25cf8f('0x0')](this[_0x25cf8f('0x21')],this['squeue']['id'],this['realtime'][_0x25cf8f('0x10')][this['agentId']],this[_0x25cf8f('0xe')],this['routing']),util[_0x25cf8f('0x6')](this[_0x25cf8f('0x8')]['id'],this['realtime'][_0x25cf8f('0x10')][this[_0x25cf8f('0xd')]],_0x25cf8f('0x11')),this['intervals'][this[_0x25cf8f('0xd')]]=setInterval(this['handleCheckReject'][_0x25cf8f('0x1')](this,_0x7c9ee3),0x3e8)):(logger[_0x25cf8f('0x1f')]('[%s][QUEUE]\x20agent\x20skipped,\x20not\x20available\x20id\x20%s',this[_0x25cf8f('0x8')]['id'],this[_0x25cf8f('0xd')]),_0x7c9ee3[_0x25cf8f('0x18')](),setTimeout(this[_0x25cf8f('0x24')]['bind'](this),0x3e8));},RRMemory['prototype'][_0x3bdd9c('0x4')]=function(_0x344224){const _0x22d8d7=_0x3bdd9c;logger[_0x22d8d7('0x1f')](_0x22d8d7('0x9'),this['squeue']['id'],this[_0x22d8d7('0xd')]),_['isNil'](this['realtime'][_0x22d8d7('0x10')][this[_0x22d8d7('0xd')]])?logger[_0x22d8d7('0x1f')]('[%s][QUEUE]\x20agent\x20skipped,\x20unknown\x20id\x20%s',this[_0x22d8d7('0x8')]['id'],this[_0x22d8d7('0xd')]):(clearInterval(this[_0x22d8d7('0x15')][this[_0x22d8d7('0xd')]]),util['hideNotification'](this['notificationId'],this['squeue']['id'],this[_0x22d8d7('0x13')]['agents'][this['agentId']],this['queue'],this[_0x22d8d7('0x16')]),util['writeLog'](this[_0x22d8d7('0x8')]['id'],this['realtime'][_0x22d8d7('0x10')][this['agentId']],_0x22d8d7('0x3')),this['realtime'][_0x22d8d7('0x10')][this[_0x22d8d7('0xd')]][_0x22d8d7('0x19')]=![],this[_0x22d8d7('0x13')][_0x22d8d7('0x10')][this['agentId']]['busyQueue']=undefined),!_0x344224&&setTimeout(this[_0x22d8d7('0x24')]['bind'](this),0x3e8);};function rrmemory(_0x9470a3,_0x419543,_0xadfd23,_0x18a958){return new RRMemory(_0x9470a3,_0x419543,_0xadfd23,_0x18a958);}module['exports']=rrmemory;
\ No newline at end of file
+const a1212_0x4a9f=['writeLog','hideNotification','RINGING','intervals','drained','module','agentId','realtime','[%s][QUEUE]\x20try\x20with\x20%s','name','handleRun','busyQueue','[%s][QUEUE]\x20agent\x20skipped,\x20unknown\x20id\x20%s','routing','agents','showNotification','notificationId','push','handleTimeout','busy','prototype','bind','exports','TIMEOUT','[%s][QUEUE]\x20available\x20again\x20%s','channel','squeue','isNil','[%s][QUEUE]\x20timeout\x20with\x20%s','handleCheckReject','isAgentAvailable','queue','info','[%s][QUEUE]\x20agent\x20skipped,\x20not\x20available\x20id\x20%s'];(function(_0x507375,_0x4a9f39){const _0x1abf9b=function(_0x2095a7){while(--_0x2095a7){_0x507375['push'](_0x507375['shift']());}};_0x1abf9b(++_0x4a9f39);}(a1212_0x4a9f,0x19a));const a1212_0x1abf=function(_0x507375,_0x4a9f39){_0x507375=_0x507375-0x0;let _0x1abf9b=a1212_0x4a9f[_0x507375];return _0x1abf9b;};const _0xd9449b=a1212_0x1abf;'use strict';const rr=require('rr'),_=require('lodash'),uuid=require('uuid'),util=require('./util'),logger=require('../../../../../config/logger')(_0xd9449b('0xb')),RRMemory=function(_0x2095a7,_0x2388fc,_0x1aa340,_0x358c83){const _0x4b10ce=_0xd9449b;this[_0x4b10ce('0xe')]=uuid['v4'](),this[_0x4b10ce('0x18')]=_0x2095a7,this[_0x4b10ce('0x1d')]=_0x2388fc,this['realtime']=_0x1aa340,this['routing']=_0x358c83,this[_0x4b10ce('0x1')]={},this[_0x4b10ce('0x18')]['push'](this[_0x4b10ce('0x8')]['bind'](this),this[_0x4b10ce('0x10')][_0x4b10ce('0x13')](this),this[_0x4b10ce('0x3')]),this[_0x4b10ce('0x18')]['on']('timeout',this[_0x4b10ce('0x10')][_0x4b10ce('0x13')](this)),this[_0x4b10ce('0x18')]['on'](_0x4b10ce('0x2'),this['handleDrained'][_0x4b10ce('0x13')](this));};RRMemory[_0xd9449b('0x12')][_0xd9449b('0xf')]=function(){const _0x43f8f4=_0xd9449b;this['squeue'][_0x43f8f4('0xf')](this[_0x43f8f4('0x8')]['bind'](this),this['handleTimeout'][_0x43f8f4('0x13')](this));},RRMemory[_0xd9449b('0x12')]['handleDrained']=function(){const _0x2d72e8=_0xd9449b;this[_0x2d72e8('0x10')](!![]);},RRMemory[_0xd9449b('0x12')][_0xd9449b('0x1b')]=function(_0x13a0f9){const _0x2c71d5=_0xd9449b;util['isAgentAvailable'](this[_0x2c71d5('0x18')]['id'],this['realtime'][_0x2c71d5('0xc')][this['agentId']],this[_0x2c71d5('0x18')][_0x2c71d5('0x17')],!![])&&(logger[_0x2c71d5('0x1e')](_0x2c71d5('0x16'),this['squeue']['id'],this[_0x2c71d5('0x4')]),clearInterval(this[_0x2c71d5('0x1')][this[_0x2c71d5('0x4')]]),_0x13a0f9['done'](),setTimeout(this[_0x2c71d5('0xf')][_0x2c71d5('0x13')](this),0x3e8));},RRMemory[_0xd9449b('0x12')][_0xd9449b('0x8')]=function(_0x527d49){const _0x518b9e=_0xd9449b;this[_0x518b9e('0x4')]=rr(this[_0x518b9e('0x1d')]['mapAgentsId']),logger[_0x518b9e('0x1e')](_0x518b9e('0x6'),this[_0x518b9e('0x18')]['id'],this[_0x518b9e('0x4')]),_[_0x518b9e('0x19')](this[_0x518b9e('0x5')][_0x518b9e('0xc')][this[_0x518b9e('0x4')]])?(logger[_0x518b9e('0x1e')](_0x518b9e('0xa'),this[_0x518b9e('0x18')]['id'],this['agentId']),_0x527d49['done'](),setTimeout(this[_0x518b9e('0xf')][_0x518b9e('0x13')](this),0x3e8)):util[_0x518b9e('0x1c')](this['squeue']['id'],this[_0x518b9e('0x5')][_0x518b9e('0xc')][this[_0x518b9e('0x4')]],this[_0x518b9e('0x18')][_0x518b9e('0x17')],!![])?(this['realtime']['agents'][this['agentId']][_0x518b9e('0x11')]=!![],this[_0x518b9e('0x5')][_0x518b9e('0xc')][this[_0x518b9e('0x4')]][_0x518b9e('0x9')]=this[_0x518b9e('0x1d')][_0x518b9e('0x7')],util[_0x518b9e('0xd')](this['notificationId'],this['squeue']['id'],this['realtime'][_0x518b9e('0xc')][this[_0x518b9e('0x4')]],this['queue'],this['routing']),util[_0x518b9e('0x20')](this[_0x518b9e('0x18')]['id'],this[_0x518b9e('0x5')]['agents'][this['agentId']],_0x518b9e('0x0')),this[_0x518b9e('0x1')][this['agentId']]=setInterval(this['handleCheckReject'][_0x518b9e('0x13')](this,_0x527d49),0x3e8)):(logger['info'](_0x518b9e('0x1f'),this['squeue']['id'],this['agentId']),_0x527d49['done'](),setTimeout(this[_0x518b9e('0xf')][_0x518b9e('0x13')](this),0x3e8));},RRMemory[_0xd9449b('0x12')][_0xd9449b('0x10')]=function(_0x32fc64){const _0x3770f7=_0xd9449b;logger['info'](_0x3770f7('0x1a'),this[_0x3770f7('0x18')]['id'],this[_0x3770f7('0x4')]),_['isNil'](this[_0x3770f7('0x5')]['agents'][this['agentId']])?logger[_0x3770f7('0x1e')](_0x3770f7('0xa'),this[_0x3770f7('0x18')]['id'],this['agentId']):(clearInterval(this[_0x3770f7('0x1')][this[_0x3770f7('0x4')]]),util[_0x3770f7('0x21')](this['notificationId'],this[_0x3770f7('0x18')]['id'],this[_0x3770f7('0x5')][_0x3770f7('0xc')][this['agentId']],this[_0x3770f7('0x1d')],this['routing']),util[_0x3770f7('0x20')](this[_0x3770f7('0x18')]['id'],this[_0x3770f7('0x5')]['agents'][this[_0x3770f7('0x4')]],_0x3770f7('0x15')),this[_0x3770f7('0x5')][_0x3770f7('0xc')][this[_0x3770f7('0x4')]][_0x3770f7('0x11')]=![],this['realtime'][_0x3770f7('0xc')][this[_0x3770f7('0x4')]][_0x3770f7('0x9')]=undefined),!_0x32fc64&&setTimeout(this[_0x3770f7('0xf')][_0x3770f7('0x13')](this),0x3e8);};function rrmemory(_0x272ccc,_0x5eaf9d,_0x43745d,_0x34b30e){return new RRMemory(_0x272ccc,_0x5eaf9d,_0x43745d,_0x34b30e);}module[_0xd9449b('0x14')]=rrmemory;
\ No newline at end of file