server/services/routing/server/applications/strategy/rrmemory.js

   1 const a1382_0x25b3=['handleCheckReject','bind','handleRun','handleTimeout','hideNotification','[%s][QUEUE]\x20agent\x20skipped,\x20unknown\x20id\x20%s','[%s][QUEUE]\x20agent\x20skipped,\x20not\x20available\x20id\x20%s','mapAgentsId','agentId','prototype','handleDrained','info','uuid','showNotification','squeue','intervals','done','notificationId','writeLog','module','isNil','push','isAgentAvailable','channel','../../../../../config/logger','routing','TIMEOUT','realtime','agents','name','queue','exports','busyQueue','[%s][QUEUE]\x20try\x20with\x20%s','busy'];(function(_0x199b37,_0x37e3){const _0x25b34f=function(_0x3f1502){while(--_0x3f1502){_0x199b37['push'](_0x199b37['shift']());}};_0x25b34f(++_0x37e3);}(a1382_0x25b3,0x65));const a1382_0x3f15=function(_0x199b37,_0x37e3){_0x199b37=_0x199b37-0xd9;let _0x25b34f=a1382_0x25b3[_0x199b37];return _0x25b34f;};const a1382_0x8350e3=a1382_0x3f15;'use strict';const rr=require('rr'),_=require('lodash'),uuid=require(a1382_0x8350e3(0xe9)),util=require('./util'),logger=require(a1382_0x8350e3(0xf5))(a1382_0x8350e3(0xf6)),RRMemory=function(_0x42c832,_0x29900c,_0x54aedc,_0x1936ca){const _0x444285=a1382_0x8350e3;this['notificationId']=uuid['v4'](),this[_0x444285(0xeb)]=_0x42c832,this['queue']=_0x29900c,this[_0x444285(0xf8)]=_0x54aedc,this[_0x444285(0xf6)]=_0x1936ca,this[_0x444285(0xec)]={},this[_0x444285(0xeb)]['push'](this[_0x444285(0xdf)][_0x444285(0xde)](this),this[_0x444285(0xe0)]['bind'](this),this[_0x444285(0xf0)]),this[_0x444285(0xeb)]['on']('timeout',this['handleTimeout']['bind'](this)),this[_0x444285(0xeb)]['on']('drained',this['handleDrained'][_0x444285(0xde)](this));};RRMemory[a1382_0x8350e3(0xe6)][a1382_0x8350e3(0xf2)]=function(){const _0x681409=a1382_0x8350e3;this[_0x681409(0xeb)][_0x681409(0xf2)](this[_0x681409(0xdf)][_0x681409(0xde)](this),this[_0x681409(0xe0)]['bind'](this));},RRMemory[a1382_0x8350e3(0xe6)][a1382_0x8350e3(0xe7)]=function(){const _0x39106a=a1382_0x8350e3;this[_0x39106a(0xe0)](!![]);},RRMemory[a1382_0x8350e3(0xe6)][a1382_0x8350e3(0xdd)]=function(_0x5c2174){const _0x4f9e09=a1382_0x8350e3;util[_0x4f9e09(0xf3)](this[_0x4f9e09(0xeb)]['id'],this[_0x4f9e09(0xf8)]['agents'][this[_0x4f9e09(0xe5)]],this[_0x4f9e09(0xeb)][_0x4f9e09(0xf4)],!![])&&(logger[_0x4f9e09(0xe8)]('[%s][QUEUE]\x20available\x20again\x20%s',this[_0x4f9e09(0xeb)]['id'],this[_0x4f9e09(0xe5)]),clearInterval(this[_0x4f9e09(0xec)][this[_0x4f9e09(0xe5)]]),_0x5c2174[_0x4f9e09(0xed)](),setTimeout(this[_0x4f9e09(0xf2)][_0x4f9e09(0xde)](this),0x3e8));},RRMemory[a1382_0x8350e3(0xe6)][a1382_0x8350e3(0xdf)]=function(_0x5b582c){const _0x1e41d3=a1382_0x8350e3;this[_0x1e41d3(0xe5)]=rr(this[_0x1e41d3(0xfb)][_0x1e41d3(0xe4)]),logger['info'](_0x1e41d3(0xdb),this[_0x1e41d3(0xeb)]['id'],this['agentId']),_[_0x1e41d3(0xf1)](this[_0x1e41d3(0xf8)][_0x1e41d3(0xf9)][this[_0x1e41d3(0xe5)]])?(logger[_0x1e41d3(0xe8)](_0x1e41d3(0xe2),this[_0x1e41d3(0xeb)]['id'],this[_0x1e41d3(0xe5)]),_0x5b582c[_0x1e41d3(0xed)](),setTimeout(this[_0x1e41d3(0xf2)][_0x1e41d3(0xde)](this),0x3e8)):util['isAgentAvailable'](this[_0x1e41d3(0xeb)]['id'],this[_0x1e41d3(0xf8)][_0x1e41d3(0xf9)][this[_0x1e41d3(0xe5)]],this[_0x1e41d3(0xeb)][_0x1e41d3(0xf4)],!![])?(this[_0x1e41d3(0xf8)][_0x1e41d3(0xf9)][this[_0x1e41d3(0xe5)]][_0x1e41d3(0xdc)]=!![],this[_0x1e41d3(0xf8)]['agents'][this[_0x1e41d3(0xe5)]][_0x1e41d3(0xda)]=this[_0x1e41d3(0xfb)][_0x1e41d3(0xfa)],util[_0x1e41d3(0xea)](this[_0x1e41d3(0xee)],this['squeue']['id'],this[_0x1e41d3(0xf8)][_0x1e41d3(0xf9)][this[_0x1e41d3(0xe5)]],this[_0x1e41d3(0xfb)],this[_0x1e41d3(0xf6)]),util[_0x1e41d3(0xef)](this[_0x1e41d3(0xeb)]['id'],this[_0x1e41d3(0xf8)][_0x1e41d3(0xf9)][this[_0x1e41d3(0xe5)]],'RINGING'),this[_0x1e41d3(0xec)][this[_0x1e41d3(0xe5)]]=setInterval(this[_0x1e41d3(0xdd)][_0x1e41d3(0xde)](this,_0x5b582c),0x3e8)):(logger[_0x1e41d3(0xe8)](_0x1e41d3(0xe3),this[_0x1e41d3(0xeb)]['id'],this['agentId']),_0x5b582c[_0x1e41d3(0xed)](),setTimeout(this[_0x1e41d3(0xf2)][_0x1e41d3(0xde)](this),0x3e8));},RRMemory[a1382_0x8350e3(0xe6)][a1382_0x8350e3(0xe0)]=function(_0x47b8e3){const _0xa5e001=a1382_0x8350e3;logger[_0xa5e001(0xe8)]('[%s][QUEUE]\x20timeout\x20with\x20%s',this[_0xa5e001(0xeb)]['id'],this[_0xa5e001(0xe5)]),_[_0xa5e001(0xf1)](this[_0xa5e001(0xf8)][_0xa5e001(0xf9)][this[_0xa5e001(0xe5)]])?logger[_0xa5e001(0xe8)]('[%s][QUEUE]\x20agent\x20skipped,\x20unknown\x20id\x20%s',this[_0xa5e001(0xeb)]['id'],this[_0xa5e001(0xe5)]):(clearInterval(this[_0xa5e001(0xec)][this['agentId']]),util[_0xa5e001(0xe1)](this[_0xa5e001(0xee)],this[_0xa5e001(0xeb)]['id'],this[_0xa5e001(0xf8)][_0xa5e001(0xf9)][this['agentId']],this['queue'],this[_0xa5e001(0xf6)]),util['writeLog'](this['squeue']['id'],this[_0xa5e001(0xf8)][_0xa5e001(0xf9)][this[_0xa5e001(0xe5)]],_0xa5e001(0xf7)),this[_0xa5e001(0xf8)][_0xa5e001(0xf9)][this[_0xa5e001(0xe5)]]['busy']=![],this[_0xa5e001(0xf8)][_0xa5e001(0xf9)][this['agentId']][_0xa5e001(0xda)]=undefined),!_0x47b8e3&&setTimeout(this[_0xa5e001(0xf2)][_0xa5e001(0xde)](this),0x3e8);};function rrmemory(_0xe5ca9d,_0x4bae7f,_0x5f3688,_0x2162b2){return new RRMemory(_0xe5ca9d,_0x4bae7f,_0x5f3688,_0x2162b2);}module[a1382_0x8350e3(0xd9)]=rrmemory;