// * treaties. The SOFTWARE PRODUCT is licensed, not sold. *
// * *
// *************************************************************************
-var _0x637d=['[%s][AGENT]\x20ROUTING\x20STOPPED','close','rules','complete','error','[%s][AGENT]\x20agent\x20not\x20found\x20%s','log','[%s][QUEUE]\x20%s','stack','validate','lodash','util','seq-queue','../../../../config/logger','./strategy','string','number','timeout\x20is\x20a\x20number','info','format','name','toLowerCase','consequence','[%s][AGENT]\x20%s','map','join','stop','agents','timeout','createQueue','atimeout','channel','START:%s','end'];(function(_0x9cc1d7,_0x126bd4){var _0x294e87=function(_0x272bd3){while(--_0x272bd3){_0x9cc1d7['push'](_0x9cc1d7['shift']());}};_0x294e87(++_0x126bd4);}(_0x637d,0x1e5));var _0xd637=function(_0x139bf8,_0x8aa9b8){_0x139bf8=_0x139bf8-0x0;var _0x3d9630=_0x637d[_0x139bf8];return _0x3d9630;};'use strict';var schema=require(_0xd637('0x0'));var _=require(_0xd637('0x1'));var util=require(_0xd637('0x2'));var seqqueue=require(_0xd637('0x3'));var logger=require(_0xd637('0x4'))('routing');var strategy=require(_0xd637('0x5'));var queue=schema({'name':{'type':_0xd637('0x6'),'required':!![],'message':'name\x20is\x20a\x20string\x20and\x20it\x20is\x20required'},'timeout':{'type':_0xd637('0x7'),'message':_0xd637('0x8')}});function writeLog(_0x382aaa,_0x41ecdb,_0x5166e5){return logger[_0xd637('0x9')](util[_0xd637('0xa')]('[%s][AGENT][NAME:%s][STATUS:%s]',_0x382aaa,_0x41ecdb['name'],_0x5166e5));}function handleFindAgent(_0x2ff366){return function(_0x3672ab){return _0x3672ab[_0xd637('0xb')][_0xd637('0xc')]()===_0x2ff366['toLowerCase']();};}exports[_0xd637('0xd')]=function(_0x2c54fb,_0x3143fb,_0x166bc6,_0x400493){return function(_0x45d442){try{var _0x2ecb09={'name':_0x3143fb[0x0],'timeout':_0x3143fb[0x1]};var _0xbae55=queue[_0xd637('0x0')](_0x2ecb09,{'typecast':!![]});if(_0xbae55['length']){logger['error'](_0xd637('0xe'),_0x2c54fb,_[_0xd637('0xf')](_0xbae55,'message')[_0xd637('0x10')](',\x20'));_0x45d442[_0xd637('0x11')]();}else{var _0x564066=_['find'](_0x166bc6[_0xd637('0x12')],handleFindAgent(_0x2ecb09[_0xd637('0xb')]));if(_0x564066){var _0x1e6cfb=(_0x2ecb09[_0xd637('0x13')]||0xa)*0x3e8;var _0x2fe68b,_0x324152;var _0x2511ea=seqqueue[_0xd637('0x14')](_0x1e6cfb);_0x2511ea['id']=_0x2c54fb;_0x2511ea[_0xd637('0x15')]=_0x1e6cfb;_0x2511ea[_0xd637('0x16')]=_0x400493[_0xd637('0x16')];writeLog(_0x2c54fb,_0x564066,util['format'](_0xd637('0x17'),_0x1e6cfb));_0x166bc6['rules'][_0x2c54fb]['on'](_0xd637('0x18'),function(){logger[_0xd637('0x9')](_0xd637('0x19'),_0x2c54fb);clearTimeout(_0x324152);_0x324152=undefined;_0x2511ea[_0xd637('0x1a')]();if(_0x166bc6[_0xd637('0x1b')][_0x2c54fb]){delete _0x166bc6[_0xd637('0x1b')][_0x2c54fb];}_0x45d442[_0xd637('0x11')]();});_0x166bc6['rules'][_0x2c54fb]['on'](_0xd637('0x1c'),function(){if(_0x166bc6[_0xd637('0x1b')][_0x2c54fb]){delete _0x166bc6['rules'][_0x2c54fb];}});_0x324152=setTimeout(function(){logger[_0xd637('0x9')]('[%s][AGENT]\x20ROUTING\x20END',_0x2c54fb);clearTimeout(_0x324152);_0x2511ea['close']();_0x45d442['next']();},_0x1e6cfb);strategy['agent'](_0x2511ea,_0x564066,_0x166bc6,_0x400493);}else{logger[_0xd637('0x1d')](_0xd637('0x1e'),_0x2c54fb,_0x2ecb09[_0xd637('0xb')]);_0x45d442['stop']();}}}catch(_0x1fa42b){console[_0xd637('0x1f')](_0x1fa42b);logger['error'](_0xd637('0x20'),_0x2c54fb,_0x1fa42b[_0xd637('0x21')]);_0x45d442[_0xd637('0x11')]();}};};
\ No newline at end of file
+var _0xb2c7=['../../../../config/logger','routing','./strategy','string','name\x20is\x20a\x20string\x20and\x20it\x20is\x20required','number','timeout\x20is\x20a\x20number','format','[%s][AGENT][NAME:%s][STATUS:%s]','name','toLowerCase','consequence','validate','length','[%s][AGENT]\x20%s','map','find','agents','timeout','createQueue','atimeout','channel','START:%s','rules','end','info','complete','[%s][AGENT]\x20ROUTING\x20END','next','agent','error','[%s][AGENT]\x20agent\x20not\x20found\x20%s','stop','[%s][QUEUE]\x20%s','lodash','seq-queue'];(function(_0xa464c9,_0x7c86d8){var _0x3d73c4=function(_0x5c2056){while(--_0x5c2056){_0xa464c9['push'](_0xa464c9['shift']());}};_0x3d73c4(++_0x7c86d8);}(_0xb2c7,0x18a));var _0x7b2c=function(_0x53ccf2,_0x13cb67){_0x53ccf2=_0x53ccf2-0x0;var _0x5a2964=_0xb2c7[_0x53ccf2];return _0x5a2964;};'use strict';var schema=require('validate');var _=require(_0x7b2c('0x0'));var util=require('util');var seqqueue=require(_0x7b2c('0x1'));var logger=require(_0x7b2c('0x2'))(_0x7b2c('0x3'));var strategy=require(_0x7b2c('0x4'));var queue=schema({'name':{'type':_0x7b2c('0x5'),'required':!![],'message':_0x7b2c('0x6')},'timeout':{'type':_0x7b2c('0x7'),'message':_0x7b2c('0x8')}});function writeLog(_0x19dd4f,_0x34d006,_0x249bcf){return logger['info'](util[_0x7b2c('0x9')](_0x7b2c('0xa'),_0x19dd4f,_0x34d006[_0x7b2c('0xb')],_0x249bcf));}function handleFindAgent(_0x396865){return function(_0x4caef0){return _0x4caef0['name'][_0x7b2c('0xc')]()===_0x396865['toLowerCase']();};}exports[_0x7b2c('0xd')]=function(_0x341c3f,_0x1f7bcd,_0x28ee57,_0x44f61a){return function(_0x43dc59){try{var _0x1a734a={'name':_0x1f7bcd[0x0],'timeout':_0x1f7bcd[0x1]};var _0xc73eac=queue[_0x7b2c('0xe')](_0x1a734a,{'typecast':!![]});if(_0xc73eac[_0x7b2c('0xf')]){logger['error'](_0x7b2c('0x10'),_0x341c3f,_[_0x7b2c('0x11')](_0xc73eac,'message')['join'](',\x20'));_0x43dc59['stop']();}else{var _0x5cd279=_[_0x7b2c('0x12')](_0x28ee57[_0x7b2c('0x13')],handleFindAgent(_0x1a734a[_0x7b2c('0xb')]));if(_0x5cd279){var _0x4448f7=(_0x1a734a[_0x7b2c('0x14')]||0xa)*0x3e8;var _0x408855,_0x26fbe7;var _0x13281a=seqqueue[_0x7b2c('0x15')](_0x4448f7);_0x13281a['id']=_0x341c3f;_0x13281a[_0x7b2c('0x16')]=_0x4448f7;_0x13281a[_0x7b2c('0x17')]=_0x44f61a['channel'];writeLog(_0x341c3f,_0x5cd279,util[_0x7b2c('0x9')](_0x7b2c('0x18'),_0x4448f7));_0x28ee57[_0x7b2c('0x19')][_0x341c3f]['on'](_0x7b2c('0x1a'),function(){logger[_0x7b2c('0x1b')]('[%s][AGENT]\x20ROUTING\x20STOPPED',_0x341c3f);clearTimeout(_0x26fbe7);_0x26fbe7=undefined;_0x13281a['close']();if(_0x28ee57['rules'][_0x341c3f]){delete _0x28ee57[_0x7b2c('0x19')][_0x341c3f];}_0x43dc59['stop']();});_0x28ee57['rules'][_0x341c3f]['on'](_0x7b2c('0x1c'),function(){if(_0x28ee57[_0x7b2c('0x19')][_0x341c3f]){delete _0x28ee57[_0x7b2c('0x19')][_0x341c3f];}});_0x26fbe7=setTimeout(function(){logger[_0x7b2c('0x1b')](_0x7b2c('0x1d'),_0x341c3f);clearTimeout(_0x26fbe7);_0x13281a['close']();_0x43dc59[_0x7b2c('0x1e')]();},_0x4448f7);strategy[_0x7b2c('0x1f')](_0x13281a,_0x5cd279,_0x28ee57,_0x44f61a);}else{logger[_0x7b2c('0x20')](_0x7b2c('0x21'),_0x341c3f,_0x1a734a[_0x7b2c('0xb')]);_0x43dc59[_0x7b2c('0x22')]();}}}catch(_0x1427fa){console['log'](_0x1427fa);logger['error'](_0x7b2c('0x23'),_0x341c3f,_0x1427fa['stack']);_0x43dc59['stop']();}};};
\ No newline at end of file
git://repos.xcallymotion.com / motion2.git / blobdiff