// * treaties. The SOFTWARE PRODUCT is licensed, not sold. *
// * *
// *************************************************************************
-var _0xba44=['push','capitalize','InteractionId','format','%s:queue:%s','save','remove','pick','../../rpc/openchannelQueueReport','../../rpc/mailQueueReport','../../rpc/chatQueueReport','../../rpc/smsQueueReport','../../rpc/faxQueueReport','../../rpc/whatsappQueueReport','../../rpc/chatInteraction','../../rpc/faxInteraction','../../rpc/mailInteraction','../../rpc/openchannelInteraction','../../rpc/whatsappInteraction','name\x20is\x20a\x20string\x20and\x20it\x20is\x20required','number','timeout\x20is\x20a\x20number','waiting','body','YYYY-MM-DD\x20HH:mm:ss','contact','upperFirst','channel','interaction','MessageId','message','chat','AccountId','WebsiteId','info','[%s][START:QUEUE][NAME:%s]','name','QueueReport','create','[%s][STOP:QUEUE][NAME:%s]','update','then','catch','error','update\x20queue\x20report','timeout','[%s][END:QUEUE][NAME:%s]','toLowerCase','length','[%s][QUEUE]\x20%s','join','stop','Queues','atimeout','qtimeout','rules','end','close','complete','[%s][QUEUE]\x20APPLICATION\x20END','next','strategy','beepall','[%s][QUEUE]\x20queue\x20not\x20found\x20%s','stack','lodash','util','seq-queue','moment','ioredis','routing','./strategy','redis','localhost','socket.io-emitter','queue_id','account','queue','from','joinAt','emit','clone'];(function(_0x4017b0,_0x4347db){var _0x5ed4f7=function(_0x706c26){while(--_0x706c26){_0x4017b0['push'](_0x4017b0['shift']());}};_0x5ed4f7(++_0x4347db);}(_0xba44,0x189));var _0x4ba4=function(_0x32cbf2,_0x10ecc1){_0x32cbf2=_0x32cbf2-0x0;var _0x399962=_0xba44[_0x32cbf2];return _0x399962;};'use strict';var schema=require('validate');var _=require(_0x4ba4('0x0'));var util=require(_0x4ba4('0x1'));var seqqueue=require(_0x4ba4('0x2'));var moment=require(_0x4ba4('0x3'));var Redis=require(_0x4ba4('0x4'));var config=require('../../../../config/environment');var logger=require('../../../../config/logger')(_0x4ba4('0x5'));var strategy=require(_0x4ba4('0x6'));config[_0x4ba4('0x7')]=_['defaults'](config[_0x4ba4('0x7')],{'host':_0x4ba4('0x8'),'port':0x18eb});var io=require(_0x4ba4('0x9'))(new Redis(config[_0x4ba4('0x7')]));var attributes=['id',_0x4ba4('0xa'),_0x4ba4('0xb'),_0x4ba4('0xc'),_0x4ba4('0xd'),_0x4ba4('0xe')];function emit(_0x47a2ed,_0x3a7e65,_0x10e5e5){io['to'](_0x47a2ed)[_0x4ba4('0xf')](_0x3a7e65,_0x10e5e5);}function emitChannelQueueInteraction(_0x455abc,_0x4f7b45,_0x3c3618,_0x3cf37b,_0x100aa4,_0x40fd27,_0x264071,_0x4d325d){var _0x20e018=_[_0x4ba4('0x10')](_0x3c3618);_0x20e018['queue_id']=_0x4d325d;_0x20e018[_0x4ba4('0xc')]=_0x4f7b45;_0x20e018[_0x4ba4('0xb')]=_0x3cf37b;_0x20e018['id']=_0x100aa4;if(_0x40fd27){attributes[_0x4ba4('0x11')](_[_0x4ba4('0x12')](_0x455abc)+_0x4ba4('0x13'));_0x264071[util[_0x4ba4('0x14')]('%sQueuesWaitingInteractions',_0x455abc)][_0x100aa4]=_['pick'](_0x20e018,attributes);}else{delete _0x264071[util[_0x4ba4('0x14')]('%sQueuesWaitingInteractions',_0x455abc)][_0x100aa4];}emit(util['format'](_0x4ba4('0x15'),_0x455abc,_0x4f7b45),util[_0x4ba4('0x14')]('%s_queue_waiting_interaction:%s',_0x455abc,_0x40fd27?_0x4ba4('0x16'):_0x4ba4('0x17')),_[_0x4ba4('0x18')](_0x20e018,attributes));}var rpc={'openchannelQueueReport':require(_0x4ba4('0x19')),'mailQueueReport':require(_0x4ba4('0x1a')),'chatQueueReport':require(_0x4ba4('0x1b')),'smsQueueReport':require(_0x4ba4('0x1c')),'faxQueueReport':require(_0x4ba4('0x1d')),'whatsappQueueReport':require(_0x4ba4('0x1e')),'chatInteraction':require(_0x4ba4('0x1f')),'faxInteraction':require(_0x4ba4('0x20')),'mailInteraction':require(_0x4ba4('0x21')),'openchannelInteraction':require(_0x4ba4('0x22')),'smsInteraction':require('../../rpc/smsInteraction'),'whatsappInteraction':require(_0x4ba4('0x23'))};var queue=schema({'name':{'type':'string','required':!![],'message':_0x4ba4('0x24')},'timeout':{'type':_0x4ba4('0x25'),'message':_0x4ba4('0x26')}});function startRouting(_0x558c77,_0x8f9b1c,_0x5979cd,_0x28a89b){if(_0x558c77&&_0x8f9b1c&&_0x5979cd){_0x8f9b1c[_0x4ba4('0x27')]+=0x1;var _0x2e3e69={'uniqueid':_0x558c77,'from':_0x5979cd[_0x4ba4('0x28')]?_0x5979cd[_0x4ba4('0x28')][_0x4ba4('0xd')]:'','joinAt':moment()[_0x4ba4('0x14')](_0x4ba4('0x29')),'ContactId':_0x5979cd[_0x4ba4('0x2a')]?_0x5979cd[_0x4ba4('0x2a')]['id']:null,'ListId':_0x5979cd['list']?_0x5979cd['list']['id']:null};_0x2e3e69[_[_0x4ba4('0x2b')](_0x5979cd[_0x4ba4('0x2c')])+'QueueId']=_0x8f9b1c['id']||null;_0x2e3e69[_['upperFirst'](_0x5979cd[_0x4ba4('0x2c')])+'InteractionId']=_0x5979cd[_0x4ba4('0x2d')]?_0x5979cd[_0x4ba4('0x2d')]['id']:null;_0x2e3e69[_[_0x4ba4('0x2b')](_0x5979cd[_0x4ba4('0x2c')])+_0x4ba4('0x2e')]=_0x5979cd[_0x4ba4('0x2f')]?_0x5979cd['message']['id']:null;_0x2e3e69[_[_0x4ba4('0x2b')](_0x5979cd[_0x4ba4('0x2c')])+(_0x5979cd[_0x4ba4('0x2c')]!==_0x4ba4('0x30')?_0x4ba4('0x31'):_0x4ba4('0x32'))]=_0x5979cd[_0x4ba4('0xb')]?_0x5979cd[_0x4ba4('0xb')]['id']:null;logger[_0x4ba4('0x33')](util[_0x4ba4('0x14')](_0x4ba4('0x34'),_0x558c77,_0x8f9b1c[_0x4ba4('0x35')]));emitChannelQueueInteraction(_0x5979cd[_0x4ba4('0x2c')],_0x8f9b1c[_0x4ba4('0x35')],_0x2e3e69,_0x5979cd[_0x4ba4('0xb')]['name'],_0x5979cd[_0x4ba4('0x2f')]['id'],!![],_0x28a89b,_0x8f9b1c['id']);if(rpc[_0x5979cd[_0x4ba4('0x2c')]+'QueueReport']){return rpc[_0x5979cd[_0x4ba4('0x2c')]+_0x4ba4('0x36')][_0x4ba4('0x37')](_0x2e3e69)['catch'](function(_0x496718){logger['error']('create\x20queue\x20report',_0x496718);});}}}function stopRouting(_0x5550f5,_0x5e35a0,_0x852dd7,_0x3d79de){if(_0x5550f5&&_0x5e35a0){_0x5e35a0[_0x4ba4('0x27')]-=0x1;var _0x511dfa={'leaveAt':moment()[_0x4ba4('0x14')](_0x4ba4('0x29')),'acceptAt':moment()[_0x4ba4('0x14')](_0x4ba4('0x29')),'reason':'accepted'};logger[_0x4ba4('0x33')](util[_0x4ba4('0x14')](_0x4ba4('0x38'),_0x5550f5,_0x5e35a0[_0x4ba4('0x35')]));emitChannelQueueInteraction(_0x852dd7[_0x4ba4('0x2c')],_0x5e35a0['name'],_0x852dd7[_0x4ba4('0x28')],_0x852dd7[_0x4ba4('0xb')][_0x4ba4('0x35')],_0x852dd7[_0x4ba4('0x2f')]['id'],![],_0x3d79de,_0x5e35a0['id']);return rpc[_0x852dd7[_0x4ba4('0x2c')]+'Interaction'][_0x4ba4('0x39')](_0x852dd7[_0x4ba4('0x2d')]['id'],{'queueId':_0x5e35a0['id']})[_0x4ba4('0x3a')](function(){if(rpc[_0x852dd7[_0x4ba4('0x2c')]+_0x4ba4('0x36')]){return rpc[_0x852dd7[_0x4ba4('0x2c')]+_0x4ba4('0x36')][_0x4ba4('0x39')](_0x5550f5,_0x511dfa)[_0x4ba4('0x3b')](function(_0x24e1fc){logger[_0x4ba4('0x3c')](_0x4ba4('0x3d'),_0x24e1fc);});}});}}function endRouting(_0x5011fc,_0xafc5f2,_0x56923f,_0x216f35){if(_0x5011fc&&_0xafc5f2){_0xafc5f2[_0x4ba4('0x27')]-=0x1;var _0xe6009a={'leaveAt':moment()[_0x4ba4('0x14')]('YYYY-MM-DD\x20HH:mm:ss'),'exitAt':moment()[_0x4ba4('0x14')]('YYYY-MM-DD\x20HH:mm:ss'),'reason':_0x4ba4('0x3e')};logger[_0x4ba4('0x33')](util[_0x4ba4('0x14')](_0x4ba4('0x3f'),_0x5011fc,_0xafc5f2[_0x4ba4('0x35')]));emitChannelQueueInteraction(_0x56923f['channel'],_0xafc5f2['name'],_0x56923f[_0x4ba4('0x28')],_0x56923f[_0x4ba4('0xb')]['name'],_0x56923f[_0x4ba4('0x2f')]['id'],![],_0x216f35);if(rpc[_0x56923f[_0x4ba4('0x2c')]+_0x4ba4('0x36')]){return rpc[_0x56923f[_0x4ba4('0x2c')]+_0x4ba4('0x36')][_0x4ba4('0x39')](_0x5011fc,_0xe6009a)[_0x4ba4('0x3b')](function(_0x3a3aaa){logger[_0x4ba4('0x3c')]('update\x20queue\x20report',_0x3a3aaa);});}}}function handleFindQueue(_0x180b6a){return function(_0x1c3b90){return _0x1c3b90[_0x4ba4('0x35')][_0x4ba4('0x40')]()===_0x180b6a[_0x4ba4('0x40')]();};}exports['consequence']=function(_0x3251cf,_0x2ea0e2,_0x346d00,_0x576d96){return function(_0x567f29){try{var _0x493f64={'name':_0x2ea0e2[0x0],'timeout':_0x2ea0e2[0x1]};var _0x160c72=queue['validate'](_0x493f64,{'typecast':!![]});if(_0x160c72[_0x4ba4('0x41')]){logger['error'](_0x4ba4('0x42'),_0x3251cf,_['map'](_0x160c72,_0x4ba4('0x2f'))[_0x4ba4('0x43')](',\x20'));_0x567f29[_0x4ba4('0x44')]();}else{var _0x43e6e5=_['find'](_0x346d00[_0x576d96['channel']+_0x4ba4('0x45')],handleFindQueue(_0x493f64[_0x4ba4('0x35')]));if(_0x43e6e5){startRouting(_0x3251cf,_0x43e6e5,_0x576d96,_0x346d00);var _0x1a2bd3=(_0x43e6e5[_0x4ba4('0x3e')]||0xa)*0x3e8;var _0x1002f4=(_0x493f64['timeout']||0x14)*0x3e8;var _0x241086;if(_0x1a2bd3>_0x1002f4){_0x1002f4=_0x1a2bd3;}var _0x34d6e1=seqqueue['createQueue'](_0x1a2bd3);_0x34d6e1['id']=_0x3251cf;_0x34d6e1[_0x4ba4('0x46')]=_0x1a2bd3;_0x34d6e1[_0x4ba4('0x47')]=_0x1002f4;_0x34d6e1[_0x4ba4('0x2c')]=_0x576d96['channel'];_0x346d00[_0x4ba4('0x48')][_0x3251cf]['on'](_0x4ba4('0x49'),function(){logger[_0x4ba4('0x33')]('[%s][QUEUE]\x20ROUTING\x20STOPPED',_0x3251cf);stopRouting(_0x3251cf,_0x43e6e5,_0x576d96,_0x346d00);clearTimeout(_0x241086);_0x241086=undefined;_0x34d6e1[_0x4ba4('0x4a')](!![]);if(_0x346d00[_0x4ba4('0x48')][_0x3251cf]){delete _0x346d00[_0x4ba4('0x48')][_0x3251cf];}_0x567f29['stop']();});_0x346d00['rules'][_0x3251cf]['on'](_0x4ba4('0x4b'),function(){if(_0x346d00[_0x4ba4('0x48')][_0x3251cf]){delete _0x346d00['rules'][_0x3251cf];}});_0x241086=setTimeout(function(){logger[_0x4ba4('0x33')](_0x4ba4('0x4c'),_0x3251cf);endRouting(_0x3251cf,_0x43e6e5,_0x576d96,_0x346d00);clearTimeout(_0x241086);_0x34d6e1[_0x4ba4('0x4a')](!![]);_0x567f29[_0x4ba4('0x4d')]();},_0x1002f4);switch(_0x43e6e5[_0x4ba4('0x4e')]){case'rrmemory':strategy['rrmemory'](_0x34d6e1,_0x43e6e5,_0x346d00,_0x576d96);break;default:strategy[_0x4ba4('0x4f')](_0x34d6e1,_0x43e6e5,_0x346d00,_0x576d96);}}else{logger[_0x4ba4('0x3c')](_0x4ba4('0x50'),_0x3251cf,_0x493f64['name']);_0x567f29[_0x4ba4('0x44')]();}}}catch(_0x57fbc2){logger['error'](_0x4ba4('0x42'),_0x3251cf,_0x57fbc2[_0x4ba4('0x51')]);_0x567f29[_0x4ba4('0x44')]();}};};
\ No newline at end of file
+var _0xcf2f=['from','joinAt','clone','InteractionId','format','%sQueuesWaitingInteractions','%s_queue_waiting_interaction:%s','save','remove','../../rpc/openchannelQueueReport','../../rpc/smsQueueReport','../../rpc/faxQueueReport','../../rpc/whatsappQueueReport','../../rpc/chatInteraction','../../rpc/faxInteraction','../../rpc/mailInteraction','../../rpc/openchannelInteraction','../../rpc/whatsappInteraction','string','timeout\x20is\x20a\x20number','body','contact','list','upperFirst','channel','QueueId','interaction','MessageId','message','chat','info','name','QueueReport','create','catch','error','waiting','YYYY-MM-DD\x20HH:mm:ss','accepted','[%s][STOP:QUEUE][NAME:%s]','Interaction','update','then','update\x20queue\x20report','timeout','toLowerCase','[%s][QUEUE]\x20%s','map','join','stop','find','Queues','createQueue','atimeout','qtimeout','rules','end','[%s][QUEUE]\x20ROUTING\x20STOPPED','complete','strategy','rrmemory','beepall','[%s][QUEUE]\x20queue\x20not\x20found\x20%s','stack','lodash','util','seq-queue','moment','../../../../config/environment','../../../../config/logger','./strategy','redis','defaults','localhost','socket.io-emitter','queue_id','account','queue'];(function(_0x311c35,_0x534915){var _0x5cc50c=function(_0x3ad680){while(--_0x3ad680){_0x311c35['push'](_0x311c35['shift']());}};_0x5cc50c(++_0x534915);}(_0xcf2f,0x1c6));var _0xfcf2=function(_0x280fe2,_0xb4bbfa){_0x280fe2=_0x280fe2-0x0;var _0x28aed7=_0xcf2f[_0x280fe2];return _0x28aed7;};'use strict';var schema=require('validate');var _=require(_0xfcf2('0x0'));var util=require(_0xfcf2('0x1'));var seqqueue=require(_0xfcf2('0x2'));var moment=require(_0xfcf2('0x3'));var Redis=require('ioredis');var config=require(_0xfcf2('0x4'));var logger=require(_0xfcf2('0x5'))('routing');var strategy=require(_0xfcf2('0x6'));config[_0xfcf2('0x7')]=_[_0xfcf2('0x8')](config[_0xfcf2('0x7')],{'host':_0xfcf2('0x9'),'port':0x18eb});var io=require(_0xfcf2('0xa'))(new Redis(config['redis']));var attributes=['id',_0xfcf2('0xb'),_0xfcf2('0xc'),_0xfcf2('0xd'),_0xfcf2('0xe'),_0xfcf2('0xf')];function emit(_0x12deb9,_0x435c77,_0x12ed5a){io['to'](_0x12deb9)['emit'](_0x435c77,_0x12ed5a);}function emitChannelQueueInteraction(_0x56cdd4,_0x2ab73d,_0x8bdb88,_0x65614,_0x40679b,_0x5c7de0,_0x235a90,_0x4dbb50){var _0x457862=_[_0xfcf2('0x10')](_0x8bdb88);_0x457862[_0xfcf2('0xb')]=_0x4dbb50;_0x457862[_0xfcf2('0xd')]=_0x2ab73d;_0x457862[_0xfcf2('0xc')]=_0x65614;_0x457862['id']=_0x40679b;if(_0x5c7de0){attributes['push'](_['capitalize'](_0x56cdd4)+_0xfcf2('0x11'));_0x235a90[util[_0xfcf2('0x12')](_0xfcf2('0x13'),_0x56cdd4)][_0x40679b]=_['pick'](_0x457862,attributes);}else{delete _0x235a90[util[_0xfcf2('0x12')](_0xfcf2('0x13'),_0x56cdd4)][_0x40679b];}emit(util[_0xfcf2('0x12')]('%s:queue:%s',_0x56cdd4,_0x2ab73d),util['format'](_0xfcf2('0x14'),_0x56cdd4,_0x5c7de0?_0xfcf2('0x15'):_0xfcf2('0x16')),_['pick'](_0x457862,attributes));}var rpc={'openchannelQueueReport':require(_0xfcf2('0x17')),'mailQueueReport':require('../../rpc/mailQueueReport'),'chatQueueReport':require('../../rpc/chatQueueReport'),'smsQueueReport':require(_0xfcf2('0x18')),'faxQueueReport':require(_0xfcf2('0x19')),'whatsappQueueReport':require(_0xfcf2('0x1a')),'chatInteraction':require(_0xfcf2('0x1b')),'faxInteraction':require(_0xfcf2('0x1c')),'mailInteraction':require(_0xfcf2('0x1d')),'openchannelInteraction':require(_0xfcf2('0x1e')),'smsInteraction':require('../../rpc/smsInteraction'),'whatsappInteraction':require(_0xfcf2('0x1f'))};var queue=schema({'name':{'type':_0xfcf2('0x20'),'required':!![],'message':'name\x20is\x20a\x20string\x20and\x20it\x20is\x20required'},'timeout':{'type':'number','message':_0xfcf2('0x21')}});function startRouting(_0x2a750b,_0x289565,_0x14a9fd,_0x9850a){if(_0x2a750b&&_0x289565&&_0x14a9fd){_0x289565['waiting']+=0x1;var _0x3c8b92={'uniqueid':_0x2a750b,'from':_0x14a9fd[_0xfcf2('0x22')]?_0x14a9fd[_0xfcf2('0x22')][_0xfcf2('0xe')]:'','joinAt':moment()[_0xfcf2('0x12')]('YYYY-MM-DD\x20HH:mm:ss'),'ContactId':_0x14a9fd['contact']?_0x14a9fd[_0xfcf2('0x23')]['id']:null,'ListId':_0x14a9fd['list']?_0x14a9fd[_0xfcf2('0x24')]['id']:null};_0x3c8b92[_[_0xfcf2('0x25')](_0x14a9fd[_0xfcf2('0x26')])+_0xfcf2('0x27')]=_0x289565['id']||null;_0x3c8b92[_[_0xfcf2('0x25')](_0x14a9fd['channel'])+'InteractionId']=_0x14a9fd[_0xfcf2('0x28')]?_0x14a9fd[_0xfcf2('0x28')]['id']:null;_0x3c8b92[_[_0xfcf2('0x25')](_0x14a9fd[_0xfcf2('0x26')])+_0xfcf2('0x29')]=_0x14a9fd[_0xfcf2('0x2a')]?_0x14a9fd[_0xfcf2('0x2a')]['id']:null;_0x3c8b92[_['upperFirst'](_0x14a9fd[_0xfcf2('0x26')])+(_0x14a9fd[_0xfcf2('0x26')]!==_0xfcf2('0x2b')?'AccountId':'WebsiteId')]=_0x14a9fd[_0xfcf2('0xc')]?_0x14a9fd['account']['id']:null;logger[_0xfcf2('0x2c')](util['format']('[%s][START:QUEUE][NAME:%s]',_0x2a750b,_0x289565[_0xfcf2('0x2d')]));emitChannelQueueInteraction(_0x14a9fd[_0xfcf2('0x26')],_0x289565['name'],_0x3c8b92,_0x14a9fd[_0xfcf2('0xc')][_0xfcf2('0x2d')],_0x14a9fd[_0xfcf2('0x2a')]['id'],!![],_0x9850a,_0x289565['id']);if(rpc[_0x14a9fd[_0xfcf2('0x26')]+_0xfcf2('0x2e')]){return rpc[_0x14a9fd[_0xfcf2('0x26')]+_0xfcf2('0x2e')][_0xfcf2('0x2f')](_0x3c8b92)[_0xfcf2('0x30')](function(_0x448e0a){logger[_0xfcf2('0x31')]('create\x20queue\x20report',_0x448e0a);});}}}function stopRouting(_0x1b514a,_0x5108c9,_0x5e24dd,_0x2adda2){if(_0x1b514a&&_0x5108c9){_0x5108c9[_0xfcf2('0x32')]-=0x1;var _0x4af080={'leaveAt':moment()['format']('YYYY-MM-DD\x20HH:mm:ss'),'acceptAt':moment()['format'](_0xfcf2('0x33')),'reason':_0xfcf2('0x34')};logger[_0xfcf2('0x2c')](util['format'](_0xfcf2('0x35'),_0x1b514a,_0x5108c9[_0xfcf2('0x2d')]));emitChannelQueueInteraction(_0x5e24dd['channel'],_0x5108c9[_0xfcf2('0x2d')],_0x5e24dd[_0xfcf2('0x22')],_0x5e24dd[_0xfcf2('0xc')][_0xfcf2('0x2d')],_0x5e24dd[_0xfcf2('0x2a')]['id'],![],_0x2adda2,_0x5108c9['id']);return rpc[_0x5e24dd[_0xfcf2('0x26')]+_0xfcf2('0x36')][_0xfcf2('0x37')](_0x5e24dd[_0xfcf2('0x28')]['id'],{'queueId':_0x5108c9['id']})[_0xfcf2('0x38')](function(){if(rpc[_0x5e24dd[_0xfcf2('0x26')]+_0xfcf2('0x2e')]){return rpc[_0x5e24dd[_0xfcf2('0x26')]+_0xfcf2('0x2e')][_0xfcf2('0x37')](_0x1b514a,_0x4af080)[_0xfcf2('0x30')](function(_0xaf04ca){logger[_0xfcf2('0x31')](_0xfcf2('0x39'),_0xaf04ca);});}});}}function endRouting(_0x285a66,_0x1f7c42,_0x47dbf4,_0x503260){if(_0x285a66&&_0x1f7c42){_0x1f7c42[_0xfcf2('0x32')]-=0x1;var _0x52cbe2={'leaveAt':moment()[_0xfcf2('0x12')](_0xfcf2('0x33')),'exitAt':moment()[_0xfcf2('0x12')]('YYYY-MM-DD\x20HH:mm:ss'),'reason':_0xfcf2('0x3a')};logger['info'](util[_0xfcf2('0x12')]('[%s][END:QUEUE][NAME:%s]',_0x285a66,_0x1f7c42[_0xfcf2('0x2d')]));emitChannelQueueInteraction(_0x47dbf4[_0xfcf2('0x26')],_0x1f7c42[_0xfcf2('0x2d')],_0x47dbf4[_0xfcf2('0x22')],_0x47dbf4[_0xfcf2('0xc')]['name'],_0x47dbf4[_0xfcf2('0x2a')]['id'],![],_0x503260);if(rpc[_0x47dbf4[_0xfcf2('0x26')]+_0xfcf2('0x2e')]){return rpc[_0x47dbf4['channel']+_0xfcf2('0x2e')][_0xfcf2('0x37')](_0x285a66,_0x52cbe2)[_0xfcf2('0x30')](function(_0x4b550a){logger['error'](_0xfcf2('0x39'),_0x4b550a);});}}}function handleFindQueue(_0x4e873a){return function(_0xdb4ea1){return _0xdb4ea1[_0xfcf2('0x2d')][_0xfcf2('0x3b')]()===_0x4e873a[_0xfcf2('0x3b')]();};}exports['consequence']=function(_0x7f8371,_0x548323,_0x17a5e1,_0x2e0880){return function(_0x159eaf){try{var _0x39e257={'name':_0x548323[0x0],'timeout':_0x548323[0x1]};var _0x180ddf=queue['validate'](_0x39e257,{'typecast':!![]});if(_0x180ddf['length']){logger['error'](_0xfcf2('0x3c'),_0x7f8371,_[_0xfcf2('0x3d')](_0x180ddf,'message')[_0xfcf2('0x3e')](',\x20'));_0x159eaf[_0xfcf2('0x3f')]();}else{var _0x199b40=_[_0xfcf2('0x40')](_0x17a5e1[_0x2e0880[_0xfcf2('0x26')]+_0xfcf2('0x41')],handleFindQueue(_0x39e257['name']));if(_0x199b40){startRouting(_0x7f8371,_0x199b40,_0x2e0880,_0x17a5e1);var _0x25be04=(_0x199b40[_0xfcf2('0x3a')]||0xa)*0x3e8;var _0x1aca50=(_0x39e257[_0xfcf2('0x3a')]||0x14)*0x3e8;var _0x33dfc3;if(_0x25be04>_0x1aca50){_0x1aca50=_0x25be04;}var _0x136f4b=seqqueue[_0xfcf2('0x42')](_0x25be04);_0x136f4b['id']=_0x7f8371;_0x136f4b[_0xfcf2('0x43')]=_0x25be04;_0x136f4b[_0xfcf2('0x44')]=_0x1aca50;_0x136f4b[_0xfcf2('0x26')]=_0x2e0880['channel'];_0x17a5e1[_0xfcf2('0x45')][_0x7f8371]['on'](_0xfcf2('0x46'),function(){logger['info'](_0xfcf2('0x47'),_0x7f8371);stopRouting(_0x7f8371,_0x199b40,_0x2e0880,_0x17a5e1);clearTimeout(_0x33dfc3);_0x33dfc3=undefined;_0x136f4b['close'](!![]);if(_0x17a5e1['rules'][_0x7f8371]){delete _0x17a5e1['rules'][_0x7f8371];}_0x159eaf[_0xfcf2('0x3f')]();});_0x17a5e1[_0xfcf2('0x45')][_0x7f8371]['on'](_0xfcf2('0x48'),function(){if(_0x17a5e1[_0xfcf2('0x45')][_0x7f8371]){delete _0x17a5e1['rules'][_0x7f8371];}});_0x33dfc3=setTimeout(function(){logger['info']('[%s][QUEUE]\x20APPLICATION\x20END',_0x7f8371);endRouting(_0x7f8371,_0x199b40,_0x2e0880,_0x17a5e1);clearTimeout(_0x33dfc3);_0x136f4b['close'](!![]);_0x159eaf['next']();},_0x1aca50);switch(_0x199b40[_0xfcf2('0x49')]){case _0xfcf2('0x4a'):strategy['rrmemory'](_0x136f4b,_0x199b40,_0x17a5e1,_0x2e0880);break;default:strategy[_0xfcf2('0x4b')](_0x136f4b,_0x199b40,_0x17a5e1,_0x2e0880);}}else{logger[_0xfcf2('0x31')](_0xfcf2('0x4c'),_0x7f8371,_0x39e257['name']);_0x159eaf[_0xfcf2('0x3f')]();}}}catch(_0x899592){logger[_0xfcf2('0x31')](_0xfcf2('0x3c'),_0x7f8371,_0x899592[_0xfcf2('0x4d')]);_0x159eaf['stop']();}};};
\ No newline at end of file
git://repos.xcallymotion.com / motion2.git / blobdiff