// * treaties. The SOFTWARE PRODUCT is licensed, not sold. *
// * *
// *************************************************************************
-var _0x0795=['validate','length','error','[%s][AGENT]\x20%s','map','message','stop','agents','timeout','createQueue','atimeout','channel','rules','end','info','[%s][AGENT]\x20ROUTING\x20STOPPED','complete','[%s][AGENT]\x20ROUTING\x20END','next','agent','[%s][AGENT]\x20agent\x20not\x20found\x20%s','stack','routing','string','name\x20is\x20a\x20string\x20and\x20it\x20is\x20required','number','timeout\x20is\x20a\x20number','format','[%s][AGENT][NAME:%s][STATUS:%s]','name','toLowerCase','consequence'];(function(_0x1f47b2,_0x32ea9c){var _0xf37729=function(_0x15ed33){while(--_0x15ed33){_0x1f47b2['push'](_0x1f47b2['shift']());}};_0xf37729(++_0x32ea9c);}(_0x0795,0x1b6));var _0x5079=function(_0x36d065,_0x4d7819){_0x36d065=_0x36d065-0x0;var _0x251782=_0x0795[_0x36d065];return _0x251782;};'use strict';var schema=require('validate');var _=require('lodash');var util=require('util');var seqqueue=require('seq-queue');var logger=require('../../../../config/logger')(_0x5079('0x0'));var strategy=require('./strategy');var queue=schema({'name':{'type':_0x5079('0x1'),'required':!![],'message':_0x5079('0x2')},'timeout':{'type':_0x5079('0x3'),'message':_0x5079('0x4')}});function writeLog(_0x341407,_0x2e60b6,_0xd1a8f6){return logger['info'](util[_0x5079('0x5')](_0x5079('0x6'),_0x341407,_0x2e60b6[_0x5079('0x7')],_0xd1a8f6));}function handleFindAgent(_0x4bdddb){return function(_0x2fe39f){return _0x2fe39f[_0x5079('0x7')][_0x5079('0x8')]()===_0x4bdddb[_0x5079('0x8')]();};}exports[_0x5079('0x9')]=function(_0x4a1cea,_0xe048,_0x1f3a1b,_0x42ff98){return function(_0x4c343e){try{var _0x41ad02={'name':_0xe048[0x0],'timeout':_0xe048[0x1]};var _0xc0bbf6=queue[_0x5079('0xa')](_0x41ad02,{'typecast':!![]});if(_0xc0bbf6[_0x5079('0xb')]){logger[_0x5079('0xc')](_0x5079('0xd'),_0x4a1cea,_[_0x5079('0xe')](_0xc0bbf6,_0x5079('0xf'))['join'](',\x20'));_0x4c343e[_0x5079('0x10')]();}else{var _0x33d486=_['find'](_0x1f3a1b[_0x5079('0x11')],handleFindAgent(_0x41ad02['name']));if(_0x33d486){var _0x2663aa=(_0x41ad02[_0x5079('0x12')]||0xa)*0x3e8;var _0x476f0a,_0x170a94;var _0x4241ce=seqqueue[_0x5079('0x13')](_0x2663aa);_0x4241ce['id']=_0x4a1cea;_0x4241ce[_0x5079('0x14')]=_0x2663aa;_0x4241ce[_0x5079('0x15')]=_0x42ff98[_0x5079('0x15')];writeLog(_0x4a1cea,_0x33d486,util[_0x5079('0x5')]('START:%s',_0x2663aa));_0x1f3a1b[_0x5079('0x16')][_0x4a1cea]['on'](_0x5079('0x17'),function(){logger[_0x5079('0x18')](_0x5079('0x19'),_0x4a1cea);clearTimeout(_0x170a94);_0x170a94=undefined;_0x4241ce['close']();if(_0x1f3a1b[_0x5079('0x16')][_0x4a1cea]){delete _0x1f3a1b[_0x5079('0x16')][_0x4a1cea];}_0x4c343e['stop']();});_0x1f3a1b[_0x5079('0x16')][_0x4a1cea]['on'](_0x5079('0x1a'),function(){if(_0x1f3a1b[_0x5079('0x16')][_0x4a1cea]){delete _0x1f3a1b[_0x5079('0x16')][_0x4a1cea];}});_0x170a94=setTimeout(function(){logger[_0x5079('0x18')](_0x5079('0x1b'),_0x4a1cea);clearTimeout(_0x170a94);_0x4241ce['close']();_0x4c343e[_0x5079('0x1c')]();},_0x2663aa);strategy[_0x5079('0x1d')](_0x4241ce,_0x33d486,_0x1f3a1b,_0x42ff98);}else{logger['error'](_0x5079('0x1e'),_0x4a1cea,_0x41ad02[_0x5079('0x7')]);_0x4c343e[_0x5079('0x10')]();}}}catch(_0x4c2f0c){console['log'](_0x4c2f0c);logger[_0x5079('0xc')]('[%s][QUEUE]\x20%s',_0x4a1cea,_0x4c2f0c[_0x5079('0x1f')]);_0x4c343e['stop']();}};};
\ No newline at end of file
+var _0x6536=['[%s][QUEUE]\x20%s','util','../../../../config/logger','string','name\x20is\x20a\x20string\x20and\x20it\x20is\x20required','number','timeout\x20is\x20a\x20number','info','[%s][AGENT][NAME:%s][STATUS:%s]','name','toLowerCase','consequence','validate','error','map','message','join','stop','find','agents','createQueue','atimeout','channel','format','START:%s','rules','end','close','complete','[%s][AGENT]\x20ROUTING\x20END','agent','[%s][AGENT]\x20agent\x20not\x20found\x20%s','log'];(function(_0x17ef0d,_0x338019){var _0x41edb4=function(_0x47fa4f){while(--_0x47fa4f){_0x17ef0d['push'](_0x17ef0d['shift']());}};_0x41edb4(++_0x338019);}(_0x6536,0x1cf));var _0x6653=function(_0xf6b870,_0x53f617){_0xf6b870=_0xf6b870-0x0;var _0x3905d2=_0x6536[_0xf6b870];return _0x3905d2;};'use strict';var schema=require('validate');var _=require('lodash');var util=require(_0x6653('0x0'));var seqqueue=require('seq-queue');var logger=require(_0x6653('0x1'))('routing');var strategy=require('./strategy');var queue=schema({'name':{'type':_0x6653('0x2'),'required':!![],'message':_0x6653('0x3')},'timeout':{'type':_0x6653('0x4'),'message':_0x6653('0x5')}});function writeLog(_0x14f8b9,_0x3f57c9,_0x44d8ff){return logger[_0x6653('0x6')](util['format'](_0x6653('0x7'),_0x14f8b9,_0x3f57c9[_0x6653('0x8')],_0x44d8ff));}function handleFindAgent(_0x4eda51){return function(_0x1b92d2){return _0x1b92d2[_0x6653('0x8')][_0x6653('0x9')]()===_0x4eda51['toLowerCase']();};}exports[_0x6653('0xa')]=function(_0x2179f3,_0x4f8aa9,_0x1027cc,_0x3d17bc){return function(_0x3a47a0){try{var _0x55b1c0={'name':_0x4f8aa9[0x0],'timeout':_0x4f8aa9[0x1]};var _0x47c620=queue[_0x6653('0xb')](_0x55b1c0,{'typecast':!![]});if(_0x47c620['length']){logger[_0x6653('0xc')]('[%s][AGENT]\x20%s',_0x2179f3,_[_0x6653('0xd')](_0x47c620,_0x6653('0xe'))[_0x6653('0xf')](',\x20'));_0x3a47a0[_0x6653('0x10')]();}else{var _0x24dfb0=_[_0x6653('0x11')](_0x1027cc[_0x6653('0x12')],handleFindAgent(_0x55b1c0[_0x6653('0x8')]));if(_0x24dfb0){var _0x10c65f=(_0x55b1c0['timeout']||0xa)*0x3e8;var _0x83284,_0x4ac3e1;var _0xf82e12=seqqueue[_0x6653('0x13')](_0x10c65f);_0xf82e12['id']=_0x2179f3;_0xf82e12[_0x6653('0x14')]=_0x10c65f;_0xf82e12[_0x6653('0x15')]=_0x3d17bc[_0x6653('0x15')];writeLog(_0x2179f3,_0x24dfb0,util[_0x6653('0x16')](_0x6653('0x17'),_0x10c65f));_0x1027cc[_0x6653('0x18')][_0x2179f3]['on'](_0x6653('0x19'),function(){logger[_0x6653('0x6')]('[%s][AGENT]\x20ROUTING\x20STOPPED',_0x2179f3);clearTimeout(_0x4ac3e1);_0x4ac3e1=undefined;_0xf82e12[_0x6653('0x1a')]();if(_0x1027cc['rules'][_0x2179f3]){delete _0x1027cc[_0x6653('0x18')][_0x2179f3];}_0x3a47a0[_0x6653('0x10')]();});_0x1027cc[_0x6653('0x18')][_0x2179f3]['on'](_0x6653('0x1b'),function(){if(_0x1027cc[_0x6653('0x18')][_0x2179f3]){delete _0x1027cc[_0x6653('0x18')][_0x2179f3];}});_0x4ac3e1=setTimeout(function(){logger['info'](_0x6653('0x1c'),_0x2179f3);clearTimeout(_0x4ac3e1);_0xf82e12[_0x6653('0x1a')]();_0x3a47a0['next']();},_0x10c65f);strategy[_0x6653('0x1d')](_0xf82e12,_0x24dfb0,_0x1027cc,_0x3d17bc);}else{logger[_0x6653('0xc')](_0x6653('0x1e'),_0x2179f3,_0x55b1c0[_0x6653('0x8')]);_0x3a47a0[_0x6653('0x10')]();}}}catch(_0x21f725){console[_0x6653('0x1f')](_0x21f725);logger[_0x6653('0xc')](_0x6653('0x20'),_0x2179f3,_0x21f725['stack']);_0x3a47a0[_0x6653('0x10')]();}};};
\ No newline at end of file
git://repos.xcallymotion.com / motion2.git / blobdiff