// * treaties. The SOFTWARE PRODUCT is licensed, not sold. *
// * *
// *************************************************************************
-var _0x2c91=['accepted','info','[%s][STOP:QUEUE][NAME:%s]','Interaction','update','then','timeout','update\x20queue\x20report','toLowerCase','consequence','[%s][QUEUE]\x20%s','join','stop','find','Queues','createQueue','atimeout','qtimeout','rules','end','[%s][QUEUE]\x20ROUTING\x20STOPPED','close','complete','[%s][QUEUE]\x20APPLICATION\x20END','next','strategy','rrmemory','beepall','[%s][QUEUE]\x20queue\x20not\x20found\x20%s','stack','validate','lodash','seq-queue','ioredis','../../../../config/environment','../../../../config/logger','routing','./strategy','defaults','redis','localhost','socket.io-emitter','queue_id','account','queue','from','joinAt','emit','clone','push','capitalize','pick','format','%sQueuesWaitingInteractions','%s:queue:%s','%s_queue_waiting_interaction:%s','save','remove','../../rpc/openchannelQueueReport','../../rpc/chatQueueReport','../../rpc/smsQueueReport','../../rpc/faxQueueReport','../../rpc/whatsappQueueReport','../../rpc/faxInteraction','../../rpc/mailInteraction','../../rpc/openchannelInteraction','../../rpc/whatsappInteraction','name\x20is\x20a\x20string\x20and\x20it\x20is\x20required','waiting','body','contact','list','upperFirst','channel','QueueId','InteractionId','interaction','MessageId','message','chat','AccountId','WebsiteId','[%s][START:QUEUE][NAME:%s]','name','QueueReport','catch','error','create\x20queue\x20report','YYYY-MM-DD\x20HH:mm:ss'];(function(_0x419e17,_0x7fe78c){var _0x1f2044=function(_0x3723e6){while(--_0x3723e6){_0x419e17['push'](_0x419e17['shift']());}};_0x1f2044(++_0x7fe78c);}(_0x2c91,0x1db));var _0x12c9=function(_0x10c712,_0x223e99){_0x10c712=_0x10c712-0x0;var _0x184cd3=_0x2c91[_0x10c712];return _0x184cd3;};'use strict';var schema=require(_0x12c9('0x0'));var _=require(_0x12c9('0x1'));var util=require('util');var seqqueue=require(_0x12c9('0x2'));var moment=require('moment');var Redis=require(_0x12c9('0x3'));var config=require(_0x12c9('0x4'));var logger=require(_0x12c9('0x5'))(_0x12c9('0x6'));var strategy=require(_0x12c9('0x7'));config['redis']=_[_0x12c9('0x8')](config[_0x12c9('0x9')],{'host':_0x12c9('0xa'),'port':0x18eb});var io=require(_0x12c9('0xb'))(new Redis(config['redis']));var attributes=['id',_0x12c9('0xc'),_0x12c9('0xd'),_0x12c9('0xe'),_0x12c9('0xf'),_0x12c9('0x10')];function emit(_0x346976,_0x221cd4,_0x54f3ed){io['to'](_0x346976)[_0x12c9('0x11')](_0x221cd4,_0x54f3ed);}function emitChannelQueueInteraction(_0x289081,_0x50eee8,_0x1ad2c0,_0x4bc9f6,_0x4a7b07,_0x3fcec5,_0x38a414,_0x39425c){var _0xa6572c=_[_0x12c9('0x12')](_0x1ad2c0);_0xa6572c[_0x12c9('0xc')]=_0x39425c;_0xa6572c[_0x12c9('0xe')]=_0x50eee8;_0xa6572c[_0x12c9('0xd')]=_0x4bc9f6;_0xa6572c['id']=_0x4a7b07;if(_0x3fcec5){attributes[_0x12c9('0x13')](_[_0x12c9('0x14')](_0x289081)+'InteractionId');_0x38a414[util['format']('%sQueuesWaitingInteractions',_0x289081)][_0x4a7b07]=_[_0x12c9('0x15')](_0xa6572c,attributes);}else{delete _0x38a414[util[_0x12c9('0x16')](_0x12c9('0x17'),_0x289081)][_0x4a7b07];}emit(util['format'](_0x12c9('0x18'),_0x289081,_0x50eee8),util[_0x12c9('0x16')](_0x12c9('0x19'),_0x289081,_0x3fcec5?_0x12c9('0x1a'):_0x12c9('0x1b')),_[_0x12c9('0x15')](_0xa6572c,attributes));}var rpc={'openchannelQueueReport':require(_0x12c9('0x1c')),'mailQueueReport':require('../../rpc/mailQueueReport'),'chatQueueReport':require(_0x12c9('0x1d')),'smsQueueReport':require(_0x12c9('0x1e')),'faxQueueReport':require(_0x12c9('0x1f')),'whatsappQueueReport':require(_0x12c9('0x20')),'chatInteraction':require('../../rpc/chatInteraction'),'faxInteraction':require(_0x12c9('0x21')),'mailInteraction':require(_0x12c9('0x22')),'openchannelInteraction':require(_0x12c9('0x23')),'smsInteraction':require('../../rpc/smsInteraction'),'whatsappInteraction':require(_0x12c9('0x24'))};var queue=schema({'name':{'type':'string','required':!![],'message':_0x12c9('0x25')},'timeout':{'type':'number','message':'timeout\x20is\x20a\x20number'}});function startRouting(_0x5e24c3,_0xa3ad35,_0x10729a,_0x301786){if(_0x5e24c3&&_0xa3ad35&&_0x10729a){_0xa3ad35[_0x12c9('0x26')]+=0x1;var _0xb56f79={'uniqueid':_0x5e24c3,'from':_0x10729a[_0x12c9('0x27')]?_0x10729a[_0x12c9('0x27')][_0x12c9('0xf')]:'','joinAt':moment()[_0x12c9('0x16')]('YYYY-MM-DD\x20HH:mm:ss'),'ContactId':_0x10729a['contact']?_0x10729a[_0x12c9('0x28')]['id']:null,'ListId':_0x10729a['list']?_0x10729a[_0x12c9('0x29')]['id']:null};_0xb56f79[_[_0x12c9('0x2a')](_0x10729a[_0x12c9('0x2b')])+_0x12c9('0x2c')]=_0xa3ad35['id']||null;_0xb56f79[_[_0x12c9('0x2a')](_0x10729a[_0x12c9('0x2b')])+_0x12c9('0x2d')]=_0x10729a[_0x12c9('0x2e')]?_0x10729a[_0x12c9('0x2e')]['id']:null;_0xb56f79[_[_0x12c9('0x2a')](_0x10729a[_0x12c9('0x2b')])+_0x12c9('0x2f')]=_0x10729a[_0x12c9('0x30')]?_0x10729a['message']['id']:null;_0xb56f79[_[_0x12c9('0x2a')](_0x10729a[_0x12c9('0x2b')])+(_0x10729a[_0x12c9('0x2b')]!==_0x12c9('0x31')?_0x12c9('0x32'):_0x12c9('0x33'))]=_0x10729a[_0x12c9('0xd')]?_0x10729a[_0x12c9('0xd')]['id']:null;logger['info'](util[_0x12c9('0x16')](_0x12c9('0x34'),_0x5e24c3,_0xa3ad35[_0x12c9('0x35')]));emitChannelQueueInteraction(_0x10729a[_0x12c9('0x2b')],_0xa3ad35['name'],_0xb56f79,_0x10729a[_0x12c9('0xd')]['name'],_0x10729a[_0x12c9('0x30')]['id'],!![],_0x301786,_0xa3ad35['id']);if(rpc[_0x10729a['channel']+_0x12c9('0x36')]){return rpc[_0x10729a['channel']+_0x12c9('0x36')]['create'](_0xb56f79)[_0x12c9('0x37')](function(_0x39a8a4){logger[_0x12c9('0x38')](_0x12c9('0x39'),_0x39a8a4);});}}}function stopRouting(_0x17657,_0x2515e0,_0x3badcf,_0x304b60){if(_0x17657&&_0x2515e0){_0x2515e0[_0x12c9('0x26')]-=0x1;var _0xed0cf9={'leaveAt':moment()[_0x12c9('0x16')](_0x12c9('0x3a')),'acceptAt':moment()['format']('YYYY-MM-DD\x20HH:mm:ss'),'reason':_0x12c9('0x3b')};logger[_0x12c9('0x3c')](util[_0x12c9('0x16')](_0x12c9('0x3d'),_0x17657,_0x2515e0[_0x12c9('0x35')]));emitChannelQueueInteraction(_0x3badcf[_0x12c9('0x2b')],_0x2515e0[_0x12c9('0x35')],_0x3badcf['body'],_0x3badcf[_0x12c9('0xd')][_0x12c9('0x35')],_0x3badcf[_0x12c9('0x30')]['id'],![],_0x304b60,_0x2515e0['id']);return rpc[_0x3badcf[_0x12c9('0x2b')]+_0x12c9('0x3e')][_0x12c9('0x3f')](_0x3badcf[_0x12c9('0x2e')]['id'],{'queueId':_0x2515e0['id']})[_0x12c9('0x40')](function(){if(rpc[_0x3badcf[_0x12c9('0x2b')]+_0x12c9('0x36')]){return rpc[_0x3badcf[_0x12c9('0x2b')]+_0x12c9('0x36')][_0x12c9('0x3f')](_0x17657,_0xed0cf9)[_0x12c9('0x37')](function(_0x944014){logger[_0x12c9('0x38')]('update\x20queue\x20report',_0x944014);});}});}}function endRouting(_0x42ec3c,_0x24856b,_0xaef8ed,_0x49ee29){if(_0x42ec3c&&_0x24856b){_0x24856b[_0x12c9('0x26')]-=0x1;var _0x3cae0a={'leaveAt':moment()[_0x12c9('0x16')]('YYYY-MM-DD\x20HH:mm:ss'),'exitAt':moment()[_0x12c9('0x16')](_0x12c9('0x3a')),'reason':_0x12c9('0x41')};logger[_0x12c9('0x3c')](util[_0x12c9('0x16')]('[%s][END:QUEUE][NAME:%s]',_0x42ec3c,_0x24856b[_0x12c9('0x35')]));emitChannelQueueInteraction(_0xaef8ed[_0x12c9('0x2b')],_0x24856b[_0x12c9('0x35')],_0xaef8ed['body'],_0xaef8ed[_0x12c9('0xd')][_0x12c9('0x35')],_0xaef8ed[_0x12c9('0x30')]['id'],![],_0x49ee29);if(rpc[_0xaef8ed['channel']+'QueueReport']){return rpc[_0xaef8ed[_0x12c9('0x2b')]+_0x12c9('0x36')][_0x12c9('0x3f')](_0x42ec3c,_0x3cae0a)[_0x12c9('0x37')](function(_0x640552){logger['error'](_0x12c9('0x42'),_0x640552);});}}}function handleFindQueue(_0x468d29){return function(_0x39d3ed){return _0x39d3ed['name'][_0x12c9('0x43')]()===_0x468d29[_0x12c9('0x43')]();};}exports[_0x12c9('0x44')]=function(_0x1f4b33,_0x59fe73,_0x4d8783,_0x3d016a){return function(_0x252c8f){try{var _0x41dca5={'name':_0x59fe73[0x0],'timeout':_0x59fe73[0x1]};var _0x44f27e=queue[_0x12c9('0x0')](_0x41dca5,{'typecast':!![]});if(_0x44f27e['length']){logger[_0x12c9('0x38')](_0x12c9('0x45'),_0x1f4b33,_['map'](_0x44f27e,_0x12c9('0x30'))[_0x12c9('0x46')](',\x20'));_0x252c8f[_0x12c9('0x47')]();}else{var _0x47bbc0=_[_0x12c9('0x48')](_0x4d8783[_0x3d016a['channel']+_0x12c9('0x49')],handleFindQueue(_0x41dca5[_0x12c9('0x35')]));if(_0x47bbc0){startRouting(_0x1f4b33,_0x47bbc0,_0x3d016a,_0x4d8783);var _0x2202c5=(_0x47bbc0['timeout']||0xa)*0x3e8;var _0x73bc8d=(_0x41dca5[_0x12c9('0x41')]||0x14)*0x3e8;var _0x18b441;if(_0x2202c5>_0x73bc8d){_0x73bc8d=_0x2202c5;}var _0x31340e=seqqueue[_0x12c9('0x4a')](_0x2202c5);_0x31340e['id']=_0x1f4b33;_0x31340e[_0x12c9('0x4b')]=_0x2202c5;_0x31340e[_0x12c9('0x4c')]=_0x73bc8d;_0x31340e[_0x12c9('0x2b')]=_0x3d016a[_0x12c9('0x2b')];_0x4d8783[_0x12c9('0x4d')][_0x1f4b33]['on'](_0x12c9('0x4e'),function(){logger[_0x12c9('0x3c')](_0x12c9('0x4f'),_0x1f4b33);stopRouting(_0x1f4b33,_0x47bbc0,_0x3d016a,_0x4d8783);clearTimeout(_0x18b441);_0x18b441=undefined;_0x31340e[_0x12c9('0x50')](!![]);if(_0x4d8783[_0x12c9('0x4d')][_0x1f4b33]){delete _0x4d8783[_0x12c9('0x4d')][_0x1f4b33];}_0x252c8f[_0x12c9('0x47')]();});_0x4d8783[_0x12c9('0x4d')][_0x1f4b33]['on'](_0x12c9('0x51'),function(){if(_0x4d8783['rules'][_0x1f4b33]){delete _0x4d8783[_0x12c9('0x4d')][_0x1f4b33];}});_0x18b441=setTimeout(function(){logger[_0x12c9('0x3c')](_0x12c9('0x52'),_0x1f4b33);endRouting(_0x1f4b33,_0x47bbc0,_0x3d016a,_0x4d8783);clearTimeout(_0x18b441);_0x31340e[_0x12c9('0x50')](!![]);_0x252c8f[_0x12c9('0x53')]();},_0x73bc8d);switch(_0x47bbc0[_0x12c9('0x54')]){case _0x12c9('0x55'):strategy[_0x12c9('0x55')](_0x31340e,_0x47bbc0,_0x4d8783,_0x3d016a);break;default:strategy[_0x12c9('0x56')](_0x31340e,_0x47bbc0,_0x4d8783,_0x3d016a);}}else{logger['error'](_0x12c9('0x57'),_0x1f4b33,_0x41dca5['name']);_0x252c8f[_0x12c9('0x47')]();}}}catch(_0x57f777){logger['error'](_0x12c9('0x45'),_0x1f4b33,_0x57f777[_0x12c9('0x58')]);_0x252c8f[_0x12c9('0x47')]();}};};
\ No newline at end of file
+var _0xa846=['strategy','rrmemory','[%s][QUEUE]\x20queue\x20not\x20found\x20%s','stack','lodash','util','seq-queue','../../../../config/environment','../../../../config/logger','routing','./strategy','redis','defaults','socket.io-emitter','account','queue','joinAt','clone','queue_id','InteractionId','format','%sQueuesWaitingInteractions','pick','%s:queue:%s','%s_queue_waiting_interaction:%s','save','remove','../../rpc/mailQueueReport','../../rpc/chatQueueReport','../../rpc/smsQueueReport','../../rpc/faxQueueReport','../../rpc/whatsappQueueReport','../../rpc/chatInteraction','../../rpc/faxInteraction','../../rpc/smsInteraction','string','name\x20is\x20a\x20string\x20and\x20it\x20is\x20required','number','timeout\x20is\x20a\x20number','waiting','body','contact','list','QueueId','upperFirst','channel','interaction','message','AccountId','info','[%s][START:QUEUE][NAME:%s]','name','QueueReport','create','catch','error','create\x20queue\x20report','YYYY-MM-DD\x20HH:mm:ss','accepted','Interaction','update','then','timeout','toLowerCase','consequence','[%s][QUEUE]\x20%s','map','join','stop','Queues','createQueue','qtimeout','rules','end','[%s][QUEUE]\x20ROUTING\x20STOPPED','close','complete','next'];(function(_0x27af45,_0x1b57aa){var _0x18df21=function(_0x4b7679){while(--_0x4b7679){_0x27af45['push'](_0x27af45['shift']());}};_0x18df21(++_0x1b57aa);}(_0xa846,0x18a));var _0x6a84=function(_0x2f4767,_0x4f317b){_0x2f4767=_0x2f4767-0x0;var _0x3d8aae=_0xa846[_0x2f4767];return _0x3d8aae;};'use strict';var schema=require('validate');var _=require(_0x6a84('0x0'));var util=require(_0x6a84('0x1'));var seqqueue=require(_0x6a84('0x2'));var moment=require('moment');var Redis=require('ioredis');var config=require(_0x6a84('0x3'));var logger=require(_0x6a84('0x4'))(_0x6a84('0x5'));var strategy=require(_0x6a84('0x6'));config[_0x6a84('0x7')]=_[_0x6a84('0x8')](config[_0x6a84('0x7')],{'host':'localhost','port':0x18eb});var io=require(_0x6a84('0x9'))(new Redis(config[_0x6a84('0x7')]));var attributes=['id','queue_id',_0x6a84('0xa'),_0x6a84('0xb'),'from',_0x6a84('0xc')];function emit(_0x4c752b,_0x55f147,_0x6cd601){io['to'](_0x4c752b)['emit'](_0x55f147,_0x6cd601);}function emitChannelQueueInteraction(_0x18bfbe,_0x330a32,_0xa8c3f1,_0x484440,_0x3741f3,_0x30bd6d,_0x3b6a7e,_0x14afb2){var _0x4724c6=_[_0x6a84('0xd')](_0xa8c3f1);_0x4724c6[_0x6a84('0xe')]=_0x14afb2;_0x4724c6[_0x6a84('0xb')]=_0x330a32;_0x4724c6[_0x6a84('0xa')]=_0x484440;_0x4724c6['id']=_0x3741f3;if(_0x30bd6d){attributes['push'](_['capitalize'](_0x18bfbe)+_0x6a84('0xf'));_0x3b6a7e[util[_0x6a84('0x10')](_0x6a84('0x11'),_0x18bfbe)][_0x3741f3]=_[_0x6a84('0x12')](_0x4724c6,attributes);}else{delete _0x3b6a7e[util[_0x6a84('0x10')]('%sQueuesWaitingInteractions',_0x18bfbe)][_0x3741f3];}emit(util[_0x6a84('0x10')](_0x6a84('0x13'),_0x18bfbe,_0x330a32),util[_0x6a84('0x10')](_0x6a84('0x14'),_0x18bfbe,_0x30bd6d?_0x6a84('0x15'):_0x6a84('0x16')),_[_0x6a84('0x12')](_0x4724c6,attributes));}var rpc={'openchannelQueueReport':require('../../rpc/openchannelQueueReport'),'mailQueueReport':require(_0x6a84('0x17')),'chatQueueReport':require(_0x6a84('0x18')),'smsQueueReport':require(_0x6a84('0x19')),'faxQueueReport':require(_0x6a84('0x1a')),'whatsappQueueReport':require(_0x6a84('0x1b')),'chatInteraction':require(_0x6a84('0x1c')),'faxInteraction':require(_0x6a84('0x1d')),'mailInteraction':require('../../rpc/mailInteraction'),'openchannelInteraction':require('../../rpc/openchannelInteraction'),'smsInteraction':require(_0x6a84('0x1e')),'whatsappInteraction':require('../../rpc/whatsappInteraction')};var queue=schema({'name':{'type':_0x6a84('0x1f'),'required':!![],'message':_0x6a84('0x20')},'timeout':{'type':_0x6a84('0x21'),'message':_0x6a84('0x22')}});function startRouting(_0x5eec64,_0x1f45a7,_0x31aeba,_0x3bfdfb){if(_0x5eec64&&_0x1f45a7&&_0x31aeba){_0x1f45a7[_0x6a84('0x23')]+=0x1;var _0x4c86db={'uniqueid':_0x5eec64,'from':_0x31aeba['body']?_0x31aeba[_0x6a84('0x24')]['from']:'','joinAt':moment()[_0x6a84('0x10')]('YYYY-MM-DD\x20HH:mm:ss'),'ContactId':_0x31aeba[_0x6a84('0x25')]?_0x31aeba['contact']['id']:null,'ListId':_0x31aeba[_0x6a84('0x26')]?_0x31aeba['list']['id']:null};_0x4c86db[_['upperFirst'](_0x31aeba['channel'])+_0x6a84('0x27')]=_0x1f45a7['id']||null;_0x4c86db[_[_0x6a84('0x28')](_0x31aeba[_0x6a84('0x29')])+_0x6a84('0xf')]=_0x31aeba[_0x6a84('0x2a')]?_0x31aeba[_0x6a84('0x2a')]['id']:null;_0x4c86db[_[_0x6a84('0x28')](_0x31aeba[_0x6a84('0x29')])+'MessageId']=_0x31aeba[_0x6a84('0x2b')]?_0x31aeba[_0x6a84('0x2b')]['id']:null;_0x4c86db[_[_0x6a84('0x28')](_0x31aeba[_0x6a84('0x29')])+(_0x31aeba[_0x6a84('0x29')]!=='chat'?_0x6a84('0x2c'):'WebsiteId')]=_0x31aeba[_0x6a84('0xa')]?_0x31aeba[_0x6a84('0xa')]['id']:null;logger[_0x6a84('0x2d')](util[_0x6a84('0x10')](_0x6a84('0x2e'),_0x5eec64,_0x1f45a7[_0x6a84('0x2f')]));emitChannelQueueInteraction(_0x31aeba[_0x6a84('0x29')],_0x1f45a7[_0x6a84('0x2f')],_0x4c86db,_0x31aeba[_0x6a84('0xa')][_0x6a84('0x2f')],_0x31aeba['message']['id'],!![],_0x3bfdfb,_0x1f45a7['id']);if(rpc[_0x31aeba[_0x6a84('0x29')]+_0x6a84('0x30')]){return rpc[_0x31aeba[_0x6a84('0x29')]+_0x6a84('0x30')][_0x6a84('0x31')](_0x4c86db)[_0x6a84('0x32')](function(_0x765a25){logger[_0x6a84('0x33')](_0x6a84('0x34'),_0x765a25);});}}}function stopRouting(_0x8859e5,_0x22d655,_0x411a34,_0x24ce3f){if(_0x8859e5&&_0x22d655){_0x22d655[_0x6a84('0x23')]-=0x1;var _0x33ee75={'leaveAt':moment()[_0x6a84('0x10')](_0x6a84('0x35')),'acceptAt':moment()[_0x6a84('0x10')](_0x6a84('0x35')),'reason':_0x6a84('0x36')};logger[_0x6a84('0x2d')](util[_0x6a84('0x10')]('[%s][STOP:QUEUE][NAME:%s]',_0x8859e5,_0x22d655[_0x6a84('0x2f')]));emitChannelQueueInteraction(_0x411a34[_0x6a84('0x29')],_0x22d655[_0x6a84('0x2f')],_0x411a34[_0x6a84('0x24')],_0x411a34['account'][_0x6a84('0x2f')],_0x411a34['message']['id'],![],_0x24ce3f,_0x22d655['id']);return rpc[_0x411a34['channel']+_0x6a84('0x37')][_0x6a84('0x38')](_0x411a34['interaction']['id'],{'queueId':_0x22d655['id']})[_0x6a84('0x39')](function(){if(rpc[_0x411a34[_0x6a84('0x29')]+'QueueReport']){return rpc[_0x411a34[_0x6a84('0x29')]+_0x6a84('0x30')]['update'](_0x8859e5,_0x33ee75)[_0x6a84('0x32')](function(_0xa4e474){logger['error']('update\x20queue\x20report',_0xa4e474);});}});}}function endRouting(_0x3e79b2,_0x5cb0a6,_0x3dbda8,_0x5bcd15){if(_0x3e79b2&&_0x5cb0a6){_0x5cb0a6[_0x6a84('0x23')]-=0x1;var _0x41fb64={'leaveAt':moment()[_0x6a84('0x10')](_0x6a84('0x35')),'exitAt':moment()['format'](_0x6a84('0x35')),'reason':_0x6a84('0x3a')};logger[_0x6a84('0x2d')](util['format']('[%s][END:QUEUE][NAME:%s]',_0x3e79b2,_0x5cb0a6[_0x6a84('0x2f')]));emitChannelQueueInteraction(_0x3dbda8[_0x6a84('0x29')],_0x5cb0a6[_0x6a84('0x2f')],_0x3dbda8[_0x6a84('0x24')],_0x3dbda8[_0x6a84('0xa')][_0x6a84('0x2f')],_0x3dbda8[_0x6a84('0x2b')]['id'],![],_0x5bcd15);if(rpc[_0x3dbda8['channel']+_0x6a84('0x30')]){return rpc[_0x3dbda8['channel']+_0x6a84('0x30')][_0x6a84('0x38')](_0x3e79b2,_0x41fb64)['catch'](function(_0x283561){logger[_0x6a84('0x33')]('update\x20queue\x20report',_0x283561);});}}}function handleFindQueue(_0xe47105){return function(_0x32712b){return _0x32712b[_0x6a84('0x2f')][_0x6a84('0x3b')]()===_0xe47105[_0x6a84('0x3b')]();};}exports[_0x6a84('0x3c')]=function(_0x3a296a,_0x577140,_0x4cfff5,_0x2dc1e2){return function(_0x2d5247){try{var _0x3a2f97={'name':_0x577140[0x0],'timeout':_0x577140[0x1]};var _0x2f2c74=queue['validate'](_0x3a2f97,{'typecast':!![]});if(_0x2f2c74['length']){logger[_0x6a84('0x33')](_0x6a84('0x3d'),_0x3a296a,_[_0x6a84('0x3e')](_0x2f2c74,_0x6a84('0x2b'))[_0x6a84('0x3f')](',\x20'));_0x2d5247[_0x6a84('0x40')]();}else{var _0x423116=_['find'](_0x4cfff5[_0x2dc1e2[_0x6a84('0x29')]+_0x6a84('0x41')],handleFindQueue(_0x3a2f97['name']));if(_0x423116){startRouting(_0x3a296a,_0x423116,_0x2dc1e2,_0x4cfff5);var _0x538614=(_0x423116['timeout']||0xa)*0x3e8;var _0xb497a4=(_0x3a2f97[_0x6a84('0x3a')]||0x14)*0x3e8;var _0x264e75;if(_0x538614>_0xb497a4){_0xb497a4=_0x538614;}var _0x16e372=seqqueue[_0x6a84('0x42')](_0x538614);_0x16e372['id']=_0x3a296a;_0x16e372['atimeout']=_0x538614;_0x16e372[_0x6a84('0x43')]=_0xb497a4;_0x16e372[_0x6a84('0x29')]=_0x2dc1e2[_0x6a84('0x29')];_0x4cfff5[_0x6a84('0x44')][_0x3a296a]['on'](_0x6a84('0x45'),function(){logger[_0x6a84('0x2d')](_0x6a84('0x46'),_0x3a296a);stopRouting(_0x3a296a,_0x423116,_0x2dc1e2,_0x4cfff5);clearTimeout(_0x264e75);_0x264e75=undefined;_0x16e372[_0x6a84('0x47')](!![]);if(_0x4cfff5[_0x6a84('0x44')][_0x3a296a]){delete _0x4cfff5[_0x6a84('0x44')][_0x3a296a];}_0x2d5247[_0x6a84('0x40')]();});_0x4cfff5[_0x6a84('0x44')][_0x3a296a]['on'](_0x6a84('0x48'),function(){if(_0x4cfff5[_0x6a84('0x44')][_0x3a296a]){delete _0x4cfff5[_0x6a84('0x44')][_0x3a296a];}});_0x264e75=setTimeout(function(){logger[_0x6a84('0x2d')]('[%s][QUEUE]\x20APPLICATION\x20END',_0x3a296a);endRouting(_0x3a296a,_0x423116,_0x2dc1e2,_0x4cfff5);clearTimeout(_0x264e75);_0x16e372['close'](!![]);_0x2d5247[_0x6a84('0x49')]();},_0xb497a4);switch(_0x423116[_0x6a84('0x4a')]){case'rrmemory':strategy[_0x6a84('0x4b')](_0x16e372,_0x423116,_0x4cfff5,_0x2dc1e2);break;default:strategy['beepall'](_0x16e372,_0x423116,_0x4cfff5,_0x2dc1e2);}}else{logger[_0x6a84('0x33')](_0x6a84('0x4c'),_0x3a296a,_0x3a2f97[_0x6a84('0x2f')]);_0x2d5247[_0x6a84('0x40')]();}}}catch(_0x9df22f){logger[_0x6a84('0x33')]('[%s][QUEUE]\x20%s',_0x3a296a,_0x9df22f[_0x6a84('0x4d')]);_0x2d5247['stop']();}};};
\ No newline at end of file
git://repos.xcallymotion.com / motion2.git / blobdiff