// * treaties. The SOFTWARE PRODUCT is licensed, not sold. *
// * *
// *************************************************************************
-var _0x5cd9=['string','name\x20is\x20a\x20string\x20and\x20it\x20is\x20required','number','timeout\x20is\x20a\x20number','format','[%s][AGENT][NAME:%s][STATUS:%s]','name','toLowerCase','consequence','length','map','message','join','stop','find','timeout','atimeout','channel','START:%s','end','[%s][AGENT]\x20ROUTING\x20STOPPED','rules','complete','info','close','next','agent','error','log','stack','validate','seq-queue','../../../../config/logger','routing','./strategy'];(function(_0x274b55,_0x2823fe){var _0x1bafce=function(_0x19524b){while(--_0x19524b){_0x274b55['push'](_0x274b55['shift']());}};_0x1bafce(++_0x2823fe);}(_0x5cd9,0xcd));var _0x95cd=function(_0x5237fa,_0x2219d8){_0x5237fa=_0x5237fa-0x0;var _0x3f1a66=_0x5cd9[_0x5237fa];return _0x3f1a66;};'use strict';var schema=require(_0x95cd('0x0'));var _=require('lodash');var util=require('util');var seqqueue=require(_0x95cd('0x1'));var logger=require(_0x95cd('0x2'))(_0x95cd('0x3'));var strategy=require(_0x95cd('0x4'));var queue=schema({'name':{'type':_0x95cd('0x5'),'required':!![],'message':_0x95cd('0x6')},'timeout':{'type':_0x95cd('0x7'),'message':_0x95cd('0x8')}});function writeLog(_0x55d299,_0x455f7d,_0x3f03d7){return logger['info'](util[_0x95cd('0x9')](_0x95cd('0xa'),_0x55d299,_0x455f7d[_0x95cd('0xb')],_0x3f03d7));}function handleFindAgent(_0x450e54){return function(_0x4e236f){return _0x4e236f[_0x95cd('0xb')][_0x95cd('0xc')]()===_0x450e54[_0x95cd('0xc')]();};}exports[_0x95cd('0xd')]=function(_0x121a4e,_0x294e54,_0x6b9610,_0x511cf2){return function(_0x1fbab8){try{var _0x1d3edd={'name':_0x294e54[0x0],'timeout':_0x294e54[0x1]};var _0x510ce8=queue[_0x95cd('0x0')](_0x1d3edd,{'typecast':!![]});if(_0x510ce8[_0x95cd('0xe')]){logger['error']('[%s][AGENT]\x20%s',_0x121a4e,_[_0x95cd('0xf')](_0x510ce8,_0x95cd('0x10'))[_0x95cd('0x11')](',\x20'));_0x1fbab8[_0x95cd('0x12')]();}else{var _0x3fd28b=_[_0x95cd('0x13')](_0x6b9610['agents'],handleFindAgent(_0x1d3edd[_0x95cd('0xb')]));if(_0x3fd28b){var _0xf1483c=(_0x1d3edd[_0x95cd('0x14')]||0xa)*0x3e8;var _0x46d790,_0x1c9812;var _0x56ff86=seqqueue['createQueue'](_0xf1483c);_0x56ff86['id']=_0x121a4e;_0x56ff86[_0x95cd('0x15')]=_0xf1483c;_0x56ff86[_0x95cd('0x16')]=_0x511cf2['channel'];writeLog(_0x121a4e,_0x3fd28b,util['format'](_0x95cd('0x17'),_0xf1483c));_0x6b9610['rules'][_0x121a4e]['on'](_0x95cd('0x18'),function(){logger['info'](_0x95cd('0x19'),_0x121a4e);clearTimeout(_0x1c9812);_0x1c9812=undefined;_0x56ff86['close']();if(_0x6b9610[_0x95cd('0x1a')][_0x121a4e]){delete _0x6b9610['rules'][_0x121a4e];}_0x1fbab8[_0x95cd('0x12')]();});_0x6b9610[_0x95cd('0x1a')][_0x121a4e]['on'](_0x95cd('0x1b'),function(){if(_0x6b9610[_0x95cd('0x1a')][_0x121a4e]){delete _0x6b9610[_0x95cd('0x1a')][_0x121a4e];}});_0x1c9812=setTimeout(function(){logger[_0x95cd('0x1c')]('[%s][AGENT]\x20ROUTING\x20END',_0x121a4e);clearTimeout(_0x1c9812);_0x56ff86[_0x95cd('0x1d')]();_0x1fbab8[_0x95cd('0x1e')]();},_0xf1483c);strategy[_0x95cd('0x1f')](_0x56ff86,_0x3fd28b,_0x6b9610,_0x511cf2);}else{logger[_0x95cd('0x20')]('[%s][AGENT]\x20agent\x20not\x20found\x20%s',_0x121a4e,_0x1d3edd['name']);_0x1fbab8['stop']();}}}catch(_0x38912b){console[_0x95cd('0x21')](_0x38912b);logger[_0x95cd('0x20')]('[%s][QUEUE]\x20%s',_0x121a4e,_0x38912b[_0x95cd('0x22')]);_0x1fbab8[_0x95cd('0x12')]();}};};
\ No newline at end of file
+var _0xc535=['atimeout','channel','START:%s','rules','end','[%s][AGENT]\x20ROUTING\x20STOPPED','complete','[%s][AGENT]\x20ROUTING\x20END','close','next','agent','error','[%s][AGENT]\x20agent\x20not\x20found\x20%s','log','[%s][QUEUE]\x20%s','stack','validate','lodash','seq-queue','../../../../config/logger','routing','./strategy','timeout\x20is\x20a\x20number','info','format','[%s][AGENT][NAME:%s][STATUS:%s]','name','toLowerCase','consequence','length','map','join','stop','find','timeout','createQueue'];(function(_0x570bfa,_0x44a280){var _0x5d7348=function(_0x4c6fab){while(--_0x4c6fab){_0x570bfa['push'](_0x570bfa['shift']());}};_0x5d7348(++_0x44a280);}(_0xc535,0x1e4));var _0x5c53=function(_0x30c373,_0x3805c6){_0x30c373=_0x30c373-0x0;var _0x2d0763=_0xc535[_0x30c373];return _0x2d0763;};'use strict';var schema=require(_0x5c53('0x0'));var _=require(_0x5c53('0x1'));var util=require('util');var seqqueue=require(_0x5c53('0x2'));var logger=require(_0x5c53('0x3'))(_0x5c53('0x4'));var strategy=require(_0x5c53('0x5'));var queue=schema({'name':{'type':'string','required':!![],'message':'name\x20is\x20a\x20string\x20and\x20it\x20is\x20required'},'timeout':{'type':'number','message':_0x5c53('0x6')}});function writeLog(_0xa39c3b,_0x29e1ba,_0x52e0de){return logger[_0x5c53('0x7')](util[_0x5c53('0x8')](_0x5c53('0x9'),_0xa39c3b,_0x29e1ba[_0x5c53('0xa')],_0x52e0de));}function handleFindAgent(_0x2c602a){return function(_0x59bfb3){return _0x59bfb3[_0x5c53('0xa')]['toLowerCase']()===_0x2c602a[_0x5c53('0xb')]();};}exports[_0x5c53('0xc')]=function(_0xd39c1,_0x2c55d2,_0xde673d,_0x3468d0){return function(_0x1e14c2){try{var _0x446d95={'name':_0x2c55d2[0x0],'timeout':_0x2c55d2[0x1]};var _0x280ccd=queue['validate'](_0x446d95,{'typecast':!![]});if(_0x280ccd[_0x5c53('0xd')]){logger['error']('[%s][AGENT]\x20%s',_0xd39c1,_[_0x5c53('0xe')](_0x280ccd,'message')[_0x5c53('0xf')](',\x20'));_0x1e14c2[_0x5c53('0x10')]();}else{var _0x161110=_[_0x5c53('0x11')](_0xde673d['agents'],handleFindAgent(_0x446d95[_0x5c53('0xa')]));if(_0x161110){var _0x1a0a4e=(_0x446d95[_0x5c53('0x12')]||0xa)*0x3e8;var _0x3315b0,_0x3b0a01;var _0x3f0cbc=seqqueue[_0x5c53('0x13')](_0x1a0a4e);_0x3f0cbc['id']=_0xd39c1;_0x3f0cbc[_0x5c53('0x14')]=_0x1a0a4e;_0x3f0cbc[_0x5c53('0x15')]=_0x3468d0[_0x5c53('0x15')];writeLog(_0xd39c1,_0x161110,util[_0x5c53('0x8')](_0x5c53('0x16'),_0x1a0a4e));_0xde673d[_0x5c53('0x17')][_0xd39c1]['on'](_0x5c53('0x18'),function(){logger[_0x5c53('0x7')](_0x5c53('0x19'),_0xd39c1);clearTimeout(_0x3b0a01);_0x3b0a01=undefined;_0x3f0cbc['close']();if(_0xde673d[_0x5c53('0x17')][_0xd39c1]){delete _0xde673d[_0x5c53('0x17')][_0xd39c1];}_0x1e14c2[_0x5c53('0x10')]();});_0xde673d[_0x5c53('0x17')][_0xd39c1]['on'](_0x5c53('0x1a'),function(){if(_0xde673d[_0x5c53('0x17')][_0xd39c1]){delete _0xde673d[_0x5c53('0x17')][_0xd39c1];}});_0x3b0a01=setTimeout(function(){logger[_0x5c53('0x7')](_0x5c53('0x1b'),_0xd39c1);clearTimeout(_0x3b0a01);_0x3f0cbc[_0x5c53('0x1c')]();_0x1e14c2[_0x5c53('0x1d')]();},_0x1a0a4e);strategy[_0x5c53('0x1e')](_0x3f0cbc,_0x161110,_0xde673d,_0x3468d0);}else{logger[_0x5c53('0x1f')](_0x5c53('0x20'),_0xd39c1,_0x446d95[_0x5c53('0xa')]);_0x1e14c2[_0x5c53('0x10')]();}}}catch(_0x5f4303){console[_0x5c53('0x21')](_0x5f4303);logger[_0x5c53('0x1f')](_0x5c53('0x22'),_0xd39c1,_0x5f4303[_0x5c53('0x23')]);_0x1e14c2['stop']();}};};
\ No newline at end of file
git://repos.xcallymotion.com / motion2.git / blobdiff