Built motion from commit 511216ff.|2.6.34
[motion2.git] / server / services / routing / server / applications / queue.js
index 2dd2571..bc8fb9c 100644 (file)
@@ -15,4 +15,4 @@
 // * treaties. The SOFTWARE PRODUCT is licensed, not sold.                        *
 // *                                                                       *
 // *************************************************************************
-var _0x64d9=['name','QueueReport','create','catch','error','accepted','[%s][STOP:QUEUE][NAME:%s]','Interaction','update','then','update\x20queue\x20report','timeout','[%s][END:QUEUE][NAME:%s]','toLowerCase','consequence','length','[%s][QUEUE]\x20%s','map','join','stop','find','Queues','createQueue','qtimeout','rules','end','[%s][QUEUE]\x20ROUTING\x20STOPPED','next','rrmemory','beepall','[%s][QUEUE]\x20queue\x20not\x20found\x20%s','validate','lodash','util','seq-queue','moment','ioredis','../../../../config/environment','../../../../config/logger','routing','defaults','redis','socket.io-emitter','queue_id','account','queue','from','joinAt','clone','push','InteractionId','format','%sQueuesWaitingInteractions','pick','%s:queue:%s','%s_queue_waiting_interaction:%s','save','remove','../../rpc/openchannelQueueReport','../../rpc/mailQueueReport','../../rpc/chatQueueReport','../../rpc/faxQueueReport','../../rpc/whatsappQueueReport','../../rpc/chatInteraction','../../rpc/faxInteraction','../../rpc/smsInteraction','../../rpc/whatsappInteraction','string','name\x20is\x20a\x20string\x20and\x20it\x20is\x20required','number','timeout\x20is\x20a\x20number','waiting','body','YYYY-MM-DD\x20HH:mm:ss','contact','list','upperFirst','QueueId','channel','interaction','MessageId','message','AccountId','WebsiteId','info','[%s][START:QUEUE][NAME:%s]'];(function(_0x14add3,_0x13ce8d){var _0x4a174f=function(_0x2b3ed7){while(--_0x2b3ed7){_0x14add3['push'](_0x14add3['shift']());}};_0x4a174f(++_0x13ce8d);}(_0x64d9,0xcb));var _0x964d=function(_0x34e76b,_0x402494){_0x34e76b=_0x34e76b-0x0;var _0xdcb6bd=_0x64d9[_0x34e76b];return _0xdcb6bd;};'use strict';var schema=require(_0x964d('0x0'));var _=require(_0x964d('0x1'));var util=require(_0x964d('0x2'));var seqqueue=require(_0x964d('0x3'));var moment=require(_0x964d('0x4'));var Redis=require(_0x964d('0x5'));var config=require(_0x964d('0x6'));var logger=require(_0x964d('0x7'))(_0x964d('0x8'));var strategy=require('./strategy');config['redis']=_[_0x964d('0x9')](config[_0x964d('0xa')],{'host':'localhost','port':0x18eb});var io=require(_0x964d('0xb'))(new Redis(config['redis']));var attributes=['id',_0x964d('0xc'),_0x964d('0xd'),_0x964d('0xe'),_0x964d('0xf'),_0x964d('0x10')];function emit(_0x553560,_0x43b3a1,_0xc5f7f4){io['to'](_0x553560)['emit'](_0x43b3a1,_0xc5f7f4);}function emitChannelQueueInteraction(_0x6e72ec,_0x3fef2e,_0x5d55fe,_0x17484a,_0x3e90cb,_0x18addc,_0x31421d,_0x57827f){var _0x1d3cba=_[_0x964d('0x11')](_0x5d55fe);_0x1d3cba[_0x964d('0xc')]=_0x57827f;_0x1d3cba[_0x964d('0xe')]=_0x3fef2e;_0x1d3cba[_0x964d('0xd')]=_0x17484a;_0x1d3cba['id']=_0x3e90cb;if(_0x18addc){attributes[_0x964d('0x12')](_['capitalize'](_0x6e72ec)+_0x964d('0x13'));_0x31421d[util[_0x964d('0x14')](_0x964d('0x15'),_0x6e72ec)][_0x3e90cb]=_[_0x964d('0x16')](_0x1d3cba,attributes);}else{delete _0x31421d[util[_0x964d('0x14')](_0x964d('0x15'),_0x6e72ec)][_0x3e90cb];}emit(util[_0x964d('0x14')](_0x964d('0x17'),_0x6e72ec,_0x3fef2e),util[_0x964d('0x14')](_0x964d('0x18'),_0x6e72ec,_0x18addc?_0x964d('0x19'):_0x964d('0x1a')),_[_0x964d('0x16')](_0x1d3cba,attributes));}var rpc={'openchannelQueueReport':require(_0x964d('0x1b')),'mailQueueReport':require(_0x964d('0x1c')),'chatQueueReport':require(_0x964d('0x1d')),'smsQueueReport':require('../../rpc/smsQueueReport'),'faxQueueReport':require(_0x964d('0x1e')),'whatsappQueueReport':require(_0x964d('0x1f')),'chatInteraction':require(_0x964d('0x20')),'faxInteraction':require(_0x964d('0x21')),'mailInteraction':require('../../rpc/mailInteraction'),'openchannelInteraction':require('../../rpc/openchannelInteraction'),'smsInteraction':require(_0x964d('0x22')),'whatsappInteraction':require(_0x964d('0x23'))};var queue=schema({'name':{'type':_0x964d('0x24'),'required':!![],'message':_0x964d('0x25')},'timeout':{'type':_0x964d('0x26'),'message':_0x964d('0x27')}});function startRouting(_0x17b1db,_0x4be4e7,_0x5e5404,_0x1aa0bb){if(_0x17b1db&&_0x4be4e7&&_0x5e5404){_0x4be4e7[_0x964d('0x28')]+=0x1;var _0x2b0791={'uniqueid':_0x17b1db,'from':_0x5e5404['body']?_0x5e5404[_0x964d('0x29')][_0x964d('0xf')]:'','joinAt':moment()[_0x964d('0x14')](_0x964d('0x2a')),'ContactId':_0x5e5404[_0x964d('0x2b')]?_0x5e5404['contact']['id']:null,'ListId':_0x5e5404[_0x964d('0x2c')]?_0x5e5404[_0x964d('0x2c')]['id']:null};_0x2b0791[_[_0x964d('0x2d')](_0x5e5404['channel'])+_0x964d('0x2e')]=_0x4be4e7['id']||null;_0x2b0791[_[_0x964d('0x2d')](_0x5e5404[_0x964d('0x2f')])+_0x964d('0x13')]=_0x5e5404[_0x964d('0x30')]?_0x5e5404[_0x964d('0x30')]['id']:null;_0x2b0791[_['upperFirst'](_0x5e5404[_0x964d('0x2f')])+_0x964d('0x31')]=_0x5e5404['message']?_0x5e5404[_0x964d('0x32')]['id']:null;_0x2b0791[_['upperFirst'](_0x5e5404['channel'])+(_0x5e5404['channel']!=='chat'?_0x964d('0x33'):_0x964d('0x34'))]=_0x5e5404[_0x964d('0xd')]?_0x5e5404[_0x964d('0xd')]['id']:null;logger[_0x964d('0x35')](util[_0x964d('0x14')](_0x964d('0x36'),_0x17b1db,_0x4be4e7['name']));emitChannelQueueInteraction(_0x5e5404['channel'],_0x4be4e7[_0x964d('0x37')],_0x2b0791,_0x5e5404[_0x964d('0xd')][_0x964d('0x37')],_0x5e5404[_0x964d('0x32')]['id'],!![],_0x1aa0bb,_0x4be4e7['id']);if(rpc[_0x5e5404[_0x964d('0x2f')]+_0x964d('0x38')]){return rpc[_0x5e5404[_0x964d('0x2f')]+_0x964d('0x38')][_0x964d('0x39')](_0x2b0791)[_0x964d('0x3a')](function(_0x134f60){logger[_0x964d('0x3b')]('create\x20queue\x20report',_0x134f60);});}}}function stopRouting(_0x57b545,_0x57e1c5,_0x2eedf1,_0x59ea3c){if(_0x57b545&&_0x57e1c5){_0x57e1c5['waiting']-=0x1;var _0x2e1b0f={'leaveAt':moment()[_0x964d('0x14')](_0x964d('0x2a')),'acceptAt':moment()[_0x964d('0x14')](_0x964d('0x2a')),'reason':_0x964d('0x3c')};logger[_0x964d('0x35')](util[_0x964d('0x14')](_0x964d('0x3d'),_0x57b545,_0x57e1c5[_0x964d('0x37')]));emitChannelQueueInteraction(_0x2eedf1[_0x964d('0x2f')],_0x57e1c5[_0x964d('0x37')],_0x2eedf1[_0x964d('0x29')],_0x2eedf1[_0x964d('0xd')]['name'],_0x2eedf1[_0x964d('0x32')]['id'],![],_0x59ea3c,_0x57e1c5['id']);return rpc[_0x2eedf1['channel']+_0x964d('0x3e')][_0x964d('0x3f')](_0x2eedf1[_0x964d('0x30')]['id'],{'queueId':_0x57e1c5['id']})[_0x964d('0x40')](function(){if(rpc[_0x2eedf1[_0x964d('0x2f')]+_0x964d('0x38')]){return rpc[_0x2eedf1['channel']+'QueueReport'][_0x964d('0x3f')](_0x57b545,_0x2e1b0f)[_0x964d('0x3a')](function(_0x40d840){logger[_0x964d('0x3b')](_0x964d('0x41'),_0x40d840);});}});}}function endRouting(_0x416919,_0x15aab8,_0x5358cc,_0x11ed4e){if(_0x416919&&_0x15aab8){_0x15aab8[_0x964d('0x28')]-=0x1;var _0x57c6cf={'leaveAt':moment()[_0x964d('0x14')](_0x964d('0x2a')),'exitAt':moment()[_0x964d('0x14')]('YYYY-MM-DD\x20HH:mm:ss'),'reason':_0x964d('0x42')};logger[_0x964d('0x35')](util['format'](_0x964d('0x43'),_0x416919,_0x15aab8[_0x964d('0x37')]));emitChannelQueueInteraction(_0x5358cc[_0x964d('0x2f')],_0x15aab8[_0x964d('0x37')],_0x5358cc[_0x964d('0x29')],_0x5358cc[_0x964d('0xd')][_0x964d('0x37')],_0x5358cc[_0x964d('0x32')]['id'],![],_0x11ed4e);if(rpc[_0x5358cc[_0x964d('0x2f')]+_0x964d('0x38')]){return rpc[_0x5358cc[_0x964d('0x2f')]+_0x964d('0x38')]['update'](_0x416919,_0x57c6cf)[_0x964d('0x3a')](function(_0x2139be){logger[_0x964d('0x3b')]('update\x20queue\x20report',_0x2139be);});}}}function handleFindQueue(_0x33acae){return function(_0x3974b3){return _0x3974b3['name']['toLowerCase']()===_0x33acae[_0x964d('0x44')]();};}exports[_0x964d('0x45')]=function(_0xc704d0,_0x86014e,_0x349670,_0x486e51){return function(_0x57eff3){try{var _0x4d4d9a={'name':_0x86014e[0x0],'timeout':_0x86014e[0x1]};var _0x1abbc9=queue[_0x964d('0x0')](_0x4d4d9a,{'typecast':!![]});if(_0x1abbc9[_0x964d('0x46')]){logger[_0x964d('0x3b')](_0x964d('0x47'),_0xc704d0,_[_0x964d('0x48')](_0x1abbc9,_0x964d('0x32'))[_0x964d('0x49')](',\x20'));_0x57eff3[_0x964d('0x4a')]();}else{var _0x51efbe=_[_0x964d('0x4b')](_0x349670[_0x486e51['channel']+_0x964d('0x4c')],handleFindQueue(_0x4d4d9a[_0x964d('0x37')]));if(_0x51efbe){startRouting(_0xc704d0,_0x51efbe,_0x486e51,_0x349670);var _0x4370e6=(_0x51efbe[_0x964d('0x42')]||0xa)*0x3e8;var _0x503b73=(_0x4d4d9a[_0x964d('0x42')]||0x14)*0x3e8;var _0x3c979e;if(_0x4370e6>_0x503b73){_0x503b73=_0x4370e6;}var _0x331216=seqqueue[_0x964d('0x4d')](_0x4370e6);_0x331216['id']=_0xc704d0;_0x331216['atimeout']=_0x4370e6;_0x331216[_0x964d('0x4e')]=_0x503b73;_0x331216['channel']=_0x486e51[_0x964d('0x2f')];_0x349670[_0x964d('0x4f')][_0xc704d0]['on'](_0x964d('0x50'),function(){logger[_0x964d('0x35')](_0x964d('0x51'),_0xc704d0);stopRouting(_0xc704d0,_0x51efbe,_0x486e51,_0x349670);clearTimeout(_0x3c979e);_0x3c979e=undefined;_0x331216['close'](!![]);if(_0x349670[_0x964d('0x4f')][_0xc704d0]){delete _0x349670[_0x964d('0x4f')][_0xc704d0];}_0x57eff3[_0x964d('0x4a')]();});_0x349670['rules'][_0xc704d0]['on']('complete',function(){if(_0x349670[_0x964d('0x4f')][_0xc704d0]){delete _0x349670[_0x964d('0x4f')][_0xc704d0];}});_0x3c979e=setTimeout(function(){logger[_0x964d('0x35')]('[%s][QUEUE]\x20APPLICATION\x20END',_0xc704d0);endRouting(_0xc704d0,_0x51efbe,_0x486e51,_0x349670);clearTimeout(_0x3c979e);_0x331216['close'](!![]);_0x57eff3[_0x964d('0x52')]();},_0x503b73);switch(_0x51efbe['strategy']){case _0x964d('0x53'):strategy[_0x964d('0x53')](_0x331216,_0x51efbe,_0x349670,_0x486e51);break;default:strategy[_0x964d('0x54')](_0x331216,_0x51efbe,_0x349670,_0x486e51);}}else{logger['error'](_0x964d('0x55'),_0xc704d0,_0x4d4d9a[_0x964d('0x37')]);_0x57eff3[_0x964d('0x4a')]();}}}catch(_0x36efa8){logger[_0x964d('0x3b')](_0x964d('0x47'),_0xc704d0,_0x36efa8['stack']);_0x57eff3[_0x964d('0x4a')]();}};};
\ No newline at end of file
+var _0x54d5=['../../rpc/whatsappInteraction','name\x20is\x20a\x20string\x20and\x20it\x20is\x20required','number','waiting','body','YYYY-MM-DD\x20HH:mm:ss','contact','list','channel','QueueId','upperFirst','interaction','MessageId','message','chat','AccountId','info','[%s][START:QUEUE][NAME:%s]','name','QueueReport','create\x20queue\x20report','accepted','[%s][STOP:QUEUE][NAME:%s]','update','then','catch','update\x20queue\x20report','timeout','[%s][END:QUEUE][NAME:%s]','error','toLowerCase','consequence','length','[%s][QUEUE]\x20%s','stop','Queues','qtimeout','end','[%s][QUEUE]\x20ROUTING\x20STOPPED','rules','[%s][QUEUE]\x20APPLICATION\x20END','close','next','rrmemory','beepall','[%s][QUEUE]\x20queue\x20not\x20found\x20%s','stack','validate','lodash','util','seq-queue','moment','ioredis','../../../../config/environment','../../../../config/logger','routing','./strategy','redis','defaults','localhost','socket.io-emitter','queue_id','account','queue','from','joinAt','emit','clone','InteractionId','format','%sQueuesWaitingInteractions','pick','%s:queue:%s','%s_queue_waiting_interaction:%s','save','remove','../../rpc/openchannelQueueReport','../../rpc/chatQueueReport','../../rpc/smsQueueReport','../../rpc/faxInteraction','../../rpc/mailInteraction','../../rpc/smsInteraction'];(function(_0x3712e2,_0x32d752){var _0x1faff4=function(_0x550dc0){while(--_0x550dc0){_0x3712e2['push'](_0x3712e2['shift']());}};_0x1faff4(++_0x32d752);}(_0x54d5,0x1c9));var _0x554d=function(_0x240b3a,_0x1586aa){_0x240b3a=_0x240b3a-0x0;var _0x5a81ed=_0x54d5[_0x240b3a];return _0x5a81ed;};'use strict';var schema=require(_0x554d('0x0'));var _=require(_0x554d('0x1'));var util=require(_0x554d('0x2'));var seqqueue=require(_0x554d('0x3'));var moment=require(_0x554d('0x4'));var Redis=require(_0x554d('0x5'));var config=require(_0x554d('0x6'));var logger=require(_0x554d('0x7'))(_0x554d('0x8'));var strategy=require(_0x554d('0x9'));config[_0x554d('0xa')]=_[_0x554d('0xb')](config[_0x554d('0xa')],{'host':_0x554d('0xc'),'port':0x18eb});var io=require(_0x554d('0xd'))(new Redis(config[_0x554d('0xa')]));var attributes=['id',_0x554d('0xe'),_0x554d('0xf'),_0x554d('0x10'),_0x554d('0x11'),_0x554d('0x12')];function emit(_0x297ca0,_0x1a59b0,_0x2c4e2c){io['to'](_0x297ca0)[_0x554d('0x13')](_0x1a59b0,_0x2c4e2c);}function emitChannelQueueInteraction(_0x5e387a,_0x3912e6,_0x293ed4,_0x36dceb,_0x563535,_0x44f612,_0xd1822e,_0x5c1633){var _0x42214a=_[_0x554d('0x14')](_0x293ed4);_0x42214a['queue_id']=_0x5c1633;_0x42214a[_0x554d('0x10')]=_0x3912e6;_0x42214a[_0x554d('0xf')]=_0x36dceb;_0x42214a['id']=_0x563535;if(_0x44f612){attributes['push'](_['capitalize'](_0x5e387a)+_0x554d('0x15'));_0xd1822e[util[_0x554d('0x16')](_0x554d('0x17'),_0x5e387a)][_0x563535]=_[_0x554d('0x18')](_0x42214a,attributes);}else{delete _0xd1822e[util['format'](_0x554d('0x17'),_0x5e387a)][_0x563535];}emit(util[_0x554d('0x16')](_0x554d('0x19'),_0x5e387a,_0x3912e6),util[_0x554d('0x16')](_0x554d('0x1a'),_0x5e387a,_0x44f612?_0x554d('0x1b'):_0x554d('0x1c')),_[_0x554d('0x18')](_0x42214a,attributes));}var rpc={'openchannelQueueReport':require(_0x554d('0x1d')),'mailQueueReport':require('../../rpc/mailQueueReport'),'chatQueueReport':require(_0x554d('0x1e')),'smsQueueReport':require(_0x554d('0x1f')),'faxQueueReport':require('../../rpc/faxQueueReport'),'whatsappQueueReport':require('../../rpc/whatsappQueueReport'),'chatInteraction':require('../../rpc/chatInteraction'),'faxInteraction':require(_0x554d('0x20')),'mailInteraction':require(_0x554d('0x21')),'openchannelInteraction':require('../../rpc/openchannelInteraction'),'smsInteraction':require(_0x554d('0x22')),'whatsappInteraction':require(_0x554d('0x23'))};var queue=schema({'name':{'type':'string','required':!![],'message':_0x554d('0x24')},'timeout':{'type':_0x554d('0x25'),'message':'timeout\x20is\x20a\x20number'}});function startRouting(_0x207178,_0x18aaa3,_0x306851,_0x43bd4e){if(_0x207178&&_0x18aaa3&&_0x306851){_0x18aaa3[_0x554d('0x26')]+=0x1;var _0x3195d0={'uniqueid':_0x207178,'from':_0x306851[_0x554d('0x27')]?_0x306851[_0x554d('0x27')][_0x554d('0x11')]:'','joinAt':moment()[_0x554d('0x16')](_0x554d('0x28')),'ContactId':_0x306851[_0x554d('0x29')]?_0x306851[_0x554d('0x29')]['id']:null,'ListId':_0x306851[_0x554d('0x2a')]?_0x306851['list']['id']:null};_0x3195d0[_['upperFirst'](_0x306851[_0x554d('0x2b')])+_0x554d('0x2c')]=_0x18aaa3['id']||null;_0x3195d0[_[_0x554d('0x2d')](_0x306851['channel'])+_0x554d('0x15')]=_0x306851[_0x554d('0x2e')]?_0x306851[_0x554d('0x2e')]['id']:null;_0x3195d0[_['upperFirst'](_0x306851[_0x554d('0x2b')])+_0x554d('0x2f')]=_0x306851[_0x554d('0x30')]?_0x306851[_0x554d('0x30')]['id']:null;_0x3195d0[_[_0x554d('0x2d')](_0x306851[_0x554d('0x2b')])+(_0x306851[_0x554d('0x2b')]!==_0x554d('0x31')?_0x554d('0x32'):'WebsiteId')]=_0x306851[_0x554d('0xf')]?_0x306851['account']['id']:null;logger[_0x554d('0x33')](util[_0x554d('0x16')](_0x554d('0x34'),_0x207178,_0x18aaa3[_0x554d('0x35')]));emitChannelQueueInteraction(_0x306851[_0x554d('0x2b')],_0x18aaa3[_0x554d('0x35')],_0x3195d0,_0x306851[_0x554d('0xf')][_0x554d('0x35')],_0x306851[_0x554d('0x30')]['id'],!![],_0x43bd4e,_0x18aaa3['id']);if(rpc[_0x306851[_0x554d('0x2b')]+_0x554d('0x36')]){return rpc[_0x306851['channel']+_0x554d('0x36')]['create'](_0x3195d0)['catch'](function(_0x5cb28d){logger['error'](_0x554d('0x37'),_0x5cb28d);});}}}function stopRouting(_0x523b8d,_0x150ff8,_0x1d0468,_0x107a24){if(_0x523b8d&&_0x150ff8){_0x150ff8[_0x554d('0x26')]-=0x1;var _0x389510={'leaveAt':moment()[_0x554d('0x16')](_0x554d('0x28')),'acceptAt':moment()['format'](_0x554d('0x28')),'reason':_0x554d('0x38')};logger[_0x554d('0x33')](util[_0x554d('0x16')](_0x554d('0x39'),_0x523b8d,_0x150ff8[_0x554d('0x35')]));emitChannelQueueInteraction(_0x1d0468['channel'],_0x150ff8[_0x554d('0x35')],_0x1d0468[_0x554d('0x27')],_0x1d0468[_0x554d('0xf')][_0x554d('0x35')],_0x1d0468[_0x554d('0x30')]['id'],![],_0x107a24,_0x150ff8['id']);return rpc[_0x1d0468[_0x554d('0x2b')]+'Interaction'][_0x554d('0x3a')](_0x1d0468[_0x554d('0x2e')]['id'],{'queueId':_0x150ff8['id']})[_0x554d('0x3b')](function(){if(rpc[_0x1d0468[_0x554d('0x2b')]+_0x554d('0x36')]){return rpc[_0x1d0468[_0x554d('0x2b')]+'QueueReport']['update'](_0x523b8d,_0x389510)[_0x554d('0x3c')](function(_0xc12129){logger['error'](_0x554d('0x3d'),_0xc12129);});}});}}function endRouting(_0x1869c1,_0x5ecd67,_0x438ce2,_0x350dd3){if(_0x1869c1&&_0x5ecd67){_0x5ecd67[_0x554d('0x26')]-=0x1;var _0x5bde4c={'leaveAt':moment()['format'](_0x554d('0x28')),'exitAt':moment()[_0x554d('0x16')]('YYYY-MM-DD\x20HH:mm:ss'),'reason':_0x554d('0x3e')};logger[_0x554d('0x33')](util[_0x554d('0x16')](_0x554d('0x3f'),_0x1869c1,_0x5ecd67['name']));emitChannelQueueInteraction(_0x438ce2[_0x554d('0x2b')],_0x5ecd67[_0x554d('0x35')],_0x438ce2[_0x554d('0x27')],_0x438ce2[_0x554d('0xf')][_0x554d('0x35')],_0x438ce2[_0x554d('0x30')]['id'],![],_0x350dd3);if(rpc[_0x438ce2[_0x554d('0x2b')]+_0x554d('0x36')]){return rpc[_0x438ce2['channel']+_0x554d('0x36')]['update'](_0x1869c1,_0x5bde4c)[_0x554d('0x3c')](function(_0x2e5f6e){logger[_0x554d('0x40')](_0x554d('0x3d'),_0x2e5f6e);});}}}function handleFindQueue(_0x4cbe01){return function(_0xf6d48d){return _0xf6d48d[_0x554d('0x35')][_0x554d('0x41')]()===_0x4cbe01[_0x554d('0x41')]();};}exports[_0x554d('0x42')]=function(_0x3394dc,_0x2543e7,_0x55af74,_0x528795){return function(_0x2da5db){try{var _0x39e34e={'name':_0x2543e7[0x0],'timeout':_0x2543e7[0x1]};var _0x41db09=queue[_0x554d('0x0')](_0x39e34e,{'typecast':!![]});if(_0x41db09[_0x554d('0x43')]){logger[_0x554d('0x40')](_0x554d('0x44'),_0x3394dc,_['map'](_0x41db09,_0x554d('0x30'))['join'](',\x20'));_0x2da5db[_0x554d('0x45')]();}else{var _0x18f135=_['find'](_0x55af74[_0x528795[_0x554d('0x2b')]+_0x554d('0x46')],handleFindQueue(_0x39e34e[_0x554d('0x35')]));if(_0x18f135){startRouting(_0x3394dc,_0x18f135,_0x528795,_0x55af74);var _0x402797=(_0x18f135[_0x554d('0x3e')]||0xa)*0x3e8;var _0x36d89f=(_0x39e34e[_0x554d('0x3e')]||0x14)*0x3e8;var _0x2b2c91;if(_0x402797>_0x36d89f){_0x36d89f=_0x402797;}var _0x21eec6=seqqueue['createQueue'](_0x402797);_0x21eec6['id']=_0x3394dc;_0x21eec6['atimeout']=_0x402797;_0x21eec6[_0x554d('0x47')]=_0x36d89f;_0x21eec6['channel']=_0x528795[_0x554d('0x2b')];_0x55af74['rules'][_0x3394dc]['on'](_0x554d('0x48'),function(){logger[_0x554d('0x33')](_0x554d('0x49'),_0x3394dc);stopRouting(_0x3394dc,_0x18f135,_0x528795,_0x55af74);clearTimeout(_0x2b2c91);_0x2b2c91=undefined;_0x21eec6['close'](!![]);if(_0x55af74[_0x554d('0x4a')][_0x3394dc]){delete _0x55af74['rules'][_0x3394dc];}_0x2da5db[_0x554d('0x45')]();});_0x55af74[_0x554d('0x4a')][_0x3394dc]['on']('complete',function(){if(_0x55af74[_0x554d('0x4a')][_0x3394dc]){delete _0x55af74[_0x554d('0x4a')][_0x3394dc];}});_0x2b2c91=setTimeout(function(){logger[_0x554d('0x33')](_0x554d('0x4b'),_0x3394dc);endRouting(_0x3394dc,_0x18f135,_0x528795,_0x55af74);clearTimeout(_0x2b2c91);_0x21eec6[_0x554d('0x4c')](!![]);_0x2da5db[_0x554d('0x4d')]();},_0x36d89f);switch(_0x18f135['strategy']){case _0x554d('0x4e'):strategy['rrmemory'](_0x21eec6,_0x18f135,_0x55af74,_0x528795);break;default:strategy[_0x554d('0x4f')](_0x21eec6,_0x18f135,_0x55af74,_0x528795);}}else{logger['error'](_0x554d('0x50'),_0x3394dc,_0x39e34e[_0x554d('0x35')]);_0x2da5db[_0x554d('0x45')]();}}}catch(_0x1fb624){logger[_0x554d('0x40')]('[%s][QUEUE]\x20%s',_0x3394dc,_0x1fb624[_0x554d('0x51')]);_0x2da5db[_0x554d('0x45')]();}};};
\ No newline at end of file