// * treaties. The SOFTWARE PRODUCT is licensed, not sold. *
// * *
// *************************************************************************
-var _0x9d36=['string','name\x20is\x20a\x20string\x20and\x20it\x20is\x20required','number','timeout\x20is\x20a\x20number','info','format','[%s][AGENT][NAME:%s][STATUS:%s]','name','toLowerCase','consequence','length','[%s][AGENT]\x20%s','message','join','stop','find','agents','timeout','channel','end','close','rules','[%s][AGENT]\x20ROUTING\x20END','next','agent','error','log','[%s][QUEUE]\x20%s','stack','lodash','util','seq-queue','../../../../config/logger','./strategy'];(function(_0x183256,_0x1a596d){var _0x5394a2=function(_0x192025){while(--_0x192025){_0x183256['push'](_0x183256['shift']());}};_0x5394a2(++_0x1a596d);}(_0x9d36,0x1b5));var _0x69d3=function(_0x1aab89,_0x1c9d54){_0x1aab89=_0x1aab89-0x0;var _0x168bc0=_0x9d36[_0x1aab89];return _0x168bc0;};'use strict';var schema=require('validate');var _=require(_0x69d3('0x0'));var util=require(_0x69d3('0x1'));var seqqueue=require(_0x69d3('0x2'));var logger=require(_0x69d3('0x3'))('routing');var strategy=require(_0x69d3('0x4'));var queue=schema({'name':{'type':_0x69d3('0x5'),'required':!![],'message':_0x69d3('0x6')},'timeout':{'type':_0x69d3('0x7'),'message':_0x69d3('0x8')}});function writeLog(_0x20cbd1,_0x449fd6,_0x51abef){return logger[_0x69d3('0x9')](util[_0x69d3('0xa')](_0x69d3('0xb'),_0x20cbd1,_0x449fd6[_0x69d3('0xc')],_0x51abef));}function handleFindAgent(_0x1e885e){return function(_0xa0dde1){return _0xa0dde1[_0x69d3('0xc')][_0x69d3('0xd')]()===_0x1e885e[_0x69d3('0xd')]();};}exports[_0x69d3('0xe')]=function(_0x4ca6bb,_0x57af44,_0x4d642b,_0xf4f80e){return function(_0x20325b){try{var _0x433c15={'name':_0x57af44[0x0],'timeout':_0x57af44[0x1]};var _0x37ab30=queue['validate'](_0x433c15,{'typecast':!![]});if(_0x37ab30[_0x69d3('0xf')]){logger['error'](_0x69d3('0x10'),_0x4ca6bb,_['map'](_0x37ab30,_0x69d3('0x11'))[_0x69d3('0x12')](',\x20'));_0x20325b[_0x69d3('0x13')]();}else{var _0x1c3b7d=_[_0x69d3('0x14')](_0x4d642b[_0x69d3('0x15')],handleFindAgent(_0x433c15[_0x69d3('0xc')]));if(_0x1c3b7d){var _0xbbc693=(_0x433c15[_0x69d3('0x16')]||0xa)*0x3e8;var _0x3093fd,_0x1d44e3;var _0x3fc0d1=seqqueue['createQueue'](_0xbbc693);_0x3fc0d1['id']=_0x4ca6bb;_0x3fc0d1['atimeout']=_0xbbc693;_0x3fc0d1[_0x69d3('0x17')]=_0xf4f80e[_0x69d3('0x17')];writeLog(_0x4ca6bb,_0x1c3b7d,util[_0x69d3('0xa')]('START:%s',_0xbbc693));_0x4d642b['rules'][_0x4ca6bb]['on'](_0x69d3('0x18'),function(){logger[_0x69d3('0x9')]('[%s][AGENT]\x20ROUTING\x20STOPPED',_0x4ca6bb);clearTimeout(_0x1d44e3);_0x1d44e3=undefined;_0x3fc0d1[_0x69d3('0x19')]();if(_0x4d642b[_0x69d3('0x1a')][_0x4ca6bb]){delete _0x4d642b[_0x69d3('0x1a')][_0x4ca6bb];}_0x20325b[_0x69d3('0x13')]();});_0x4d642b[_0x69d3('0x1a')][_0x4ca6bb]['on']('complete',function(){if(_0x4d642b[_0x69d3('0x1a')][_0x4ca6bb]){delete _0x4d642b[_0x69d3('0x1a')][_0x4ca6bb];}});_0x1d44e3=setTimeout(function(){logger[_0x69d3('0x9')](_0x69d3('0x1b'),_0x4ca6bb);clearTimeout(_0x1d44e3);_0x3fc0d1[_0x69d3('0x19')]();_0x20325b[_0x69d3('0x1c')]();},_0xbbc693);strategy[_0x69d3('0x1d')](_0x3fc0d1,_0x1c3b7d,_0x4d642b,_0xf4f80e);}else{logger[_0x69d3('0x1e')]('[%s][AGENT]\x20agent\x20not\x20found\x20%s',_0x4ca6bb,_0x433c15['name']);_0x20325b[_0x69d3('0x13')]();}}}catch(_0x1d0b4b){console[_0x69d3('0x1f')](_0x1d0b4b);logger[_0x69d3('0x1e')](_0x69d3('0x20'),_0x4ca6bb,_0x1d0b4b[_0x69d3('0x21')]);_0x20325b[_0x69d3('0x13')]();}};};
\ No newline at end of file
+var _0x7fa3=['createQueue','atimeout','channel','START:%s','rules','[%s][AGENT]\x20ROUTING\x20STOPPED','complete','[%s][AGENT]\x20ROUTING\x20END','close','next','agent','error','[%s][AGENT]\x20agent\x20not\x20found\x20%s','log','stack','validate','util','../../../../config/logger','routing','string','name\x20is\x20a\x20string\x20and\x20it\x20is\x20required','number','timeout\x20is\x20a\x20number','info','format','name','toLowerCase','length','map','message','join','stop','agents'];(function(_0x56ab71,_0x40df33){var _0x44bafc=function(_0x13cf3e){while(--_0x13cf3e){_0x56ab71['push'](_0x56ab71['shift']());}};_0x44bafc(++_0x40df33);}(_0x7fa3,0x138));var _0x37fa=function(_0x27179a,_0x1583a3){_0x27179a=_0x27179a-0x0;var _0x355b44=_0x7fa3[_0x27179a];return _0x355b44;};'use strict';var schema=require(_0x37fa('0x0'));var _=require('lodash');var util=require(_0x37fa('0x1'));var seqqueue=require('seq-queue');var logger=require(_0x37fa('0x2'))(_0x37fa('0x3'));var strategy=require('./strategy');var queue=schema({'name':{'type':_0x37fa('0x4'),'required':!![],'message':_0x37fa('0x5')},'timeout':{'type':_0x37fa('0x6'),'message':_0x37fa('0x7')}});function writeLog(_0x56c0a7,_0x1348b1,_0x4078a7){return logger[_0x37fa('0x8')](util[_0x37fa('0x9')]('[%s][AGENT][NAME:%s][STATUS:%s]',_0x56c0a7,_0x1348b1['name'],_0x4078a7));}function handleFindAgent(_0x3d1e52){return function(_0x462c7c){return _0x462c7c[_0x37fa('0xa')]['toLowerCase']()===_0x3d1e52[_0x37fa('0xb')]();};}exports['consequence']=function(_0x3133ba,_0x44652c,_0x47c436,_0x2b4f0a){return function(_0x4277d0){try{var _0x6103a0={'name':_0x44652c[0x0],'timeout':_0x44652c[0x1]};var _0x2f380a=queue[_0x37fa('0x0')](_0x6103a0,{'typecast':!![]});if(_0x2f380a[_0x37fa('0xc')]){logger['error']('[%s][AGENT]\x20%s',_0x3133ba,_[_0x37fa('0xd')](_0x2f380a,_0x37fa('0xe'))[_0x37fa('0xf')](',\x20'));_0x4277d0[_0x37fa('0x10')]();}else{var _0x46d068=_['find'](_0x47c436[_0x37fa('0x11')],handleFindAgent(_0x6103a0[_0x37fa('0xa')]));if(_0x46d068){var _0x3378b7=(_0x6103a0['timeout']||0xa)*0x3e8;var _0x24d5cd,_0x5599d9;var _0x17c427=seqqueue[_0x37fa('0x12')](_0x3378b7);_0x17c427['id']=_0x3133ba;_0x17c427[_0x37fa('0x13')]=_0x3378b7;_0x17c427[_0x37fa('0x14')]=_0x2b4f0a[_0x37fa('0x14')];writeLog(_0x3133ba,_0x46d068,util[_0x37fa('0x9')](_0x37fa('0x15'),_0x3378b7));_0x47c436[_0x37fa('0x16')][_0x3133ba]['on']('end',function(){logger[_0x37fa('0x8')](_0x37fa('0x17'),_0x3133ba);clearTimeout(_0x5599d9);_0x5599d9=undefined;_0x17c427['close']();if(_0x47c436['rules'][_0x3133ba]){delete _0x47c436[_0x37fa('0x16')][_0x3133ba];}_0x4277d0[_0x37fa('0x10')]();});_0x47c436[_0x37fa('0x16')][_0x3133ba]['on'](_0x37fa('0x18'),function(){if(_0x47c436[_0x37fa('0x16')][_0x3133ba]){delete _0x47c436['rules'][_0x3133ba];}});_0x5599d9=setTimeout(function(){logger[_0x37fa('0x8')](_0x37fa('0x19'),_0x3133ba);clearTimeout(_0x5599d9);_0x17c427[_0x37fa('0x1a')]();_0x4277d0[_0x37fa('0x1b')]();},_0x3378b7);strategy[_0x37fa('0x1c')](_0x17c427,_0x46d068,_0x47c436,_0x2b4f0a);}else{logger[_0x37fa('0x1d')](_0x37fa('0x1e'),_0x3133ba,_0x6103a0[_0x37fa('0xa')]);_0x4277d0['stop']();}}}catch(_0x555b9d){console[_0x37fa('0x1f')](_0x555b9d);logger[_0x37fa('0x1d')]('[%s][QUEUE]\x20%s',_0x3133ba,_0x555b9d[_0x37fa('0x20')]);_0x4277d0[_0x37fa('0x10')]();}};};
\ No newline at end of file
git://repos.xcallymotion.com / motion2.git / blobdiff