// * treaties. The SOFTWARE PRODUCT is licensed, not sold. *
// * *
// *************************************************************************
-var _0x7e0b=['push','capitalize','%sQueuesWaitingInteractions','pick','format','%s:queue:%s','%s_queue_waiting_interaction:%s','save','../../rpc/openchannelQueueReport','../../rpc/mailQueueReport','../../rpc/chatQueueReport','../../rpc/faxQueueReport','../../rpc/whatsappQueueReport','../../rpc/chatInteraction','../../rpc/mailInteraction','../../rpc/openchannelInteraction','../../rpc/smsInteraction','string','number','timeout\x20is\x20a\x20number','waiting','body','from','YYYY-MM-DD\x20HH:mm:ss','contact','list','upperFirst','channel','InteractionId','interaction','MessageId','message','chat','AccountId','info','[%s][START:QUEUE][NAME:%s]','name','QueueReport','create','catch','error','accepted','[%s][STOP:QUEUE][NAME:%s]','update','then','update\x20queue\x20report','[%s][END:QUEUE][NAME:%s]','toLowerCase','consequence','validate','length','[%s][QUEUE]\x20%s','map','join','stop','find','Queues','timeout','atimeout','qtimeout','end','[%s][QUEUE]\x20ROUTING\x20STOPPED','close','rules','complete','[%s][QUEUE]\x20APPLICATION\x20END','next','rrmemory','beepall','[%s][QUEUE]\x20queue\x20not\x20found\x20%s','stack','lodash','util','seq-queue','moment','../../../../config/environment','./strategy','redis','defaults','localhost','socket.io-emitter','queue_id','account','queue','joinAt','clone'];(function(_0x43b7a7,_0x57d7db){var _0x42fca3=function(_0x1e82b4){while(--_0x1e82b4){_0x43b7a7['push'](_0x43b7a7['shift']());}};_0x42fca3(++_0x57d7db);}(_0x7e0b,0x149));var _0xb7e0=function(_0x19d648,_0x563fce){_0x19d648=_0x19d648-0x0;var _0x461be0=_0x7e0b[_0x19d648];return _0x461be0;};'use strict';var schema=require('validate');var _=require(_0xb7e0('0x0'));var util=require(_0xb7e0('0x1'));var seqqueue=require(_0xb7e0('0x2'));var moment=require(_0xb7e0('0x3'));var Redis=require('ioredis');var config=require(_0xb7e0('0x4'));var logger=require('../../../../config/logger')('routing');var strategy=require(_0xb7e0('0x5'));config[_0xb7e0('0x6')]=_[_0xb7e0('0x7')](config['redis'],{'host':_0xb7e0('0x8'),'port':0x18eb});var io=require(_0xb7e0('0x9'))(new Redis(config[_0xb7e0('0x6')]));var attributes=['id',_0xb7e0('0xa'),_0xb7e0('0xb'),_0xb7e0('0xc'),'from',_0xb7e0('0xd')];function emit(_0x3c35bc,_0x4279da,_0x500573){io['to'](_0x3c35bc)['emit'](_0x4279da,_0x500573);}function emitChannelQueueInteraction(_0x41e22b,_0x248386,_0x7ab55e,_0x3cdbb5,_0x20717d,_0x4dae49,_0x5e3ad1,_0x1e5eaa){var _0x3036da=_[_0xb7e0('0xe')](_0x7ab55e);_0x3036da[_0xb7e0('0xa')]=_0x1e5eaa;_0x3036da[_0xb7e0('0xc')]=_0x248386;_0x3036da[_0xb7e0('0xb')]=_0x3cdbb5;_0x3036da['id']=_0x20717d;if(_0x4dae49){attributes[_0xb7e0('0xf')](_[_0xb7e0('0x10')](_0x41e22b)+'InteractionId');_0x5e3ad1[util['format'](_0xb7e0('0x11'),_0x41e22b)][_0x20717d]=_[_0xb7e0('0x12')](_0x3036da,attributes);}else{delete _0x5e3ad1[util['format']('%sQueuesWaitingInteractions',_0x41e22b)][_0x20717d];}emit(util[_0xb7e0('0x13')](_0xb7e0('0x14'),_0x41e22b,_0x248386),util[_0xb7e0('0x13')](_0xb7e0('0x15'),_0x41e22b,_0x4dae49?_0xb7e0('0x16'):'remove'),_['pick'](_0x3036da,attributes));}var rpc={'openchannelQueueReport':require(_0xb7e0('0x17')),'mailQueueReport':require(_0xb7e0('0x18')),'chatQueueReport':require(_0xb7e0('0x19')),'smsQueueReport':require('../../rpc/smsQueueReport'),'faxQueueReport':require(_0xb7e0('0x1a')),'whatsappQueueReport':require(_0xb7e0('0x1b')),'chatInteraction':require(_0xb7e0('0x1c')),'faxInteraction':require('../../rpc/faxInteraction'),'mailInteraction':require(_0xb7e0('0x1d')),'openchannelInteraction':require(_0xb7e0('0x1e')),'smsInteraction':require(_0xb7e0('0x1f')),'whatsappInteraction':require('../../rpc/whatsappInteraction')};var queue=schema({'name':{'type':_0xb7e0('0x20'),'required':!![],'message':'name\x20is\x20a\x20string\x20and\x20it\x20is\x20required'},'timeout':{'type':_0xb7e0('0x21'),'message':_0xb7e0('0x22')}});function startRouting(_0x550c49,_0x1d8b5c,_0xc9ee39,_0x1f3bee){if(_0x550c49&&_0x1d8b5c&&_0xc9ee39){_0x1d8b5c[_0xb7e0('0x23')]+=0x1;var _0x3696b8={'uniqueid':_0x550c49,'from':_0xc9ee39['body']?_0xc9ee39[_0xb7e0('0x24')][_0xb7e0('0x25')]:'','joinAt':moment()['format'](_0xb7e0('0x26')),'ContactId':_0xc9ee39[_0xb7e0('0x27')]?_0xc9ee39[_0xb7e0('0x27')]['id']:null,'ListId':_0xc9ee39[_0xb7e0('0x28')]?_0xc9ee39[_0xb7e0('0x28')]['id']:null};_0x3696b8[_[_0xb7e0('0x29')](_0xc9ee39['channel'])+'QueueId']=_0x1d8b5c['id']||null;_0x3696b8[_['upperFirst'](_0xc9ee39[_0xb7e0('0x2a')])+_0xb7e0('0x2b')]=_0xc9ee39['interaction']?_0xc9ee39[_0xb7e0('0x2c')]['id']:null;_0x3696b8[_[_0xb7e0('0x29')](_0xc9ee39[_0xb7e0('0x2a')])+_0xb7e0('0x2d')]=_0xc9ee39[_0xb7e0('0x2e')]?_0xc9ee39['message']['id']:null;_0x3696b8[_[_0xb7e0('0x29')](_0xc9ee39[_0xb7e0('0x2a')])+(_0xc9ee39[_0xb7e0('0x2a')]!==_0xb7e0('0x2f')?_0xb7e0('0x30'):'WebsiteId')]=_0xc9ee39['account']?_0xc9ee39['account']['id']:null;logger[_0xb7e0('0x31')](util['format'](_0xb7e0('0x32'),_0x550c49,_0x1d8b5c[_0xb7e0('0x33')]));emitChannelQueueInteraction(_0xc9ee39[_0xb7e0('0x2a')],_0x1d8b5c['name'],_0x3696b8,_0xc9ee39['account']['name'],_0xc9ee39['message']['id'],!![],_0x1f3bee,_0x1d8b5c['id']);if(rpc[_0xc9ee39[_0xb7e0('0x2a')]+_0xb7e0('0x34')]){return rpc[_0xc9ee39[_0xb7e0('0x2a')]+'QueueReport'][_0xb7e0('0x35')](_0x3696b8)[_0xb7e0('0x36')](function(_0x4c8c1e){logger[_0xb7e0('0x37')]('create\x20queue\x20report',_0x4c8c1e);});}}}function stopRouting(_0x7b9c4f,_0x423373,_0x2499ed,_0x32d875){if(_0x7b9c4f&&_0x423373){_0x423373[_0xb7e0('0x23')]-=0x1;var _0x40ba06={'leaveAt':moment()[_0xb7e0('0x13')](_0xb7e0('0x26')),'acceptAt':moment()[_0xb7e0('0x13')](_0xb7e0('0x26')),'reason':_0xb7e0('0x38')};logger['info'](util[_0xb7e0('0x13')](_0xb7e0('0x39'),_0x7b9c4f,_0x423373['name']));emitChannelQueueInteraction(_0x2499ed[_0xb7e0('0x2a')],_0x423373[_0xb7e0('0x33')],_0x2499ed[_0xb7e0('0x24')],_0x2499ed[_0xb7e0('0xb')]['name'],_0x2499ed[_0xb7e0('0x2e')]['id'],![],_0x32d875,_0x423373['id']);return rpc[_0x2499ed[_0xb7e0('0x2a')]+'Interaction'][_0xb7e0('0x3a')](_0x2499ed[_0xb7e0('0x2c')]['id'],{'queueId':_0x423373['id']})[_0xb7e0('0x3b')](function(){if(rpc[_0x2499ed[_0xb7e0('0x2a')]+_0xb7e0('0x34')]){return rpc[_0x2499ed[_0xb7e0('0x2a')]+'QueueReport']['update'](_0x7b9c4f,_0x40ba06)[_0xb7e0('0x36')](function(_0x15916d){logger[_0xb7e0('0x37')](_0xb7e0('0x3c'),_0x15916d);});}});}}function endRouting(_0x42cfa5,_0xd74148,_0x3fb7d1,_0x5719ea){if(_0x42cfa5&&_0xd74148){_0xd74148[_0xb7e0('0x23')]-=0x1;var _0x568d5c={'leaveAt':moment()[_0xb7e0('0x13')]('YYYY-MM-DD\x20HH:mm:ss'),'exitAt':moment()['format'](_0xb7e0('0x26')),'reason':'timeout'};logger[_0xb7e0('0x31')](util[_0xb7e0('0x13')](_0xb7e0('0x3d'),_0x42cfa5,_0xd74148[_0xb7e0('0x33')]));emitChannelQueueInteraction(_0x3fb7d1['channel'],_0xd74148[_0xb7e0('0x33')],_0x3fb7d1[_0xb7e0('0x24')],_0x3fb7d1[_0xb7e0('0xb')][_0xb7e0('0x33')],_0x3fb7d1['message']['id'],![],_0x5719ea);if(rpc[_0x3fb7d1['channel']+'QueueReport']){return rpc[_0x3fb7d1[_0xb7e0('0x2a')]+'QueueReport'][_0xb7e0('0x3a')](_0x42cfa5,_0x568d5c)[_0xb7e0('0x36')](function(_0x50f898){logger[_0xb7e0('0x37')](_0xb7e0('0x3c'),_0x50f898);});}}}function handleFindQueue(_0x50ad86){return function(_0x4b7e34){return _0x4b7e34[_0xb7e0('0x33')]['toLowerCase']()===_0x50ad86[_0xb7e0('0x3e')]();};}exports[_0xb7e0('0x3f')]=function(_0x5c9e5f,_0x3ea8b2,_0x7db347,_0x1edccf){return function(_0x518f0d){try{var _0x984ec9={'name':_0x3ea8b2[0x0],'timeout':_0x3ea8b2[0x1]};var _0x597579=queue[_0xb7e0('0x40')](_0x984ec9,{'typecast':!![]});if(_0x597579[_0xb7e0('0x41')]){logger['error'](_0xb7e0('0x42'),_0x5c9e5f,_[_0xb7e0('0x43')](_0x597579,'message')[_0xb7e0('0x44')](',\x20'));_0x518f0d[_0xb7e0('0x45')]();}else{var _0x478d37=_[_0xb7e0('0x46')](_0x7db347[_0x1edccf[_0xb7e0('0x2a')]+_0xb7e0('0x47')],handleFindQueue(_0x984ec9['name']));if(_0x478d37){startRouting(_0x5c9e5f,_0x478d37,_0x1edccf,_0x7db347);var _0x30d6b7=(_0x478d37['timeout']||0xa)*0x3e8;var _0x511673=(_0x984ec9[_0xb7e0('0x48')]||0x14)*0x3e8;var _0x2876de;if(_0x30d6b7>_0x511673){_0x511673=_0x30d6b7;}var _0x2c605=seqqueue['createQueue'](_0x30d6b7);_0x2c605['id']=_0x5c9e5f;_0x2c605[_0xb7e0('0x49')]=_0x30d6b7;_0x2c605[_0xb7e0('0x4a')]=_0x511673;_0x2c605[_0xb7e0('0x2a')]=_0x1edccf['channel'];_0x7db347['rules'][_0x5c9e5f]['on'](_0xb7e0('0x4b'),function(){logger['info'](_0xb7e0('0x4c'),_0x5c9e5f);stopRouting(_0x5c9e5f,_0x478d37,_0x1edccf,_0x7db347);clearTimeout(_0x2876de);_0x2876de=undefined;_0x2c605[_0xb7e0('0x4d')](!![]);if(_0x7db347[_0xb7e0('0x4e')][_0x5c9e5f]){delete _0x7db347[_0xb7e0('0x4e')][_0x5c9e5f];}_0x518f0d['stop']();});_0x7db347[_0xb7e0('0x4e')][_0x5c9e5f]['on'](_0xb7e0('0x4f'),function(){if(_0x7db347['rules'][_0x5c9e5f]){delete _0x7db347[_0xb7e0('0x4e')][_0x5c9e5f];}});_0x2876de=setTimeout(function(){logger[_0xb7e0('0x31')](_0xb7e0('0x50'),_0x5c9e5f);endRouting(_0x5c9e5f,_0x478d37,_0x1edccf,_0x7db347);clearTimeout(_0x2876de);_0x2c605['close'](!![]);_0x518f0d[_0xb7e0('0x51')]();},_0x511673);switch(_0x478d37['strategy']){case _0xb7e0('0x52'):strategy[_0xb7e0('0x52')](_0x2c605,_0x478d37,_0x7db347,_0x1edccf);break;default:strategy[_0xb7e0('0x53')](_0x2c605,_0x478d37,_0x7db347,_0x1edccf);}}else{logger[_0xb7e0('0x37')](_0xb7e0('0x54'),_0x5c9e5f,_0x984ec9['name']);_0x518f0d[_0xb7e0('0x45')]();}}}catch(_0x3dede2){logger['error']('[%s][QUEUE]\x20%s',_0x5c9e5f,_0x3dede2[_0xb7e0('0x55')]);_0x518f0d[_0xb7e0('0x45')]();}};};
\ No newline at end of file
+var _0xe206=['push','capitalize','InteractionId','format','%sQueuesWaitingInteractions','pick','%s_queue_waiting_interaction:%s','remove','../../rpc/openchannelQueueReport','../../rpc/mailQueueReport','../../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','timeout\x20is\x20a\x20number','waiting','body','from','YYYY-MM-DD\x20HH:mm:ss','list','upperFirst','channel','QueueId','interaction','MessageId','message','AccountId','WebsiteId','info','[%s][START:QUEUE][NAME:%s]','name','QueueReport','catch','error','create\x20queue\x20report','accepted','Interaction','update','then','update\x20queue\x20report','timeout','[%s][END:QUEUE][NAME:%s]','consequence','validate','length','[%s][QUEUE]\x20%s','map','stop','find','Queues','createQueue','qtimeout','rules','close','complete','[%s][QUEUE]\x20APPLICATION\x20END','next','strategy','rrmemory','beepall','[%s][QUEUE]\x20queue\x20not\x20found\x20%s','stack','lodash','util','ioredis','../../../../config/environment','../../../../config/logger','./strategy','redis','defaults','socket.io-emitter','queue_id','joinAt','emit','queue','account'];(function(_0x3bf83f,_0x181cac){var _0x22c4a9=function(_0xb3ff0d){while(--_0xb3ff0d){_0x3bf83f['push'](_0x3bf83f['shift']());}};_0x22c4a9(++_0x181cac);}(_0xe206,0x1e4));var _0x6e20=function(_0x525c7b,_0x488fcc){_0x525c7b=_0x525c7b-0x0;var _0x27b33e=_0xe206[_0x525c7b];return _0x27b33e;};'use strict';var schema=require('validate');var _=require(_0x6e20('0x0'));var util=require(_0x6e20('0x1'));var seqqueue=require('seq-queue');var moment=require('moment');var Redis=require(_0x6e20('0x2'));var config=require(_0x6e20('0x3'));var logger=require(_0x6e20('0x4'))('routing');var strategy=require(_0x6e20('0x5'));config[_0x6e20('0x6')]=_[_0x6e20('0x7')](config['redis'],{'host':'localhost','port':0x18eb});var io=require(_0x6e20('0x8'))(new Redis(config[_0x6e20('0x6')]));var attributes=['id',_0x6e20('0x9'),'account','queue','from',_0x6e20('0xa')];function emit(_0x1a36a4,_0x1e2d6e,_0x1b9f25){io['to'](_0x1a36a4)[_0x6e20('0xb')](_0x1e2d6e,_0x1b9f25);}function emitChannelQueueInteraction(_0x2b13bd,_0x15eb1d,_0x6ddbb7,_0x15383d,_0x3ffcfd,_0x3432fe,_0xa4b354,_0x85c491){var _0x2ac21c=_['clone'](_0x6ddbb7);_0x2ac21c['queue_id']=_0x85c491;_0x2ac21c[_0x6e20('0xc')]=_0x15eb1d;_0x2ac21c[_0x6e20('0xd')]=_0x15383d;_0x2ac21c['id']=_0x3ffcfd;if(_0x3432fe){attributes[_0x6e20('0xe')](_[_0x6e20('0xf')](_0x2b13bd)+_0x6e20('0x10'));_0xa4b354[util[_0x6e20('0x11')](_0x6e20('0x12'),_0x2b13bd)][_0x3ffcfd]=_[_0x6e20('0x13')](_0x2ac21c,attributes);}else{delete _0xa4b354[util[_0x6e20('0x11')]('%sQueuesWaitingInteractions',_0x2b13bd)][_0x3ffcfd];}emit(util[_0x6e20('0x11')]('%s:queue:%s',_0x2b13bd,_0x15eb1d),util[_0x6e20('0x11')](_0x6e20('0x14'),_0x2b13bd,_0x3432fe?'save':_0x6e20('0x15')),_['pick'](_0x2ac21c,attributes));}var rpc={'openchannelQueueReport':require(_0x6e20('0x16')),'mailQueueReport':require(_0x6e20('0x17')),'chatQueueReport':require('../../rpc/chatQueueReport'),'smsQueueReport':require(_0x6e20('0x18')),'faxQueueReport':require(_0x6e20('0x19')),'whatsappQueueReport':require(_0x6e20('0x1a')),'chatInteraction':require(_0x6e20('0x1b')),'faxInteraction':require(_0x6e20('0x1c')),'mailInteraction':require(_0x6e20('0x1d')),'openchannelInteraction':require(_0x6e20('0x1e')),'smsInteraction':require(_0x6e20('0x1f')),'whatsappInteraction':require(_0x6e20('0x20'))};var queue=schema({'name':{'type':_0x6e20('0x21'),'required':!![],'message':_0x6e20('0x22')},'timeout':{'type':'number','message':_0x6e20('0x23')}});function startRouting(_0x5ecdb3,_0x1ee94c,_0x402b5e,_0x3d1242){if(_0x5ecdb3&&_0x1ee94c&&_0x402b5e){_0x1ee94c[_0x6e20('0x24')]+=0x1;var _0x1c7fc0={'uniqueid':_0x5ecdb3,'from':_0x402b5e[_0x6e20('0x25')]?_0x402b5e[_0x6e20('0x25')][_0x6e20('0x26')]:'','joinAt':moment()[_0x6e20('0x11')](_0x6e20('0x27')),'ContactId':_0x402b5e['contact']?_0x402b5e['contact']['id']:null,'ListId':_0x402b5e['list']?_0x402b5e[_0x6e20('0x28')]['id']:null};_0x1c7fc0[_[_0x6e20('0x29')](_0x402b5e[_0x6e20('0x2a')])+_0x6e20('0x2b')]=_0x1ee94c['id']||null;_0x1c7fc0[_[_0x6e20('0x29')](_0x402b5e['channel'])+_0x6e20('0x10')]=_0x402b5e[_0x6e20('0x2c')]?_0x402b5e[_0x6e20('0x2c')]['id']:null;_0x1c7fc0[_[_0x6e20('0x29')](_0x402b5e['channel'])+_0x6e20('0x2d')]=_0x402b5e[_0x6e20('0x2e')]?_0x402b5e[_0x6e20('0x2e')]['id']:null;_0x1c7fc0[_[_0x6e20('0x29')](_0x402b5e[_0x6e20('0x2a')])+(_0x402b5e[_0x6e20('0x2a')]!=='chat'?_0x6e20('0x2f'):_0x6e20('0x30'))]=_0x402b5e[_0x6e20('0xd')]?_0x402b5e[_0x6e20('0xd')]['id']:null;logger[_0x6e20('0x31')](util[_0x6e20('0x11')](_0x6e20('0x32'),_0x5ecdb3,_0x1ee94c['name']));emitChannelQueueInteraction(_0x402b5e[_0x6e20('0x2a')],_0x1ee94c[_0x6e20('0x33')],_0x1c7fc0,_0x402b5e[_0x6e20('0xd')]['name'],_0x402b5e[_0x6e20('0x2e')]['id'],!![],_0x3d1242,_0x1ee94c['id']);if(rpc[_0x402b5e[_0x6e20('0x2a')]+'QueueReport']){return rpc[_0x402b5e[_0x6e20('0x2a')]+_0x6e20('0x34')]['create'](_0x1c7fc0)[_0x6e20('0x35')](function(_0x27797a){logger[_0x6e20('0x36')](_0x6e20('0x37'),_0x27797a);});}}}function stopRouting(_0xa5fc65,_0x3ed385,_0x36cc43,_0x2af17c){if(_0xa5fc65&&_0x3ed385){_0x3ed385['waiting']-=0x1;var _0x21950c={'leaveAt':moment()[_0x6e20('0x11')](_0x6e20('0x27')),'acceptAt':moment()[_0x6e20('0x11')](_0x6e20('0x27')),'reason':_0x6e20('0x38')};logger[_0x6e20('0x31')](util['format']('[%s][STOP:QUEUE][NAME:%s]',_0xa5fc65,_0x3ed385[_0x6e20('0x33')]));emitChannelQueueInteraction(_0x36cc43[_0x6e20('0x2a')],_0x3ed385[_0x6e20('0x33')],_0x36cc43[_0x6e20('0x25')],_0x36cc43['account'][_0x6e20('0x33')],_0x36cc43[_0x6e20('0x2e')]['id'],![],_0x2af17c,_0x3ed385['id']);return rpc[_0x36cc43[_0x6e20('0x2a')]+_0x6e20('0x39')][_0x6e20('0x3a')](_0x36cc43['interaction']['id'],{'queueId':_0x3ed385['id']})[_0x6e20('0x3b')](function(){if(rpc[_0x36cc43[_0x6e20('0x2a')]+_0x6e20('0x34')]){return rpc[_0x36cc43['channel']+'QueueReport'][_0x6e20('0x3a')](_0xa5fc65,_0x21950c)[_0x6e20('0x35')](function(_0x24a624){logger[_0x6e20('0x36')](_0x6e20('0x3c'),_0x24a624);});}});}}function endRouting(_0x2ef130,_0x1452b3,_0x2b85b8,_0x38df1f){if(_0x2ef130&&_0x1452b3){_0x1452b3[_0x6e20('0x24')]-=0x1;var _0xc93f55={'leaveAt':moment()[_0x6e20('0x11')]('YYYY-MM-DD\x20HH:mm:ss'),'exitAt':moment()['format'](_0x6e20('0x27')),'reason':_0x6e20('0x3d')};logger[_0x6e20('0x31')](util[_0x6e20('0x11')](_0x6e20('0x3e'),_0x2ef130,_0x1452b3[_0x6e20('0x33')]));emitChannelQueueInteraction(_0x2b85b8['channel'],_0x1452b3[_0x6e20('0x33')],_0x2b85b8['body'],_0x2b85b8['account'][_0x6e20('0x33')],_0x2b85b8[_0x6e20('0x2e')]['id'],![],_0x38df1f);if(rpc[_0x2b85b8['channel']+_0x6e20('0x34')]){return rpc[_0x2b85b8[_0x6e20('0x2a')]+_0x6e20('0x34')]['update'](_0x2ef130,_0xc93f55)['catch'](function(_0x8a21b5){logger[_0x6e20('0x36')](_0x6e20('0x3c'),_0x8a21b5);});}}}function handleFindQueue(_0x5bec55){return function(_0x127e07){return _0x127e07[_0x6e20('0x33')]['toLowerCase']()===_0x5bec55['toLowerCase']();};}exports[_0x6e20('0x3f')]=function(_0x40cce3,_0x5e954a,_0x51af35,_0x4667fe){return function(_0x1b02fb){try{var _0x3a65c8={'name':_0x5e954a[0x0],'timeout':_0x5e954a[0x1]};var _0xf5c914=queue[_0x6e20('0x40')](_0x3a65c8,{'typecast':!![]});if(_0xf5c914[_0x6e20('0x41')]){logger[_0x6e20('0x36')](_0x6e20('0x42'),_0x40cce3,_[_0x6e20('0x43')](_0xf5c914,_0x6e20('0x2e'))['join'](',\x20'));_0x1b02fb[_0x6e20('0x44')]();}else{var _0x4388f8=_[_0x6e20('0x45')](_0x51af35[_0x4667fe[_0x6e20('0x2a')]+_0x6e20('0x46')],handleFindQueue(_0x3a65c8[_0x6e20('0x33')]));if(_0x4388f8){startRouting(_0x40cce3,_0x4388f8,_0x4667fe,_0x51af35);var _0x2ccbf1=(_0x4388f8['timeout']||0xa)*0x3e8;var _0x57c1e6=(_0x3a65c8['timeout']||0x14)*0x3e8;var _0x262bfd;if(_0x2ccbf1>_0x57c1e6){_0x57c1e6=_0x2ccbf1;}var _0x575f0a=seqqueue[_0x6e20('0x47')](_0x2ccbf1);_0x575f0a['id']=_0x40cce3;_0x575f0a['atimeout']=_0x2ccbf1;_0x575f0a[_0x6e20('0x48')]=_0x57c1e6;_0x575f0a[_0x6e20('0x2a')]=_0x4667fe[_0x6e20('0x2a')];_0x51af35[_0x6e20('0x49')][_0x40cce3]['on']('end',function(){logger['info']('[%s][QUEUE]\x20ROUTING\x20STOPPED',_0x40cce3);stopRouting(_0x40cce3,_0x4388f8,_0x4667fe,_0x51af35);clearTimeout(_0x262bfd);_0x262bfd=undefined;_0x575f0a[_0x6e20('0x4a')](!![]);if(_0x51af35[_0x6e20('0x49')][_0x40cce3]){delete _0x51af35[_0x6e20('0x49')][_0x40cce3];}_0x1b02fb['stop']();});_0x51af35[_0x6e20('0x49')][_0x40cce3]['on'](_0x6e20('0x4b'),function(){if(_0x51af35[_0x6e20('0x49')][_0x40cce3]){delete _0x51af35[_0x6e20('0x49')][_0x40cce3];}});_0x262bfd=setTimeout(function(){logger['info'](_0x6e20('0x4c'),_0x40cce3);endRouting(_0x40cce3,_0x4388f8,_0x4667fe,_0x51af35);clearTimeout(_0x262bfd);_0x575f0a['close'](!![]);_0x1b02fb[_0x6e20('0x4d')]();},_0x57c1e6);switch(_0x4388f8[_0x6e20('0x4e')]){case _0x6e20('0x4f'):strategy[_0x6e20('0x4f')](_0x575f0a,_0x4388f8,_0x51af35,_0x4667fe);break;default:strategy[_0x6e20('0x50')](_0x575f0a,_0x4388f8,_0x51af35,_0x4667fe);}}else{logger[_0x6e20('0x36')](_0x6e20('0x51'),_0x40cce3,_0x3a65c8[_0x6e20('0x33')]);_0x1b02fb[_0x6e20('0x44')]();}}}catch(_0x42bd85){logger[_0x6e20('0x36')](_0x6e20('0x42'),_0x40cce3,_0x42bd85[_0x6e20('0x52')]);_0x1b02fb[_0x6e20('0x44')]();}};};
\ No newline at end of file
git://repos.xcallymotion.com / motion2.git / blobdiff