// * treaties. The SOFTWARE PRODUCT is licensed, not sold. *
// * *
// *************************************************************************
-var _0x666c=['number','timeout\x20is\x20a\x20number','info','[%s][AGENT][NAME:%s][STATUS:%s]','name','toLowerCase','length','error','[%s][AGENT]\x20%s','map','join','stop','agents','timeout','createQueue','atimeout','channel','START:%s','rules','end','[%s][AGENT]\x20ROUTING\x20STOPPED','close','complete','[%s][AGENT]\x20ROUTING\x20END','agent','[%s][AGENT]\x20agent\x20not\x20found\x20%s','log','stack','validate','lodash','util','../../../../config/logger','routing','./strategy','string','name\x20is\x20a\x20string\x20and\x20it\x20is\x20required'];(function(_0x26ac27,_0x574b86){var _0x44a599=function(_0x130e2c){while(--_0x130e2c){_0x26ac27['push'](_0x26ac27['shift']());}};_0x44a599(++_0x574b86);}(_0x666c,0x1f0));var _0xc666=function(_0x231e16,_0x67347b){_0x231e16=_0x231e16-0x0;var _0x570a7c=_0x666c[_0x231e16];return _0x570a7c;};'use strict';var schema=require(_0xc666('0x0'));var _=require(_0xc666('0x1'));var util=require(_0xc666('0x2'));var seqqueue=require('seq-queue');var logger=require(_0xc666('0x3'))(_0xc666('0x4'));var strategy=require(_0xc666('0x5'));var queue=schema({'name':{'type':_0xc666('0x6'),'required':!![],'message':_0xc666('0x7')},'timeout':{'type':_0xc666('0x8'),'message':_0xc666('0x9')}});function writeLog(_0x12f820,_0x5b8cfe,_0x142da8){return logger[_0xc666('0xa')](util['format'](_0xc666('0xb'),_0x12f820,_0x5b8cfe[_0xc666('0xc')],_0x142da8));}function handleFindAgent(_0x5d4d44){return function(_0x58a76d){return _0x58a76d[_0xc666('0xc')][_0xc666('0xd')]()===_0x5d4d44[_0xc666('0xd')]();};}exports['consequence']=function(_0x49d789,_0x5bad47,_0x34d747,_0x1e96e4){return function(_0x21e176){try{var _0x27e325={'name':_0x5bad47[0x0],'timeout':_0x5bad47[0x1]};var _0x74e99c=queue[_0xc666('0x0')](_0x27e325,{'typecast':!![]});if(_0x74e99c[_0xc666('0xe')]){logger[_0xc666('0xf')](_0xc666('0x10'),_0x49d789,_[_0xc666('0x11')](_0x74e99c,'message')[_0xc666('0x12')](',\x20'));_0x21e176[_0xc666('0x13')]();}else{var _0x34ec62=_['find'](_0x34d747[_0xc666('0x14')],handleFindAgent(_0x27e325['name']));if(_0x34ec62){var _0x64bb42=(_0x27e325[_0xc666('0x15')]||0xa)*0x3e8;var _0x44cfa9,_0x5acd26;var _0x1b969f=seqqueue[_0xc666('0x16')](_0x64bb42);_0x1b969f['id']=_0x49d789;_0x1b969f[_0xc666('0x17')]=_0x64bb42;_0x1b969f['channel']=_0x1e96e4[_0xc666('0x18')];writeLog(_0x49d789,_0x34ec62,util['format'](_0xc666('0x19'),_0x64bb42));_0x34d747[_0xc666('0x1a')][_0x49d789]['on'](_0xc666('0x1b'),function(){logger[_0xc666('0xa')](_0xc666('0x1c'),_0x49d789);clearTimeout(_0x5acd26);_0x5acd26=undefined;_0x1b969f[_0xc666('0x1d')]();if(_0x34d747[_0xc666('0x1a')][_0x49d789]){delete _0x34d747['rules'][_0x49d789];}_0x21e176['stop']();});_0x34d747[_0xc666('0x1a')][_0x49d789]['on'](_0xc666('0x1e'),function(){if(_0x34d747['rules'][_0x49d789]){delete _0x34d747[_0xc666('0x1a')][_0x49d789];}});_0x5acd26=setTimeout(function(){logger['info'](_0xc666('0x1f'),_0x49d789);clearTimeout(_0x5acd26);_0x1b969f[_0xc666('0x1d')]();_0x21e176['next']();},_0x64bb42);strategy[_0xc666('0x20')](_0x1b969f,_0x34ec62,_0x34d747,_0x1e96e4);}else{logger['error'](_0xc666('0x21'),_0x49d789,_0x27e325[_0xc666('0xc')]);_0x21e176[_0xc666('0x13')]();}}}catch(_0x46f7a7){console[_0xc666('0x22')](_0x46f7a7);logger[_0xc666('0xf')]('[%s][QUEUE]\x20%s',_0x49d789,_0x46f7a7[_0xc666('0x23')]);_0x21e176[_0xc666('0x13')]();}};};
\ No newline at end of file
+var _0x5934=['find','agents','createQueue','channel','rules','end','[%s][AGENT]\x20ROUTING\x20STOPPED','close','stop','complete','[%s][AGENT]\x20ROUTING\x20END','next','error','[%s][AGENT]\x20agent\x20not\x20found\x20%s','log','[%s][QUEUE]\x20%s','util','../../../../config/logger','./strategy','string','number','timeout\x20is\x20a\x20number','info','format','[%s][AGENT][NAME:%s][STATUS:%s]','name','toLowerCase','consequence','validate','length','[%s][AGENT]\x20%s','map','message'];(function(_0x4b22d8,_0x7d1697){var _0x1882c5=function(_0x1c72d2){while(--_0x1c72d2){_0x4b22d8['push'](_0x4b22d8['shift']());}};_0x1882c5(++_0x7d1697);}(_0x5934,0xb5));var _0x4593=function(_0x2e15ca,_0x3c97e8){_0x2e15ca=_0x2e15ca-0x0;var _0x5e6b57=_0x5934[_0x2e15ca];return _0x5e6b57;};'use strict';var schema=require('validate');var _=require('lodash');var util=require(_0x4593('0x0'));var seqqueue=require('seq-queue');var logger=require(_0x4593('0x1'))('routing');var strategy=require(_0x4593('0x2'));var queue=schema({'name':{'type':_0x4593('0x3'),'required':!![],'message':'name\x20is\x20a\x20string\x20and\x20it\x20is\x20required'},'timeout':{'type':_0x4593('0x4'),'message':_0x4593('0x5')}});function writeLog(_0x52013e,_0x1dd2ff,_0x506b87){return logger[_0x4593('0x6')](util[_0x4593('0x7')](_0x4593('0x8'),_0x52013e,_0x1dd2ff[_0x4593('0x9')],_0x506b87));}function handleFindAgent(_0xc4fc5d){return function(_0x3f82f5){return _0x3f82f5[_0x4593('0x9')][_0x4593('0xa')]()===_0xc4fc5d[_0x4593('0xa')]();};}exports[_0x4593('0xb')]=function(_0x3958a9,_0x2b2160,_0x3c165d,_0x15b523){return function(_0x40fe88){try{var _0x3ec23d={'name':_0x2b2160[0x0],'timeout':_0x2b2160[0x1]};var _0x173ceb=queue[_0x4593('0xc')](_0x3ec23d,{'typecast':!![]});if(_0x173ceb[_0x4593('0xd')]){logger['error'](_0x4593('0xe'),_0x3958a9,_[_0x4593('0xf')](_0x173ceb,_0x4593('0x10'))['join'](',\x20'));_0x40fe88['stop']();}else{var _0x44637b=_[_0x4593('0x11')](_0x3c165d[_0x4593('0x12')],handleFindAgent(_0x3ec23d[_0x4593('0x9')]));if(_0x44637b){var _0x1da009=(_0x3ec23d['timeout']||0xa)*0x3e8;var _0xf0e291,_0xe76e3e;var _0x520fa3=seqqueue[_0x4593('0x13')](_0x1da009);_0x520fa3['id']=_0x3958a9;_0x520fa3['atimeout']=_0x1da009;_0x520fa3[_0x4593('0x14')]=_0x15b523[_0x4593('0x14')];writeLog(_0x3958a9,_0x44637b,util[_0x4593('0x7')]('START:%s',_0x1da009));_0x3c165d[_0x4593('0x15')][_0x3958a9]['on'](_0x4593('0x16'),function(){logger[_0x4593('0x6')](_0x4593('0x17'),_0x3958a9);clearTimeout(_0xe76e3e);_0xe76e3e=undefined;_0x520fa3[_0x4593('0x18')]();if(_0x3c165d['rules'][_0x3958a9]){delete _0x3c165d[_0x4593('0x15')][_0x3958a9];}_0x40fe88[_0x4593('0x19')]();});_0x3c165d[_0x4593('0x15')][_0x3958a9]['on'](_0x4593('0x1a'),function(){if(_0x3c165d[_0x4593('0x15')][_0x3958a9]){delete _0x3c165d['rules'][_0x3958a9];}});_0xe76e3e=setTimeout(function(){logger[_0x4593('0x6')](_0x4593('0x1b'),_0x3958a9);clearTimeout(_0xe76e3e);_0x520fa3['close']();_0x40fe88[_0x4593('0x1c')]();},_0x1da009);strategy['agent'](_0x520fa3,_0x44637b,_0x3c165d,_0x15b523);}else{logger[_0x4593('0x1d')](_0x4593('0x1e'),_0x3958a9,_0x3ec23d[_0x4593('0x9')]);_0x40fe88[_0x4593('0x19')]();}}}catch(_0x1abcce){console[_0x4593('0x1f')](_0x1abcce);logger[_0x4593('0x1d')](_0x4593('0x20'),_0x3958a9,_0x1abcce['stack']);_0x40fe88[_0x4593('0x19')]();}};};
\ No newline at end of file
git://repos.xcallymotion.com / motion2.git / blobdiff