// * treaties. The SOFTWARE PRODUCT is licensed, not sold. *
// * *
// *************************************************************************
-var _0xf2c1=['stack','seq-queue','../../../../config/logger','routing','name\x20is\x20a\x20string\x20and\x20it\x20is\x20required','number','timeout\x20is\x20a\x20number','info','format','[%s][AGENT][NAME:%s][STATUS:%s]','name','toLowerCase','consequence','validate','length','error','[%s][AGENT]\x20%s','map','join','find','agents','createQueue','atimeout','channel','START:%s','rules','end','[%s][AGENT]\x20ROUTING\x20STOPPED','stop','[%s][AGENT]\x20ROUTING\x20END','next','agent','[%s][AGENT]\x20agent\x20not\x20found\x20%s','log'];(function(_0x153b0b,_0x204749){var _0x16bd75=function(_0x5314c4){while(--_0x5314c4){_0x153b0b['push'](_0x153b0b['shift']());}};_0x16bd75(++_0x204749);}(_0xf2c1,0x199));var _0x1f2c=function(_0x3eaafa,_0x1a41b7){_0x3eaafa=_0x3eaafa-0x0;var _0x16e821=_0xf2c1[_0x3eaafa];return _0x16e821;};'use strict';var schema=require('validate');var _=require('lodash');var util=require('util');var seqqueue=require(_0x1f2c('0x0'));var logger=require(_0x1f2c('0x1'))(_0x1f2c('0x2'));var strategy=require('./strategy');var queue=schema({'name':{'type':'string','required':!![],'message':_0x1f2c('0x3')},'timeout':{'type':_0x1f2c('0x4'),'message':_0x1f2c('0x5')}});function writeLog(_0x35127d,_0x2ff0bd,_0x1e00bc){return logger[_0x1f2c('0x6')](util[_0x1f2c('0x7')](_0x1f2c('0x8'),_0x35127d,_0x2ff0bd[_0x1f2c('0x9')],_0x1e00bc));}function handleFindAgent(_0x1bfa0){return function(_0x20e908){return _0x20e908['name'][_0x1f2c('0xa')]()===_0x1bfa0[_0x1f2c('0xa')]();};}exports[_0x1f2c('0xb')]=function(_0x363d6e,_0x2cc516,_0xea3b4e,_0xe7cf1b){return function(_0x232250){try{var _0x45ff43={'name':_0x2cc516[0x0],'timeout':_0x2cc516[0x1]};var _0x32f1be=queue[_0x1f2c('0xc')](_0x45ff43,{'typecast':!![]});if(_0x32f1be[_0x1f2c('0xd')]){logger[_0x1f2c('0xe')](_0x1f2c('0xf'),_0x363d6e,_[_0x1f2c('0x10')](_0x32f1be,'message')[_0x1f2c('0x11')](',\x20'));_0x232250['stop']();}else{var _0x2c38fb=_[_0x1f2c('0x12')](_0xea3b4e[_0x1f2c('0x13')],handleFindAgent(_0x45ff43['name']));if(_0x2c38fb){var _0x278585=(_0x45ff43['timeout']||0xa)*0x3e8;var _0x2ff909,_0x2845d7;var _0x1f8e44=seqqueue[_0x1f2c('0x14')](_0x278585);_0x1f8e44['id']=_0x363d6e;_0x1f8e44[_0x1f2c('0x15')]=_0x278585;_0x1f8e44[_0x1f2c('0x16')]=_0xe7cf1b['channel'];writeLog(_0x363d6e,_0x2c38fb,util[_0x1f2c('0x7')](_0x1f2c('0x17'),_0x278585));_0xea3b4e[_0x1f2c('0x18')][_0x363d6e]['on'](_0x1f2c('0x19'),function(){_0x1f8e44['close']();clearTimeout(_0x2845d7);_0x2845d7=undefined;if(_0xea3b4e['rules'][_0x363d6e]){delete _0xea3b4e[_0x1f2c('0x18')][_0x363d6e];}logger[_0x1f2c('0x6')](_0x1f2c('0x1a'),_0x363d6e);_0x232250[_0x1f2c('0x1b')]();});_0x2845d7=setTimeout(function(){clearTimeout(_0x2845d7);_0x1f8e44['close']();logger[_0x1f2c('0x6')](_0x1f2c('0x1c'),_0x363d6e);_0x232250[_0x1f2c('0x1d')]();},_0x278585);strategy[_0x1f2c('0x1e')](_0x1f8e44,_0x2c38fb,_0xea3b4e,_0xe7cf1b);}else{logger[_0x1f2c('0xe')](_0x1f2c('0x1f'),_0x363d6e,_0x45ff43[_0x1f2c('0x9')]);_0x232250[_0x1f2c('0x1b')]();}}}catch(_0x9799c5){console[_0x1f2c('0x20')](_0x9799c5);logger[_0x1f2c('0xe')]('[%s][QUEUE]\x20%s',_0x363d6e,_0x9799c5[_0x1f2c('0x21')]);_0x232250[_0x1f2c('0x1b')]();}};};
\ No newline at end of file
+var _0xe0c2=['join','stop','find','agents','atimeout','channel','rules','end','close','[%s][AGENT]\x20ROUTING\x20STOPPED','[%s][AGENT]\x20ROUTING\x20END','next','agent','error','[%s][AGENT]\x20agent\x20not\x20found\x20%s','log','stack','validate','lodash','util','seq-queue','routing','name\x20is\x20a\x20string\x20and\x20it\x20is\x20required','number','timeout\x20is\x20a\x20number','info','format','[%s][AGENT][NAME:%s][STATUS:%s]','name','toLowerCase','consequence','[%s][AGENT]\x20%s','map'];(function(_0x1e9521,_0x396374){var _0x2106f2=function(_0xa3758a){while(--_0xa3758a){_0x1e9521['push'](_0x1e9521['shift']());}};_0x2106f2(++_0x396374);}(_0xe0c2,0xd7));var _0x2e0c=function(_0x4cff96,_0x584782){_0x4cff96=_0x4cff96-0x0;var _0x39dd96=_0xe0c2[_0x4cff96];return _0x39dd96;};'use strict';var schema=require(_0x2e0c('0x0'));var _=require(_0x2e0c('0x1'));var util=require(_0x2e0c('0x2'));var seqqueue=require(_0x2e0c('0x3'));var logger=require('../../../../config/logger')(_0x2e0c('0x4'));var strategy=require('./strategy');var queue=schema({'name':{'type':'string','required':!![],'message':_0x2e0c('0x5')},'timeout':{'type':_0x2e0c('0x6'),'message':_0x2e0c('0x7')}});function writeLog(_0x45d592,_0x40a5ff,_0x15c4d4){return logger[_0x2e0c('0x8')](util[_0x2e0c('0x9')](_0x2e0c('0xa'),_0x45d592,_0x40a5ff[_0x2e0c('0xb')],_0x15c4d4));}function handleFindAgent(_0x5d4fef){return function(_0x2381ca){return _0x2381ca[_0x2e0c('0xb')][_0x2e0c('0xc')]()===_0x5d4fef[_0x2e0c('0xc')]();};}exports[_0x2e0c('0xd')]=function(_0x3a84dd,_0x304d4f,_0x2b858c,_0x3c7378){return function(_0x1a0e95){try{var _0x328f03={'name':_0x304d4f[0x0],'timeout':_0x304d4f[0x1]};var _0x59a87e=queue[_0x2e0c('0x0')](_0x328f03,{'typecast':!![]});if(_0x59a87e['length']){logger['error'](_0x2e0c('0xe'),_0x3a84dd,_[_0x2e0c('0xf')](_0x59a87e,'message')[_0x2e0c('0x10')](',\x20'));_0x1a0e95[_0x2e0c('0x11')]();}else{var _0x524619=_[_0x2e0c('0x12')](_0x2b858c[_0x2e0c('0x13')],handleFindAgent(_0x328f03[_0x2e0c('0xb')]));if(_0x524619){var _0x5d23ec=(_0x328f03['timeout']||0xa)*0x3e8;var _0x91310d,_0x368c6d;var _0x9d2f17=seqqueue['createQueue'](_0x5d23ec);_0x9d2f17['id']=_0x3a84dd;_0x9d2f17[_0x2e0c('0x14')]=_0x5d23ec;_0x9d2f17[_0x2e0c('0x15')]=_0x3c7378[_0x2e0c('0x15')];writeLog(_0x3a84dd,_0x524619,util['format']('START:%s',_0x5d23ec));_0x2b858c[_0x2e0c('0x16')][_0x3a84dd]['on'](_0x2e0c('0x17'),function(){_0x9d2f17[_0x2e0c('0x18')]();clearTimeout(_0x368c6d);_0x368c6d=undefined;if(_0x2b858c[_0x2e0c('0x16')][_0x3a84dd]){delete _0x2b858c[_0x2e0c('0x16')][_0x3a84dd];}logger[_0x2e0c('0x8')](_0x2e0c('0x19'),_0x3a84dd);_0x1a0e95[_0x2e0c('0x11')]();});_0x368c6d=setTimeout(function(){clearTimeout(_0x368c6d);_0x9d2f17[_0x2e0c('0x18')]();logger[_0x2e0c('0x8')](_0x2e0c('0x1a'),_0x3a84dd);_0x1a0e95[_0x2e0c('0x1b')]();},_0x5d23ec);strategy[_0x2e0c('0x1c')](_0x9d2f17,_0x524619,_0x2b858c,_0x3c7378);}else{logger[_0x2e0c('0x1d')](_0x2e0c('0x1e'),_0x3a84dd,_0x328f03[_0x2e0c('0xb')]);_0x1a0e95[_0x2e0c('0x11')]();}}}catch(_0x1a779a){console[_0x2e0c('0x1f')](_0x1a779a);logger[_0x2e0c('0x1d')]('[%s][QUEUE]\x20%s',_0x3a84dd,_0x1a779a[_0x2e0c('0x20')]);_0x1a0e95[_0x2e0c('0x11')]();}};};
\ No newline at end of file
git://repos.xcallymotion.com / motion2.git / blobdiff