// * treaties. The SOFTWARE PRODUCT is licensed, not sold. *
// * *
// *************************************************************************
-var _0xee30=['stop','find','Queues','createQueue','atimeout','rules','end','[%s][QUEUE]\x20ROUTING\x20STOPPED','close','complete','next','[%s][QUEUE]\x20queue\x20not\x20found\x20%s','stack','validate','lodash','util','seq-queue','moment','ioredis','../../../../config/logger','routing','./strategy','redis','defaults','localhost','socket.io-emitter','queue_id','account','queue','from','emit','push','capitalize','InteractionId','%sQueuesWaitingInteractions','pick','format','%s:queue:%s','save','remove','../../rpc/mailQueueReport','../../rpc/chatQueueReport','../../rpc/smsQueueReport','../../rpc/faxQueueReport','../../rpc/chatInteraction','../../rpc/mailInteraction','../../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','MessageId','message','chat','WebsiteId','info','[%s][START:QUEUE][NAME:%s]','name','QueueReport','create','create\x20queue\x20report','[%s][STOP:QUEUE][NAME:%s]','update','catch','error','update\x20queue\x20report','timeout','[%s][END:QUEUE][NAME:%s]','toLowerCase','consequence','length','[%s][QUEUE]\x20%s','map','join'];(function(_0x49f9bf,_0x1b0e2f){var _0x3b0a6f=function(_0x52bf02){while(--_0x52bf02){_0x49f9bf['push'](_0x49f9bf['shift']());}};_0x3b0a6f(++_0x1b0e2f);}(_0xee30,0x159));var _0x0ee3=function(_0x392f66,_0x44940d){_0x392f66=_0x392f66-0x0;var _0x3afd79=_0xee30[_0x392f66];return _0x3afd79;};'use strict';var schema=require(_0x0ee3('0x0'));var _=require(_0x0ee3('0x1'));var util=require(_0x0ee3('0x2'));var seqqueue=require(_0x0ee3('0x3'));var moment=require(_0x0ee3('0x4'));var Redis=require(_0x0ee3('0x5'));var config=require('../../../../config/environment');var logger=require(_0x0ee3('0x6'))(_0x0ee3('0x7'));var strategy=require(_0x0ee3('0x8'));config[_0x0ee3('0x9')]=_[_0x0ee3('0xa')](config[_0x0ee3('0x9')],{'host':_0x0ee3('0xb'),'port':0x18eb});var io=require(_0x0ee3('0xc'))(new Redis(config[_0x0ee3('0x9')]));var attributes=['id',_0x0ee3('0xd'),_0x0ee3('0xe'),_0x0ee3('0xf'),_0x0ee3('0x10'),'joinAt'];function emit(_0x195390,_0x381eb3,_0x37ca39){io['to'](_0x195390)[_0x0ee3('0x11')](_0x381eb3,_0x37ca39);}function emitChannelQueueInteraction(_0x7cb77f,_0x45fae5,_0x5f1de8,_0x385668,_0x4062a0,_0x55e20f,_0x247750,_0x1d0291){var _0x5f00fe=_['clone'](_0x5f1de8);_0x5f00fe['queue_id']=_0x1d0291;_0x5f00fe[_0x0ee3('0xf')]=_0x45fae5;_0x5f00fe[_0x0ee3('0xe')]=_0x385668;_0x5f00fe['id']=_0x4062a0;if(_0x55e20f){attributes[_0x0ee3('0x12')](_[_0x0ee3('0x13')](_0x7cb77f)+_0x0ee3('0x14'));_0x247750[util['format'](_0x0ee3('0x15'),_0x7cb77f)][_0x4062a0]=_[_0x0ee3('0x16')](_0x5f00fe,attributes);}else{delete _0x247750[util[_0x0ee3('0x17')]('%sQueuesWaitingInteractions',_0x7cb77f)][_0x4062a0];}emit(util['format'](_0x0ee3('0x18'),_0x7cb77f,_0x45fae5),util[_0x0ee3('0x17')]('%s_queue_waiting_interaction:%s',_0x7cb77f,_0x55e20f?_0x0ee3('0x19'):_0x0ee3('0x1a')),_[_0x0ee3('0x16')](_0x5f00fe,attributes));}var rpc={'openchannelQueueReport':require('../../rpc/openchannelQueueReport'),'mailQueueReport':require(_0x0ee3('0x1b')),'chatQueueReport':require(_0x0ee3('0x1c')),'smsQueueReport':require(_0x0ee3('0x1d')),'faxQueueReport':require(_0x0ee3('0x1e')),'whatsappQueueReport':require('../../rpc/whatsappQueueReport'),'chatInteraction':require(_0x0ee3('0x1f')),'faxInteraction':require('../../rpc/faxInteraction'),'mailInteraction':require(_0x0ee3('0x20')),'openchannelInteraction':require(_0x0ee3('0x21')),'smsInteraction':require(_0x0ee3('0x22')),'whatsappInteraction':require(_0x0ee3('0x23'))};var queue=schema({'name':{'type':_0x0ee3('0x24'),'required':!![],'message':_0x0ee3('0x25')},'timeout':{'type':_0x0ee3('0x26'),'message':_0x0ee3('0x27')}});function startRouting(_0x15bef7,_0x1599bd,_0x5d98a9,_0x4e0ef4){if(_0x15bef7&&_0x1599bd&&_0x5d98a9){_0x1599bd[_0x0ee3('0x28')]+=0x1;var _0x203b63={'uniqueid':_0x15bef7,'from':_0x5d98a9[_0x0ee3('0x29')]?_0x5d98a9[_0x0ee3('0x29')]['from']:'','joinAt':moment()[_0x0ee3('0x17')](_0x0ee3('0x2a')),'ContactId':_0x5d98a9['contact']?_0x5d98a9[_0x0ee3('0x2b')]['id']:null,'ListId':_0x5d98a9[_0x0ee3('0x2c')]?_0x5d98a9[_0x0ee3('0x2c')]['id']:null};_0x203b63[_[_0x0ee3('0x2d')](_0x5d98a9['channel'])+'QueueId']=_0x1599bd['id']||null;_0x203b63[_[_0x0ee3('0x2d')](_0x5d98a9[_0x0ee3('0x2e')])+_0x0ee3('0x14')]=_0x5d98a9['interaction']?_0x5d98a9['interaction']['id']:null;_0x203b63[_[_0x0ee3('0x2d')](_0x5d98a9[_0x0ee3('0x2e')])+_0x0ee3('0x2f')]=_0x5d98a9['message']?_0x5d98a9[_0x0ee3('0x30')]['id']:null;_0x203b63[_['upperFirst'](_0x5d98a9[_0x0ee3('0x2e')])+(_0x5d98a9[_0x0ee3('0x2e')]!==_0x0ee3('0x31')?'AccountId':_0x0ee3('0x32'))]=_0x5d98a9[_0x0ee3('0xe')]?_0x5d98a9[_0x0ee3('0xe')]['id']:null;logger[_0x0ee3('0x33')](util[_0x0ee3('0x17')](_0x0ee3('0x34'),_0x15bef7,_0x1599bd['name']));emitChannelQueueInteraction(_0x5d98a9[_0x0ee3('0x2e')],_0x1599bd[_0x0ee3('0x35')],_0x203b63,_0x5d98a9['account'][_0x0ee3('0x35')],_0x5d98a9[_0x0ee3('0x30')]['id'],!![],_0x4e0ef4,_0x1599bd['id']);if(rpc[_0x5d98a9['channel']+_0x0ee3('0x36')]){return rpc[_0x5d98a9[_0x0ee3('0x2e')]+'QueueReport'][_0x0ee3('0x37')](_0x203b63)['catch'](function(_0x5f317f){logger['error'](_0x0ee3('0x38'),_0x5f317f);});}}}function stopRouting(_0x4afa54,_0x27fb6d,_0x3105c2,_0x329c39){if(_0x4afa54&&_0x27fb6d){_0x27fb6d[_0x0ee3('0x28')]-=0x1;var _0xe382a6={'leaveAt':moment()[_0x0ee3('0x17')](_0x0ee3('0x2a')),'acceptAt':moment()[_0x0ee3('0x17')](_0x0ee3('0x2a')),'reason':'accepted'};logger['info'](util[_0x0ee3('0x17')](_0x0ee3('0x39'),_0x4afa54,_0x27fb6d['name']));emitChannelQueueInteraction(_0x3105c2[_0x0ee3('0x2e')],_0x27fb6d['name'],_0x3105c2[_0x0ee3('0x29')],_0x3105c2['account']['name'],_0x3105c2['message']['id'],![],_0x329c39,_0x27fb6d['id']);return rpc[_0x3105c2[_0x0ee3('0x2e')]+'Interaction'][_0x0ee3('0x3a')](_0x3105c2['interaction']['id'],{'queueId':_0x27fb6d['id']})['then'](function(){if(rpc[_0x3105c2[_0x0ee3('0x2e')]+'QueueReport']){return rpc[_0x3105c2[_0x0ee3('0x2e')]+'QueueReport']['update'](_0x4afa54,_0xe382a6)[_0x0ee3('0x3b')](function(_0x25f8bc){logger[_0x0ee3('0x3c')](_0x0ee3('0x3d'),_0x25f8bc);});}});}}function endRouting(_0x26903a,_0x2892d6,_0x28f0b3,_0x32d70c){if(_0x26903a&&_0x2892d6){_0x2892d6[_0x0ee3('0x28')]-=0x1;var _0x557646={'leaveAt':moment()[_0x0ee3('0x17')](_0x0ee3('0x2a')),'exitAt':moment()[_0x0ee3('0x17')](_0x0ee3('0x2a')),'reason':_0x0ee3('0x3e')};logger[_0x0ee3('0x33')](util['format'](_0x0ee3('0x3f'),_0x26903a,_0x2892d6[_0x0ee3('0x35')]));emitChannelQueueInteraction(_0x28f0b3['channel'],_0x2892d6['name'],_0x28f0b3[_0x0ee3('0x29')],_0x28f0b3[_0x0ee3('0xe')][_0x0ee3('0x35')],_0x28f0b3[_0x0ee3('0x30')]['id'],![],_0x32d70c);if(rpc[_0x28f0b3[_0x0ee3('0x2e')]+_0x0ee3('0x36')]){return rpc[_0x28f0b3[_0x0ee3('0x2e')]+_0x0ee3('0x36')][_0x0ee3('0x3a')](_0x26903a,_0x557646)[_0x0ee3('0x3b')](function(_0x42271d){logger[_0x0ee3('0x3c')]('update\x20queue\x20report',_0x42271d);});}}}function handleFindQueue(_0x1678b6){return function(_0x58b617){return _0x58b617['name'][_0x0ee3('0x40')]()===_0x1678b6[_0x0ee3('0x40')]();};}exports[_0x0ee3('0x41')]=function(_0x16ef9b,_0x2cb0a7,_0x38f801,_0x591d44){return function(_0x50806e){try{var _0x1aa973={'name':_0x2cb0a7[0x0],'timeout':_0x2cb0a7[0x1]};var _0x280507=queue[_0x0ee3('0x0')](_0x1aa973,{'typecast':!![]});if(_0x280507[_0x0ee3('0x42')]){logger[_0x0ee3('0x3c')](_0x0ee3('0x43'),_0x16ef9b,_[_0x0ee3('0x44')](_0x280507,_0x0ee3('0x30'))[_0x0ee3('0x45')](',\x20'));_0x50806e[_0x0ee3('0x46')]();}else{var _0x384d22=_[_0x0ee3('0x47')](_0x38f801[_0x591d44['channel']+_0x0ee3('0x48')],handleFindQueue(_0x1aa973[_0x0ee3('0x35')]));if(_0x384d22){startRouting(_0x16ef9b,_0x384d22,_0x591d44,_0x38f801);var _0x4b3f8d=(_0x384d22[_0x0ee3('0x3e')]||0xa)*0x3e8;var _0x2a4de2=(_0x1aa973[_0x0ee3('0x3e')]||0x14)*0x3e8;var _0x299e81;if(_0x4b3f8d>_0x2a4de2){_0x2a4de2=_0x4b3f8d;}var _0x2848d5=seqqueue[_0x0ee3('0x49')](_0x4b3f8d);_0x2848d5['id']=_0x16ef9b;_0x2848d5[_0x0ee3('0x4a')]=_0x4b3f8d;_0x2848d5['qtimeout']=_0x2a4de2;_0x2848d5[_0x0ee3('0x2e')]=_0x591d44['channel'];_0x38f801[_0x0ee3('0x4b')][_0x16ef9b]['on'](_0x0ee3('0x4c'),function(){logger[_0x0ee3('0x33')](_0x0ee3('0x4d'),_0x16ef9b);stopRouting(_0x16ef9b,_0x384d22,_0x591d44,_0x38f801);clearTimeout(_0x299e81);_0x299e81=undefined;_0x2848d5[_0x0ee3('0x4e')](!![]);if(_0x38f801[_0x0ee3('0x4b')][_0x16ef9b]){delete _0x38f801[_0x0ee3('0x4b')][_0x16ef9b];}_0x50806e[_0x0ee3('0x46')]();});_0x38f801[_0x0ee3('0x4b')][_0x16ef9b]['on'](_0x0ee3('0x4f'),function(){if(_0x38f801[_0x0ee3('0x4b')][_0x16ef9b]){delete _0x38f801['rules'][_0x16ef9b];}});_0x299e81=setTimeout(function(){logger[_0x0ee3('0x33')]('[%s][QUEUE]\x20APPLICATION\x20END',_0x16ef9b);endRouting(_0x16ef9b,_0x384d22,_0x591d44,_0x38f801);clearTimeout(_0x299e81);_0x2848d5[_0x0ee3('0x4e')](!![]);_0x50806e[_0x0ee3('0x50')]();},_0x2a4de2);switch(_0x384d22['strategy']){case'rrmemory':strategy['rrmemory'](_0x2848d5,_0x384d22,_0x38f801,_0x591d44);break;default:strategy['beepall'](_0x2848d5,_0x384d22,_0x38f801,_0x591d44);}}else{logger[_0x0ee3('0x3c')](_0x0ee3('0x51'),_0x16ef9b,_0x1aa973[_0x0ee3('0x35')]);_0x50806e[_0x0ee3('0x46')]();}}}catch(_0x19505e){logger[_0x0ee3('0x3c')]('[%s][QUEUE]\x20%s',_0x16ef9b,_0x19505e[_0x0ee3('0x52')]);_0x50806e[_0x0ee3('0x46')]();}};};
\ No newline at end of file
+var _0x5e7f=['./strategy','redis','defaults','localhost','socket.io-emitter','account','queue','from','emit','clone','queue_id','push','InteractionId','format','%sQueuesWaitingInteractions','%s:queue:%s','%s_queue_waiting_interaction:%s','remove','pick','../../rpc/openchannelQueueReport','../../rpc/mailQueueReport','../../rpc/chatQueueReport','../../rpc/faxQueueReport','../../rpc/whatsappQueueReport','../../rpc/faxInteraction','../../rpc/mailInteraction','../../rpc/openchannelInteraction','../../rpc/smsInteraction','../../rpc/whatsappInteraction','string','number','waiting','body','YYYY-MM-DD\x20HH:mm:ss','contact','list','upperFirst','channel','QueueId','interaction','MessageId','message','chat','AccountId','[%s][START:QUEUE][NAME:%s]','name','QueueReport','create','catch','accepted','Interaction','update','then','error','timeout','info','[%s][END:QUEUE][NAME:%s]','update\x20queue\x20report','toLowerCase','consequence','length','[%s][QUEUE]\x20%s','map','join','stop','find','atimeout','qtimeout','rules','end','[%s][QUEUE]\x20ROUTING\x20STOPPED','close','complete','next','strategy','rrmemory','beepall','[%s][QUEUE]\x20queue\x20not\x20found\x20%s','stack','validate','lodash','util','seq-queue','moment','ioredis','../../../../config/environment','../../../../config/logger','routing'];(function(_0x48deaf,_0x91fc6a){var _0x35ba9b=function(_0x66a1ca){while(--_0x66a1ca){_0x48deaf['push'](_0x48deaf['shift']());}};_0x35ba9b(++_0x91fc6a);}(_0x5e7f,0xff));var _0xf5e7=function(_0x37d34c,_0x501153){_0x37d34c=_0x37d34c-0x0;var _0x11a0ba=_0x5e7f[_0x37d34c];return _0x11a0ba;};'use strict';var schema=require(_0xf5e7('0x0'));var _=require(_0xf5e7('0x1'));var util=require(_0xf5e7('0x2'));var seqqueue=require(_0xf5e7('0x3'));var moment=require(_0xf5e7('0x4'));var Redis=require(_0xf5e7('0x5'));var config=require(_0xf5e7('0x6'));var logger=require(_0xf5e7('0x7'))(_0xf5e7('0x8'));var strategy=require(_0xf5e7('0x9'));config[_0xf5e7('0xa')]=_[_0xf5e7('0xb')](config[_0xf5e7('0xa')],{'host':_0xf5e7('0xc'),'port':0x18eb});var io=require(_0xf5e7('0xd'))(new Redis(config[_0xf5e7('0xa')]));var attributes=['id','queue_id',_0xf5e7('0xe'),_0xf5e7('0xf'),_0xf5e7('0x10'),'joinAt'];function emit(_0x210b3b,_0x774f2a,_0x194e65){io['to'](_0x210b3b)[_0xf5e7('0x11')](_0x774f2a,_0x194e65);}function emitChannelQueueInteraction(_0x139f86,_0x4672a9,_0x3115eb,_0xbb55e6,_0x5c399d,_0x14c72,_0x42f970,_0x5151a1){var _0x5e5514=_[_0xf5e7('0x12')](_0x3115eb);_0x5e5514[_0xf5e7('0x13')]=_0x5151a1;_0x5e5514['queue']=_0x4672a9;_0x5e5514[_0xf5e7('0xe')]=_0xbb55e6;_0x5e5514['id']=_0x5c399d;if(_0x14c72){attributes[_0xf5e7('0x14')](_['capitalize'](_0x139f86)+_0xf5e7('0x15'));_0x42f970[util[_0xf5e7('0x16')]('%sQueuesWaitingInteractions',_0x139f86)][_0x5c399d]=_['pick'](_0x5e5514,attributes);}else{delete _0x42f970[util['format'](_0xf5e7('0x17'),_0x139f86)][_0x5c399d];}emit(util[_0xf5e7('0x16')](_0xf5e7('0x18'),_0x139f86,_0x4672a9),util[_0xf5e7('0x16')](_0xf5e7('0x19'),_0x139f86,_0x14c72?'save':_0xf5e7('0x1a')),_[_0xf5e7('0x1b')](_0x5e5514,attributes));}var rpc={'openchannelQueueReport':require(_0xf5e7('0x1c')),'mailQueueReport':require(_0xf5e7('0x1d')),'chatQueueReport':require(_0xf5e7('0x1e')),'smsQueueReport':require('../../rpc/smsQueueReport'),'faxQueueReport':require(_0xf5e7('0x1f')),'whatsappQueueReport':require(_0xf5e7('0x20')),'chatInteraction':require('../../rpc/chatInteraction'),'faxInteraction':require(_0xf5e7('0x21')),'mailInteraction':require(_0xf5e7('0x22')),'openchannelInteraction':require(_0xf5e7('0x23')),'smsInteraction':require(_0xf5e7('0x24')),'whatsappInteraction':require(_0xf5e7('0x25'))};var queue=schema({'name':{'type':_0xf5e7('0x26'),'required':!![],'message':'name\x20is\x20a\x20string\x20and\x20it\x20is\x20required'},'timeout':{'type':_0xf5e7('0x27'),'message':'timeout\x20is\x20a\x20number'}});function startRouting(_0x4ef266,_0x131a6b,_0x4876e3,_0x3a5f5f){if(_0x4ef266&&_0x131a6b&&_0x4876e3){_0x131a6b[_0xf5e7('0x28')]+=0x1;var _0x196772={'uniqueid':_0x4ef266,'from':_0x4876e3[_0xf5e7('0x29')]?_0x4876e3[_0xf5e7('0x29')][_0xf5e7('0x10')]:'','joinAt':moment()['format'](_0xf5e7('0x2a')),'ContactId':_0x4876e3[_0xf5e7('0x2b')]?_0x4876e3[_0xf5e7('0x2b')]['id']:null,'ListId':_0x4876e3[_0xf5e7('0x2c')]?_0x4876e3['list']['id']:null};_0x196772[_[_0xf5e7('0x2d')](_0x4876e3[_0xf5e7('0x2e')])+_0xf5e7('0x2f')]=_0x131a6b['id']||null;_0x196772[_[_0xf5e7('0x2d')](_0x4876e3['channel'])+_0xf5e7('0x15')]=_0x4876e3[_0xf5e7('0x30')]?_0x4876e3[_0xf5e7('0x30')]['id']:null;_0x196772[_['upperFirst'](_0x4876e3[_0xf5e7('0x2e')])+_0xf5e7('0x31')]=_0x4876e3[_0xf5e7('0x32')]?_0x4876e3[_0xf5e7('0x32')]['id']:null;_0x196772[_[_0xf5e7('0x2d')](_0x4876e3[_0xf5e7('0x2e')])+(_0x4876e3[_0xf5e7('0x2e')]!==_0xf5e7('0x33')?_0xf5e7('0x34'):'WebsiteId')]=_0x4876e3['account']?_0x4876e3[_0xf5e7('0xe')]['id']:null;logger['info'](util['format'](_0xf5e7('0x35'),_0x4ef266,_0x131a6b[_0xf5e7('0x36')]));emitChannelQueueInteraction(_0x4876e3[_0xf5e7('0x2e')],_0x131a6b['name'],_0x196772,_0x4876e3[_0xf5e7('0xe')][_0xf5e7('0x36')],_0x4876e3['message']['id'],!![],_0x3a5f5f,_0x131a6b['id']);if(rpc[_0x4876e3[_0xf5e7('0x2e')]+_0xf5e7('0x37')]){return rpc[_0x4876e3[_0xf5e7('0x2e')]+'QueueReport'][_0xf5e7('0x38')](_0x196772)[_0xf5e7('0x39')](function(_0x4e9eb1){logger['error']('create\x20queue\x20report',_0x4e9eb1);});}}}function stopRouting(_0xf446d,_0x1b22f8,_0x2df34c,_0x2bd551){if(_0xf446d&&_0x1b22f8){_0x1b22f8['waiting']-=0x1;var _0x25123d={'leaveAt':moment()['format'](_0xf5e7('0x2a')),'acceptAt':moment()[_0xf5e7('0x16')]('YYYY-MM-DD\x20HH:mm:ss'),'reason':_0xf5e7('0x3a')};logger['info'](util[_0xf5e7('0x16')]('[%s][STOP:QUEUE][NAME:%s]',_0xf446d,_0x1b22f8[_0xf5e7('0x36')]));emitChannelQueueInteraction(_0x2df34c[_0xf5e7('0x2e')],_0x1b22f8[_0xf5e7('0x36')],_0x2df34c['body'],_0x2df34c[_0xf5e7('0xe')][_0xf5e7('0x36')],_0x2df34c[_0xf5e7('0x32')]['id'],![],_0x2bd551,_0x1b22f8['id']);return rpc[_0x2df34c[_0xf5e7('0x2e')]+_0xf5e7('0x3b')][_0xf5e7('0x3c')](_0x2df34c[_0xf5e7('0x30')]['id'],{'queueId':_0x1b22f8['id']})[_0xf5e7('0x3d')](function(){if(rpc[_0x2df34c[_0xf5e7('0x2e')]+_0xf5e7('0x37')]){return rpc[_0x2df34c[_0xf5e7('0x2e')]+'QueueReport'][_0xf5e7('0x3c')](_0xf446d,_0x25123d)[_0xf5e7('0x39')](function(_0x487fa8){logger[_0xf5e7('0x3e')]('update\x20queue\x20report',_0x487fa8);});}});}}function endRouting(_0x1bb628,_0x4dd40f,_0x13e49d,_0x157f41){if(_0x1bb628&&_0x4dd40f){_0x4dd40f[_0xf5e7('0x28')]-=0x1;var _0x19c1be={'leaveAt':moment()[_0xf5e7('0x16')](_0xf5e7('0x2a')),'exitAt':moment()['format'](_0xf5e7('0x2a')),'reason':_0xf5e7('0x3f')};logger[_0xf5e7('0x40')](util['format'](_0xf5e7('0x41'),_0x1bb628,_0x4dd40f[_0xf5e7('0x36')]));emitChannelQueueInteraction(_0x13e49d[_0xf5e7('0x2e')],_0x4dd40f[_0xf5e7('0x36')],_0x13e49d[_0xf5e7('0x29')],_0x13e49d[_0xf5e7('0xe')][_0xf5e7('0x36')],_0x13e49d[_0xf5e7('0x32')]['id'],![],_0x157f41);if(rpc[_0x13e49d[_0xf5e7('0x2e')]+_0xf5e7('0x37')]){return rpc[_0x13e49d[_0xf5e7('0x2e')]+'QueueReport'][_0xf5e7('0x3c')](_0x1bb628,_0x19c1be)[_0xf5e7('0x39')](function(_0x14a699){logger[_0xf5e7('0x3e')](_0xf5e7('0x42'),_0x14a699);});}}}function handleFindQueue(_0xba1bd0){return function(_0x3aa355){return _0x3aa355[_0xf5e7('0x36')][_0xf5e7('0x43')]()===_0xba1bd0[_0xf5e7('0x43')]();};}exports[_0xf5e7('0x44')]=function(_0x135f1b,_0x2036d3,_0x1317f8,_0x3ca53f){return function(_0x5894c2){try{var _0x1dd4f3={'name':_0x2036d3[0x0],'timeout':_0x2036d3[0x1]};var _0x41a85f=queue[_0xf5e7('0x0')](_0x1dd4f3,{'typecast':!![]});if(_0x41a85f[_0xf5e7('0x45')]){logger[_0xf5e7('0x3e')](_0xf5e7('0x46'),_0x135f1b,_[_0xf5e7('0x47')](_0x41a85f,_0xf5e7('0x32'))[_0xf5e7('0x48')](',\x20'));_0x5894c2[_0xf5e7('0x49')]();}else{var _0x49d70f=_[_0xf5e7('0x4a')](_0x1317f8[_0x3ca53f[_0xf5e7('0x2e')]+'Queues'],handleFindQueue(_0x1dd4f3['name']));if(_0x49d70f){startRouting(_0x135f1b,_0x49d70f,_0x3ca53f,_0x1317f8);var _0x5df3d5=(_0x49d70f['timeout']||0xa)*0x3e8;var _0x326082=(_0x1dd4f3[_0xf5e7('0x3f')]||0x14)*0x3e8;var _0x3e90be;if(_0x5df3d5>_0x326082){_0x326082=_0x5df3d5;}var _0x2be198=seqqueue['createQueue'](_0x5df3d5);_0x2be198['id']=_0x135f1b;_0x2be198[_0xf5e7('0x4b')]=_0x5df3d5;_0x2be198[_0xf5e7('0x4c')]=_0x326082;_0x2be198[_0xf5e7('0x2e')]=_0x3ca53f[_0xf5e7('0x2e')];_0x1317f8[_0xf5e7('0x4d')][_0x135f1b]['on'](_0xf5e7('0x4e'),function(){logger['info'](_0xf5e7('0x4f'),_0x135f1b);stopRouting(_0x135f1b,_0x49d70f,_0x3ca53f,_0x1317f8);clearTimeout(_0x3e90be);_0x3e90be=undefined;_0x2be198[_0xf5e7('0x50')](!![]);if(_0x1317f8[_0xf5e7('0x4d')][_0x135f1b]){delete _0x1317f8[_0xf5e7('0x4d')][_0x135f1b];}_0x5894c2['stop']();});_0x1317f8[_0xf5e7('0x4d')][_0x135f1b]['on'](_0xf5e7('0x51'),function(){if(_0x1317f8[_0xf5e7('0x4d')][_0x135f1b]){delete _0x1317f8[_0xf5e7('0x4d')][_0x135f1b];}});_0x3e90be=setTimeout(function(){logger[_0xf5e7('0x40')]('[%s][QUEUE]\x20APPLICATION\x20END',_0x135f1b);endRouting(_0x135f1b,_0x49d70f,_0x3ca53f,_0x1317f8);clearTimeout(_0x3e90be);_0x2be198['close'](!![]);_0x5894c2[_0xf5e7('0x52')]();},_0x326082);switch(_0x49d70f[_0xf5e7('0x53')]){case'rrmemory':strategy[_0xf5e7('0x54')](_0x2be198,_0x49d70f,_0x1317f8,_0x3ca53f);break;default:strategy[_0xf5e7('0x55')](_0x2be198,_0x49d70f,_0x1317f8,_0x3ca53f);}}else{logger[_0xf5e7('0x3e')](_0xf5e7('0x56'),_0x135f1b,_0x1dd4f3[_0xf5e7('0x36')]);_0x5894c2['stop']();}}}catch(_0x5810f3){logger[_0xf5e7('0x3e')]('[%s][QUEUE]\x20%s',_0x135f1b,_0x5810f3[_0xf5e7('0x57')]);_0x5894c2['stop']();}};};
\ No newline at end of file
git://repos.xcallymotion.com / motion2.git / blobdiff