Built motion from commit f3da74b7.|2.5.36
[motion2.git] / server / services / routing / server / applications / queue.js
index 4ce680b..fa8e00f 100644 (file)
@@ -15,4 +15,4 @@
 // * treaties. The SOFTWARE PRODUCT is licensed, not sold.                        *
 // *                                                                       *
 // *************************************************************************
-var _0x90fd=['timeout','[%s][END:QUEUE][NAME:%s]','update\x20queue\x20report','consequence','length','[%s][QUEUE]\x20%s','map','join','stop','createQueue','atimeout','qtimeout','rules','end','[%s][QUEUE]\x20ROUTING\x20STOPPED','close','complete','info','[%s][QUEUE]\x20APPLICATION\x20END','next','strategy','rrmemory','beepall','[%s][QUEUE]\x20queue\x20not\x20found\x20%s','log','validate','lodash','util','seq-queue','moment','ioredis','../../../../config/environment','../../../../config/logger','./strategy','redis','localhost','socket.io-emitter','queue_id','joinAt','emit','clone','queue','account','%sQueuesWaitingInteractions','pick','format','%s_queue_waiting_interaction:%s','save','remove','../../rpc/mailQueueReport','../../rpc/chatQueueReport','../../rpc/smsQueueReport','../../rpc/whatsappQueueReport','string','name\x20is\x20a\x20string\x20and\x20it\x20is\x20required','number','timeout\x20is\x20a\x20number','waiting','body','from','YYYY-MM-DD\x20HH:mm:ss','contact','upperFirst','QueueId','channel','InteractionId','interaction','MessageId','message','chat','AccountId','WebsiteId','name','QueueReport','catch','error','create\x20queue\x20report','accepted','[%s][STOP:QUEUE][NAME:%s]','update'];(function(_0xee9ecf,_0x1819a8){var _0x1e448c=function(_0x402111){while(--_0x402111){_0xee9ecf['push'](_0xee9ecf['shift']());}};_0x1e448c(++_0x1819a8);}(_0x90fd,0x1a9));var _0xd90f=function(_0x275ff4,_0x3f085e){_0x275ff4=_0x275ff4-0x0;var _0x21cbf7=_0x90fd[_0x275ff4];return _0x21cbf7;};'use strict';var schema=require(_0xd90f('0x0'));var _=require(_0xd90f('0x1'));var util=require(_0xd90f('0x2'));var seqqueue=require(_0xd90f('0x3'));var moment=require(_0xd90f('0x4'));var Redis=require(_0xd90f('0x5'));var config=require(_0xd90f('0x6'));var logger=require(_0xd90f('0x7'))('routing');var strategy=require(_0xd90f('0x8'));config['redis']=_['defaults'](config[_0xd90f('0x9')],{'host':_0xd90f('0xa'),'port':0x18eb});var io=require(_0xd90f('0xb'))(new Redis(config[_0xd90f('0x9')]));var attributes=['id',_0xd90f('0xc'),'account','queue','from',_0xd90f('0xd')];function emit(_0x266385,_0x272fe8,_0x5d8f3d){io['to'](_0x266385)[_0xd90f('0xe')](_0x272fe8,_0x5d8f3d);}function emitChannelQueueInteraction(_0x3a9259,_0x58a0d7,_0x56e1e0,_0xe33b8b,_0x4f9e44,_0x18c992,_0x13855f,_0x47e0e3){var _0x38763f=_[_0xd90f('0xf')](_0x56e1e0);_0x38763f['queue_id']=_0x47e0e3;_0x38763f[_0xd90f('0x10')]=_0x58a0d7;_0x38763f[_0xd90f('0x11')]=_0xe33b8b;_0x38763f['id']=_0x4f9e44;if(_0x18c992){_0x13855f[util['format'](_0xd90f('0x12'),_0x3a9259)][_0x4f9e44]=_[_0xd90f('0x13')](_0x38763f,attributes);}else{delete _0x13855f[util[_0xd90f('0x14')](_0xd90f('0x12'),_0x3a9259)][_0x4f9e44];}emit(util[_0xd90f('0x14')]('%s:queue:%s',_0x3a9259,_0x58a0d7),util['format'](_0xd90f('0x15'),_0x3a9259,_0x18c992?_0xd90f('0x16'):_0xd90f('0x17')),_['pick'](_0x38763f,attributes));}var rpc={'openchannelQueueReport':require('../../rpc/openchannelQueueReport'),'mailQueueReport':require(_0xd90f('0x18')),'chatQueueReport':require(_0xd90f('0x19')),'smsQueueReport':require(_0xd90f('0x1a')),'faxQueueReport':require('../../rpc/faxQueueReport'),'whatsappQueueReport':require(_0xd90f('0x1b'))};var queue=schema({'name':{'type':_0xd90f('0x1c'),'required':!![],'message':_0xd90f('0x1d')},'timeout':{'type':_0xd90f('0x1e'),'message':_0xd90f('0x1f')}});function startRouting(_0x26b33d,_0x1127b8,_0x276162,_0x200fbe){if(_0x26b33d&&_0x1127b8&&_0x276162){_0x1127b8[_0xd90f('0x20')]+=0x1;var _0x29834c={'uniqueid':_0x26b33d,'from':_0x276162[_0xd90f('0x21')]?_0x276162['body'][_0xd90f('0x22')]:'','joinAt':moment()[_0xd90f('0x14')](_0xd90f('0x23')),'ContactId':_0x276162['contact']?_0x276162[_0xd90f('0x24')]['id']:null,'ListId':_0x276162['list']?_0x276162['list']['id']:null};_0x29834c[_[_0xd90f('0x25')](_0x276162['channel'])+_0xd90f('0x26')]=_0x1127b8['id']||null;_0x29834c[_[_0xd90f('0x25')](_0x276162[_0xd90f('0x27')])+_0xd90f('0x28')]=_0x276162[_0xd90f('0x29')]?_0x276162[_0xd90f('0x29')]['id']:null;_0x29834c[_[_0xd90f('0x25')](_0x276162[_0xd90f('0x27')])+_0xd90f('0x2a')]=_0x276162[_0xd90f('0x2b')]?_0x276162[_0xd90f('0x2b')]['id']:null;_0x29834c[_[_0xd90f('0x25')](_0x276162['channel'])+(_0x276162[_0xd90f('0x27')]!==_0xd90f('0x2c')?_0xd90f('0x2d'):_0xd90f('0x2e'))]=_0x276162[_0xd90f('0x11')]?_0x276162[_0xd90f('0x11')]['id']:null;logger['info'](util[_0xd90f('0x14')]('[%s][START:QUEUE][NAME:%s]',_0x26b33d,_0x1127b8[_0xd90f('0x2f')]));emitChannelQueueInteraction(_0x276162[_0xd90f('0x27')],_0x1127b8[_0xd90f('0x2f')],_0x29834c,_0x276162[_0xd90f('0x11')][_0xd90f('0x2f')],_0x276162['message']['id'],!![],_0x200fbe,_0x1127b8['id']);if(rpc[_0x276162['channel']+_0xd90f('0x30')]){return rpc[_0x276162[_0xd90f('0x27')]+_0xd90f('0x30')]['create'](_0x29834c)[_0xd90f('0x31')](function(_0x4fd643){logger[_0xd90f('0x32')](_0xd90f('0x33'));});}}}function stopRouting(_0x14bc3b,_0x13ff90,_0x29a56f,_0x207c25){if(_0x14bc3b&&_0x13ff90){_0x13ff90[_0xd90f('0x20')]-=0x1;var _0x4011b2={'leaveAt':moment()[_0xd90f('0x14')]('YYYY-MM-DD\x20HH:mm:ss'),'acceptAt':moment()[_0xd90f('0x14')](_0xd90f('0x23')),'reason':_0xd90f('0x34')};logger['info'](util[_0xd90f('0x14')](_0xd90f('0x35'),_0x14bc3b,_0x13ff90[_0xd90f('0x2f')]));emitChannelQueueInteraction(_0x29a56f[_0xd90f('0x27')],_0x13ff90[_0xd90f('0x2f')],_0x29a56f['body'],_0x29a56f[_0xd90f('0x11')][_0xd90f('0x2f')],_0x29a56f[_0xd90f('0x2b')]['id'],![],_0x207c25,_0x13ff90['id']);if(rpc[_0x29a56f['channel']+'QueueReport']){return rpc[_0x29a56f[_0xd90f('0x27')]+_0xd90f('0x30')][_0xd90f('0x36')](_0x14bc3b,_0x4011b2)['catch'](function(_0x41aa5d){logger[_0xd90f('0x32')]('update\x20queue\x20report');});}}}function endRouting(_0x24cc70,_0x5eac1f,_0x124249,_0x1b0115){if(_0x24cc70&&_0x5eac1f){_0x5eac1f[_0xd90f('0x20')]-=0x1;var _0x4f8a69={'leaveAt':moment()[_0xd90f('0x14')](_0xd90f('0x23')),'exitAt':moment()[_0xd90f('0x14')](_0xd90f('0x23')),'reason':_0xd90f('0x37')};logger['info'](util[_0xd90f('0x14')](_0xd90f('0x38'),_0x24cc70,_0x5eac1f[_0xd90f('0x2f')]));emitChannelQueueInteraction(_0x124249[_0xd90f('0x27')],_0x5eac1f['name'],_0x124249[_0xd90f('0x21')],_0x124249[_0xd90f('0x11')][_0xd90f('0x2f')],_0x124249[_0xd90f('0x2b')]['id'],![],_0x1b0115);if(rpc[_0x124249[_0xd90f('0x27')]+_0xd90f('0x30')]){return rpc[_0x124249[_0xd90f('0x27')]+_0xd90f('0x30')]['update'](_0x24cc70,_0x4f8a69)['catch'](function(_0x555f79){logger[_0xd90f('0x32')](_0xd90f('0x39'));});}}}function handleFindQueue(_0x4ed93d){return function(_0x18386e){return _0x18386e[_0xd90f('0x2f')]['toLowerCase']()===_0x4ed93d['toLowerCase']();};}exports[_0xd90f('0x3a')]=function(_0x30493c,_0x46d44b,_0x10052b,_0x2cb646){return function(_0x13d611){try{var _0x128cd1={'name':_0x46d44b[0x0],'timeout':_0x46d44b[0x1]};var _0x2d5b15=queue[_0xd90f('0x0')](_0x128cd1,{'typecast':!![]});if(_0x2d5b15[_0xd90f('0x3b')]){logger[_0xd90f('0x32')](_0xd90f('0x3c'),_0x30493c,_[_0xd90f('0x3d')](_0x2d5b15,'message')[_0xd90f('0x3e')](',\x20'));_0x13d611[_0xd90f('0x3f')]();}else{var _0x36121b=_['find'](_0x10052b[_0x2cb646[_0xd90f('0x27')]+'Queues'],handleFindQueue(_0x128cd1['name']));if(_0x36121b){startRouting(_0x30493c,_0x36121b,_0x2cb646,_0x10052b);var _0x2b60fc=(_0x36121b[_0xd90f('0x37')]||0xa)*0x3e8;var _0x2475b7=(_0x128cd1[_0xd90f('0x37')]||0x14)*0x3e8;var _0x17a2a2,_0x584070;if(_0x2b60fc>_0x2475b7){_0x2475b7=_0x2b60fc;}var _0x350ec5=seqqueue[_0xd90f('0x40')](_0x2b60fc);_0x350ec5['id']=_0x30493c;_0x350ec5[_0xd90f('0x41')]=_0x2b60fc;_0x350ec5[_0xd90f('0x42')]=_0x2475b7;_0x350ec5['channel']=_0x2cb646[_0xd90f('0x27')];_0x10052b[_0xd90f('0x43')][_0x30493c]['on'](_0xd90f('0x44'),function(){logger['info'](_0xd90f('0x45'),_0x30493c);stopRouting(_0x30493c,_0x36121b,_0x2cb646,_0x10052b);clearTimeout(_0x17a2a2);_0x17a2a2=undefined;_0x350ec5[_0xd90f('0x46')](!![]);if(_0x10052b[_0xd90f('0x43')][_0x30493c]){delete _0x10052b[_0xd90f('0x43')][_0x30493c];}_0x13d611[_0xd90f('0x3f')]();});_0x10052b[_0xd90f('0x43')][_0x30493c]['on'](_0xd90f('0x47'),function(){if(_0x10052b[_0xd90f('0x43')][_0x30493c]){delete _0x10052b[_0xd90f('0x43')][_0x30493c];}});_0x17a2a2=setTimeout(function(){logger[_0xd90f('0x48')](_0xd90f('0x49'),_0x30493c);endRouting(_0x30493c,_0x36121b,_0x2cb646,_0x10052b);clearTimeout(_0x17a2a2);_0x350ec5[_0xd90f('0x46')](!![]);_0x13d611[_0xd90f('0x4a')]();},_0x2475b7);switch(_0x36121b[_0xd90f('0x4b')]){case _0xd90f('0x4c'):strategy[_0xd90f('0x4c')](_0x350ec5,_0x36121b,_0x10052b,_0x2cb646);break;default:strategy[_0xd90f('0x4d')](_0x350ec5,_0x36121b,_0x10052b,_0x2cb646);}}else{logger[_0xd90f('0x32')](_0xd90f('0x4e'),_0x30493c,_0x128cd1[_0xd90f('0x2f')]);_0x13d611[_0xd90f('0x3f')]();}}}catch(_0x3eb85c){console[_0xd90f('0x4f')](_0x3eb85c);logger[_0xd90f('0x32')](_0xd90f('0x3c'),_0x30493c,_0x3eb85c['stack']);_0x13d611[_0xd90f('0x3f')]();}};};
\ No newline at end of file
+var _0x71f6=['timeout\x20is\x20a\x20number','waiting','body','from','YYYY-MM-DD\x20HH:mm:ss','contact','upperFirst','channel','QueueId','interaction','message','chat','AccountId','info','[%s][START:QUEUE][NAME:%s]','name','QueueReport','catch','error','create\x20queue\x20report','accepted','[%s][STOP:QUEUE][NAME:%s]','update\x20queue\x20report','timeout','update','toLowerCase','consequence','validate','length','[%s][QUEUE]\x20%s','map','join','stop','Queues','createQueue','atimeout','qtimeout','rules','[%s][QUEUE]\x20ROUTING\x20STOPPED','close','complete','[%s][QUEUE]\x20APPLICATION\x20END','next','strategy','rrmemory','beepall','log','stack','lodash','seq-queue','moment','ioredis','../../../../config/logger','routing','./strategy','redis','defaults','socket.io-emitter','queue_id','account','queue','joinAt','emit','clone','format','%sQueuesWaitingInteractions','pick','%s:queue:%s','save','remove','../../rpc/openchannelQueueReport','../../rpc/mailQueueReport','../../rpc/chatQueueReport','../../rpc/whatsappQueueReport','name\x20is\x20a\x20string\x20and\x20it\x20is\x20required','number'];(function(_0x39853d,_0x2501bf){var _0x5864ca=function(_0xbc99d5){while(--_0xbc99d5){_0x39853d['push'](_0x39853d['shift']());}};_0x5864ca(++_0x2501bf);}(_0x71f6,0x1ac));var _0x671f=function(_0x545c00,_0x5f026e){_0x545c00=_0x545c00-0x0;var _0x3f0f48=_0x71f6[_0x545c00];return _0x3f0f48;};'use strict';var schema=require('validate');var _=require(_0x671f('0x0'));var util=require('util');var seqqueue=require(_0x671f('0x1'));var moment=require(_0x671f('0x2'));var Redis=require(_0x671f('0x3'));var config=require('../../../../config/environment');var logger=require(_0x671f('0x4'))(_0x671f('0x5'));var strategy=require(_0x671f('0x6'));config[_0x671f('0x7')]=_[_0x671f('0x8')](config[_0x671f('0x7')],{'host':'localhost','port':0x18eb});var io=require(_0x671f('0x9'))(new Redis(config[_0x671f('0x7')]));var attributes=['id',_0x671f('0xa'),_0x671f('0xb'),_0x671f('0xc'),'from',_0x671f('0xd')];function emit(_0x337ebd,_0x475334,_0x3f0204){io['to'](_0x337ebd)[_0x671f('0xe')](_0x475334,_0x3f0204);}function emitChannelQueueInteraction(_0x5e633b,_0x578f1b,_0x1bdde2,_0x2b0960,_0x340808,_0x5eb7d7,_0x45a059,_0x4e93aa){var _0x590d83=_[_0x671f('0xf')](_0x1bdde2);_0x590d83['queue_id']=_0x4e93aa;_0x590d83['queue']=_0x578f1b;_0x590d83[_0x671f('0xb')]=_0x2b0960;_0x590d83['id']=_0x340808;if(_0x5eb7d7){_0x45a059[util[_0x671f('0x10')](_0x671f('0x11'),_0x5e633b)][_0x340808]=_[_0x671f('0x12')](_0x590d83,attributes);}else{delete _0x45a059[util['format'](_0x671f('0x11'),_0x5e633b)][_0x340808];}emit(util[_0x671f('0x10')](_0x671f('0x13'),_0x5e633b,_0x578f1b),util['format']('%s_queue_waiting_interaction:%s',_0x5e633b,_0x5eb7d7?_0x671f('0x14'):_0x671f('0x15')),_[_0x671f('0x12')](_0x590d83,attributes));}var rpc={'openchannelQueueReport':require(_0x671f('0x16')),'mailQueueReport':require(_0x671f('0x17')),'chatQueueReport':require(_0x671f('0x18')),'smsQueueReport':require('../../rpc/smsQueueReport'),'faxQueueReport':require('../../rpc/faxQueueReport'),'whatsappQueueReport':require(_0x671f('0x19'))};var queue=schema({'name':{'type':'string','required':!![],'message':_0x671f('0x1a')},'timeout':{'type':_0x671f('0x1b'),'message':_0x671f('0x1c')}});function startRouting(_0x518c36,_0x4465d2,_0x41e04c,_0x49d9b6){if(_0x518c36&&_0x4465d2&&_0x41e04c){_0x4465d2[_0x671f('0x1d')]+=0x1;var _0xcdd791={'uniqueid':_0x518c36,'from':_0x41e04c[_0x671f('0x1e')]?_0x41e04c[_0x671f('0x1e')][_0x671f('0x1f')]:'','joinAt':moment()[_0x671f('0x10')](_0x671f('0x20')),'ContactId':_0x41e04c['contact']?_0x41e04c[_0x671f('0x21')]['id']:null,'ListId':_0x41e04c['list']?_0x41e04c['list']['id']:null};_0xcdd791[_[_0x671f('0x22')](_0x41e04c[_0x671f('0x23')])+_0x671f('0x24')]=_0x4465d2['id']||null;_0xcdd791[_[_0x671f('0x22')](_0x41e04c[_0x671f('0x23')])+'InteractionId']=_0x41e04c[_0x671f('0x25')]?_0x41e04c[_0x671f('0x25')]['id']:null;_0xcdd791[_[_0x671f('0x22')](_0x41e04c[_0x671f('0x23')])+'MessageId']=_0x41e04c[_0x671f('0x26')]?_0x41e04c[_0x671f('0x26')]['id']:null;_0xcdd791[_[_0x671f('0x22')](_0x41e04c[_0x671f('0x23')])+(_0x41e04c[_0x671f('0x23')]!==_0x671f('0x27')?_0x671f('0x28'):'WebsiteId')]=_0x41e04c[_0x671f('0xb')]?_0x41e04c['account']['id']:null;logger[_0x671f('0x29')](util[_0x671f('0x10')](_0x671f('0x2a'),_0x518c36,_0x4465d2[_0x671f('0x2b')]));emitChannelQueueInteraction(_0x41e04c['channel'],_0x4465d2[_0x671f('0x2b')],_0xcdd791,_0x41e04c[_0x671f('0xb')][_0x671f('0x2b')],_0x41e04c[_0x671f('0x26')]['id'],!![],_0x49d9b6,_0x4465d2['id']);if(rpc[_0x41e04c['channel']+_0x671f('0x2c')]){return rpc[_0x41e04c['channel']+_0x671f('0x2c')]['create'](_0xcdd791)[_0x671f('0x2d')](function(_0xea441f){logger[_0x671f('0x2e')](_0x671f('0x2f'));});}}}function stopRouting(_0x2d6ada,_0x4402aa,_0x473b45,_0x3fe654){if(_0x2d6ada&&_0x4402aa){_0x4402aa[_0x671f('0x1d')]-=0x1;var _0x2582dd={'leaveAt':moment()[_0x671f('0x10')](_0x671f('0x20')),'acceptAt':moment()[_0x671f('0x10')](_0x671f('0x20')),'reason':_0x671f('0x30')};logger[_0x671f('0x29')](util[_0x671f('0x10')](_0x671f('0x31'),_0x2d6ada,_0x4402aa['name']));emitChannelQueueInteraction(_0x473b45[_0x671f('0x23')],_0x4402aa[_0x671f('0x2b')],_0x473b45[_0x671f('0x1e')],_0x473b45[_0x671f('0xb')][_0x671f('0x2b')],_0x473b45[_0x671f('0x26')]['id'],![],_0x3fe654,_0x4402aa['id']);if(rpc[_0x473b45[_0x671f('0x23')]+_0x671f('0x2c')]){return rpc[_0x473b45['channel']+_0x671f('0x2c')]['update'](_0x2d6ada,_0x2582dd)['catch'](function(_0x1b473a){logger[_0x671f('0x2e')](_0x671f('0x32'));});}}}function endRouting(_0x338f87,_0x46ae59,_0x1ac9c3,_0xe240ef){if(_0x338f87&&_0x46ae59){_0x46ae59[_0x671f('0x1d')]-=0x1;var _0xfba2c6={'leaveAt':moment()[_0x671f('0x10')](_0x671f('0x20')),'exitAt':moment()[_0x671f('0x10')](_0x671f('0x20')),'reason':_0x671f('0x33')};logger['info'](util['format']('[%s][END:QUEUE][NAME:%s]',_0x338f87,_0x46ae59[_0x671f('0x2b')]));emitChannelQueueInteraction(_0x1ac9c3['channel'],_0x46ae59[_0x671f('0x2b')],_0x1ac9c3[_0x671f('0x1e')],_0x1ac9c3['account'][_0x671f('0x2b')],_0x1ac9c3[_0x671f('0x26')]['id'],![],_0xe240ef);if(rpc[_0x1ac9c3[_0x671f('0x23')]+_0x671f('0x2c')]){return rpc[_0x1ac9c3[_0x671f('0x23')]+_0x671f('0x2c')][_0x671f('0x34')](_0x338f87,_0xfba2c6)[_0x671f('0x2d')](function(_0x2b29c5){logger[_0x671f('0x2e')]('update\x20queue\x20report');});}}}function handleFindQueue(_0x3334aa){return function(_0x16d77f){return _0x16d77f[_0x671f('0x2b')][_0x671f('0x35')]()===_0x3334aa[_0x671f('0x35')]();};}exports[_0x671f('0x36')]=function(_0x568815,_0x2860ec,_0x233499,_0x3b2c3b){return function(_0x41c11f){try{var _0x3cc39b={'name':_0x2860ec[0x0],'timeout':_0x2860ec[0x1]};var _0x4cde8a=queue[_0x671f('0x37')](_0x3cc39b,{'typecast':!![]});if(_0x4cde8a[_0x671f('0x38')]){logger[_0x671f('0x2e')](_0x671f('0x39'),_0x568815,_[_0x671f('0x3a')](_0x4cde8a,_0x671f('0x26'))[_0x671f('0x3b')](',\x20'));_0x41c11f[_0x671f('0x3c')]();}else{var _0x4f06c2=_['find'](_0x233499[_0x3b2c3b[_0x671f('0x23')]+_0x671f('0x3d')],handleFindQueue(_0x3cc39b[_0x671f('0x2b')]));if(_0x4f06c2){startRouting(_0x568815,_0x4f06c2,_0x3b2c3b,_0x233499);var _0x59f340=(_0x4f06c2[_0x671f('0x33')]||0xa)*0x3e8;var _0x4d9484=(_0x3cc39b[_0x671f('0x33')]||0x14)*0x3e8;var _0x362489,_0x14330a;if(_0x59f340>_0x4d9484){_0x4d9484=_0x59f340;}var _0x28deab=seqqueue[_0x671f('0x3e')](_0x59f340);_0x28deab['id']=_0x568815;_0x28deab[_0x671f('0x3f')]=_0x59f340;_0x28deab[_0x671f('0x40')]=_0x4d9484;_0x28deab[_0x671f('0x23')]=_0x3b2c3b[_0x671f('0x23')];_0x233499[_0x671f('0x41')][_0x568815]['on']('end',function(){logger[_0x671f('0x29')](_0x671f('0x42'),_0x568815);stopRouting(_0x568815,_0x4f06c2,_0x3b2c3b,_0x233499);clearTimeout(_0x362489);_0x362489=undefined;_0x28deab[_0x671f('0x43')](!![]);if(_0x233499[_0x671f('0x41')][_0x568815]){delete _0x233499[_0x671f('0x41')][_0x568815];}_0x41c11f[_0x671f('0x3c')]();});_0x233499[_0x671f('0x41')][_0x568815]['on'](_0x671f('0x44'),function(){if(_0x233499[_0x671f('0x41')][_0x568815]){delete _0x233499[_0x671f('0x41')][_0x568815];}});_0x362489=setTimeout(function(){logger[_0x671f('0x29')](_0x671f('0x45'),_0x568815);endRouting(_0x568815,_0x4f06c2,_0x3b2c3b,_0x233499);clearTimeout(_0x362489);_0x28deab[_0x671f('0x43')](!![]);_0x41c11f[_0x671f('0x46')]();},_0x4d9484);switch(_0x4f06c2[_0x671f('0x47')]){case'rrmemory':strategy[_0x671f('0x48')](_0x28deab,_0x4f06c2,_0x233499,_0x3b2c3b);break;default:strategy[_0x671f('0x49')](_0x28deab,_0x4f06c2,_0x233499,_0x3b2c3b);}}else{logger[_0x671f('0x2e')]('[%s][QUEUE]\x20queue\x20not\x20found\x20%s',_0x568815,_0x3cc39b[_0x671f('0x2b')]);_0x41c11f[_0x671f('0x3c')]();}}}catch(_0x3add15){console[_0x671f('0x4a')](_0x3add15);logger[_0x671f('0x2e')](_0x671f('0x39'),_0x568815,_0x3add15[_0x671f('0x4b')]);_0x41c11f['stop']();}};};
\ No newline at end of file