// * treaties. The SOFTWARE PRODUCT is licensed, not sold. *
// * *
// *************************************************************************
-var _0xec9a=['stop','timeout','createQueue','atimeout','channel','format','START:%s','rules','end','close','complete','[%s][AGENT]\x20ROUTING\x20END','agent','[%s][AGENT]\x20agent\x20not\x20found\x20%s','log','[%s][QUEUE]\x20%s','stack','validate','lodash','util','../../../../config/logger','routing','./strategy','string','name\x20is\x20a\x20string\x20and\x20it\x20is\x20required','number','timeout\x20is\x20a\x20number','info','name','toLowerCase','consequence','error','[%s][AGENT]\x20%s','message','join'];(function(_0x590698,_0x367956){var _0x2a692d=function(_0x45dc29){while(--_0x45dc29){_0x590698['push'](_0x590698['shift']());}};_0x2a692d(++_0x367956);}(_0xec9a,0x7a));var _0xaec9=function(_0x545dd3,_0x2a4af4){_0x545dd3=_0x545dd3-0x0;var _0x2ba373=_0xec9a[_0x545dd3];return _0x2ba373;};'use strict';var schema=require(_0xaec9('0x0'));var _=require(_0xaec9('0x1'));var util=require(_0xaec9('0x2'));var seqqueue=require('seq-queue');var logger=require(_0xaec9('0x3'))(_0xaec9('0x4'));var strategy=require(_0xaec9('0x5'));var queue=schema({'name':{'type':_0xaec9('0x6'),'required':!![],'message':_0xaec9('0x7')},'timeout':{'type':_0xaec9('0x8'),'message':_0xaec9('0x9')}});function writeLog(_0x4f4ce5,_0x41cb1b,_0x3d2bde){return logger[_0xaec9('0xa')](util['format']('[%s][AGENT][NAME:%s][STATUS:%s]',_0x4f4ce5,_0x41cb1b[_0xaec9('0xb')],_0x3d2bde));}function handleFindAgent(_0x4ed696){return function(_0x55ddd8){return _0x55ddd8[_0xaec9('0xb')][_0xaec9('0xc')]()===_0x4ed696['toLowerCase']();};}exports[_0xaec9('0xd')]=function(_0x562d13,_0x4eaf9e,_0x348258,_0x563301){return function(_0x1f404c){try{var _0x37f6ba={'name':_0x4eaf9e[0x0],'timeout':_0x4eaf9e[0x1]};var _0x576461=queue[_0xaec9('0x0')](_0x37f6ba,{'typecast':!![]});if(_0x576461['length']){logger[_0xaec9('0xe')](_0xaec9('0xf'),_0x562d13,_['map'](_0x576461,_0xaec9('0x10'))[_0xaec9('0x11')](',\x20'));_0x1f404c[_0xaec9('0x12')]();}else{var _0x48d6c4=_['find'](_0x348258['agents'],handleFindAgent(_0x37f6ba[_0xaec9('0xb')]));if(_0x48d6c4){var _0x333452=(_0x37f6ba[_0xaec9('0x13')]||0xa)*0x3e8;var _0x2df1f6,_0x21cc20;var _0x3de6d1=seqqueue[_0xaec9('0x14')](_0x333452);_0x3de6d1['id']=_0x562d13;_0x3de6d1[_0xaec9('0x15')]=_0x333452;_0x3de6d1[_0xaec9('0x16')]=_0x563301[_0xaec9('0x16')];writeLog(_0x562d13,_0x48d6c4,util[_0xaec9('0x17')](_0xaec9('0x18'),_0x333452));_0x348258[_0xaec9('0x19')][_0x562d13]['on'](_0xaec9('0x1a'),function(){logger[_0xaec9('0xa')]('[%s][AGENT]\x20ROUTING\x20STOPPED',_0x562d13);clearTimeout(_0x21cc20);_0x21cc20=undefined;_0x3de6d1[_0xaec9('0x1b')]();if(_0x348258[_0xaec9('0x19')][_0x562d13]){delete _0x348258[_0xaec9('0x19')][_0x562d13];}_0x1f404c[_0xaec9('0x12')]();});_0x348258['rules'][_0x562d13]['on'](_0xaec9('0x1c'),function(){if(_0x348258[_0xaec9('0x19')][_0x562d13]){delete _0x348258['rules'][_0x562d13];}});_0x21cc20=setTimeout(function(){logger[_0xaec9('0xa')](_0xaec9('0x1d'),_0x562d13);clearTimeout(_0x21cc20);_0x3de6d1[_0xaec9('0x1b')]();_0x1f404c['next']();},_0x333452);strategy[_0xaec9('0x1e')](_0x3de6d1,_0x48d6c4,_0x348258,_0x563301);}else{logger[_0xaec9('0xe')](_0xaec9('0x1f'),_0x562d13,_0x37f6ba[_0xaec9('0xb')]);_0x1f404c[_0xaec9('0x12')]();}}}catch(_0x5bb5dd){console[_0xaec9('0x20')](_0x5bb5dd);logger[_0xaec9('0xe')](_0xaec9('0x21'),_0x562d13,_0x5bb5dd[_0xaec9('0x22')]);_0x1f404c['stop']();}};};
\ No newline at end of file
+var _0x216b=['complete','[%s][AGENT]\x20ROUTING\x20END','next','[%s][AGENT]\x20agent\x20not\x20found\x20%s','log','[%s][QUEUE]\x20%s','stack','validate','util','seq-queue','../../../../config/logger','routing','./strategy','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','error','[%s][AGENT]\x20%s','map','message','join','stop','find','timeout','createQueue','atimeout','channel','START:%s','rules','end','[%s][AGENT]\x20ROUTING\x20STOPPED','close'];(function(_0x37bd26,_0x5ad346){var _0xe83dc4=function(_0x1ac229){while(--_0x1ac229){_0x37bd26['push'](_0x37bd26['shift']());}};_0xe83dc4(++_0x5ad346);}(_0x216b,0xcf));var _0xb216=function(_0x201bae,_0x24c602){_0x201bae=_0x201bae-0x0;var _0x5dd069=_0x216b[_0x201bae];return _0x5dd069;};'use strict';var schema=require(_0xb216('0x0'));var _=require('lodash');var util=require(_0xb216('0x1'));var seqqueue=require(_0xb216('0x2'));var logger=require(_0xb216('0x3'))(_0xb216('0x4'));var strategy=require(_0xb216('0x5'));var queue=schema({'name':{'type':_0xb216('0x6'),'required':!![],'message':_0xb216('0x7')},'timeout':{'type':_0xb216('0x8'),'message':_0xb216('0x9')}});function writeLog(_0x3c3684,_0x5ef215,_0x263158){return logger[_0xb216('0xa')](util[_0xb216('0xb')](_0xb216('0xc'),_0x3c3684,_0x5ef215['name'],_0x263158));}function handleFindAgent(_0x36a5c0){return function(_0x209953){return _0x209953[_0xb216('0xd')][_0xb216('0xe')]()===_0x36a5c0[_0xb216('0xe')]();};}exports[_0xb216('0xf')]=function(_0x47a72f,_0x7a120f,_0x1fd3ae,_0x5e9d93){return function(_0x5efc5a){try{var _0x1dce31={'name':_0x7a120f[0x0],'timeout':_0x7a120f[0x1]};var _0x5e1a1f=queue[_0xb216('0x0')](_0x1dce31,{'typecast':!![]});if(_0x5e1a1f[_0xb216('0x10')]){logger[_0xb216('0x11')](_0xb216('0x12'),_0x47a72f,_[_0xb216('0x13')](_0x5e1a1f,_0xb216('0x14'))[_0xb216('0x15')](',\x20'));_0x5efc5a[_0xb216('0x16')]();}else{var _0x5b2b3e=_[_0xb216('0x17')](_0x1fd3ae['agents'],handleFindAgent(_0x1dce31['name']));if(_0x5b2b3e){var _0x457d61=(_0x1dce31[_0xb216('0x18')]||0xa)*0x3e8;var _0x1a9db2,_0x17c10c;var _0x3b08eb=seqqueue[_0xb216('0x19')](_0x457d61);_0x3b08eb['id']=_0x47a72f;_0x3b08eb[_0xb216('0x1a')]=_0x457d61;_0x3b08eb['channel']=_0x5e9d93[_0xb216('0x1b')];writeLog(_0x47a72f,_0x5b2b3e,util['format'](_0xb216('0x1c'),_0x457d61));_0x1fd3ae[_0xb216('0x1d')][_0x47a72f]['on'](_0xb216('0x1e'),function(){logger['info'](_0xb216('0x1f'),_0x47a72f);clearTimeout(_0x17c10c);_0x17c10c=undefined;_0x3b08eb[_0xb216('0x20')]();if(_0x1fd3ae[_0xb216('0x1d')][_0x47a72f]){delete _0x1fd3ae[_0xb216('0x1d')][_0x47a72f];}_0x5efc5a[_0xb216('0x16')]();});_0x1fd3ae['rules'][_0x47a72f]['on'](_0xb216('0x21'),function(){if(_0x1fd3ae[_0xb216('0x1d')][_0x47a72f]){delete _0x1fd3ae[_0xb216('0x1d')][_0x47a72f];}});_0x17c10c=setTimeout(function(){logger[_0xb216('0xa')](_0xb216('0x22'),_0x47a72f);clearTimeout(_0x17c10c);_0x3b08eb[_0xb216('0x20')]();_0x5efc5a[_0xb216('0x23')]();},_0x457d61);strategy['agent'](_0x3b08eb,_0x5b2b3e,_0x1fd3ae,_0x5e9d93);}else{logger[_0xb216('0x11')](_0xb216('0x24'),_0x47a72f,_0x1dce31[_0xb216('0xd')]);_0x5efc5a['stop']();}}}catch(_0x1e224a){console[_0xb216('0x25')](_0x1e224a);logger['error'](_0xb216('0x26'),_0x47a72f,_0x1e224a[_0xb216('0x27')]);_0x5efc5a['stop']();}};};
\ No newline at end of file
git://repos.xcallymotion.com / motion2.git / blobdiff