// * treaties. The SOFTWARE PRODUCT is licensed, not sold. *
// * *
// *************************************************************************
-var _0x109f=['create\x20queue\x20report','waiting','[%s][STOP:QUEUE][NAME:%s]','Interaction','update','then','catch','error','update\x20queue\x20report','timeout','toLowerCase','[%s][QUEUE]\x20%s','map','join','stop','find','Queues','createQueue','atimeout','rules','end','close','complete','[%s][QUEUE]\x20APPLICATION\x20END','next','strategy','rrmemory','beepall','stack','validate','lodash','util','moment','ioredis','../../../../config/environment','../../../../config/logger','routing','./strategy','redis','socket.io-emitter','queue_id','account','queue','from','joinAt','emit','clone','push','capitalize','InteractionId','format','%sQueuesWaitingInteractions','pick','%s:queue:%s','%s_queue_waiting_interaction:%s','save','remove','../../rpc/openchannelQueueReport','../../rpc/mailQueueReport','../../rpc/chatQueueReport','../../rpc/smsQueueReport','../../rpc/faxQueueReport','../../rpc/whatsappQueueReport','../../rpc/chatInteraction','../../rpc/faxInteraction','../../rpc/mailInteraction','../../rpc/openchannelInteraction','../../rpc/smsInteraction','../../rpc/whatsappInteraction','string','name\x20is\x20a\x20string\x20and\x20it\x20is\x20required','number','timeout\x20is\x20a\x20number','body','YYYY-MM-DD\x20HH:mm:ss','contact','list','upperFirst','channel','QueueId','interaction','MessageId','message','chat','AccountId','WebsiteId','info','[%s][START:QUEUE][NAME:%s]','name','QueueReport','create'];(function(_0x2ac5bd,_0x335b3a){var _0x44a564=function(_0x214b33){while(--_0x214b33){_0x2ac5bd['push'](_0x2ac5bd['shift']());}};_0x44a564(++_0x335b3a);}(_0x109f,0x1e4));var _0xf109=function(_0x3ba112,_0x130621){_0x3ba112=_0x3ba112-0x0;var _0x37ba71=_0x109f[_0x3ba112];return _0x37ba71;};'use strict';var schema=require(_0xf109('0x0'));var _=require(_0xf109('0x1'));var util=require(_0xf109('0x2'));var seqqueue=require('seq-queue');var moment=require(_0xf109('0x3'));var Redis=require(_0xf109('0x4'));var config=require(_0xf109('0x5'));var logger=require(_0xf109('0x6'))(_0xf109('0x7'));var strategy=require(_0xf109('0x8'));config[_0xf109('0x9')]=_['defaults'](config[_0xf109('0x9')],{'host':'localhost','port':0x18eb});var io=require(_0xf109('0xa'))(new Redis(config['redis']));var attributes=['id',_0xf109('0xb'),_0xf109('0xc'),_0xf109('0xd'),_0xf109('0xe'),_0xf109('0xf')];function emit(_0x726676,_0x525613,_0x1d2f90){io['to'](_0x726676)[_0xf109('0x10')](_0x525613,_0x1d2f90);}function emitChannelQueueInteraction(_0x8b3e44,_0x5d46e1,_0x37f6cd,_0x4d7926,_0x148e7b,_0x45e472,_0x351b4c,_0x2538d9){var _0x5c17fb=_[_0xf109('0x11')](_0x37f6cd);_0x5c17fb['queue_id']=_0x2538d9;_0x5c17fb[_0xf109('0xd')]=_0x5d46e1;_0x5c17fb[_0xf109('0xc')]=_0x4d7926;_0x5c17fb['id']=_0x148e7b;if(_0x45e472){attributes[_0xf109('0x12')](_[_0xf109('0x13')](_0x8b3e44)+_0xf109('0x14'));_0x351b4c[util[_0xf109('0x15')](_0xf109('0x16'),_0x8b3e44)][_0x148e7b]=_[_0xf109('0x17')](_0x5c17fb,attributes);}else{delete _0x351b4c[util[_0xf109('0x15')](_0xf109('0x16'),_0x8b3e44)][_0x148e7b];}emit(util[_0xf109('0x15')](_0xf109('0x18'),_0x8b3e44,_0x5d46e1),util['format'](_0xf109('0x19'),_0x8b3e44,_0x45e472?_0xf109('0x1a'):_0xf109('0x1b')),_[_0xf109('0x17')](_0x5c17fb,attributes));}var rpc={'openchannelQueueReport':require(_0xf109('0x1c')),'mailQueueReport':require(_0xf109('0x1d')),'chatQueueReport':require(_0xf109('0x1e')),'smsQueueReport':require(_0xf109('0x1f')),'faxQueueReport':require(_0xf109('0x20')),'whatsappQueueReport':require(_0xf109('0x21')),'chatInteraction':require(_0xf109('0x22')),'faxInteraction':require(_0xf109('0x23')),'mailInteraction':require(_0xf109('0x24')),'openchannelInteraction':require(_0xf109('0x25')),'smsInteraction':require(_0xf109('0x26')),'whatsappInteraction':require(_0xf109('0x27'))};var queue=schema({'name':{'type':_0xf109('0x28'),'required':!![],'message':_0xf109('0x29')},'timeout':{'type':_0xf109('0x2a'),'message':_0xf109('0x2b')}});function startRouting(_0x1be1f9,_0x1b76da,_0x231ed6,_0xd513ef){if(_0x1be1f9&&_0x1b76da&&_0x231ed6){_0x1b76da['waiting']+=0x1;var _0x206630={'uniqueid':_0x1be1f9,'from':_0x231ed6[_0xf109('0x2c')]?_0x231ed6['body'][_0xf109('0xe')]:'','joinAt':moment()['format'](_0xf109('0x2d')),'ContactId':_0x231ed6['contact']?_0x231ed6[_0xf109('0x2e')]['id']:null,'ListId':_0x231ed6[_0xf109('0x2f')]?_0x231ed6['list']['id']:null};_0x206630[_[_0xf109('0x30')](_0x231ed6[_0xf109('0x31')])+_0xf109('0x32')]=_0x1b76da['id']||null;_0x206630[_[_0xf109('0x30')](_0x231ed6[_0xf109('0x31')])+_0xf109('0x14')]=_0x231ed6[_0xf109('0x33')]?_0x231ed6[_0xf109('0x33')]['id']:null;_0x206630[_['upperFirst'](_0x231ed6[_0xf109('0x31')])+_0xf109('0x34')]=_0x231ed6[_0xf109('0x35')]?_0x231ed6['message']['id']:null;_0x206630[_[_0xf109('0x30')](_0x231ed6[_0xf109('0x31')])+(_0x231ed6[_0xf109('0x31')]!==_0xf109('0x36')?_0xf109('0x37'):_0xf109('0x38'))]=_0x231ed6[_0xf109('0xc')]?_0x231ed6[_0xf109('0xc')]['id']:null;logger[_0xf109('0x39')](util[_0xf109('0x15')](_0xf109('0x3a'),_0x1be1f9,_0x1b76da[_0xf109('0x3b')]));emitChannelQueueInteraction(_0x231ed6[_0xf109('0x31')],_0x1b76da['name'],_0x206630,_0x231ed6[_0xf109('0xc')]['name'],_0x231ed6[_0xf109('0x35')]['id'],!![],_0xd513ef,_0x1b76da['id']);if(rpc[_0x231ed6[_0xf109('0x31')]+_0xf109('0x3c')]){return rpc[_0x231ed6[_0xf109('0x31')]+'QueueReport'][_0xf109('0x3d')](_0x206630)['catch'](function(_0x468c43){logger['error'](_0xf109('0x3e'),_0x468c43);});}}}function stopRouting(_0x3326b9,_0x4f25b3,_0x4e0463,_0x140a5a){if(_0x3326b9&&_0x4f25b3){_0x4f25b3[_0xf109('0x3f')]-=0x1;var _0x828fae={'leaveAt':moment()[_0xf109('0x15')](_0xf109('0x2d')),'acceptAt':moment()[_0xf109('0x15')](_0xf109('0x2d')),'reason':'accepted'};logger[_0xf109('0x39')](util[_0xf109('0x15')](_0xf109('0x40'),_0x3326b9,_0x4f25b3[_0xf109('0x3b')]));emitChannelQueueInteraction(_0x4e0463[_0xf109('0x31')],_0x4f25b3['name'],_0x4e0463[_0xf109('0x2c')],_0x4e0463[_0xf109('0xc')][_0xf109('0x3b')],_0x4e0463['message']['id'],![],_0x140a5a,_0x4f25b3['id']);return rpc[_0x4e0463[_0xf109('0x31')]+_0xf109('0x41')][_0xf109('0x42')](_0x4e0463[_0xf109('0x33')]['id'],{'queueId':_0x4f25b3['id']})[_0xf109('0x43')](function(){if(rpc[_0x4e0463['channel']+_0xf109('0x3c')]){return rpc[_0x4e0463[_0xf109('0x31')]+_0xf109('0x3c')][_0xf109('0x42')](_0x3326b9,_0x828fae)[_0xf109('0x44')](function(_0x4789c7){logger[_0xf109('0x45')](_0xf109('0x46'),_0x4789c7);});}});}}function endRouting(_0x59e562,_0x5763d7,_0x997326,_0x4e662a){if(_0x59e562&&_0x5763d7){_0x5763d7[_0xf109('0x3f')]-=0x1;var _0x1b82ca={'leaveAt':moment()[_0xf109('0x15')]('YYYY-MM-DD\x20HH:mm:ss'),'exitAt':moment()[_0xf109('0x15')](_0xf109('0x2d')),'reason':_0xf109('0x47')};logger[_0xf109('0x39')](util[_0xf109('0x15')]('[%s][END:QUEUE][NAME:%s]',_0x59e562,_0x5763d7[_0xf109('0x3b')]));emitChannelQueueInteraction(_0x997326[_0xf109('0x31')],_0x5763d7[_0xf109('0x3b')],_0x997326[_0xf109('0x2c')],_0x997326[_0xf109('0xc')][_0xf109('0x3b')],_0x997326[_0xf109('0x35')]['id'],![],_0x4e662a);if(rpc[_0x997326['channel']+_0xf109('0x3c')]){return rpc[_0x997326[_0xf109('0x31')]+_0xf109('0x3c')][_0xf109('0x42')](_0x59e562,_0x1b82ca)['catch'](function(_0x3b2c14){logger[_0xf109('0x45')](_0xf109('0x46'),_0x3b2c14);});}}}function handleFindQueue(_0x2f00ec){return function(_0x31470a){return _0x31470a['name'][_0xf109('0x48')]()===_0x2f00ec[_0xf109('0x48')]();};}exports['consequence']=function(_0x5e2cd4,_0x415ed5,_0x513334,_0x38e88b){return function(_0x3dcc8e){try{var _0x47f729={'name':_0x415ed5[0x0],'timeout':_0x415ed5[0x1]};var _0x864126=queue[_0xf109('0x0')](_0x47f729,{'typecast':!![]});if(_0x864126['length']){logger[_0xf109('0x45')](_0xf109('0x49'),_0x5e2cd4,_[_0xf109('0x4a')](_0x864126,'message')[_0xf109('0x4b')](',\x20'));_0x3dcc8e[_0xf109('0x4c')]();}else{var _0x31f2ca=_[_0xf109('0x4d')](_0x513334[_0x38e88b['channel']+_0xf109('0x4e')],handleFindQueue(_0x47f729[_0xf109('0x3b')]));if(_0x31f2ca){startRouting(_0x5e2cd4,_0x31f2ca,_0x38e88b,_0x513334);var _0x3137d7=(_0x31f2ca[_0xf109('0x47')]||0xa)*0x3e8;var _0x471e0c=(_0x47f729[_0xf109('0x47')]||0x14)*0x3e8;var _0x36f1b8;if(_0x3137d7>_0x471e0c){_0x471e0c=_0x3137d7;}var _0x5c7d1d=seqqueue[_0xf109('0x4f')](_0x3137d7);_0x5c7d1d['id']=_0x5e2cd4;_0x5c7d1d[_0xf109('0x50')]=_0x3137d7;_0x5c7d1d['qtimeout']=_0x471e0c;_0x5c7d1d[_0xf109('0x31')]=_0x38e88b[_0xf109('0x31')];_0x513334[_0xf109('0x51')][_0x5e2cd4]['on'](_0xf109('0x52'),function(){logger[_0xf109('0x39')]('[%s][QUEUE]\x20ROUTING\x20STOPPED',_0x5e2cd4);stopRouting(_0x5e2cd4,_0x31f2ca,_0x38e88b,_0x513334);clearTimeout(_0x36f1b8);_0x36f1b8=undefined;_0x5c7d1d[_0xf109('0x53')](!![]);if(_0x513334[_0xf109('0x51')][_0x5e2cd4]){delete _0x513334['rules'][_0x5e2cd4];}_0x3dcc8e[_0xf109('0x4c')]();});_0x513334[_0xf109('0x51')][_0x5e2cd4]['on'](_0xf109('0x54'),function(){if(_0x513334[_0xf109('0x51')][_0x5e2cd4]){delete _0x513334['rules'][_0x5e2cd4];}});_0x36f1b8=setTimeout(function(){logger[_0xf109('0x39')](_0xf109('0x55'),_0x5e2cd4);endRouting(_0x5e2cd4,_0x31f2ca,_0x38e88b,_0x513334);clearTimeout(_0x36f1b8);_0x5c7d1d[_0xf109('0x53')](!![]);_0x3dcc8e[_0xf109('0x56')]();},_0x471e0c);switch(_0x31f2ca[_0xf109('0x57')]){case _0xf109('0x58'):strategy['rrmemory'](_0x5c7d1d,_0x31f2ca,_0x513334,_0x38e88b);break;default:strategy[_0xf109('0x59')](_0x5c7d1d,_0x31f2ca,_0x513334,_0x38e88b);}}else{logger[_0xf109('0x45')]('[%s][QUEUE]\x20queue\x20not\x20found\x20%s',_0x5e2cd4,_0x47f729[_0xf109('0x3b')]);_0x3dcc8e['stop']();}}}catch(_0x5bfb11){logger[_0xf109('0x45')]('[%s][QUEUE]\x20%s',_0x5e2cd4,_0x5bfb11[_0xf109('0x5a')]);_0x3dcc8e[_0xf109('0x4c')]();}};};
\ No newline at end of file
+var _0xc358=['seq-queue','moment','ioredis','../../../../config/logger','routing','./strategy','defaults','redis','localhost','socket.io-emitter','queue_id','account','queue','clone','push','capitalize','InteractionId','format','%sQueuesWaitingInteractions','pick','save','remove','../../rpc/openchannelQueueReport','../../rpc/mailQueueReport','../../rpc/chatQueueReport','../../rpc/smsQueueReport','../../rpc/faxQueueReport','../../rpc/whatsappQueueReport','../../rpc/chatInteraction','../../rpc/mailInteraction','../../rpc/smsInteraction','../../rpc/whatsappInteraction','string','name\x20is\x20a\x20string\x20and\x20it\x20is\x20required','number','waiting','body','from','YYYY-MM-DD\x20HH:mm:ss','list','upperFirst','channel','QueueId','interaction','MessageId','chat','AccountId','[%s][START:QUEUE][NAME:%s]','name','QueueReport','create','catch','create\x20queue\x20report','info','message','Interaction','update','then','error','update\x20queue\x20report','timeout','[%s][END:QUEUE][NAME:%s]','toLowerCase','consequence','validate','[%s][QUEUE]\x20%s','join','stop','find','Queues','atimeout','rules','end','[%s][QUEUE]\x20ROUTING\x20STOPPED','close','complete','next','strategy','beepall','[%s][QUEUE]\x20queue\x20not\x20found\x20%s','lodash','util'];(function(_0x20a584,_0xe384a5){var _0x4b41a8=function(_0x2127c6){while(--_0x2127c6){_0x20a584['push'](_0x20a584['shift']());}};_0x4b41a8(++_0xe384a5);}(_0xc358,0xf4));var _0x8c35=function(_0x3dd15e,_0x1f0015){_0x3dd15e=_0x3dd15e-0x0;var _0x231fd0=_0xc358[_0x3dd15e];return _0x231fd0;};'use strict';var schema=require('validate');var _=require(_0x8c35('0x0'));var util=require(_0x8c35('0x1'));var seqqueue=require(_0x8c35('0x2'));var moment=require(_0x8c35('0x3'));var Redis=require(_0x8c35('0x4'));var config=require('../../../../config/environment');var logger=require(_0x8c35('0x5'))(_0x8c35('0x6'));var strategy=require(_0x8c35('0x7'));config['redis']=_[_0x8c35('0x8')](config[_0x8c35('0x9')],{'host':_0x8c35('0xa'),'port':0x18eb});var io=require(_0x8c35('0xb'))(new Redis(config[_0x8c35('0x9')]));var attributes=['id',_0x8c35('0xc'),_0x8c35('0xd'),_0x8c35('0xe'),'from','joinAt'];function emit(_0x25d2ce,_0x4e43b3,_0x2f3f34){io['to'](_0x25d2ce)['emit'](_0x4e43b3,_0x2f3f34);}function emitChannelQueueInteraction(_0x3d7668,_0x287637,_0x16c075,_0x40b7a4,_0x5c66e3,_0x5c7397,_0x4688ad,_0x472fbc){var _0x535246=_[_0x8c35('0xf')](_0x16c075);_0x535246[_0x8c35('0xc')]=_0x472fbc;_0x535246[_0x8c35('0xe')]=_0x287637;_0x535246[_0x8c35('0xd')]=_0x40b7a4;_0x535246['id']=_0x5c66e3;if(_0x5c7397){attributes[_0x8c35('0x10')](_[_0x8c35('0x11')](_0x3d7668)+_0x8c35('0x12'));_0x4688ad[util[_0x8c35('0x13')](_0x8c35('0x14'),_0x3d7668)][_0x5c66e3]=_[_0x8c35('0x15')](_0x535246,attributes);}else{delete _0x4688ad[util[_0x8c35('0x13')](_0x8c35('0x14'),_0x3d7668)][_0x5c66e3];}emit(util[_0x8c35('0x13')]('%s:queue:%s',_0x3d7668,_0x287637),util[_0x8c35('0x13')]('%s_queue_waiting_interaction:%s',_0x3d7668,_0x5c7397?_0x8c35('0x16'):_0x8c35('0x17')),_[_0x8c35('0x15')](_0x535246,attributes));}var rpc={'openchannelQueueReport':require(_0x8c35('0x18')),'mailQueueReport':require(_0x8c35('0x19')),'chatQueueReport':require(_0x8c35('0x1a')),'smsQueueReport':require(_0x8c35('0x1b')),'faxQueueReport':require(_0x8c35('0x1c')),'whatsappQueueReport':require(_0x8c35('0x1d')),'chatInteraction':require(_0x8c35('0x1e')),'faxInteraction':require('../../rpc/faxInteraction'),'mailInteraction':require(_0x8c35('0x1f')),'openchannelInteraction':require('../../rpc/openchannelInteraction'),'smsInteraction':require(_0x8c35('0x20')),'whatsappInteraction':require(_0x8c35('0x21'))};var queue=schema({'name':{'type':_0x8c35('0x22'),'required':!![],'message':_0x8c35('0x23')},'timeout':{'type':_0x8c35('0x24'),'message':'timeout\x20is\x20a\x20number'}});function startRouting(_0x4d70da,_0x111a36,_0x5a0fb4,_0x4f87b3){if(_0x4d70da&&_0x111a36&&_0x5a0fb4){_0x111a36[_0x8c35('0x25')]+=0x1;var _0x176704={'uniqueid':_0x4d70da,'from':_0x5a0fb4[_0x8c35('0x26')]?_0x5a0fb4[_0x8c35('0x26')][_0x8c35('0x27')]:'','joinAt':moment()['format'](_0x8c35('0x28')),'ContactId':_0x5a0fb4['contact']?_0x5a0fb4['contact']['id']:null,'ListId':_0x5a0fb4[_0x8c35('0x29')]?_0x5a0fb4[_0x8c35('0x29')]['id']:null};_0x176704[_[_0x8c35('0x2a')](_0x5a0fb4[_0x8c35('0x2b')])+_0x8c35('0x2c')]=_0x111a36['id']||null;_0x176704[_[_0x8c35('0x2a')](_0x5a0fb4[_0x8c35('0x2b')])+'InteractionId']=_0x5a0fb4[_0x8c35('0x2d')]?_0x5a0fb4[_0x8c35('0x2d')]['id']:null;_0x176704[_[_0x8c35('0x2a')](_0x5a0fb4[_0x8c35('0x2b')])+_0x8c35('0x2e')]=_0x5a0fb4['message']?_0x5a0fb4['message']['id']:null;_0x176704[_[_0x8c35('0x2a')](_0x5a0fb4['channel'])+(_0x5a0fb4[_0x8c35('0x2b')]!==_0x8c35('0x2f')?_0x8c35('0x30'):'WebsiteId')]=_0x5a0fb4[_0x8c35('0xd')]?_0x5a0fb4['account']['id']:null;logger['info'](util['format'](_0x8c35('0x31'),_0x4d70da,_0x111a36[_0x8c35('0x32')]));emitChannelQueueInteraction(_0x5a0fb4['channel'],_0x111a36[_0x8c35('0x32')],_0x176704,_0x5a0fb4['account'][_0x8c35('0x32')],_0x5a0fb4['message']['id'],!![],_0x4f87b3,_0x111a36['id']);if(rpc[_0x5a0fb4[_0x8c35('0x2b')]+'QueueReport']){return rpc[_0x5a0fb4['channel']+_0x8c35('0x33')][_0x8c35('0x34')](_0x176704)[_0x8c35('0x35')](function(_0x488b71){logger['error'](_0x8c35('0x36'),_0x488b71);});}}}function stopRouting(_0x17d82a,_0x4ea808,_0x201200,_0x5696fe){if(_0x17d82a&&_0x4ea808){_0x4ea808[_0x8c35('0x25')]-=0x1;var _0x404a0b={'leaveAt':moment()[_0x8c35('0x13')](_0x8c35('0x28')),'acceptAt':moment()[_0x8c35('0x13')]('YYYY-MM-DD\x20HH:mm:ss'),'reason':'accepted'};logger[_0x8c35('0x37')](util[_0x8c35('0x13')]('[%s][STOP:QUEUE][NAME:%s]',_0x17d82a,_0x4ea808[_0x8c35('0x32')]));emitChannelQueueInteraction(_0x201200[_0x8c35('0x2b')],_0x4ea808[_0x8c35('0x32')],_0x201200['body'],_0x201200[_0x8c35('0xd')][_0x8c35('0x32')],_0x201200[_0x8c35('0x38')]['id'],![],_0x5696fe,_0x4ea808['id']);return rpc[_0x201200[_0x8c35('0x2b')]+_0x8c35('0x39')][_0x8c35('0x3a')](_0x201200[_0x8c35('0x2d')]['id'],{'queueId':_0x4ea808['id']})[_0x8c35('0x3b')](function(){if(rpc[_0x201200[_0x8c35('0x2b')]+'QueueReport']){return rpc[_0x201200[_0x8c35('0x2b')]+'QueueReport'][_0x8c35('0x3a')](_0x17d82a,_0x404a0b)['catch'](function(_0x4dafab){logger[_0x8c35('0x3c')](_0x8c35('0x3d'),_0x4dafab);});}});}}function endRouting(_0x16efba,_0x57c1e2,_0x33d14c,_0x19297f){if(_0x16efba&&_0x57c1e2){_0x57c1e2[_0x8c35('0x25')]-=0x1;var _0x278c7f={'leaveAt':moment()['format'](_0x8c35('0x28')),'exitAt':moment()[_0x8c35('0x13')](_0x8c35('0x28')),'reason':_0x8c35('0x3e')};logger[_0x8c35('0x37')](util[_0x8c35('0x13')](_0x8c35('0x3f'),_0x16efba,_0x57c1e2[_0x8c35('0x32')]));emitChannelQueueInteraction(_0x33d14c[_0x8c35('0x2b')],_0x57c1e2[_0x8c35('0x32')],_0x33d14c[_0x8c35('0x26')],_0x33d14c['account'][_0x8c35('0x32')],_0x33d14c['message']['id'],![],_0x19297f);if(rpc[_0x33d14c[_0x8c35('0x2b')]+'QueueReport']){return rpc[_0x33d14c[_0x8c35('0x2b')]+_0x8c35('0x33')][_0x8c35('0x3a')](_0x16efba,_0x278c7f)[_0x8c35('0x35')](function(_0x3a744e){logger[_0x8c35('0x3c')](_0x8c35('0x3d'),_0x3a744e);});}}}function handleFindQueue(_0x1c0f95){return function(_0x309fb7){return _0x309fb7['name'][_0x8c35('0x40')]()===_0x1c0f95[_0x8c35('0x40')]();};}exports[_0x8c35('0x41')]=function(_0x5334c3,_0x1af1b3,_0x4394d9,_0x1ff8ee){return function(_0x23313b){try{var _0x2072ac={'name':_0x1af1b3[0x0],'timeout':_0x1af1b3[0x1]};var _0x16ddb4=queue[_0x8c35('0x42')](_0x2072ac,{'typecast':!![]});if(_0x16ddb4['length']){logger['error'](_0x8c35('0x43'),_0x5334c3,_['map'](_0x16ddb4,_0x8c35('0x38'))[_0x8c35('0x44')](',\x20'));_0x23313b[_0x8c35('0x45')]();}else{var _0x450383=_[_0x8c35('0x46')](_0x4394d9[_0x1ff8ee[_0x8c35('0x2b')]+_0x8c35('0x47')],handleFindQueue(_0x2072ac[_0x8c35('0x32')]));if(_0x450383){startRouting(_0x5334c3,_0x450383,_0x1ff8ee,_0x4394d9);var _0x46c795=(_0x450383[_0x8c35('0x3e')]||0xa)*0x3e8;var _0x3e264a=(_0x2072ac['timeout']||0x14)*0x3e8;var _0x3d836e;if(_0x46c795>_0x3e264a){_0x3e264a=_0x46c795;}var _0x6f4167=seqqueue['createQueue'](_0x46c795);_0x6f4167['id']=_0x5334c3;_0x6f4167[_0x8c35('0x48')]=_0x46c795;_0x6f4167['qtimeout']=_0x3e264a;_0x6f4167['channel']=_0x1ff8ee['channel'];_0x4394d9[_0x8c35('0x49')][_0x5334c3]['on'](_0x8c35('0x4a'),function(){logger['info'](_0x8c35('0x4b'),_0x5334c3);stopRouting(_0x5334c3,_0x450383,_0x1ff8ee,_0x4394d9);clearTimeout(_0x3d836e);_0x3d836e=undefined;_0x6f4167[_0x8c35('0x4c')](!![]);if(_0x4394d9[_0x8c35('0x49')][_0x5334c3]){delete _0x4394d9[_0x8c35('0x49')][_0x5334c3];}_0x23313b[_0x8c35('0x45')]();});_0x4394d9[_0x8c35('0x49')][_0x5334c3]['on'](_0x8c35('0x4d'),function(){if(_0x4394d9[_0x8c35('0x49')][_0x5334c3]){delete _0x4394d9[_0x8c35('0x49')][_0x5334c3];}});_0x3d836e=setTimeout(function(){logger[_0x8c35('0x37')]('[%s][QUEUE]\x20APPLICATION\x20END',_0x5334c3);endRouting(_0x5334c3,_0x450383,_0x1ff8ee,_0x4394d9);clearTimeout(_0x3d836e);_0x6f4167[_0x8c35('0x4c')](!![]);_0x23313b[_0x8c35('0x4e')]();},_0x3e264a);switch(_0x450383[_0x8c35('0x4f')]){case'rrmemory':strategy['rrmemory'](_0x6f4167,_0x450383,_0x4394d9,_0x1ff8ee);break;default:strategy[_0x8c35('0x50')](_0x6f4167,_0x450383,_0x4394d9,_0x1ff8ee);}}else{logger[_0x8c35('0x3c')](_0x8c35('0x51'),_0x5334c3,_0x2072ac[_0x8c35('0x32')]);_0x23313b['stop']();}}}catch(_0x3deaa4){logger['error'](_0x8c35('0x43'),_0x5334c3,_0x3deaa4['stack']);_0x23313b[_0x8c35('0x45')]();}};};
\ No newline at end of file
git://repos.xcallymotion.com / motion2.git / blobdiff