Built motion from commit (unavailable).|2.4.4
[motion2.git] / server / services / routing / server / applications / queue.js
index 9bdb324..05fa8c4 100644 (file)
@@ -15,4 +15,4 @@
 // * treaties. The SOFTWARE PRODUCT is licensed, not sold.                        *
 // *                                                                       *
 // *************************************************************************
-var _0xaaf5=['name','QueueReport','create','catch','error','create\x20queue\x20report','[%s][STOP:QUEUE][NAME:%s]','timeout','[%s][END:QUEUE][NAME:%s]','update\x20queue\x20report','toLowerCase','length','[%s][QUEUE]\x20%s','map','join','stop','find','Queues','atimeout','qtimeout','end','close','rules','[%s][QUEUE]\x20ROUTING\x20END','next','strategy','beepall','log','stack','validate','lodash','util','moment','ioredis','../../../../config/environment','routing','./strategy','redis','defaults','localhost','socket.io-emitter','queue_id','from','joinAt','queue','account','format','pick','%s:queue:%s','%s_queue_waiting_interaction:%s','save','remove','../../rpc/openchannelQueueReport','../../rpc/mailQueueReport','../../rpc/chatQueueReport','../../rpc/smsQueueReport','../../rpc/faxQueueReport','string','number','timeout\x20is\x20a\x20number','waiting','body','YYYY-MM-DD\x20HH:mm:ss','contact','list','upperFirst','channel','QueueId','InteractionId','interaction','MessageId','message','chat','WebsiteId','info','[%s][START:QUEUE][NAME:%s]'];(function(_0x441f09,_0x46fbdc){var _0x286e78=function(_0x141f42){while(--_0x141f42){_0x441f09['push'](_0x441f09['shift']());}};_0x286e78(++_0x46fbdc);}(_0xaaf5,0x199));var _0x5aaf=function(_0xd514a6,_0x47f47e){_0xd514a6=_0xd514a6-0x0;var _0x39a1bd=_0xaaf5[_0xd514a6];return _0x39a1bd;};'use strict';var schema=require(_0x5aaf('0x0'));var _=require(_0x5aaf('0x1'));var util=require(_0x5aaf('0x2'));var seqqueue=require('seq-queue');var moment=require(_0x5aaf('0x3'));var Redis=require(_0x5aaf('0x4'));var config=require(_0x5aaf('0x5'));var logger=require('../../../../config/logger')(_0x5aaf('0x6'));var strategy=require(_0x5aaf('0x7'));config[_0x5aaf('0x8')]=_[_0x5aaf('0x9')](config[_0x5aaf('0x8')],{'host':_0x5aaf('0xa'),'port':0x18eb});var io=require(_0x5aaf('0xb'))(new Redis(config[_0x5aaf('0x8')]));var attributes=['id',_0x5aaf('0xc'),'account','queue',_0x5aaf('0xd'),_0x5aaf('0xe')];function emit(_0x248e0a,_0x4a33b9,_0x4c2102){io['to'](_0x248e0a)['emit'](_0x4a33b9,_0x4c2102);}function emitChannelQueueInteraction(_0x1107b9,_0x3bcd5b,_0x146b85,_0x2e757c,_0x5dabab,_0xf0d1f6,_0x37ab81,_0x23dd64){_0x146b85[_0x5aaf('0xc')]=_0x23dd64;_0x146b85[_0x5aaf('0xf')]=_0x3bcd5b;_0x146b85[_0x5aaf('0x10')]=_0x2e757c;_0x146b85['id']=_0x5dabab;if(_0xf0d1f6){_0x37ab81[util[_0x5aaf('0x11')]('%sQueuesWaitingInteractions',_0x1107b9)][_0x5dabab]=_[_0x5aaf('0x12')](_0x146b85,attributes);}else{delete _0x37ab81[util[_0x5aaf('0x11')]('%sQueuesWaitingInteractions',_0x1107b9)][_0x5dabab];}emit(util[_0x5aaf('0x11')](_0x5aaf('0x13'),_0x1107b9,_0x3bcd5b),util[_0x5aaf('0x11')](_0x5aaf('0x14'),_0x1107b9,_0xf0d1f6?_0x5aaf('0x15'):_0x5aaf('0x16')),_[_0x5aaf('0x12')](_0x146b85,attributes));}var rpc={'openchannelQueueReport':require(_0x5aaf('0x17')),'mailQueueReport':require(_0x5aaf('0x18')),'chatQueueReport':require(_0x5aaf('0x19')),'smsQueueReport':require(_0x5aaf('0x1a')),'faxQueueReport':require(_0x5aaf('0x1b'))};var queue=schema({'name':{'type':_0x5aaf('0x1c'),'required':!![],'message':'name\x20is\x20a\x20string\x20and\x20it\x20is\x20required'},'timeout':{'type':_0x5aaf('0x1d'),'message':_0x5aaf('0x1e')}});function startRouting(_0x358ec2,_0x281255,_0x251982,_0x14f26b){if(_0x358ec2&&_0x281255&&_0x251982){_0x281255[_0x5aaf('0x1f')]+=0x1;var _0x9cb1aa={'uniqueid':_0x358ec2,'from':_0x251982['body']?_0x251982[_0x5aaf('0x20')][_0x5aaf('0xd')]:'','joinAt':moment()[_0x5aaf('0x11')](_0x5aaf('0x21')),'ContactId':_0x251982[_0x5aaf('0x22')]?_0x251982['contact']['id']:null,'ListId':_0x251982[_0x5aaf('0x23')]?_0x251982[_0x5aaf('0x23')]['id']:null};_0x9cb1aa[_[_0x5aaf('0x24')](_0x251982[_0x5aaf('0x25')])+_0x5aaf('0x26')]=_0x281255['id']||null;_0x9cb1aa[_[_0x5aaf('0x24')](_0x251982['channel'])+_0x5aaf('0x27')]=_0x251982[_0x5aaf('0x28')]?_0x251982[_0x5aaf('0x28')]['id']:null;_0x9cb1aa[_[_0x5aaf('0x24')](_0x251982[_0x5aaf('0x25')])+_0x5aaf('0x29')]=_0x251982[_0x5aaf('0x2a')]?_0x251982[_0x5aaf('0x2a')]['id']:null;_0x9cb1aa[_[_0x5aaf('0x24')](_0x251982[_0x5aaf('0x25')])+(_0x251982[_0x5aaf('0x25')]!==_0x5aaf('0x2b')?'AccountId':_0x5aaf('0x2c'))]=_0x251982[_0x5aaf('0x10')]?_0x251982[_0x5aaf('0x10')]['id']:null;logger[_0x5aaf('0x2d')](util[_0x5aaf('0x11')](_0x5aaf('0x2e'),_0x358ec2,_0x281255[_0x5aaf('0x2f')]));emitChannelQueueInteraction(_0x251982[_0x5aaf('0x25')],_0x281255['name'],_0x9cb1aa,_0x251982[_0x5aaf('0x10')][_0x5aaf('0x2f')],_0x251982['message']['id'],!![],_0x14f26b,_0x281255['id']);if(rpc[_0x251982[_0x5aaf('0x25')]+'QueueReport']){return rpc[_0x251982[_0x5aaf('0x25')]+_0x5aaf('0x30')][_0x5aaf('0x31')](_0x9cb1aa)[_0x5aaf('0x32')](function(_0x3552f8){logger[_0x5aaf('0x33')](_0x5aaf('0x34'));});}}}function stopRouting(_0x385fb7,_0x3b7702,_0x4c6c67,_0x494b87){if(_0x385fb7&&_0x3b7702){_0x3b7702['waiting']-=0x1;var _0x54cb0f={'leaveAt':moment()['format'](_0x5aaf('0x21')),'acceptAt':moment()['format'](_0x5aaf('0x21')),'reason':'accepted'};logger['info'](util[_0x5aaf('0x11')](_0x5aaf('0x35'),_0x385fb7,_0x3b7702[_0x5aaf('0x2f')]));emitChannelQueueInteraction(_0x4c6c67[_0x5aaf('0x25')],_0x3b7702[_0x5aaf('0x2f')],_0x4c6c67[_0x5aaf('0x20')],_0x4c6c67[_0x5aaf('0x10')][_0x5aaf('0x2f')],_0x4c6c67['message']['id'],![],_0x494b87,_0x3b7702['id']);if(rpc[_0x4c6c67[_0x5aaf('0x25')]+_0x5aaf('0x30')]){return rpc[_0x4c6c67[_0x5aaf('0x25')]+'QueueReport']['update'](_0x385fb7,_0x54cb0f)['catch'](function(_0x3ee847){logger[_0x5aaf('0x33')]('update\x20queue\x20report');});}}}function endRouting(_0x36e395,_0x23a8b4,_0x5ed12b,_0x2bec95){if(_0x36e395&&_0x23a8b4){_0x23a8b4['waiting']-=0x1;var _0x5dfe0b={'leaveAt':moment()[_0x5aaf('0x11')](_0x5aaf('0x21')),'exitAt':moment()[_0x5aaf('0x11')](_0x5aaf('0x21')),'reason':_0x5aaf('0x36')};logger[_0x5aaf('0x2d')](util[_0x5aaf('0x11')](_0x5aaf('0x37'),_0x36e395,_0x23a8b4[_0x5aaf('0x2f')]));emitChannelQueueInteraction(_0x5ed12b[_0x5aaf('0x25')],_0x23a8b4[_0x5aaf('0x2f')],_0x5ed12b[_0x5aaf('0x20')],_0x5ed12b[_0x5aaf('0x10')][_0x5aaf('0x2f')],_0x5ed12b['message']['id'],![],_0x2bec95);if(rpc[_0x5ed12b['channel']+_0x5aaf('0x30')]){return rpc[_0x5ed12b[_0x5aaf('0x25')]+_0x5aaf('0x30')]['update'](_0x36e395,_0x5dfe0b)[_0x5aaf('0x32')](function(_0x2d75b0){logger[_0x5aaf('0x33')](_0x5aaf('0x38'));});}}}function handleFindQueue(_0x533c48){return function(_0x484cbe){return _0x484cbe[_0x5aaf('0x2f')]['toLowerCase']()===_0x533c48[_0x5aaf('0x39')]();};}exports['consequence']=function(_0x1485fe,_0x5007c2,_0x574cb5,_0x549d90){return function(_0x15c29c){try{var _0x36d426={'name':_0x5007c2[0x0],'timeout':_0x5007c2[0x1]};var _0x57d282=queue[_0x5aaf('0x0')](_0x36d426,{'typecast':!![]});if(_0x57d282[_0x5aaf('0x3a')]){logger[_0x5aaf('0x33')](_0x5aaf('0x3b'),_0x1485fe,_[_0x5aaf('0x3c')](_0x57d282,_0x5aaf('0x2a'))[_0x5aaf('0x3d')](',\x20'));_0x15c29c[_0x5aaf('0x3e')]();}else{var _0x283ad9=_[_0x5aaf('0x3f')](_0x574cb5[_0x549d90[_0x5aaf('0x25')]+_0x5aaf('0x40')],handleFindQueue(_0x36d426['name']));if(_0x283ad9){startRouting(_0x1485fe,_0x283ad9,_0x549d90,_0x574cb5);var _0x41f312=(_0x283ad9[_0x5aaf('0x36')]||0xa)*0x3e8;var _0x52560c=(_0x36d426[_0x5aaf('0x36')]||0x14)*0x3e8;var _0x1cb213,_0x5e8cb4;if(_0x41f312>_0x52560c){_0x52560c=_0x41f312;}var _0xe2cef9=seqqueue['createQueue'](_0x41f312);_0xe2cef9['id']=_0x1485fe;_0xe2cef9[_0x5aaf('0x41')]=_0x41f312;_0xe2cef9[_0x5aaf('0x42')]=_0x52560c;_0xe2cef9['channel']=_0x549d90[_0x5aaf('0x25')];_0x574cb5['rules'][_0x1485fe]['on'](_0x5aaf('0x43'),function(){stopRouting(_0x1485fe,_0x283ad9,_0x549d90,_0x574cb5);_0xe2cef9[_0x5aaf('0x44')](!![]);clearTimeout(_0x1cb213);_0x1cb213=undefined;if(_0x574cb5['rules'][_0x1485fe]){delete _0x574cb5[_0x5aaf('0x45')][_0x1485fe];}logger[_0x5aaf('0x2d')]('[%s][QUEUE]\x20ROUTING\x20STOPPED',_0x1485fe);_0x15c29c[_0x5aaf('0x3e')]();});_0x1cb213=setTimeout(function(){endRouting(_0x1485fe,_0x283ad9,_0x549d90,_0x574cb5);clearTimeout(_0x1cb213);_0xe2cef9[_0x5aaf('0x44')](!![]);logger['info'](_0x5aaf('0x46'),_0x1485fe);_0x15c29c[_0x5aaf('0x47')]();},_0x52560c);switch(_0x283ad9[_0x5aaf('0x48')]){case'rrmemory':strategy['rrmemory'](_0xe2cef9,_0x283ad9,_0x574cb5,_0x549d90);break;default:strategy[_0x5aaf('0x49')](_0xe2cef9,_0x283ad9,_0x574cb5,_0x549d90);}}else{logger['error']('[%s][QUEUE]\x20queue\x20not\x20found\x20%s',_0x1485fe,_0x36d426[_0x5aaf('0x2f')]);_0x15c29c[_0x5aaf('0x3e')]();}}}catch(_0x373b4d){console[_0x5aaf('0x4a')](_0x373b4d);logger[_0x5aaf('0x33')](_0x5aaf('0x3b'),_0x1485fe,_0x373b4d[_0x5aaf('0x4b')]);_0x15c29c['stop']();}};};
\ No newline at end of file
+var _0xfd92=['strategy','rrmemory','beepall','[%s][QUEUE]\x20queue\x20not\x20found\x20%s','log','stack','validate','lodash','util','ioredis','../../../../config/logger','routing','./strategy','defaults','redis','localhost','queue_id','account','queue','from','joinAt','emit','format','%sQueuesWaitingInteractions','pick','%s:queue:%s','%s_queue_waiting_interaction:%s','../../rpc/openchannelQueueReport','../../rpc/mailQueueReport','../../rpc/chatQueueReport','../../rpc/smsQueueReport','string','name\x20is\x20a\x20string\x20and\x20it\x20is\x20required','number','timeout\x20is\x20a\x20number','waiting','body','contact','list','channel','upperFirst','InteractionId','message','chat','WebsiteId','[%s][START:QUEUE][NAME:%s]','name','QueueReport','catch','error','YYYY-MM-DD\x20HH:mm:ss','accepted','update','update\x20queue\x20report','timeout','info','toLowerCase','consequence','length','[%s][QUEUE]\x20%s','join','stop','find','Queues','qtimeout','rules','close','[%s][QUEUE]\x20ROUTING\x20END'];(function(_0x1c5a7d,_0xed14f8){var _0x2d736d=function(_0x5f2d57){while(--_0x5f2d57){_0x1c5a7d['push'](_0x1c5a7d['shift']());}};_0x2d736d(++_0xed14f8);}(_0xfd92,0x116));var _0x2fd9=function(_0x5f3562,_0x212f41){_0x5f3562=_0x5f3562-0x0;var _0x1b39b4=_0xfd92[_0x5f3562];return _0x1b39b4;};'use strict';var schema=require(_0x2fd9('0x0'));var _=require(_0x2fd9('0x1'));var util=require(_0x2fd9('0x2'));var seqqueue=require('seq-queue');var moment=require('moment');var Redis=require(_0x2fd9('0x3'));var config=require('../../../../config/environment');var logger=require(_0x2fd9('0x4'))(_0x2fd9('0x5'));var strategy=require(_0x2fd9('0x6'));config['redis']=_[_0x2fd9('0x7')](config[_0x2fd9('0x8')],{'host':_0x2fd9('0x9'),'port':0x18eb});var io=require('socket.io-emitter')(new Redis(config['redis']));var attributes=['id',_0x2fd9('0xa'),_0x2fd9('0xb'),_0x2fd9('0xc'),_0x2fd9('0xd'),_0x2fd9('0xe')];function emit(_0x3facf4,_0x1c0c75,_0x4d9d36){io['to'](_0x3facf4)[_0x2fd9('0xf')](_0x1c0c75,_0x4d9d36);}function emitChannelQueueInteraction(_0x59bbf5,_0x9aaac9,_0x4fb807,_0x275206,_0x18b38c,_0xdcb59d,_0x222989,_0x4fc42d){_0x4fb807['queue_id']=_0x4fc42d;_0x4fb807['queue']=_0x9aaac9;_0x4fb807[_0x2fd9('0xb')]=_0x275206;_0x4fb807['id']=_0x18b38c;if(_0xdcb59d){_0x222989[util[_0x2fd9('0x10')](_0x2fd9('0x11'),_0x59bbf5)][_0x18b38c]=_[_0x2fd9('0x12')](_0x4fb807,attributes);}else{delete _0x222989[util[_0x2fd9('0x10')](_0x2fd9('0x11'),_0x59bbf5)][_0x18b38c];}emit(util['format'](_0x2fd9('0x13'),_0x59bbf5,_0x9aaac9),util[_0x2fd9('0x10')](_0x2fd9('0x14'),_0x59bbf5,_0xdcb59d?'save':'remove'),_[_0x2fd9('0x12')](_0x4fb807,attributes));}var rpc={'openchannelQueueReport':require(_0x2fd9('0x15')),'mailQueueReport':require(_0x2fd9('0x16')),'chatQueueReport':require(_0x2fd9('0x17')),'smsQueueReport':require(_0x2fd9('0x18')),'faxQueueReport':require('../../rpc/faxQueueReport')};var queue=schema({'name':{'type':_0x2fd9('0x19'),'required':!![],'message':_0x2fd9('0x1a')},'timeout':{'type':_0x2fd9('0x1b'),'message':_0x2fd9('0x1c')}});function startRouting(_0x438f70,_0x2c6257,_0x2dd180,_0x5360c8){if(_0x438f70&&_0x2c6257&&_0x2dd180){_0x2c6257[_0x2fd9('0x1d')]+=0x1;var _0x35a053={'uniqueid':_0x438f70,'from':_0x2dd180[_0x2fd9('0x1e')]?_0x2dd180[_0x2fd9('0x1e')][_0x2fd9('0xd')]:'','joinAt':moment()[_0x2fd9('0x10')]('YYYY-MM-DD\x20HH:mm:ss'),'ContactId':_0x2dd180[_0x2fd9('0x1f')]?_0x2dd180[_0x2fd9('0x1f')]['id']:null,'ListId':_0x2dd180[_0x2fd9('0x20')]?_0x2dd180['list']['id']:null};_0x35a053[_['upperFirst'](_0x2dd180[_0x2fd9('0x21')])+'QueueId']=_0x2c6257['id']||null;_0x35a053[_[_0x2fd9('0x22')](_0x2dd180['channel'])+_0x2fd9('0x23')]=_0x2dd180['interaction']?_0x2dd180['interaction']['id']:null;_0x35a053[_[_0x2fd9('0x22')](_0x2dd180['channel'])+'MessageId']=_0x2dd180['message']?_0x2dd180[_0x2fd9('0x24')]['id']:null;_0x35a053[_[_0x2fd9('0x22')](_0x2dd180[_0x2fd9('0x21')])+(_0x2dd180[_0x2fd9('0x21')]!==_0x2fd9('0x25')?'AccountId':_0x2fd9('0x26'))]=_0x2dd180[_0x2fd9('0xb')]?_0x2dd180[_0x2fd9('0xb')]['id']:null;logger['info'](util['format'](_0x2fd9('0x27'),_0x438f70,_0x2c6257[_0x2fd9('0x28')]));emitChannelQueueInteraction(_0x2dd180['channel'],_0x2c6257['name'],_0x35a053,_0x2dd180[_0x2fd9('0xb')][_0x2fd9('0x28')],_0x2dd180['message']['id'],!![],_0x5360c8,_0x2c6257['id']);if(rpc[_0x2dd180[_0x2fd9('0x21')]+_0x2fd9('0x29')]){return rpc[_0x2dd180[_0x2fd9('0x21')]+_0x2fd9('0x29')]['create'](_0x35a053)[_0x2fd9('0x2a')](function(_0xb93b24){logger[_0x2fd9('0x2b')]('create\x20queue\x20report');});}}}function stopRouting(_0x8f64ab,_0x243cfd,_0x4c2f88,_0x2b465a){if(_0x8f64ab&&_0x243cfd){_0x243cfd[_0x2fd9('0x1d')]-=0x1;var _0x4ee506={'leaveAt':moment()[_0x2fd9('0x10')](_0x2fd9('0x2c')),'acceptAt':moment()[_0x2fd9('0x10')]('YYYY-MM-DD\x20HH:mm:ss'),'reason':_0x2fd9('0x2d')};logger['info'](util[_0x2fd9('0x10')]('[%s][STOP:QUEUE][NAME:%s]',_0x8f64ab,_0x243cfd[_0x2fd9('0x28')]));emitChannelQueueInteraction(_0x4c2f88[_0x2fd9('0x21')],_0x243cfd[_0x2fd9('0x28')],_0x4c2f88[_0x2fd9('0x1e')],_0x4c2f88[_0x2fd9('0xb')][_0x2fd9('0x28')],_0x4c2f88[_0x2fd9('0x24')]['id'],![],_0x2b465a,_0x243cfd['id']);if(rpc[_0x4c2f88[_0x2fd9('0x21')]+_0x2fd9('0x29')]){return rpc[_0x4c2f88['channel']+_0x2fd9('0x29')][_0x2fd9('0x2e')](_0x8f64ab,_0x4ee506)['catch'](function(_0x1e738c){logger['error'](_0x2fd9('0x2f'));});}}}function endRouting(_0x19da11,_0x2ea57c,_0x4a1a57,_0x2bdd8c){if(_0x19da11&&_0x2ea57c){_0x2ea57c['waiting']-=0x1;var _0x1eebf5={'leaveAt':moment()['format'](_0x2fd9('0x2c')),'exitAt':moment()['format'](_0x2fd9('0x2c')),'reason':_0x2fd9('0x30')};logger[_0x2fd9('0x31')](util[_0x2fd9('0x10')]('[%s][END:QUEUE][NAME:%s]',_0x19da11,_0x2ea57c[_0x2fd9('0x28')]));emitChannelQueueInteraction(_0x4a1a57[_0x2fd9('0x21')],_0x2ea57c[_0x2fd9('0x28')],_0x4a1a57[_0x2fd9('0x1e')],_0x4a1a57['account'][_0x2fd9('0x28')],_0x4a1a57[_0x2fd9('0x24')]['id'],![],_0x2bdd8c);if(rpc[_0x4a1a57[_0x2fd9('0x21')]+_0x2fd9('0x29')]){return rpc[_0x4a1a57[_0x2fd9('0x21')]+_0x2fd9('0x29')][_0x2fd9('0x2e')](_0x19da11,_0x1eebf5)[_0x2fd9('0x2a')](function(_0x517b85){logger[_0x2fd9('0x2b')]('update\x20queue\x20report');});}}}function handleFindQueue(_0x4f38f0){return function(_0x1ca570){return _0x1ca570[_0x2fd9('0x28')][_0x2fd9('0x32')]()===_0x4f38f0[_0x2fd9('0x32')]();};}exports[_0x2fd9('0x33')]=function(_0x84f4f7,_0x548c09,_0x17c10c,_0x567c21){return function(_0x1bcc4f){try{var _0x22e589={'name':_0x548c09[0x0],'timeout':_0x548c09[0x1]};var _0x51269b=queue[_0x2fd9('0x0')](_0x22e589,{'typecast':!![]});if(_0x51269b[_0x2fd9('0x34')]){logger[_0x2fd9('0x2b')](_0x2fd9('0x35'),_0x84f4f7,_['map'](_0x51269b,'message')[_0x2fd9('0x36')](',\x20'));_0x1bcc4f[_0x2fd9('0x37')]();}else{var _0x2cc3c6=_[_0x2fd9('0x38')](_0x17c10c[_0x567c21['channel']+_0x2fd9('0x39')],handleFindQueue(_0x22e589[_0x2fd9('0x28')]));if(_0x2cc3c6){startRouting(_0x84f4f7,_0x2cc3c6,_0x567c21,_0x17c10c);var _0x53c5ad=(_0x2cc3c6['timeout']||0xa)*0x3e8;var _0x19f434=(_0x22e589['timeout']||0x14)*0x3e8;var _0x13f95b,_0x5d8b0e;if(_0x53c5ad>_0x19f434){_0x19f434=_0x53c5ad;}var _0x3cca02=seqqueue['createQueue'](_0x53c5ad);_0x3cca02['id']=_0x84f4f7;_0x3cca02['atimeout']=_0x53c5ad;_0x3cca02[_0x2fd9('0x3a')]=_0x19f434;_0x3cca02[_0x2fd9('0x21')]=_0x567c21[_0x2fd9('0x21')];_0x17c10c[_0x2fd9('0x3b')][_0x84f4f7]['on']('end',function(){stopRouting(_0x84f4f7,_0x2cc3c6,_0x567c21,_0x17c10c);_0x3cca02['close'](!![]);clearTimeout(_0x13f95b);_0x13f95b=undefined;if(_0x17c10c['rules'][_0x84f4f7]){delete _0x17c10c[_0x2fd9('0x3b')][_0x84f4f7];}logger[_0x2fd9('0x31')]('[%s][QUEUE]\x20ROUTING\x20STOPPED',_0x84f4f7);_0x1bcc4f[_0x2fd9('0x37')]();});_0x13f95b=setTimeout(function(){endRouting(_0x84f4f7,_0x2cc3c6,_0x567c21,_0x17c10c);clearTimeout(_0x13f95b);_0x3cca02[_0x2fd9('0x3c')](!![]);logger[_0x2fd9('0x31')](_0x2fd9('0x3d'),_0x84f4f7);_0x1bcc4f['next']();},_0x19f434);switch(_0x2cc3c6[_0x2fd9('0x3e')]){case _0x2fd9('0x3f'):strategy[_0x2fd9('0x3f')](_0x3cca02,_0x2cc3c6,_0x17c10c,_0x567c21);break;default:strategy[_0x2fd9('0x40')](_0x3cca02,_0x2cc3c6,_0x17c10c,_0x567c21);}}else{logger['error'](_0x2fd9('0x41'),_0x84f4f7,_0x22e589[_0x2fd9('0x28')]);_0x1bcc4f[_0x2fd9('0x37')]();}}}catch(_0x1234e9){console[_0x2fd9('0x42')](_0x1234e9);logger['error'](_0x2fd9('0x35'),_0x84f4f7,_0x1234e9[_0x2fd9('0x43')]);_0x1bcc4f[_0x2fd9('0x37')]();}};};
\ No newline at end of file