// * treaties. The SOFTWARE PRODUCT is licensed, not sold. *
// * *
// *************************************************************************
-var _0x8322=['error','accepted','[%s][STOP:QUEUE][NAME:%s]','Interaction','update','update\x20queue\x20report','timeout','[%s][END:QUEUE][NAME:%s]','toLowerCase','consequence','length','[%s][QUEUE]\x20%s','join','find','Queues','createQueue','atimeout','qtimeout','rules','end','close','stop','complete','next','rrmemory','beepall','validate','util','moment','ioredis','../../../../config/environment','../../../../config/logger','routing','redis','localhost','socket.io-emitter','queue_id','account','queue','from','joinAt','emit','clone','push','capitalize','format','pick','%sQueuesWaitingInteractions','%s:queue:%s','%s_queue_waiting_interaction:%s','save','../../rpc/mailQueueReport','../../rpc/chatQueueReport','../../rpc/smsQueueReport','../../rpc/whatsappQueueReport','../../rpc/mailInteraction','../../rpc/openchannelInteraction','../../rpc/whatsappInteraction','string','name\x20is\x20a\x20string\x20and\x20it\x20is\x20required','number','waiting','body','YYYY-MM-DD\x20HH:mm:ss','contact','list','upperFirst','channel','QueueId','InteractionId','interaction','MessageId','message','chat','AccountId','info','[%s][START:QUEUE][NAME:%s]','name','QueueReport','create','catch'];(function(_0x186376,_0x5d988a){var _0x2dbdd9=function(_0x96908e){while(--_0x96908e){_0x186376['push'](_0x186376['shift']());}};_0x2dbdd9(++_0x5d988a);}(_0x8322,0xbc));var _0x2832=function(_0x26d386,_0x1660c0){_0x26d386=_0x26d386-0x0;var _0x4ef9a8=_0x8322[_0x26d386];return _0x4ef9a8;};'use strict';var schema=require(_0x2832('0x0'));var _=require('lodash');var util=require(_0x2832('0x1'));var seqqueue=require('seq-queue');var moment=require(_0x2832('0x2'));var Redis=require(_0x2832('0x3'));var config=require(_0x2832('0x4'));var logger=require(_0x2832('0x5'))(_0x2832('0x6'));var strategy=require('./strategy');config[_0x2832('0x7')]=_['defaults'](config['redis'],{'host':_0x2832('0x8'),'port':0x18eb});var io=require(_0x2832('0x9'))(new Redis(config[_0x2832('0x7')]));var attributes=['id',_0x2832('0xa'),_0x2832('0xb'),_0x2832('0xc'),_0x2832('0xd'),_0x2832('0xe')];function emit(_0x16d391,_0x34b644,_0x14d87e){io['to'](_0x16d391)[_0x2832('0xf')](_0x34b644,_0x14d87e);}function emitChannelQueueInteraction(_0x3099db,_0x2c2fc5,_0x1f3aa,_0x341c34,_0x3dc1e5,_0x131c10,_0x3a8a27,_0x296a5a){var _0x4b50f6=_[_0x2832('0x10')](_0x1f3aa);_0x4b50f6[_0x2832('0xa')]=_0x296a5a;_0x4b50f6[_0x2832('0xc')]=_0x2c2fc5;_0x4b50f6['account']=_0x341c34;_0x4b50f6['id']=_0x3dc1e5;if(_0x131c10){attributes[_0x2832('0x11')](_[_0x2832('0x12')](_0x3099db)+'InteractionId');_0x3a8a27[util[_0x2832('0x13')]('%sQueuesWaitingInteractions',_0x3099db)][_0x3dc1e5]=_[_0x2832('0x14')](_0x4b50f6,attributes);}else{delete _0x3a8a27[util['format'](_0x2832('0x15'),_0x3099db)][_0x3dc1e5];}emit(util['format'](_0x2832('0x16'),_0x3099db,_0x2c2fc5),util['format'](_0x2832('0x17'),_0x3099db,_0x131c10?_0x2832('0x18'):'remove'),_[_0x2832('0x14')](_0x4b50f6,attributes));}var rpc={'openchannelQueueReport':require('../../rpc/openchannelQueueReport'),'mailQueueReport':require(_0x2832('0x19')),'chatQueueReport':require(_0x2832('0x1a')),'smsQueueReport':require(_0x2832('0x1b')),'faxQueueReport':require('../../rpc/faxQueueReport'),'whatsappQueueReport':require(_0x2832('0x1c')),'chatInteraction':require('../../rpc/chatInteraction'),'faxInteraction':require('../../rpc/faxInteraction'),'mailInteraction':require(_0x2832('0x1d')),'openchannelInteraction':require(_0x2832('0x1e')),'smsInteraction':require('../../rpc/smsInteraction'),'whatsappInteraction':require(_0x2832('0x1f'))};var queue=schema({'name':{'type':_0x2832('0x20'),'required':!![],'message':_0x2832('0x21')},'timeout':{'type':_0x2832('0x22'),'message':'timeout\x20is\x20a\x20number'}});function startRouting(_0xfc9ea0,_0x50d29f,_0x6b79ac,_0x5d0f0c){if(_0xfc9ea0&&_0x50d29f&&_0x6b79ac){_0x50d29f[_0x2832('0x23')]+=0x1;var _0x1844b4={'uniqueid':_0xfc9ea0,'from':_0x6b79ac[_0x2832('0x24')]?_0x6b79ac[_0x2832('0x24')][_0x2832('0xd')]:'','joinAt':moment()['format'](_0x2832('0x25')),'ContactId':_0x6b79ac['contact']?_0x6b79ac[_0x2832('0x26')]['id']:null,'ListId':_0x6b79ac[_0x2832('0x27')]?_0x6b79ac[_0x2832('0x27')]['id']:null};_0x1844b4[_[_0x2832('0x28')](_0x6b79ac[_0x2832('0x29')])+_0x2832('0x2a')]=_0x50d29f['id']||null;_0x1844b4[_[_0x2832('0x28')](_0x6b79ac[_0x2832('0x29')])+_0x2832('0x2b')]=_0x6b79ac[_0x2832('0x2c')]?_0x6b79ac['interaction']['id']:null;_0x1844b4[_['upperFirst'](_0x6b79ac[_0x2832('0x29')])+_0x2832('0x2d')]=_0x6b79ac[_0x2832('0x2e')]?_0x6b79ac['message']['id']:null;_0x1844b4[_[_0x2832('0x28')](_0x6b79ac[_0x2832('0x29')])+(_0x6b79ac[_0x2832('0x29')]!==_0x2832('0x2f')?_0x2832('0x30'):'WebsiteId')]=_0x6b79ac['account']?_0x6b79ac[_0x2832('0xb')]['id']:null;logger[_0x2832('0x31')](util[_0x2832('0x13')](_0x2832('0x32'),_0xfc9ea0,_0x50d29f[_0x2832('0x33')]));emitChannelQueueInteraction(_0x6b79ac['channel'],_0x50d29f[_0x2832('0x33')],_0x1844b4,_0x6b79ac[_0x2832('0xb')][_0x2832('0x33')],_0x6b79ac[_0x2832('0x2e')]['id'],!![],_0x5d0f0c,_0x50d29f['id']);if(rpc[_0x6b79ac[_0x2832('0x29')]+'QueueReport']){return rpc[_0x6b79ac[_0x2832('0x29')]+_0x2832('0x34')][_0x2832('0x35')](_0x1844b4)[_0x2832('0x36')](function(_0x26c2dc){logger[_0x2832('0x37')]('create\x20queue\x20report',_0x26c2dc);});}}}function stopRouting(_0xa41d52,_0x12a1dd,_0xcec23b,_0x60e055){if(_0xa41d52&&_0x12a1dd){_0x12a1dd[_0x2832('0x23')]-=0x1;var _0x170b5a={'leaveAt':moment()[_0x2832('0x13')](_0x2832('0x25')),'acceptAt':moment()[_0x2832('0x13')](_0x2832('0x25')),'reason':_0x2832('0x38')};logger[_0x2832('0x31')](util[_0x2832('0x13')](_0x2832('0x39'),_0xa41d52,_0x12a1dd['name']));emitChannelQueueInteraction(_0xcec23b['channel'],_0x12a1dd[_0x2832('0x33')],_0xcec23b[_0x2832('0x24')],_0xcec23b[_0x2832('0xb')][_0x2832('0x33')],_0xcec23b[_0x2832('0x2e')]['id'],![],_0x60e055,_0x12a1dd['id']);return rpc[_0xcec23b[_0x2832('0x29')]+_0x2832('0x3a')][_0x2832('0x3b')](_0xcec23b[_0x2832('0x2c')]['id'],{'queueId':_0x12a1dd['id']})['then'](function(){if(rpc[_0xcec23b['channel']+_0x2832('0x34')]){return rpc[_0xcec23b[_0x2832('0x29')]+_0x2832('0x34')][_0x2832('0x3b')](_0xa41d52,_0x170b5a)[_0x2832('0x36')](function(_0x446d11){logger[_0x2832('0x37')](_0x2832('0x3c'),_0x446d11);});}});}}function endRouting(_0x158c01,_0x493f82,_0x51bb72,_0x3effc7){if(_0x158c01&&_0x493f82){_0x493f82[_0x2832('0x23')]-=0x1;var _0x115826={'leaveAt':moment()[_0x2832('0x13')](_0x2832('0x25')),'exitAt':moment()[_0x2832('0x13')]('YYYY-MM-DD\x20HH:mm:ss'),'reason':_0x2832('0x3d')};logger[_0x2832('0x31')](util[_0x2832('0x13')](_0x2832('0x3e'),_0x158c01,_0x493f82['name']));emitChannelQueueInteraction(_0x51bb72[_0x2832('0x29')],_0x493f82['name'],_0x51bb72[_0x2832('0x24')],_0x51bb72['account']['name'],_0x51bb72[_0x2832('0x2e')]['id'],![],_0x3effc7);if(rpc[_0x51bb72[_0x2832('0x29')]+_0x2832('0x34')]){return rpc[_0x51bb72['channel']+_0x2832('0x34')][_0x2832('0x3b')](_0x158c01,_0x115826)[_0x2832('0x36')](function(_0x393095){logger['error'](_0x2832('0x3c'),_0x393095);});}}}function handleFindQueue(_0x900dc1){return function(_0x525596){return _0x525596[_0x2832('0x33')][_0x2832('0x3f')]()===_0x900dc1['toLowerCase']();};}exports[_0x2832('0x40')]=function(_0x4841c5,_0x5bf208,_0x2e7a63,_0x112fe0){return function(_0x4aa38a){try{var _0x56b528={'name':_0x5bf208[0x0],'timeout':_0x5bf208[0x1]};var _0x5c9979=queue[_0x2832('0x0')](_0x56b528,{'typecast':!![]});if(_0x5c9979[_0x2832('0x41')]){logger['error'](_0x2832('0x42'),_0x4841c5,_['map'](_0x5c9979,_0x2832('0x2e'))[_0x2832('0x43')](',\x20'));_0x4aa38a['stop']();}else{var _0x40c19e=_[_0x2832('0x44')](_0x2e7a63[_0x112fe0[_0x2832('0x29')]+_0x2832('0x45')],handleFindQueue(_0x56b528[_0x2832('0x33')]));if(_0x40c19e){startRouting(_0x4841c5,_0x40c19e,_0x112fe0,_0x2e7a63);var _0x2eef8a=(_0x40c19e[_0x2832('0x3d')]||0xa)*0x3e8;var _0x4807eb=(_0x56b528['timeout']||0x14)*0x3e8;var _0x319ef6;if(_0x2eef8a>_0x4807eb){_0x4807eb=_0x2eef8a;}var _0x5b5b3e=seqqueue[_0x2832('0x46')](_0x2eef8a);_0x5b5b3e['id']=_0x4841c5;_0x5b5b3e[_0x2832('0x47')]=_0x2eef8a;_0x5b5b3e[_0x2832('0x48')]=_0x4807eb;_0x5b5b3e[_0x2832('0x29')]=_0x112fe0[_0x2832('0x29')];_0x2e7a63[_0x2832('0x49')][_0x4841c5]['on'](_0x2832('0x4a'),function(){logger['info']('[%s][QUEUE]\x20ROUTING\x20STOPPED',_0x4841c5);stopRouting(_0x4841c5,_0x40c19e,_0x112fe0,_0x2e7a63);clearTimeout(_0x319ef6);_0x319ef6=undefined;_0x5b5b3e[_0x2832('0x4b')](!![]);if(_0x2e7a63[_0x2832('0x49')][_0x4841c5]){delete _0x2e7a63[_0x2832('0x49')][_0x4841c5];}_0x4aa38a[_0x2832('0x4c')]();});_0x2e7a63['rules'][_0x4841c5]['on'](_0x2832('0x4d'),function(){if(_0x2e7a63['rules'][_0x4841c5]){delete _0x2e7a63[_0x2832('0x49')][_0x4841c5];}});_0x319ef6=setTimeout(function(){logger['info']('[%s][QUEUE]\x20APPLICATION\x20END',_0x4841c5);endRouting(_0x4841c5,_0x40c19e,_0x112fe0,_0x2e7a63);clearTimeout(_0x319ef6);_0x5b5b3e[_0x2832('0x4b')](!![]);_0x4aa38a[_0x2832('0x4e')]();},_0x4807eb);switch(_0x40c19e['strategy']){case'rrmemory':strategy[_0x2832('0x4f')](_0x5b5b3e,_0x40c19e,_0x2e7a63,_0x112fe0);break;default:strategy[_0x2832('0x50')](_0x5b5b3e,_0x40c19e,_0x2e7a63,_0x112fe0);}}else{logger[_0x2832('0x37')]('[%s][QUEUE]\x20queue\x20not\x20found\x20%s',_0x4841c5,_0x56b528[_0x2832('0x33')]);_0x4aa38a[_0x2832('0x4c')]();}}}catch(_0x3281d3){logger[_0x2832('0x37')]('[%s][QUEUE]\x20%s',_0x4841c5,_0x3281d3['stack']);_0x4aa38a[_0x2832('0x4c')]();}};};
\ No newline at end of file
+var _0x0156=['AccountId','WebsiteId','info','name','catch','error','create\x20queue\x20report','[%s][STOP:QUEUE][NAME:%s]','update','QueueReport','update\x20queue\x20report','timeout','[%s][END:QUEUE][NAME:%s]','toLowerCase','consequence','length','[%s][QUEUE]\x20%s','join','stop','find','Queues','atimeout','qtimeout','rules','end','[%s][QUEUE]\x20ROUTING\x20STOPPED','close','[%s][QUEUE]\x20APPLICATION\x20END','next','strategy','rrmemory','beepall','validate','lodash','util','seq-queue','moment','ioredis','../../../../config/logger','routing','./strategy','defaults','redis','localhost','socket.io-emitter','queue_id','account','queue','from','emit','clone','capitalize','format','%sQueuesWaitingInteractions','pick','%s:queue:%s','remove','../../rpc/mailQueueReport','../../rpc/chatQueueReport','../../rpc/smsQueueReport','../../rpc/whatsappQueueReport','../../rpc/chatInteraction','../../rpc/openchannelInteraction','../../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','channel','QueueId','interaction','message'];(function(_0x5ca699,_0x4d7c82){var _0x17f08c=function(_0x2d7695){while(--_0x2d7695){_0x5ca699['push'](_0x5ca699['shift']());}};_0x17f08c(++_0x4d7c82);}(_0x0156,0xbe));var _0x6015=function(_0x54bf68,_0x1df62c){_0x54bf68=_0x54bf68-0x0;var _0x32fb54=_0x0156[_0x54bf68];return _0x32fb54;};'use strict';var schema=require(_0x6015('0x0'));var _=require(_0x6015('0x1'));var util=require(_0x6015('0x2'));var seqqueue=require(_0x6015('0x3'));var moment=require(_0x6015('0x4'));var Redis=require(_0x6015('0x5'));var config=require('../../../../config/environment');var logger=require(_0x6015('0x6'))(_0x6015('0x7'));var strategy=require(_0x6015('0x8'));config['redis']=_[_0x6015('0x9')](config[_0x6015('0xa')],{'host':_0x6015('0xb'),'port':0x18eb});var io=require(_0x6015('0xc'))(new Redis(config[_0x6015('0xa')]));var attributes=['id',_0x6015('0xd'),_0x6015('0xe'),_0x6015('0xf'),_0x6015('0x10'),'joinAt'];function emit(_0x55ae15,_0x11ea45,_0x17628a){io['to'](_0x55ae15)[_0x6015('0x11')](_0x11ea45,_0x17628a);}function emitChannelQueueInteraction(_0x19700f,_0x35a4e1,_0x265a9a,_0xb09197,_0x10e8eb,_0x108ca3,_0x268465,_0x3a28e8){var _0x560f4e=_[_0x6015('0x12')](_0x265a9a);_0x560f4e[_0x6015('0xd')]=_0x3a28e8;_0x560f4e[_0x6015('0xf')]=_0x35a4e1;_0x560f4e[_0x6015('0xe')]=_0xb09197;_0x560f4e['id']=_0x10e8eb;if(_0x108ca3){attributes['push'](_[_0x6015('0x13')](_0x19700f)+'InteractionId');_0x268465[util[_0x6015('0x14')](_0x6015('0x15'),_0x19700f)][_0x10e8eb]=_[_0x6015('0x16')](_0x560f4e,attributes);}else{delete _0x268465[util[_0x6015('0x14')](_0x6015('0x15'),_0x19700f)][_0x10e8eb];}emit(util['format'](_0x6015('0x17'),_0x19700f,_0x35a4e1),util[_0x6015('0x14')]('%s_queue_waiting_interaction:%s',_0x19700f,_0x108ca3?'save':_0x6015('0x18')),_[_0x6015('0x16')](_0x560f4e,attributes));}var rpc={'openchannelQueueReport':require('../../rpc/openchannelQueueReport'),'mailQueueReport':require(_0x6015('0x19')),'chatQueueReport':require(_0x6015('0x1a')),'smsQueueReport':require(_0x6015('0x1b')),'faxQueueReport':require('../../rpc/faxQueueReport'),'whatsappQueueReport':require(_0x6015('0x1c')),'chatInteraction':require(_0x6015('0x1d')),'faxInteraction':require('../../rpc/faxInteraction'),'mailInteraction':require('../../rpc/mailInteraction'),'openchannelInteraction':require(_0x6015('0x1e')),'smsInteraction':require(_0x6015('0x1f')),'whatsappInteraction':require(_0x6015('0x20'))};var queue=schema({'name':{'type':_0x6015('0x21'),'required':!![],'message':_0x6015('0x22')},'timeout':{'type':_0x6015('0x23'),'message':_0x6015('0x24')}});function startRouting(_0x5b24a0,_0x4fa0ac,_0x1b9ad2,_0x2d69bd){if(_0x5b24a0&&_0x4fa0ac&&_0x1b9ad2){_0x4fa0ac[_0x6015('0x25')]+=0x1;var _0x2783eb={'uniqueid':_0x5b24a0,'from':_0x1b9ad2[_0x6015('0x26')]?_0x1b9ad2[_0x6015('0x26')][_0x6015('0x10')]:'','joinAt':moment()[_0x6015('0x14')](_0x6015('0x27')),'ContactId':_0x1b9ad2[_0x6015('0x28')]?_0x1b9ad2[_0x6015('0x28')]['id']:null,'ListId':_0x1b9ad2[_0x6015('0x29')]?_0x1b9ad2[_0x6015('0x29')]['id']:null};_0x2783eb[_[_0x6015('0x2a')](_0x1b9ad2[_0x6015('0x2b')])+_0x6015('0x2c')]=_0x4fa0ac['id']||null;_0x2783eb[_[_0x6015('0x2a')](_0x1b9ad2[_0x6015('0x2b')])+'InteractionId']=_0x1b9ad2['interaction']?_0x1b9ad2[_0x6015('0x2d')]['id']:null;_0x2783eb[_[_0x6015('0x2a')](_0x1b9ad2[_0x6015('0x2b')])+'MessageId']=_0x1b9ad2[_0x6015('0x2e')]?_0x1b9ad2[_0x6015('0x2e')]['id']:null;_0x2783eb[_[_0x6015('0x2a')](_0x1b9ad2[_0x6015('0x2b')])+(_0x1b9ad2[_0x6015('0x2b')]!=='chat'?_0x6015('0x2f'):_0x6015('0x30'))]=_0x1b9ad2['account']?_0x1b9ad2['account']['id']:null;logger[_0x6015('0x31')](util[_0x6015('0x14')]('[%s][START:QUEUE][NAME:%s]',_0x5b24a0,_0x4fa0ac[_0x6015('0x32')]));emitChannelQueueInteraction(_0x1b9ad2[_0x6015('0x2b')],_0x4fa0ac[_0x6015('0x32')],_0x2783eb,_0x1b9ad2['account'][_0x6015('0x32')],_0x1b9ad2[_0x6015('0x2e')]['id'],!![],_0x2d69bd,_0x4fa0ac['id']);if(rpc[_0x1b9ad2[_0x6015('0x2b')]+'QueueReport']){return rpc[_0x1b9ad2['channel']+'QueueReport']['create'](_0x2783eb)[_0x6015('0x33')](function(_0x33210f){logger[_0x6015('0x34')](_0x6015('0x35'),_0x33210f);});}}}function stopRouting(_0xbc80cb,_0x3a7e60,_0x2b7ef6,_0x19cdf1){if(_0xbc80cb&&_0x3a7e60){_0x3a7e60[_0x6015('0x25')]-=0x1;var _0x5c92b2={'leaveAt':moment()['format'](_0x6015('0x27')),'acceptAt':moment()[_0x6015('0x14')](_0x6015('0x27')),'reason':'accepted'};logger['info'](util[_0x6015('0x14')](_0x6015('0x36'),_0xbc80cb,_0x3a7e60[_0x6015('0x32')]));emitChannelQueueInteraction(_0x2b7ef6[_0x6015('0x2b')],_0x3a7e60['name'],_0x2b7ef6['body'],_0x2b7ef6[_0x6015('0xe')][_0x6015('0x32')],_0x2b7ef6[_0x6015('0x2e')]['id'],![],_0x19cdf1,_0x3a7e60['id']);return rpc[_0x2b7ef6['channel']+'Interaction'][_0x6015('0x37')](_0x2b7ef6['interaction']['id'],{'queueId':_0x3a7e60['id']})['then'](function(){if(rpc[_0x2b7ef6[_0x6015('0x2b')]+_0x6015('0x38')]){return rpc[_0x2b7ef6[_0x6015('0x2b')]+_0x6015('0x38')][_0x6015('0x37')](_0xbc80cb,_0x5c92b2)[_0x6015('0x33')](function(_0x1f4fa3){logger[_0x6015('0x34')](_0x6015('0x39'),_0x1f4fa3);});}});}}function endRouting(_0x36b4fa,_0x2f1d7d,_0x47aa92,_0x1906ef){if(_0x36b4fa&&_0x2f1d7d){_0x2f1d7d[_0x6015('0x25')]-=0x1;var _0x2c4690={'leaveAt':moment()[_0x6015('0x14')](_0x6015('0x27')),'exitAt':moment()[_0x6015('0x14')]('YYYY-MM-DD\x20HH:mm:ss'),'reason':_0x6015('0x3a')};logger['info'](util['format'](_0x6015('0x3b'),_0x36b4fa,_0x2f1d7d[_0x6015('0x32')]));emitChannelQueueInteraction(_0x47aa92['channel'],_0x2f1d7d[_0x6015('0x32')],_0x47aa92[_0x6015('0x26')],_0x47aa92['account']['name'],_0x47aa92[_0x6015('0x2e')]['id'],![],_0x1906ef);if(rpc[_0x47aa92[_0x6015('0x2b')]+_0x6015('0x38')]){return rpc[_0x47aa92[_0x6015('0x2b')]+_0x6015('0x38')][_0x6015('0x37')](_0x36b4fa,_0x2c4690)[_0x6015('0x33')](function(_0x1e9cc8){logger[_0x6015('0x34')](_0x6015('0x39'),_0x1e9cc8);});}}}function handleFindQueue(_0x466255){return function(_0x5367f1){return _0x5367f1[_0x6015('0x32')][_0x6015('0x3c')]()===_0x466255['toLowerCase']();};}exports[_0x6015('0x3d')]=function(_0x195dc1,_0x2ebaf7,_0x32b984,_0xaee96f){return function(_0x3156c1){try{var _0x4b351a={'name':_0x2ebaf7[0x0],'timeout':_0x2ebaf7[0x1]};var _0x491374=queue[_0x6015('0x0')](_0x4b351a,{'typecast':!![]});if(_0x491374[_0x6015('0x3e')]){logger[_0x6015('0x34')](_0x6015('0x3f'),_0x195dc1,_['map'](_0x491374,_0x6015('0x2e'))[_0x6015('0x40')](',\x20'));_0x3156c1[_0x6015('0x41')]();}else{var _0x2805ca=_[_0x6015('0x42')](_0x32b984[_0xaee96f[_0x6015('0x2b')]+_0x6015('0x43')],handleFindQueue(_0x4b351a['name']));if(_0x2805ca){startRouting(_0x195dc1,_0x2805ca,_0xaee96f,_0x32b984);var _0x5b2553=(_0x2805ca[_0x6015('0x3a')]||0xa)*0x3e8;var _0x3dc8c5=(_0x4b351a['timeout']||0x14)*0x3e8;var _0x54d92e;if(_0x5b2553>_0x3dc8c5){_0x3dc8c5=_0x5b2553;}var _0x45c01b=seqqueue['createQueue'](_0x5b2553);_0x45c01b['id']=_0x195dc1;_0x45c01b[_0x6015('0x44')]=_0x5b2553;_0x45c01b[_0x6015('0x45')]=_0x3dc8c5;_0x45c01b[_0x6015('0x2b')]=_0xaee96f[_0x6015('0x2b')];_0x32b984[_0x6015('0x46')][_0x195dc1]['on'](_0x6015('0x47'),function(){logger[_0x6015('0x31')](_0x6015('0x48'),_0x195dc1);stopRouting(_0x195dc1,_0x2805ca,_0xaee96f,_0x32b984);clearTimeout(_0x54d92e);_0x54d92e=undefined;_0x45c01b[_0x6015('0x49')](!![]);if(_0x32b984['rules'][_0x195dc1]){delete _0x32b984['rules'][_0x195dc1];}_0x3156c1[_0x6015('0x41')]();});_0x32b984[_0x6015('0x46')][_0x195dc1]['on']('complete',function(){if(_0x32b984[_0x6015('0x46')][_0x195dc1]){delete _0x32b984['rules'][_0x195dc1];}});_0x54d92e=setTimeout(function(){logger[_0x6015('0x31')](_0x6015('0x4a'),_0x195dc1);endRouting(_0x195dc1,_0x2805ca,_0xaee96f,_0x32b984);clearTimeout(_0x54d92e);_0x45c01b[_0x6015('0x49')](!![]);_0x3156c1[_0x6015('0x4b')]();},_0x3dc8c5);switch(_0x2805ca[_0x6015('0x4c')]){case _0x6015('0x4d'):strategy[_0x6015('0x4d')](_0x45c01b,_0x2805ca,_0x32b984,_0xaee96f);break;default:strategy[_0x6015('0x4e')](_0x45c01b,_0x2805ca,_0x32b984,_0xaee96f);}}else{logger['error']('[%s][QUEUE]\x20queue\x20not\x20found\x20%s',_0x195dc1,_0x4b351a[_0x6015('0x32')]);_0x3156c1[_0x6015('0x41')]();}}}catch(_0x4f158c){logger['error'](_0x6015('0x3f'),_0x195dc1,_0x4f158c['stack']);_0x3156c1[_0x6015('0x41')]();}};};
\ No newline at end of file
git://repos.xcallymotion.com / motion2.git / blobdiff