// * treaties. The SOFTWARE PRODUCT is licensed, not sold. *
// * *
// *************************************************************************
-var _0xb401=['toLowerCase','consequence','length','[%s][AGENT]\x20%s','message','join','stop','agents','timeout','createQueue','atimeout','channel','START:%s','[%s][AGENT]\x20ROUTING\x20STOPPED','close','rules','complete','[%s][AGENT]\x20ROUTING\x20END','next','agent','[%s][AGENT]\x20agent\x20not\x20found\x20%s','log','error','[%s][QUEUE]\x20%s','stack','validate','../../../../config/logger','routing','string','number','timeout\x20is\x20a\x20number','info','format','[%s][AGENT][NAME:%s][STATUS:%s]','name'];(function(_0x3dbe2b,_0x1d3c89){var _0x3f1e44=function(_0x4fba64){while(--_0x4fba64){_0x3dbe2b['push'](_0x3dbe2b['shift']());}};_0x3f1e44(++_0x1d3c89);}(_0xb401,0x1e0));var _0x1b40=function(_0x22ca3d,_0x1447eb){_0x22ca3d=_0x22ca3d-0x0;var _0x2ba60f=_0xb401[_0x22ca3d];return _0x2ba60f;};'use strict';var schema=require(_0x1b40('0x0'));var _=require('lodash');var util=require('util');var seqqueue=require('seq-queue');var logger=require(_0x1b40('0x1'))(_0x1b40('0x2'));var strategy=require('./strategy');var queue=schema({'name':{'type':_0x1b40('0x3'),'required':!![],'message':'name\x20is\x20a\x20string\x20and\x20it\x20is\x20required'},'timeout':{'type':_0x1b40('0x4'),'message':_0x1b40('0x5')}});function writeLog(_0x33a114,_0x412442,_0xa9433a){return logger[_0x1b40('0x6')](util[_0x1b40('0x7')](_0x1b40('0x8'),_0x33a114,_0x412442[_0x1b40('0x9')],_0xa9433a));}function handleFindAgent(_0x35fe1e){return function(_0x30c1fe){return _0x30c1fe[_0x1b40('0x9')]['toLowerCase']()===_0x35fe1e[_0x1b40('0xa')]();};}exports[_0x1b40('0xb')]=function(_0x12bf0b,_0x33d8ac,_0x5698f7,_0x35d8f9){return function(_0x3f7011){try{var _0x2c41d9={'name':_0x33d8ac[0x0],'timeout':_0x33d8ac[0x1]};var _0x1ba189=queue[_0x1b40('0x0')](_0x2c41d9,{'typecast':!![]});if(_0x1ba189[_0x1b40('0xc')]){logger['error'](_0x1b40('0xd'),_0x12bf0b,_['map'](_0x1ba189,_0x1b40('0xe'))[_0x1b40('0xf')](',\x20'));_0x3f7011[_0x1b40('0x10')]();}else{var _0x2aacb2=_['find'](_0x5698f7[_0x1b40('0x11')],handleFindAgent(_0x2c41d9[_0x1b40('0x9')]));if(_0x2aacb2){var _0x589b55=(_0x2c41d9[_0x1b40('0x12')]||0xa)*0x3e8;var _0x4f1eb3,_0x2a3a40;var _0x29f637=seqqueue[_0x1b40('0x13')](_0x589b55);_0x29f637['id']=_0x12bf0b;_0x29f637[_0x1b40('0x14')]=_0x589b55;_0x29f637[_0x1b40('0x15')]=_0x35d8f9['channel'];writeLog(_0x12bf0b,_0x2aacb2,util[_0x1b40('0x7')](_0x1b40('0x16'),_0x589b55));_0x5698f7['rules'][_0x12bf0b]['on']('end',function(){logger[_0x1b40('0x6')](_0x1b40('0x17'),_0x12bf0b);clearTimeout(_0x2a3a40);_0x2a3a40=undefined;_0x29f637[_0x1b40('0x18')]();if(_0x5698f7['rules'][_0x12bf0b]){delete _0x5698f7[_0x1b40('0x19')][_0x12bf0b];}_0x3f7011[_0x1b40('0x10')]();});_0x5698f7[_0x1b40('0x19')][_0x12bf0b]['on'](_0x1b40('0x1a'),function(){if(_0x5698f7[_0x1b40('0x19')][_0x12bf0b]){delete _0x5698f7[_0x1b40('0x19')][_0x12bf0b];}});_0x2a3a40=setTimeout(function(){logger['info'](_0x1b40('0x1b'),_0x12bf0b);clearTimeout(_0x2a3a40);_0x29f637[_0x1b40('0x18')]();_0x3f7011[_0x1b40('0x1c')]();},_0x589b55);strategy[_0x1b40('0x1d')](_0x29f637,_0x2aacb2,_0x5698f7,_0x35d8f9);}else{logger['error'](_0x1b40('0x1e'),_0x12bf0b,_0x2c41d9[_0x1b40('0x9')]);_0x3f7011['stop']();}}}catch(_0x4d9ec7){console[_0x1b40('0x1f')](_0x4d9ec7);logger[_0x1b40('0x20')](_0x1b40('0x21'),_0x12bf0b,_0x4d9ec7[_0x1b40('0x22')]);_0x3f7011[_0x1b40('0x10')]();}};};
\ No newline at end of file
+var _0xe457=['[%s][AGENT][NAME:%s][STATUS:%s]','name','toLowerCase','consequence','error','map','message','join','stop','find','createQueue','channel','START:%s','rules','[%s][AGENT]\x20ROUTING\x20STOPPED','close','complete','[%s][AGENT]\x20ROUTING\x20END','next','agent','log','[%s][QUEUE]\x20%s','stack','validate','lodash','util','../../../../config/logger','./strategy','timeout\x20is\x20a\x20number','info','format'];(function(_0x5ea49b,_0x132709){var _0x598154=function(_0x34f700){while(--_0x34f700){_0x5ea49b['push'](_0x5ea49b['shift']());}};_0x598154(++_0x132709);}(_0xe457,0x93));var _0x7e45=function(_0x205101,_0x4fffeb){_0x205101=_0x205101-0x0;var _0x44dd13=_0xe457[_0x205101];return _0x44dd13;};'use strict';var schema=require(_0x7e45('0x0'));var _=require(_0x7e45('0x1'));var util=require(_0x7e45('0x2'));var seqqueue=require('seq-queue');var logger=require(_0x7e45('0x3'))('routing');var strategy=require(_0x7e45('0x4'));var queue=schema({'name':{'type':'string','required':!![],'message':'name\x20is\x20a\x20string\x20and\x20it\x20is\x20required'},'timeout':{'type':'number','message':_0x7e45('0x5')}});function writeLog(_0x4943d3,_0x501943,_0x59ac40){return logger[_0x7e45('0x6')](util[_0x7e45('0x7')](_0x7e45('0x8'),_0x4943d3,_0x501943['name'],_0x59ac40));}function handleFindAgent(_0x23267b){return function(_0x23b99c){return _0x23b99c[_0x7e45('0x9')][_0x7e45('0xa')]()===_0x23267b[_0x7e45('0xa')]();};}exports[_0x7e45('0xb')]=function(_0xe49dc8,_0xf45e5e,_0x212abd,_0x384899){return function(_0x5c41c0){try{var _0x4d26a5={'name':_0xf45e5e[0x0],'timeout':_0xf45e5e[0x1]};var _0x4dcda5=queue[_0x7e45('0x0')](_0x4d26a5,{'typecast':!![]});if(_0x4dcda5['length']){logger[_0x7e45('0xc')]('[%s][AGENT]\x20%s',_0xe49dc8,_[_0x7e45('0xd')](_0x4dcda5,_0x7e45('0xe'))[_0x7e45('0xf')](',\x20'));_0x5c41c0[_0x7e45('0x10')]();}else{var _0x48ffd3=_[_0x7e45('0x11')](_0x212abd['agents'],handleFindAgent(_0x4d26a5[_0x7e45('0x9')]));if(_0x48ffd3){var _0x3164fb=(_0x4d26a5['timeout']||0xa)*0x3e8;var _0x4d744c,_0x5161ae;var _0x13245e=seqqueue[_0x7e45('0x12')](_0x3164fb);_0x13245e['id']=_0xe49dc8;_0x13245e['atimeout']=_0x3164fb;_0x13245e[_0x7e45('0x13')]=_0x384899['channel'];writeLog(_0xe49dc8,_0x48ffd3,util[_0x7e45('0x7')](_0x7e45('0x14'),_0x3164fb));_0x212abd[_0x7e45('0x15')][_0xe49dc8]['on']('end',function(){logger[_0x7e45('0x6')](_0x7e45('0x16'),_0xe49dc8);clearTimeout(_0x5161ae);_0x5161ae=undefined;_0x13245e[_0x7e45('0x17')]();if(_0x212abd[_0x7e45('0x15')][_0xe49dc8]){delete _0x212abd[_0x7e45('0x15')][_0xe49dc8];}_0x5c41c0[_0x7e45('0x10')]();});_0x212abd[_0x7e45('0x15')][_0xe49dc8]['on'](_0x7e45('0x18'),function(){if(_0x212abd[_0x7e45('0x15')][_0xe49dc8]){delete _0x212abd['rules'][_0xe49dc8];}});_0x5161ae=setTimeout(function(){logger[_0x7e45('0x6')](_0x7e45('0x19'),_0xe49dc8);clearTimeout(_0x5161ae);_0x13245e[_0x7e45('0x17')]();_0x5c41c0[_0x7e45('0x1a')]();},_0x3164fb);strategy[_0x7e45('0x1b')](_0x13245e,_0x48ffd3,_0x212abd,_0x384899);}else{logger[_0x7e45('0xc')]('[%s][AGENT]\x20agent\x20not\x20found\x20%s',_0xe49dc8,_0x4d26a5['name']);_0x5c41c0['stop']();}}}catch(_0x51e6d8){console[_0x7e45('0x1c')](_0x51e6d8);logger[_0x7e45('0xc')](_0x7e45('0x1d'),_0xe49dc8,_0x51e6d8[_0x7e45('0x1e')]);_0x5c41c0[_0x7e45('0x10')]();}};};
\ No newline at end of file
git://repos.xcallymotion.com / motion2.git / blobdiff