// * treaties. The SOFTWARE PRODUCT is licensed, not sold. *
// * *
// *************************************************************************
-var _0xb96d=['name\x20is\x20a\x20string\x20and\x20it\x20is\x20required','number','timeout\x20is\x20a\x20number','info','format','name','toLowerCase','consequence','map','message','join','find','timeout','createQueue','atimeout','channel','rules','end','[%s][AGENT]\x20ROUTING\x20STOPPED','complete','next','[%s][AGENT]\x20agent\x20not\x20found\x20%s','stop','error','[%s][QUEUE]\x20%s','validate','lodash','util','seq-queue','../../../../config/logger','routing','./strategy','string'];(function(_0x4cbf78,_0x206106){var _0x2ae4f8=function(_0x1dc531){while(--_0x1dc531){_0x4cbf78['push'](_0x4cbf78['shift']());}};_0x2ae4f8(++_0x206106);}(_0xb96d,0xbe));var _0xdb96=function(_0x52f1e6,_0xf70489){_0x52f1e6=_0x52f1e6-0x0;var _0x21f104=_0xb96d[_0x52f1e6];return _0x21f104;};'use strict';var schema=require(_0xdb96('0x0'));var _=require(_0xdb96('0x1'));var util=require(_0xdb96('0x2'));var seqqueue=require(_0xdb96('0x3'));var logger=require(_0xdb96('0x4'))(_0xdb96('0x5'));var strategy=require(_0xdb96('0x6'));var queue=schema({'name':{'type':_0xdb96('0x7'),'required':!![],'message':_0xdb96('0x8')},'timeout':{'type':_0xdb96('0x9'),'message':_0xdb96('0xa')}});function writeLog(_0x57ab4e,_0x34fa92,_0x4ad0c3){return logger[_0xdb96('0xb')](util[_0xdb96('0xc')]('[%s][AGENT][NAME:%s][STATUS:%s]',_0x57ab4e,_0x34fa92['name'],_0x4ad0c3));}function handleFindAgent(_0x5b1c10){return function(_0x41fe31){return _0x41fe31[_0xdb96('0xd')][_0xdb96('0xe')]()===_0x5b1c10[_0xdb96('0xe')]();};}exports[_0xdb96('0xf')]=function(_0x3db835,_0x38f288,_0x19bc3d,_0x2a0d12){return function(_0x4d6b7c){try{var _0x168e69={'name':_0x38f288[0x0],'timeout':_0x38f288[0x1]};var _0xf2a2f0=queue[_0xdb96('0x0')](_0x168e69,{'typecast':!![]});if(_0xf2a2f0['length']){logger['error']('[%s][AGENT]\x20%s',_0x3db835,_[_0xdb96('0x10')](_0xf2a2f0,_0xdb96('0x11'))[_0xdb96('0x12')](',\x20'));_0x4d6b7c['stop']();}else{var _0x3ec420=_[_0xdb96('0x13')](_0x19bc3d['agents'],handleFindAgent(_0x168e69[_0xdb96('0xd')]));if(_0x3ec420){var _0x48211d=(_0x168e69[_0xdb96('0x14')]||0xa)*0x3e8;var _0x559d6e,_0x2e8694;var _0x4df8b0=seqqueue[_0xdb96('0x15')](_0x48211d);_0x4df8b0['id']=_0x3db835;_0x4df8b0[_0xdb96('0x16')]=_0x48211d;_0x4df8b0['channel']=_0x2a0d12[_0xdb96('0x17')];writeLog(_0x3db835,_0x3ec420,util['format']('START:%s',_0x48211d));_0x19bc3d[_0xdb96('0x18')][_0x3db835]['on'](_0xdb96('0x19'),function(){logger[_0xdb96('0xb')](_0xdb96('0x1a'),_0x3db835);clearTimeout(_0x2e8694);_0x2e8694=undefined;_0x4df8b0['close']();if(_0x19bc3d[_0xdb96('0x18')][_0x3db835]){delete _0x19bc3d['rules'][_0x3db835];}_0x4d6b7c['stop']();});_0x19bc3d[_0xdb96('0x18')][_0x3db835]['on'](_0xdb96('0x1b'),function(){if(_0x19bc3d[_0xdb96('0x18')][_0x3db835]){delete _0x19bc3d['rules'][_0x3db835];}});_0x2e8694=setTimeout(function(){logger[_0xdb96('0xb')]('[%s][AGENT]\x20ROUTING\x20END',_0x3db835);clearTimeout(_0x2e8694);_0x4df8b0['close']();_0x4d6b7c[_0xdb96('0x1c')]();},_0x48211d);strategy['agent'](_0x4df8b0,_0x3ec420,_0x19bc3d,_0x2a0d12);}else{logger['error'](_0xdb96('0x1d'),_0x3db835,_0x168e69[_0xdb96('0xd')]);_0x4d6b7c[_0xdb96('0x1e')]();}}}catch(_0x11433a){console['log'](_0x11433a);logger[_0xdb96('0x1f')](_0xdb96('0x20'),_0x3db835,_0x11433a['stack']);_0x4d6b7c['stop']();}};};
\ No newline at end of file
+var _0x1e44=['stack','lodash','../../../../config/logger','string','name\x20is\x20a\x20string\x20and\x20it\x20is\x20required','number','info','format','name','toLowerCase','consequence','validate','error','map','join','stop','timeout','createQueue','atimeout','channel','end','[%s][AGENT]\x20ROUTING\x20STOPPED','close','rules','complete','[%s][AGENT]\x20ROUTING\x20END','next','agent','[%s][AGENT]\x20agent\x20not\x20found\x20%s'];(function(_0x592d24,_0x51c3a0){var _0x1be055=function(_0x284b70){while(--_0x284b70){_0x592d24['push'](_0x592d24['shift']());}};_0x1be055(++_0x51c3a0);}(_0x1e44,0xe9));var _0x41e4=function(_0x3dd15e,_0x1f0015){_0x3dd15e=_0x3dd15e-0x0;var _0x231fd0=_0x1e44[_0x3dd15e];return _0x231fd0;};'use strict';var schema=require('validate');var _=require(_0x41e4('0x0'));var util=require('util');var seqqueue=require('seq-queue');var logger=require(_0x41e4('0x1'))('routing');var strategy=require('./strategy');var queue=schema({'name':{'type':_0x41e4('0x2'),'required':!![],'message':_0x41e4('0x3')},'timeout':{'type':_0x41e4('0x4'),'message':'timeout\x20is\x20a\x20number'}});function writeLog(_0x48ba6d,_0x8d1d1d,_0x30adc2){return logger[_0x41e4('0x5')](util[_0x41e4('0x6')]('[%s][AGENT][NAME:%s][STATUS:%s]',_0x48ba6d,_0x8d1d1d[_0x41e4('0x7')],_0x30adc2));}function handleFindAgent(_0x1f9960){return function(_0xb29e5d){return _0xb29e5d[_0x41e4('0x7')][_0x41e4('0x8')]()===_0x1f9960[_0x41e4('0x8')]();};}exports[_0x41e4('0x9')]=function(_0x3cf345,_0x1f70c1,_0x3bcd10,_0x52cf8c){return function(_0x1fadd6){try{var _0x1bdd87={'name':_0x1f70c1[0x0],'timeout':_0x1f70c1[0x1]};var _0x25bd71=queue[_0x41e4('0xa')](_0x1bdd87,{'typecast':!![]});if(_0x25bd71['length']){logger[_0x41e4('0xb')]('[%s][AGENT]\x20%s',_0x3cf345,_[_0x41e4('0xc')](_0x25bd71,'message')[_0x41e4('0xd')](',\x20'));_0x1fadd6[_0x41e4('0xe')]();}else{var _0x21eed1=_['find'](_0x3bcd10['agents'],handleFindAgent(_0x1bdd87[_0x41e4('0x7')]));if(_0x21eed1){var _0x184c37=(_0x1bdd87[_0x41e4('0xf')]||0xa)*0x3e8;var _0x36f624,_0xda9a47;var _0x182c1c=seqqueue[_0x41e4('0x10')](_0x184c37);_0x182c1c['id']=_0x3cf345;_0x182c1c[_0x41e4('0x11')]=_0x184c37;_0x182c1c[_0x41e4('0x12')]=_0x52cf8c[_0x41e4('0x12')];writeLog(_0x3cf345,_0x21eed1,util[_0x41e4('0x6')]('START:%s',_0x184c37));_0x3bcd10['rules'][_0x3cf345]['on'](_0x41e4('0x13'),function(){logger[_0x41e4('0x5')](_0x41e4('0x14'),_0x3cf345);clearTimeout(_0xda9a47);_0xda9a47=undefined;_0x182c1c[_0x41e4('0x15')]();if(_0x3bcd10[_0x41e4('0x16')][_0x3cf345]){delete _0x3bcd10['rules'][_0x3cf345];}_0x1fadd6[_0x41e4('0xe')]();});_0x3bcd10[_0x41e4('0x16')][_0x3cf345]['on'](_0x41e4('0x17'),function(){if(_0x3bcd10[_0x41e4('0x16')][_0x3cf345]){delete _0x3bcd10[_0x41e4('0x16')][_0x3cf345];}});_0xda9a47=setTimeout(function(){logger[_0x41e4('0x5')](_0x41e4('0x18'),_0x3cf345);clearTimeout(_0xda9a47);_0x182c1c[_0x41e4('0x15')]();_0x1fadd6[_0x41e4('0x19')]();},_0x184c37);strategy[_0x41e4('0x1a')](_0x182c1c,_0x21eed1,_0x3bcd10,_0x52cf8c);}else{logger[_0x41e4('0xb')](_0x41e4('0x1b'),_0x3cf345,_0x1bdd87[_0x41e4('0x7')]);_0x1fadd6[_0x41e4('0xe')]();}}}catch(_0x4ca94a){console['log'](_0x4ca94a);logger[_0x41e4('0xb')]('[%s][QUEUE]\x20%s',_0x3cf345,_0x4ca94a[_0x41e4('0x1c')]);_0x1fadd6['stop']();}};};
\ No newline at end of file
git://repos.xcallymotion.com / motion2.git / blobdiff