// * treaties. The SOFTWARE PRODUCT is licensed, not sold. *
// * *
// *************************************************************************
-var _0x76de=['%sQueuesWaitingInteractions','save','remove','pick','../../rpc/mailQueueReport','../../rpc/chatQueueReport','../../rpc/smsQueueReport','../../rpc/faxQueueReport','../../rpc/whatsappQueueReport','../../rpc/chatInteraction','../../rpc/faxInteraction','../../rpc/mailInteraction','../../rpc/openchannelInteraction','../../rpc/smsInteraction','../../rpc/whatsappInteraction','name\x20is\x20a\x20string\x20and\x20it\x20is\x20required','timeout\x20is\x20a\x20number','waiting','body','from','YYYY-MM-DD\x20HH:mm:ss','contact','list','channel','QueueId','upperFirst','interaction','MessageId','chat','AccountId','WebsiteId','account','info','[%s][START:QUEUE][NAME:%s]','name','message','QueueReport','create','catch','error','create\x20queue\x20report','accepted','Interaction','update','update\x20queue\x20report','[%s][END:QUEUE][NAME:%s]','toLowerCase','consequence','[%s][QUEUE]\x20%s','map','join','stop','timeout','createQueue','atimeout','qtimeout','rules','end','[%s][QUEUE]\x20ROUTING\x20STOPPED','close','complete','next','rrmemory','beepall','[%s][QUEUE]\x20queue\x20not\x20found\x20%s','stack','validate','lodash','util','seq-queue','ioredis','../../../../config/environment','../../../../config/logger','./strategy','redis','defaults','localhost','socket.io-emitter','queue_id','emit','clone','queue','push','capitalize','InteractionId','format'];(function(_0xfae23b,_0x2be4ba){var _0x200640=function(_0x4ae258){while(--_0x4ae258){_0xfae23b['push'](_0xfae23b['shift']());}};_0x200640(++_0x2be4ba);}(_0x76de,0x19a));var _0xe76d=function(_0x2ed7d9,_0x3e0125){_0x2ed7d9=_0x2ed7d9-0x0;var _0x473fa5=_0x76de[_0x2ed7d9];return _0x473fa5;};'use strict';var schema=require(_0xe76d('0x0'));var _=require(_0xe76d('0x1'));var util=require(_0xe76d('0x2'));var seqqueue=require(_0xe76d('0x3'));var moment=require('moment');var Redis=require(_0xe76d('0x4'));var config=require(_0xe76d('0x5'));var logger=require(_0xe76d('0x6'))('routing');var strategy=require(_0xe76d('0x7'));config[_0xe76d('0x8')]=_[_0xe76d('0x9')](config[_0xe76d('0x8')],{'host':_0xe76d('0xa'),'port':0x18eb});var io=require(_0xe76d('0xb'))(new Redis(config[_0xe76d('0x8')]));var attributes=['id',_0xe76d('0xc'),'account','queue','from','joinAt'];function emit(_0x5178cd,_0x351fc3,_0x1e2419){io['to'](_0x5178cd)[_0xe76d('0xd')](_0x351fc3,_0x1e2419);}function emitChannelQueueInteraction(_0x4e4970,_0x3d4b25,_0x4d3a8b,_0x19c29a,_0x517d51,_0x1b10ca,_0x348c5a,_0x33f20c){var _0x35254f=_[_0xe76d('0xe')](_0x4d3a8b);_0x35254f['queue_id']=_0x33f20c;_0x35254f[_0xe76d('0xf')]=_0x3d4b25;_0x35254f['account']=_0x19c29a;_0x35254f['id']=_0x517d51;if(_0x1b10ca){attributes[_0xe76d('0x10')](_[_0xe76d('0x11')](_0x4e4970)+_0xe76d('0x12'));_0x348c5a[util[_0xe76d('0x13')](_0xe76d('0x14'),_0x4e4970)][_0x517d51]=_['pick'](_0x35254f,attributes);}else{delete _0x348c5a[util[_0xe76d('0x13')](_0xe76d('0x14'),_0x4e4970)][_0x517d51];}emit(util[_0xe76d('0x13')]('%s:queue:%s',_0x4e4970,_0x3d4b25),util[_0xe76d('0x13')]('%s_queue_waiting_interaction:%s',_0x4e4970,_0x1b10ca?_0xe76d('0x15'):_0xe76d('0x16')),_[_0xe76d('0x17')](_0x35254f,attributes));}var rpc={'openchannelQueueReport':require('../../rpc/openchannelQueueReport'),'mailQueueReport':require(_0xe76d('0x18')),'chatQueueReport':require(_0xe76d('0x19')),'smsQueueReport':require(_0xe76d('0x1a')),'faxQueueReport':require(_0xe76d('0x1b')),'whatsappQueueReport':require(_0xe76d('0x1c')),'chatInteraction':require(_0xe76d('0x1d')),'faxInteraction':require(_0xe76d('0x1e')),'mailInteraction':require(_0xe76d('0x1f')),'openchannelInteraction':require(_0xe76d('0x20')),'smsInteraction':require(_0xe76d('0x21')),'whatsappInteraction':require(_0xe76d('0x22'))};var queue=schema({'name':{'type':'string','required':!![],'message':_0xe76d('0x23')},'timeout':{'type':'number','message':_0xe76d('0x24')}});function startRouting(_0x4e8f84,_0x12fb68,_0x58c122,_0x2cfba4){if(_0x4e8f84&&_0x12fb68&&_0x58c122){_0x12fb68[_0xe76d('0x25')]+=0x1;var _0x4ba1f6={'uniqueid':_0x4e8f84,'from':_0x58c122[_0xe76d('0x26')]?_0x58c122['body'][_0xe76d('0x27')]:'','joinAt':moment()['format'](_0xe76d('0x28')),'ContactId':_0x58c122[_0xe76d('0x29')]?_0x58c122[_0xe76d('0x29')]['id']:null,'ListId':_0x58c122['list']?_0x58c122[_0xe76d('0x2a')]['id']:null};_0x4ba1f6[_['upperFirst'](_0x58c122[_0xe76d('0x2b')])+_0xe76d('0x2c')]=_0x12fb68['id']||null;_0x4ba1f6[_[_0xe76d('0x2d')](_0x58c122[_0xe76d('0x2b')])+_0xe76d('0x12')]=_0x58c122['interaction']?_0x58c122[_0xe76d('0x2e')]['id']:null;_0x4ba1f6[_[_0xe76d('0x2d')](_0x58c122[_0xe76d('0x2b')])+_0xe76d('0x2f')]=_0x58c122['message']?_0x58c122['message']['id']:null;_0x4ba1f6[_[_0xe76d('0x2d')](_0x58c122[_0xe76d('0x2b')])+(_0x58c122[_0xe76d('0x2b')]!==_0xe76d('0x30')?_0xe76d('0x31'):_0xe76d('0x32'))]=_0x58c122[_0xe76d('0x33')]?_0x58c122[_0xe76d('0x33')]['id']:null;logger[_0xe76d('0x34')](util[_0xe76d('0x13')](_0xe76d('0x35'),_0x4e8f84,_0x12fb68['name']));emitChannelQueueInteraction(_0x58c122[_0xe76d('0x2b')],_0x12fb68[_0xe76d('0x36')],_0x4ba1f6,_0x58c122[_0xe76d('0x33')][_0xe76d('0x36')],_0x58c122[_0xe76d('0x37')]['id'],!![],_0x2cfba4,_0x12fb68['id']);if(rpc[_0x58c122['channel']+_0xe76d('0x38')]){return rpc[_0x58c122['channel']+'QueueReport'][_0xe76d('0x39')](_0x4ba1f6)[_0xe76d('0x3a')](function(_0x2f2852){logger[_0xe76d('0x3b')](_0xe76d('0x3c'),_0x2f2852);});}}}function stopRouting(_0xdc4a78,_0xf5d95d,_0x59a580,_0x1dc753){if(_0xdc4a78&&_0xf5d95d){_0xf5d95d[_0xe76d('0x25')]-=0x1;var _0xda46a2={'leaveAt':moment()[_0xe76d('0x13')]('YYYY-MM-DD\x20HH:mm:ss'),'acceptAt':moment()[_0xe76d('0x13')](_0xe76d('0x28')),'reason':_0xe76d('0x3d')};logger['info'](util['format']('[%s][STOP:QUEUE][NAME:%s]',_0xdc4a78,_0xf5d95d[_0xe76d('0x36')]));emitChannelQueueInteraction(_0x59a580[_0xe76d('0x2b')],_0xf5d95d[_0xe76d('0x36')],_0x59a580[_0xe76d('0x26')],_0x59a580[_0xe76d('0x33')]['name'],_0x59a580[_0xe76d('0x37')]['id'],![],_0x1dc753,_0xf5d95d['id']);return rpc[_0x59a580['channel']+_0xe76d('0x3e')][_0xe76d('0x3f')](_0x59a580['interaction']['id'],{'queueId':_0xf5d95d['id']})['then'](function(){if(rpc[_0x59a580[_0xe76d('0x2b')]+_0xe76d('0x38')]){return rpc[_0x59a580[_0xe76d('0x2b')]+_0xe76d('0x38')][_0xe76d('0x3f')](_0xdc4a78,_0xda46a2)[_0xe76d('0x3a')](function(_0xbbf684){logger[_0xe76d('0x3b')](_0xe76d('0x40'),_0xbbf684);});}});}}function endRouting(_0x1e5cff,_0x32077e,_0x5c2287,_0xd518d2){if(_0x1e5cff&&_0x32077e){_0x32077e[_0xe76d('0x25')]-=0x1;var _0x527f9f={'leaveAt':moment()[_0xe76d('0x13')](_0xe76d('0x28')),'exitAt':moment()['format']('YYYY-MM-DD\x20HH:mm:ss'),'reason':'timeout'};logger[_0xe76d('0x34')](util[_0xe76d('0x13')](_0xe76d('0x41'),_0x1e5cff,_0x32077e[_0xe76d('0x36')]));emitChannelQueueInteraction(_0x5c2287[_0xe76d('0x2b')],_0x32077e[_0xe76d('0x36')],_0x5c2287[_0xe76d('0x26')],_0x5c2287['account'][_0xe76d('0x36')],_0x5c2287[_0xe76d('0x37')]['id'],![],_0xd518d2);if(rpc[_0x5c2287[_0xe76d('0x2b')]+_0xe76d('0x38')]){return rpc[_0x5c2287[_0xe76d('0x2b')]+_0xe76d('0x38')][_0xe76d('0x3f')](_0x1e5cff,_0x527f9f)[_0xe76d('0x3a')](function(_0x4b529a){logger[_0xe76d('0x3b')]('update\x20queue\x20report',_0x4b529a);});}}}function handleFindQueue(_0x3c30bb){return function(_0x81b041){return _0x81b041[_0xe76d('0x36')][_0xe76d('0x42')]()===_0x3c30bb[_0xe76d('0x42')]();};}exports[_0xe76d('0x43')]=function(_0x451a80,_0x3efd83,_0x1e32d0,_0x2cab86){return function(_0x4a2c99){try{var _0x17c3f9={'name':_0x3efd83[0x0],'timeout':_0x3efd83[0x1]};var _0x13d222=queue[_0xe76d('0x0')](_0x17c3f9,{'typecast':!![]});if(_0x13d222['length']){logger['error'](_0xe76d('0x44'),_0x451a80,_[_0xe76d('0x45')](_0x13d222,_0xe76d('0x37'))[_0xe76d('0x46')](',\x20'));_0x4a2c99[_0xe76d('0x47')]();}else{var _0x4f08c3=_['find'](_0x1e32d0[_0x2cab86['channel']+'Queues'],handleFindQueue(_0x17c3f9['name']));if(_0x4f08c3){startRouting(_0x451a80,_0x4f08c3,_0x2cab86,_0x1e32d0);var _0x4664aa=(_0x4f08c3[_0xe76d('0x48')]||0xa)*0x3e8;var _0x3c791b=(_0x17c3f9[_0xe76d('0x48')]||0x14)*0x3e8;var _0x1d3eb7;if(_0x4664aa>_0x3c791b){_0x3c791b=_0x4664aa;}var _0x1572b7=seqqueue[_0xe76d('0x49')](_0x4664aa);_0x1572b7['id']=_0x451a80;_0x1572b7[_0xe76d('0x4a')]=_0x4664aa;_0x1572b7[_0xe76d('0x4b')]=_0x3c791b;_0x1572b7['channel']=_0x2cab86[_0xe76d('0x2b')];_0x1e32d0[_0xe76d('0x4c')][_0x451a80]['on'](_0xe76d('0x4d'),function(){logger[_0xe76d('0x34')](_0xe76d('0x4e'),_0x451a80);stopRouting(_0x451a80,_0x4f08c3,_0x2cab86,_0x1e32d0);clearTimeout(_0x1d3eb7);_0x1d3eb7=undefined;_0x1572b7[_0xe76d('0x4f')](!![]);if(_0x1e32d0[_0xe76d('0x4c')][_0x451a80]){delete _0x1e32d0['rules'][_0x451a80];}_0x4a2c99['stop']();});_0x1e32d0[_0xe76d('0x4c')][_0x451a80]['on'](_0xe76d('0x50'),function(){if(_0x1e32d0[_0xe76d('0x4c')][_0x451a80]){delete _0x1e32d0[_0xe76d('0x4c')][_0x451a80];}});_0x1d3eb7=setTimeout(function(){logger[_0xe76d('0x34')]('[%s][QUEUE]\x20APPLICATION\x20END',_0x451a80);endRouting(_0x451a80,_0x4f08c3,_0x2cab86,_0x1e32d0);clearTimeout(_0x1d3eb7);_0x1572b7[_0xe76d('0x4f')](!![]);_0x4a2c99[_0xe76d('0x51')]();},_0x3c791b);switch(_0x4f08c3['strategy']){case _0xe76d('0x52'):strategy[_0xe76d('0x52')](_0x1572b7,_0x4f08c3,_0x1e32d0,_0x2cab86);break;default:strategy[_0xe76d('0x53')](_0x1572b7,_0x4f08c3,_0x1e32d0,_0x2cab86);}}else{logger[_0xe76d('0x3b')](_0xe76d('0x54'),_0x451a80,_0x17c3f9['name']);_0x4a2c99[_0xe76d('0x47')]();}}}catch(_0x3d2896){logger['error'](_0xe76d('0x44'),_0x451a80,_0x3d2896[_0xe76d('0x55')]);_0x4a2c99[_0xe76d('0x47')]();}};};
\ No newline at end of file
+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
git://repos.xcallymotion.com / motion2.git / blobdiff