// * treaties. The SOFTWARE PRODUCT is licensed, not sold. *
// * *
// *************************************************************************
-var _0x22e7=['InteractionId','%sQueuesWaitingInteractions','format','%s:queue:%s','%s_queue_waiting_interaction:%s','remove','pick','../../rpc/mailQueueReport','../../rpc/smsQueueReport','../../rpc/faxQueueReport','../../rpc/whatsappQueueReport','../../rpc/mailInteraction','../../rpc/whatsappInteraction','string','name\x20is\x20a\x20string\x20and\x20it\x20is\x20required','number','timeout\x20is\x20a\x20number','waiting','body','contact','list','upperFirst','channel','QueueId','interaction','MessageId','chat','AccountId','WebsiteId','account','[%s][START:QUEUE][NAME:%s]','name','message','QueueReport','create','catch','create\x20queue\x20report','accepted','info','[%s][STOP:QUEUE][NAME:%s]','Interaction','update','then','update\x20queue\x20report','YYYY-MM-DD\x20HH:mm:ss','[%s][END:QUEUE][NAME:%s]','toLowerCase','consequence','length','error','join','find','timeout','createQueue','atimeout','qtimeout','end','[%s][QUEUE]\x20ROUTING\x20STOPPED','close','rules','stop','complete','[%s][QUEUE]\x20APPLICATION\x20END','next','strategy','rrmemory','beepall','[%s][QUEUE]\x20%s','stack','validate','lodash','util','seq-queue','moment','../../../../config/environment','../../../../config/logger','routing','./strategy','redis','defaults','socket.io-emitter','queue_id','queue','from','joinAt','emit','push','capitalize'];(function(_0xeef081,_0x410eb3){var _0x5739e0=function(_0x24605){while(--_0x24605){_0xeef081['push'](_0xeef081['shift']());}};_0x5739e0(++_0x410eb3);}(_0x22e7,0x9d));var _0x722e=function(_0x1b26dc,_0x3d7fdf){_0x1b26dc=_0x1b26dc-0x0;var _0x37c518=_0x22e7[_0x1b26dc];return _0x37c518;};'use strict';var schema=require(_0x722e('0x0'));var _=require(_0x722e('0x1'));var util=require(_0x722e('0x2'));var seqqueue=require(_0x722e('0x3'));var moment=require(_0x722e('0x4'));var Redis=require('ioredis');var config=require(_0x722e('0x5'));var logger=require(_0x722e('0x6'))(_0x722e('0x7'));var strategy=require(_0x722e('0x8'));config[_0x722e('0x9')]=_[_0x722e('0xa')](config['redis'],{'host':'localhost','port':0x18eb});var io=require(_0x722e('0xb'))(new Redis(config[_0x722e('0x9')]));var attributes=['id',_0x722e('0xc'),'account',_0x722e('0xd'),_0x722e('0xe'),_0x722e('0xf')];function emit(_0x220d17,_0x277d14,_0x497801){io['to'](_0x220d17)[_0x722e('0x10')](_0x277d14,_0x497801);}function emitChannelQueueInteraction(_0x29a436,_0x40cc4e,_0x558654,_0x4ea159,_0xf48b89,_0x4bb767,_0x5d8e87,_0xa88e21){var _0x69096b=_['clone'](_0x558654);_0x69096b[_0x722e('0xc')]=_0xa88e21;_0x69096b[_0x722e('0xd')]=_0x40cc4e;_0x69096b['account']=_0x4ea159;_0x69096b['id']=_0xf48b89;if(_0x4bb767){attributes[_0x722e('0x11')](_[_0x722e('0x12')](_0x29a436)+_0x722e('0x13'));_0x5d8e87[util['format'](_0x722e('0x14'),_0x29a436)][_0xf48b89]=_['pick'](_0x69096b,attributes);}else{delete _0x5d8e87[util[_0x722e('0x15')](_0x722e('0x14'),_0x29a436)][_0xf48b89];}emit(util[_0x722e('0x15')](_0x722e('0x16'),_0x29a436,_0x40cc4e),util['format'](_0x722e('0x17'),_0x29a436,_0x4bb767?'save':_0x722e('0x18')),_[_0x722e('0x19')](_0x69096b,attributes));}var rpc={'openchannelQueueReport':require('../../rpc/openchannelQueueReport'),'mailQueueReport':require(_0x722e('0x1a')),'chatQueueReport':require('../../rpc/chatQueueReport'),'smsQueueReport':require(_0x722e('0x1b')),'faxQueueReport':require(_0x722e('0x1c')),'whatsappQueueReport':require(_0x722e('0x1d')),'chatInteraction':require('../../rpc/chatInteraction'),'faxInteraction':require('../../rpc/faxInteraction'),'mailInteraction':require(_0x722e('0x1e')),'openchannelInteraction':require('../../rpc/openchannelInteraction'),'smsInteraction':require('../../rpc/smsInteraction'),'whatsappInteraction':require(_0x722e('0x1f'))};var queue=schema({'name':{'type':_0x722e('0x20'),'required':!![],'message':_0x722e('0x21')},'timeout':{'type':_0x722e('0x22'),'message':_0x722e('0x23')}});function startRouting(_0xfb4489,_0x2ad6d6,_0x5e971c,_0x259bcb){if(_0xfb4489&&_0x2ad6d6&&_0x5e971c){_0x2ad6d6[_0x722e('0x24')]+=0x1;var _0x531d58={'uniqueid':_0xfb4489,'from':_0x5e971c[_0x722e('0x25')]?_0x5e971c['body'][_0x722e('0xe')]:'','joinAt':moment()[_0x722e('0x15')]('YYYY-MM-DD\x20HH:mm:ss'),'ContactId':_0x5e971c[_0x722e('0x26')]?_0x5e971c[_0x722e('0x26')]['id']:null,'ListId':_0x5e971c[_0x722e('0x27')]?_0x5e971c[_0x722e('0x27')]['id']:null};_0x531d58[_[_0x722e('0x28')](_0x5e971c[_0x722e('0x29')])+_0x722e('0x2a')]=_0x2ad6d6['id']||null;_0x531d58[_[_0x722e('0x28')](_0x5e971c[_0x722e('0x29')])+'InteractionId']=_0x5e971c[_0x722e('0x2b')]?_0x5e971c[_0x722e('0x2b')]['id']:null;_0x531d58[_[_0x722e('0x28')](_0x5e971c[_0x722e('0x29')])+_0x722e('0x2c')]=_0x5e971c['message']?_0x5e971c['message']['id']:null;_0x531d58[_[_0x722e('0x28')](_0x5e971c[_0x722e('0x29')])+(_0x5e971c['channel']!==_0x722e('0x2d')?_0x722e('0x2e'):_0x722e('0x2f'))]=_0x5e971c[_0x722e('0x30')]?_0x5e971c[_0x722e('0x30')]['id']:null;logger['info'](util[_0x722e('0x15')](_0x722e('0x31'),_0xfb4489,_0x2ad6d6['name']));emitChannelQueueInteraction(_0x5e971c[_0x722e('0x29')],_0x2ad6d6[_0x722e('0x32')],_0x531d58,_0x5e971c[_0x722e('0x30')][_0x722e('0x32')],_0x5e971c[_0x722e('0x33')]['id'],!![],_0x259bcb,_0x2ad6d6['id']);if(rpc[_0x5e971c[_0x722e('0x29')]+_0x722e('0x34')]){return rpc[_0x5e971c[_0x722e('0x29')]+_0x722e('0x34')][_0x722e('0x35')](_0x531d58)[_0x722e('0x36')](function(_0x2efe2a){logger['error'](_0x722e('0x37'),_0x2efe2a);});}}}function stopRouting(_0x3c8f84,_0x1c1e67,_0x5b450f,_0x8b6375){if(_0x3c8f84&&_0x1c1e67){_0x1c1e67[_0x722e('0x24')]-=0x1;var _0x8341bb={'leaveAt':moment()[_0x722e('0x15')]('YYYY-MM-DD\x20HH:mm:ss'),'acceptAt':moment()[_0x722e('0x15')]('YYYY-MM-DD\x20HH:mm:ss'),'reason':_0x722e('0x38')};logger[_0x722e('0x39')](util['format'](_0x722e('0x3a'),_0x3c8f84,_0x1c1e67[_0x722e('0x32')]));emitChannelQueueInteraction(_0x5b450f[_0x722e('0x29')],_0x1c1e67[_0x722e('0x32')],_0x5b450f['body'],_0x5b450f[_0x722e('0x30')][_0x722e('0x32')],_0x5b450f[_0x722e('0x33')]['id'],![],_0x8b6375,_0x1c1e67['id']);return rpc[_0x5b450f[_0x722e('0x29')]+_0x722e('0x3b')][_0x722e('0x3c')](_0x5b450f['interaction']['id'],{'queueId':_0x1c1e67['id']})[_0x722e('0x3d')](function(){if(rpc[_0x5b450f[_0x722e('0x29')]+_0x722e('0x34')]){return rpc[_0x5b450f[_0x722e('0x29')]+'QueueReport']['update'](_0x3c8f84,_0x8341bb)[_0x722e('0x36')](function(_0x3bb3eb){logger['error'](_0x722e('0x3e'),_0x3bb3eb);});}});}}function endRouting(_0x52f22b,_0x1a151a,_0x58d58d,_0x325541){if(_0x52f22b&&_0x1a151a){_0x1a151a[_0x722e('0x24')]-=0x1;var _0x6b7e6a={'leaveAt':moment()[_0x722e('0x15')](_0x722e('0x3f')),'exitAt':moment()[_0x722e('0x15')](_0x722e('0x3f')),'reason':'timeout'};logger[_0x722e('0x39')](util['format'](_0x722e('0x40'),_0x52f22b,_0x1a151a[_0x722e('0x32')]));emitChannelQueueInteraction(_0x58d58d['channel'],_0x1a151a[_0x722e('0x32')],_0x58d58d[_0x722e('0x25')],_0x58d58d['account'][_0x722e('0x32')],_0x58d58d[_0x722e('0x33')]['id'],![],_0x325541);if(rpc[_0x58d58d['channel']+_0x722e('0x34')]){return rpc[_0x58d58d['channel']+'QueueReport']['update'](_0x52f22b,_0x6b7e6a)[_0x722e('0x36')](function(_0x34ab80){logger['error']('update\x20queue\x20report',_0x34ab80);});}}}function handleFindQueue(_0x501dc6){return function(_0x73e77){return _0x73e77['name'][_0x722e('0x41')]()===_0x501dc6[_0x722e('0x41')]();};}exports[_0x722e('0x42')]=function(_0x37f6f7,_0x3cfbc0,_0x5585d4,_0x22326c){return function(_0x10706c){try{var _0x43b375={'name':_0x3cfbc0[0x0],'timeout':_0x3cfbc0[0x1]};var _0x152cad=queue[_0x722e('0x0')](_0x43b375,{'typecast':!![]});if(_0x152cad[_0x722e('0x43')]){logger[_0x722e('0x44')]('[%s][QUEUE]\x20%s',_0x37f6f7,_['map'](_0x152cad,_0x722e('0x33'))[_0x722e('0x45')](',\x20'));_0x10706c['stop']();}else{var _0x283523=_[_0x722e('0x46')](_0x5585d4[_0x22326c[_0x722e('0x29')]+'Queues'],handleFindQueue(_0x43b375['name']));if(_0x283523){startRouting(_0x37f6f7,_0x283523,_0x22326c,_0x5585d4);var _0x21d541=(_0x283523[_0x722e('0x47')]||0xa)*0x3e8;var _0xa01dbe=(_0x43b375['timeout']||0x14)*0x3e8;var _0x1f42b8;if(_0x21d541>_0xa01dbe){_0xa01dbe=_0x21d541;}var _0x48e166=seqqueue[_0x722e('0x48')](_0x21d541);_0x48e166['id']=_0x37f6f7;_0x48e166[_0x722e('0x49')]=_0x21d541;_0x48e166[_0x722e('0x4a')]=_0xa01dbe;_0x48e166[_0x722e('0x29')]=_0x22326c[_0x722e('0x29')];_0x5585d4['rules'][_0x37f6f7]['on'](_0x722e('0x4b'),function(){logger[_0x722e('0x39')](_0x722e('0x4c'),_0x37f6f7);stopRouting(_0x37f6f7,_0x283523,_0x22326c,_0x5585d4);clearTimeout(_0x1f42b8);_0x1f42b8=undefined;_0x48e166[_0x722e('0x4d')](!![]);if(_0x5585d4['rules'][_0x37f6f7]){delete _0x5585d4[_0x722e('0x4e')][_0x37f6f7];}_0x10706c[_0x722e('0x4f')]();});_0x5585d4['rules'][_0x37f6f7]['on'](_0x722e('0x50'),function(){if(_0x5585d4[_0x722e('0x4e')][_0x37f6f7]){delete _0x5585d4[_0x722e('0x4e')][_0x37f6f7];}});_0x1f42b8=setTimeout(function(){logger['info'](_0x722e('0x51'),_0x37f6f7);endRouting(_0x37f6f7,_0x283523,_0x22326c,_0x5585d4);clearTimeout(_0x1f42b8);_0x48e166[_0x722e('0x4d')](!![]);_0x10706c[_0x722e('0x52')]();},_0xa01dbe);switch(_0x283523[_0x722e('0x53')]){case _0x722e('0x54'):strategy[_0x722e('0x54')](_0x48e166,_0x283523,_0x5585d4,_0x22326c);break;default:strategy[_0x722e('0x55')](_0x48e166,_0x283523,_0x5585d4,_0x22326c);}}else{logger[_0x722e('0x44')]('[%s][QUEUE]\x20queue\x20not\x20found\x20%s',_0x37f6f7,_0x43b375[_0x722e('0x32')]);_0x10706c[_0x722e('0x4f')]();}}}catch(_0x2391bd){logger[_0x722e('0x44')](_0x722e('0x56'),_0x37f6f7,_0x2391bd[_0x722e('0x57')]);_0x10706c[_0x722e('0x4f')]();}};};
\ No newline at end of file
+var _0xba88=['queue','joinAt','emit','push','InteractionId','pick','format','%sQueuesWaitingInteractions','%s:queue:%s','save','../../rpc/openchannelQueueReport','../../rpc/chatQueueReport','../../rpc/smsQueueReport','../../rpc/faxQueueReport','../../rpc/whatsappQueueReport','../../rpc/chatInteraction','../../rpc/faxInteraction','../../rpc/mailInteraction','../../rpc/openchannelInteraction','../../rpc/whatsappInteraction','string','name\x20is\x20a\x20string\x20and\x20it\x20is\x20required','number','timeout\x20is\x20a\x20number','waiting','body','from','YYYY-MM-DD\x20HH:mm:ss','contact','list','upperFirst','channel','interaction','MessageId','message','chat','WebsiteId','info','[%s][START:QUEUE][NAME:%s]','name','QueueReport','catch','error','create\x20queue\x20report','[%s][STOP:QUEUE][NAME:%s]','Interaction','update','update\x20queue\x20report','timeout','toLowerCase','consequence','length','[%s][QUEUE]\x20%s','map','join','stop','find','Queues','createQueue','atimeout','qtimeout','rules','end','close','complete','[%s][QUEUE]\x20APPLICATION\x20END','rrmemory','beepall','[%s][QUEUE]\x20queue\x20not\x20found\x20%s','validate','lodash','util','seq-queue','ioredis','../../../../config/environment','../../../../config/logger','routing','./strategy','redis','defaults','localhost','socket.io-emitter','queue_id','account'];(function(_0x582dfb,_0x414f3c){var _0x47aa0b=function(_0x21c0bf){while(--_0x21c0bf){_0x582dfb['push'](_0x582dfb['shift']());}};_0x47aa0b(++_0x414f3c);}(_0xba88,0xed));var _0x8ba8=function(_0x138ff3,_0x3d88d6){_0x138ff3=_0x138ff3-0x0;var _0x5e6132=_0xba88[_0x138ff3];return _0x5e6132;};'use strict';var schema=require(_0x8ba8('0x0'));var _=require(_0x8ba8('0x1'));var util=require(_0x8ba8('0x2'));var seqqueue=require(_0x8ba8('0x3'));var moment=require('moment');var Redis=require(_0x8ba8('0x4'));var config=require(_0x8ba8('0x5'));var logger=require(_0x8ba8('0x6'))(_0x8ba8('0x7'));var strategy=require(_0x8ba8('0x8'));config[_0x8ba8('0x9')]=_[_0x8ba8('0xa')](config['redis'],{'host':_0x8ba8('0xb'),'port':0x18eb});var io=require(_0x8ba8('0xc'))(new Redis(config[_0x8ba8('0x9')]));var attributes=['id',_0x8ba8('0xd'),_0x8ba8('0xe'),_0x8ba8('0xf'),'from',_0x8ba8('0x10')];function emit(_0x1634ab,_0x15bfeb,_0x582b62){io['to'](_0x1634ab)[_0x8ba8('0x11')](_0x15bfeb,_0x582b62);}function emitChannelQueueInteraction(_0x3f2b27,_0x55ea25,_0x250885,_0x53fd55,_0x119796,_0x57f48e,_0x136a28,_0x63d6be){var _0x192079=_['clone'](_0x250885);_0x192079[_0x8ba8('0xd')]=_0x63d6be;_0x192079[_0x8ba8('0xf')]=_0x55ea25;_0x192079[_0x8ba8('0xe')]=_0x53fd55;_0x192079['id']=_0x119796;if(_0x57f48e){attributes[_0x8ba8('0x12')](_['capitalize'](_0x3f2b27)+_0x8ba8('0x13'));_0x136a28[util['format']('%sQueuesWaitingInteractions',_0x3f2b27)][_0x119796]=_[_0x8ba8('0x14')](_0x192079,attributes);}else{delete _0x136a28[util[_0x8ba8('0x15')](_0x8ba8('0x16'),_0x3f2b27)][_0x119796];}emit(util['format'](_0x8ba8('0x17'),_0x3f2b27,_0x55ea25),util['format']('%s_queue_waiting_interaction:%s',_0x3f2b27,_0x57f48e?_0x8ba8('0x18'):'remove'),_[_0x8ba8('0x14')](_0x192079,attributes));}var rpc={'openchannelQueueReport':require(_0x8ba8('0x19')),'mailQueueReport':require('../../rpc/mailQueueReport'),'chatQueueReport':require(_0x8ba8('0x1a')),'smsQueueReport':require(_0x8ba8('0x1b')),'faxQueueReport':require(_0x8ba8('0x1c')),'whatsappQueueReport':require(_0x8ba8('0x1d')),'chatInteraction':require(_0x8ba8('0x1e')),'faxInteraction':require(_0x8ba8('0x1f')),'mailInteraction':require(_0x8ba8('0x20')),'openchannelInteraction':require(_0x8ba8('0x21')),'smsInteraction':require('../../rpc/smsInteraction'),'whatsappInteraction':require(_0x8ba8('0x22'))};var queue=schema({'name':{'type':_0x8ba8('0x23'),'required':!![],'message':_0x8ba8('0x24')},'timeout':{'type':_0x8ba8('0x25'),'message':_0x8ba8('0x26')}});function startRouting(_0x46328f,_0x489ce4,_0x1c29cd,_0x1691a6){if(_0x46328f&&_0x489ce4&&_0x1c29cd){_0x489ce4[_0x8ba8('0x27')]+=0x1;var _0x299988={'uniqueid':_0x46328f,'from':_0x1c29cd[_0x8ba8('0x28')]?_0x1c29cd[_0x8ba8('0x28')][_0x8ba8('0x29')]:'','joinAt':moment()[_0x8ba8('0x15')](_0x8ba8('0x2a')),'ContactId':_0x1c29cd['contact']?_0x1c29cd[_0x8ba8('0x2b')]['id']:null,'ListId':_0x1c29cd[_0x8ba8('0x2c')]?_0x1c29cd[_0x8ba8('0x2c')]['id']:null};_0x299988[_[_0x8ba8('0x2d')](_0x1c29cd[_0x8ba8('0x2e')])+'QueueId']=_0x489ce4['id']||null;_0x299988[_['upperFirst'](_0x1c29cd[_0x8ba8('0x2e')])+_0x8ba8('0x13')]=_0x1c29cd[_0x8ba8('0x2f')]?_0x1c29cd[_0x8ba8('0x2f')]['id']:null;_0x299988[_[_0x8ba8('0x2d')](_0x1c29cd[_0x8ba8('0x2e')])+_0x8ba8('0x30')]=_0x1c29cd['message']?_0x1c29cd[_0x8ba8('0x31')]['id']:null;_0x299988[_[_0x8ba8('0x2d')](_0x1c29cd[_0x8ba8('0x2e')])+(_0x1c29cd[_0x8ba8('0x2e')]!==_0x8ba8('0x32')?'AccountId':_0x8ba8('0x33'))]=_0x1c29cd['account']?_0x1c29cd[_0x8ba8('0xe')]['id']:null;logger[_0x8ba8('0x34')](util['format'](_0x8ba8('0x35'),_0x46328f,_0x489ce4[_0x8ba8('0x36')]));emitChannelQueueInteraction(_0x1c29cd[_0x8ba8('0x2e')],_0x489ce4['name'],_0x299988,_0x1c29cd[_0x8ba8('0xe')]['name'],_0x1c29cd[_0x8ba8('0x31')]['id'],!![],_0x1691a6,_0x489ce4['id']);if(rpc[_0x1c29cd['channel']+_0x8ba8('0x37')]){return rpc[_0x1c29cd[_0x8ba8('0x2e')]+'QueueReport']['create'](_0x299988)[_0x8ba8('0x38')](function(_0x11dc70){logger[_0x8ba8('0x39')](_0x8ba8('0x3a'),_0x11dc70);});}}}function stopRouting(_0x18f504,_0x12a97e,_0x4435ed,_0x35324b){if(_0x18f504&&_0x12a97e){_0x12a97e[_0x8ba8('0x27')]-=0x1;var _0x2e507a={'leaveAt':moment()['format'](_0x8ba8('0x2a')),'acceptAt':moment()[_0x8ba8('0x15')](_0x8ba8('0x2a')),'reason':'accepted'};logger['info'](util[_0x8ba8('0x15')](_0x8ba8('0x3b'),_0x18f504,_0x12a97e[_0x8ba8('0x36')]));emitChannelQueueInteraction(_0x4435ed[_0x8ba8('0x2e')],_0x12a97e['name'],_0x4435ed[_0x8ba8('0x28')],_0x4435ed[_0x8ba8('0xe')]['name'],_0x4435ed[_0x8ba8('0x31')]['id'],![],_0x35324b,_0x12a97e['id']);return rpc[_0x4435ed['channel']+_0x8ba8('0x3c')]['update'](_0x4435ed[_0x8ba8('0x2f')]['id'],{'queueId':_0x12a97e['id']})['then'](function(){if(rpc[_0x4435ed[_0x8ba8('0x2e')]+_0x8ba8('0x37')]){return rpc[_0x4435ed[_0x8ba8('0x2e')]+_0x8ba8('0x37')][_0x8ba8('0x3d')](_0x18f504,_0x2e507a)[_0x8ba8('0x38')](function(_0x7edc97){logger[_0x8ba8('0x39')](_0x8ba8('0x3e'),_0x7edc97);});}});}}function endRouting(_0x592c84,_0x516d9f,_0x16b4a1,_0x1f1404){if(_0x592c84&&_0x516d9f){_0x516d9f['waiting']-=0x1;var _0x2eba82={'leaveAt':moment()['format']('YYYY-MM-DD\x20HH:mm:ss'),'exitAt':moment()[_0x8ba8('0x15')](_0x8ba8('0x2a')),'reason':_0x8ba8('0x3f')};logger[_0x8ba8('0x34')](util['format']('[%s][END:QUEUE][NAME:%s]',_0x592c84,_0x516d9f[_0x8ba8('0x36')]));emitChannelQueueInteraction(_0x16b4a1[_0x8ba8('0x2e')],_0x516d9f[_0x8ba8('0x36')],_0x16b4a1['body'],_0x16b4a1[_0x8ba8('0xe')][_0x8ba8('0x36')],_0x16b4a1[_0x8ba8('0x31')]['id'],![],_0x1f1404);if(rpc[_0x16b4a1[_0x8ba8('0x2e')]+_0x8ba8('0x37')]){return rpc[_0x16b4a1[_0x8ba8('0x2e')]+_0x8ba8('0x37')][_0x8ba8('0x3d')](_0x592c84,_0x2eba82)[_0x8ba8('0x38')](function(_0x2b9982){logger[_0x8ba8('0x39')](_0x8ba8('0x3e'),_0x2b9982);});}}}function handleFindQueue(_0x1e44c5){return function(_0x5290c8){return _0x5290c8[_0x8ba8('0x36')][_0x8ba8('0x40')]()===_0x1e44c5[_0x8ba8('0x40')]();};}exports[_0x8ba8('0x41')]=function(_0x4715b2,_0x485105,_0x18a8b5,_0x24eb5a){return function(_0x34b1fa){try{var _0x1c034d={'name':_0x485105[0x0],'timeout':_0x485105[0x1]};var _0x33781d=queue[_0x8ba8('0x0')](_0x1c034d,{'typecast':!![]});if(_0x33781d[_0x8ba8('0x42')]){logger['error'](_0x8ba8('0x43'),_0x4715b2,_[_0x8ba8('0x44')](_0x33781d,'message')[_0x8ba8('0x45')](',\x20'));_0x34b1fa[_0x8ba8('0x46')]();}else{var _0xe21e52=_[_0x8ba8('0x47')](_0x18a8b5[_0x24eb5a['channel']+_0x8ba8('0x48')],handleFindQueue(_0x1c034d['name']));if(_0xe21e52){startRouting(_0x4715b2,_0xe21e52,_0x24eb5a,_0x18a8b5);var _0x1c8a80=(_0xe21e52['timeout']||0xa)*0x3e8;var _0x3587c3=(_0x1c034d[_0x8ba8('0x3f')]||0x14)*0x3e8;var _0x4cc3c5;if(_0x1c8a80>_0x3587c3){_0x3587c3=_0x1c8a80;}var _0x28231c=seqqueue[_0x8ba8('0x49')](_0x1c8a80);_0x28231c['id']=_0x4715b2;_0x28231c[_0x8ba8('0x4a')]=_0x1c8a80;_0x28231c[_0x8ba8('0x4b')]=_0x3587c3;_0x28231c['channel']=_0x24eb5a[_0x8ba8('0x2e')];_0x18a8b5[_0x8ba8('0x4c')][_0x4715b2]['on'](_0x8ba8('0x4d'),function(){logger[_0x8ba8('0x34')]('[%s][QUEUE]\x20ROUTING\x20STOPPED',_0x4715b2);stopRouting(_0x4715b2,_0xe21e52,_0x24eb5a,_0x18a8b5);clearTimeout(_0x4cc3c5);_0x4cc3c5=undefined;_0x28231c[_0x8ba8('0x4e')](!![]);if(_0x18a8b5[_0x8ba8('0x4c')][_0x4715b2]){delete _0x18a8b5['rules'][_0x4715b2];}_0x34b1fa[_0x8ba8('0x46')]();});_0x18a8b5[_0x8ba8('0x4c')][_0x4715b2]['on'](_0x8ba8('0x4f'),function(){if(_0x18a8b5[_0x8ba8('0x4c')][_0x4715b2]){delete _0x18a8b5[_0x8ba8('0x4c')][_0x4715b2];}});_0x4cc3c5=setTimeout(function(){logger['info'](_0x8ba8('0x50'),_0x4715b2);endRouting(_0x4715b2,_0xe21e52,_0x24eb5a,_0x18a8b5);clearTimeout(_0x4cc3c5);_0x28231c[_0x8ba8('0x4e')](!![]);_0x34b1fa['next']();},_0x3587c3);switch(_0xe21e52['strategy']){case _0x8ba8('0x51'):strategy[_0x8ba8('0x51')](_0x28231c,_0xe21e52,_0x18a8b5,_0x24eb5a);break;default:strategy[_0x8ba8('0x52')](_0x28231c,_0xe21e52,_0x18a8b5,_0x24eb5a);}}else{logger[_0x8ba8('0x39')](_0x8ba8('0x53'),_0x4715b2,_0x1c034d[_0x8ba8('0x36')]);_0x34b1fa[_0x8ba8('0x46')]();}}}catch(_0x1a6fba){logger['error']('[%s][QUEUE]\x20%s',_0x4715b2,_0x1a6fba['stack']);_0x34b1fa[_0x8ba8('0x46')]();}};};
\ No newline at end of file
git://repos.xcallymotion.com / motion2.git / blobdiff