// * treaties. The SOFTWARE PRODUCT is licensed, not sold. *
// * *
// *************************************************************************
-var _0x84b9=['[%s][AGENT]\x20%s','map','message','find','timeout','channel','START:%s','end','[%s][AGENT]\x20ROUTING\x20STOPPED','close','rules','stop','complete','[%s][AGENT]\x20ROUTING\x20END','next','agent','log','[%s][QUEUE]\x20%s','stack','validate','util','seq-queue','../../../../config/logger','routing','./strategy','string','number','info','format','[%s][AGENT][NAME:%s][STATUS:%s]','name','toLowerCase','consequence','length','error'];(function(_0x295b61,_0x808c6c){var _0x1f9558=function(_0x48a496){while(--_0x48a496){_0x295b61['push'](_0x295b61['shift']());}};_0x1f9558(++_0x808c6c);}(_0x84b9,0x171));var _0x984b=function(_0x18fb16,_0x45edbc){_0x18fb16=_0x18fb16-0x0;var _0x147b0d=_0x84b9[_0x18fb16];return _0x147b0d;};'use strict';var schema=require(_0x984b('0x0'));var _=require('lodash');var util=require(_0x984b('0x1'));var seqqueue=require(_0x984b('0x2'));var logger=require(_0x984b('0x3'))(_0x984b('0x4'));var strategy=require(_0x984b('0x5'));var queue=schema({'name':{'type':_0x984b('0x6'),'required':!![],'message':'name\x20is\x20a\x20string\x20and\x20it\x20is\x20required'},'timeout':{'type':_0x984b('0x7'),'message':'timeout\x20is\x20a\x20number'}});function writeLog(_0x39c2ec,_0x2f2736,_0x5d8106){return logger[_0x984b('0x8')](util[_0x984b('0x9')](_0x984b('0xa'),_0x39c2ec,_0x2f2736[_0x984b('0xb')],_0x5d8106));}function handleFindAgent(_0x128081){return function(_0x525ac3){return _0x525ac3[_0x984b('0xb')][_0x984b('0xc')]()===_0x128081[_0x984b('0xc')]();};}exports[_0x984b('0xd')]=function(_0x25d658,_0x38a64c,_0x25b74d,_0x38f136){return function(_0x12a121){try{var _0x1d01ba={'name':_0x38a64c[0x0],'timeout':_0x38a64c[0x1]};var _0x1c47c=queue[_0x984b('0x0')](_0x1d01ba,{'typecast':!![]});if(_0x1c47c[_0x984b('0xe')]){logger[_0x984b('0xf')](_0x984b('0x10'),_0x25d658,_[_0x984b('0x11')](_0x1c47c,_0x984b('0x12'))['join'](',\x20'));_0x12a121['stop']();}else{var _0x2027b2=_[_0x984b('0x13')](_0x25b74d['agents'],handleFindAgent(_0x1d01ba[_0x984b('0xb')]));if(_0x2027b2){var _0x3898aa=(_0x1d01ba[_0x984b('0x14')]||0xa)*0x3e8;var _0x56666,_0x365566;var _0x1986ca=seqqueue['createQueue'](_0x3898aa);_0x1986ca['id']=_0x25d658;_0x1986ca['atimeout']=_0x3898aa;_0x1986ca[_0x984b('0x15')]=_0x38f136[_0x984b('0x15')];writeLog(_0x25d658,_0x2027b2,util[_0x984b('0x9')](_0x984b('0x16'),_0x3898aa));_0x25b74d['rules'][_0x25d658]['on'](_0x984b('0x17'),function(){logger[_0x984b('0x8')](_0x984b('0x18'),_0x25d658);clearTimeout(_0x365566);_0x365566=undefined;_0x1986ca[_0x984b('0x19')]();if(_0x25b74d[_0x984b('0x1a')][_0x25d658]){delete _0x25b74d[_0x984b('0x1a')][_0x25d658];}_0x12a121[_0x984b('0x1b')]();});_0x25b74d['rules'][_0x25d658]['on'](_0x984b('0x1c'),function(){if(_0x25b74d[_0x984b('0x1a')][_0x25d658]){delete _0x25b74d[_0x984b('0x1a')][_0x25d658];}});_0x365566=setTimeout(function(){logger[_0x984b('0x8')](_0x984b('0x1d'),_0x25d658);clearTimeout(_0x365566);_0x1986ca[_0x984b('0x19')]();_0x12a121[_0x984b('0x1e')]();},_0x3898aa);strategy[_0x984b('0x1f')](_0x1986ca,_0x2027b2,_0x25b74d,_0x38f136);}else{logger[_0x984b('0xf')]('[%s][AGENT]\x20agent\x20not\x20found\x20%s',_0x25d658,_0x1d01ba[_0x984b('0xb')]);_0x12a121[_0x984b('0x1b')]();}}}catch(_0x40fc60){console[_0x984b('0x20')](_0x40fc60);logger[_0x984b('0xf')](_0x984b('0x21'),_0x25d658,_0x40fc60[_0x984b('0x22')]);_0x12a121[_0x984b('0x1b')]();}};};
\ No newline at end of file
+var _0x1a80=['rules','complete','[%s][AGENT]\x20ROUTING\x20END','close','next','agent','[%s][AGENT]\x20agent\x20not\x20found\x20%s','log','[%s][QUEUE]\x20%s','stack','validate','lodash','util','../../../../config/logger','routing','./strategy','name\x20is\x20a\x20string\x20and\x20it\x20is\x20required','number','timeout\x20is\x20a\x20number','info','format','[%s][AGENT][NAME:%s][STATUS:%s]','name','toLowerCase','consequence','error','[%s][AGENT]\x20%s','map','message','join','stop','find','agents','timeout','createQueue','channel','START:%s','end','[%s][AGENT]\x20ROUTING\x20STOPPED'];(function(_0x4baf19,_0x57b927){var _0x38abe9=function(_0x76e80b){while(--_0x76e80b){_0x4baf19['push'](_0x4baf19['shift']());}};_0x38abe9(++_0x57b927);}(_0x1a80,0x190));var _0x01a8=function(_0xd8b38,_0x37148f){_0xd8b38=_0xd8b38-0x0;var _0x40f471=_0x1a80[_0xd8b38];return _0x40f471;};'use strict';var schema=require(_0x01a8('0x0'));var _=require(_0x01a8('0x1'));var util=require(_0x01a8('0x2'));var seqqueue=require('seq-queue');var logger=require(_0x01a8('0x3'))(_0x01a8('0x4'));var strategy=require(_0x01a8('0x5'));var queue=schema({'name':{'type':'string','required':!![],'message':_0x01a8('0x6')},'timeout':{'type':_0x01a8('0x7'),'message':_0x01a8('0x8')}});function writeLog(_0x57a41c,_0x5b89ae,_0x56401c){return logger[_0x01a8('0x9')](util[_0x01a8('0xa')](_0x01a8('0xb'),_0x57a41c,_0x5b89ae[_0x01a8('0xc')],_0x56401c));}function handleFindAgent(_0xfa3d3f){return function(_0x3a2092){return _0x3a2092[_0x01a8('0xc')][_0x01a8('0xd')]()===_0xfa3d3f[_0x01a8('0xd')]();};}exports[_0x01a8('0xe')]=function(_0x56f545,_0x32a87b,_0x5a9f2c,_0x240f3d){return function(_0xc6afcb){try{var _0xce1099={'name':_0x32a87b[0x0],'timeout':_0x32a87b[0x1]};var _0x1dadee=queue[_0x01a8('0x0')](_0xce1099,{'typecast':!![]});if(_0x1dadee['length']){logger[_0x01a8('0xf')](_0x01a8('0x10'),_0x56f545,_[_0x01a8('0x11')](_0x1dadee,_0x01a8('0x12'))[_0x01a8('0x13')](',\x20'));_0xc6afcb[_0x01a8('0x14')]();}else{var _0xfb2c26=_[_0x01a8('0x15')](_0x5a9f2c[_0x01a8('0x16')],handleFindAgent(_0xce1099[_0x01a8('0xc')]));if(_0xfb2c26){var _0x28877a=(_0xce1099[_0x01a8('0x17')]||0xa)*0x3e8;var _0x42e285,_0x1e81d;var _0xc3e4=seqqueue[_0x01a8('0x18')](_0x28877a);_0xc3e4['id']=_0x56f545;_0xc3e4['atimeout']=_0x28877a;_0xc3e4[_0x01a8('0x19')]=_0x240f3d['channel'];writeLog(_0x56f545,_0xfb2c26,util[_0x01a8('0xa')](_0x01a8('0x1a'),_0x28877a));_0x5a9f2c['rules'][_0x56f545]['on'](_0x01a8('0x1b'),function(){logger[_0x01a8('0x9')](_0x01a8('0x1c'),_0x56f545);clearTimeout(_0x1e81d);_0x1e81d=undefined;_0xc3e4['close']();if(_0x5a9f2c[_0x01a8('0x1d')][_0x56f545]){delete _0x5a9f2c['rules'][_0x56f545];}_0xc6afcb[_0x01a8('0x14')]();});_0x5a9f2c[_0x01a8('0x1d')][_0x56f545]['on'](_0x01a8('0x1e'),function(){if(_0x5a9f2c[_0x01a8('0x1d')][_0x56f545]){delete _0x5a9f2c[_0x01a8('0x1d')][_0x56f545];}});_0x1e81d=setTimeout(function(){logger[_0x01a8('0x9')](_0x01a8('0x1f'),_0x56f545);clearTimeout(_0x1e81d);_0xc3e4[_0x01a8('0x20')]();_0xc6afcb[_0x01a8('0x21')]();},_0x28877a);strategy[_0x01a8('0x22')](_0xc3e4,_0xfb2c26,_0x5a9f2c,_0x240f3d);}else{logger[_0x01a8('0xf')](_0x01a8('0x23'),_0x56f545,_0xce1099[_0x01a8('0xc')]);_0xc6afcb['stop']();}}}catch(_0x1663c8){console[_0x01a8('0x24')](_0x1663c8);logger[_0x01a8('0xf')](_0x01a8('0x25'),_0x56f545,_0x1663c8[_0x01a8('0x26')]);_0xc6afcb['stop']();}};};
\ No newline at end of file
git://repos.xcallymotion.com / motion2.git / blobdiff