// * treaties. The SOFTWARE PRODUCT is licensed, not sold. *
// * *
// *************************************************************************
-var _0x6046=['number','timeout\x20is\x20a\x20number','info','format','[%s][AGENT][NAME:%s][STATUS:%s]','consequence','length','error','[%s][AGENT]\x20%s','map','join','stop','find','agents','name','timeout','createQueue','START:%s','rules','end','[%s][AGENT]\x20ROUTING\x20STOPPED','close','[%s][AGENT]\x20ROUTING\x20END','next','agent','[%s][AGENT]\x20agent\x20not\x20found\x20%s','log','[%s][QUEUE]\x20%s','validate','../../../../config/logger','routing','./strategy'];(function(_0x425b54,_0x40a8a4){var _0x1bbb97=function(_0x19ca30){while(--_0x19ca30){_0x425b54['push'](_0x425b54['shift']());}};_0x1bbb97(++_0x40a8a4);}(_0x6046,0x11c));var _0x6604=function(_0x45ca06,_0x36aacf){_0x45ca06=_0x45ca06-0x0;var _0x2d3c9d=_0x6046[_0x45ca06];return _0x2d3c9d;};'use strict';var schema=require(_0x6604('0x0'));var _=require('lodash');var util=require('util');var seqqueue=require('seq-queue');var logger=require(_0x6604('0x1'))(_0x6604('0x2'));var strategy=require(_0x6604('0x3'));var queue=schema({'name':{'type':'string','required':!![],'message':'name\x20is\x20a\x20string\x20and\x20it\x20is\x20required'},'timeout':{'type':_0x6604('0x4'),'message':_0x6604('0x5')}});function writeLog(_0x178b9a,_0x4f6e9c,_0x27ad1c){return logger[_0x6604('0x6')](util[_0x6604('0x7')](_0x6604('0x8'),_0x178b9a,_0x4f6e9c['name'],_0x27ad1c));}function handleFindAgent(_0x36bfde){return function(_0x167876){return _0x167876['name']['toLowerCase']()===_0x36bfde['toLowerCase']();};}exports[_0x6604('0x9')]=function(_0x23c99c,_0x127153,_0x5d6901,_0xf42538){return function(_0x4a5bcb){try{var _0x52a75b={'name':_0x127153[0x0],'timeout':_0x127153[0x1]};var _0x2e7179=queue['validate'](_0x52a75b,{'typecast':!![]});if(_0x2e7179[_0x6604('0xa')]){logger[_0x6604('0xb')](_0x6604('0xc'),_0x23c99c,_[_0x6604('0xd')](_0x2e7179,'message')[_0x6604('0xe')](',\x20'));_0x4a5bcb[_0x6604('0xf')]();}else{var _0x4bd90d=_[_0x6604('0x10')](_0x5d6901[_0x6604('0x11')],handleFindAgent(_0x52a75b[_0x6604('0x12')]));if(_0x4bd90d){var _0xc26038=(_0x52a75b[_0x6604('0x13')]||0xa)*0x3e8;var _0x265978,_0x53d1f7;var _0x584a4a=seqqueue[_0x6604('0x14')](_0xc26038);_0x584a4a['id']=_0x23c99c;_0x584a4a['atimeout']=_0xc26038;_0x584a4a['channel']=_0xf42538['channel'];writeLog(_0x23c99c,_0x4bd90d,util[_0x6604('0x7')](_0x6604('0x15'),_0xc26038));_0x5d6901[_0x6604('0x16')][_0x23c99c]['on'](_0x6604('0x17'),function(){logger[_0x6604('0x6')](_0x6604('0x18'),_0x23c99c);clearTimeout(_0x53d1f7);_0x53d1f7=undefined;_0x584a4a[_0x6604('0x19')]();if(_0x5d6901[_0x6604('0x16')][_0x23c99c]){delete _0x5d6901['rules'][_0x23c99c];}_0x4a5bcb['stop']();});_0x5d6901['rules'][_0x23c99c]['on']('complete',function(){if(_0x5d6901[_0x6604('0x16')][_0x23c99c]){delete _0x5d6901[_0x6604('0x16')][_0x23c99c];}});_0x53d1f7=setTimeout(function(){logger[_0x6604('0x6')](_0x6604('0x1a'),_0x23c99c);clearTimeout(_0x53d1f7);_0x584a4a['close']();_0x4a5bcb[_0x6604('0x1b')]();},_0xc26038);strategy[_0x6604('0x1c')](_0x584a4a,_0x4bd90d,_0x5d6901,_0xf42538);}else{logger[_0x6604('0xb')](_0x6604('0x1d'),_0x23c99c,_0x52a75b[_0x6604('0x12')]);_0x4a5bcb[_0x6604('0xf')]();}}}catch(_0x43cbf6){console[_0x6604('0x1e')](_0x43cbf6);logger[_0x6604('0xb')](_0x6604('0x1f'),_0x23c99c,_0x43cbf6['stack']);_0x4a5bcb[_0x6604('0xf')]();}};};
\ No newline at end of file
+var _0x03f5=['agent','[%s][AGENT]\x20agent\x20not\x20found\x20%s','[%s][QUEUE]\x20%s','validate','lodash','util','seq-queue','../../../../config/logger','routing','./strategy','string','timeout\x20is\x20a\x20number','info','format','[%s][AGENT][NAME:%s][STATUS:%s]','name','toLowerCase','consequence','length','error','[%s][AGENT]\x20%s','map','message','join','stop','agents','timeout','createQueue','channel','rules','end','close','complete','[%s][AGENT]\x20ROUTING\x20END','next'];(function(_0x565c49,_0x54acd0){var _0x20ca34=function(_0x42f7e1){while(--_0x42f7e1){_0x565c49['push'](_0x565c49['shift']());}};_0x20ca34(++_0x54acd0);}(_0x03f5,0x6c));var _0x503f=function(_0x3a81f7,_0x566379){_0x3a81f7=_0x3a81f7-0x0;var _0x5a5f8c=_0x03f5[_0x3a81f7];return _0x5a5f8c;};'use strict';var schema=require(_0x503f('0x0'));var _=require(_0x503f('0x1'));var util=require(_0x503f('0x2'));var seqqueue=require(_0x503f('0x3'));var logger=require(_0x503f('0x4'))(_0x503f('0x5'));var strategy=require(_0x503f('0x6'));var queue=schema({'name':{'type':_0x503f('0x7'),'required':!![],'message':'name\x20is\x20a\x20string\x20and\x20it\x20is\x20required'},'timeout':{'type':'number','message':_0x503f('0x8')}});function writeLog(_0x37f98d,_0x692c0b,_0x548642){return logger[_0x503f('0x9')](util[_0x503f('0xa')](_0x503f('0xb'),_0x37f98d,_0x692c0b['name'],_0x548642));}function handleFindAgent(_0x34cc3e){return function(_0x5c8e51){return _0x5c8e51[_0x503f('0xc')][_0x503f('0xd')]()===_0x34cc3e[_0x503f('0xd')]();};}exports[_0x503f('0xe')]=function(_0x30b85e,_0x3cb6e0,_0x414121,_0xe26733){return function(_0x2a6770){try{var _0x5dadf7={'name':_0x3cb6e0[0x0],'timeout':_0x3cb6e0[0x1]};var _0x550dcd=queue['validate'](_0x5dadf7,{'typecast':!![]});if(_0x550dcd[_0x503f('0xf')]){logger[_0x503f('0x10')](_0x503f('0x11'),_0x30b85e,_[_0x503f('0x12')](_0x550dcd,_0x503f('0x13'))[_0x503f('0x14')](',\x20'));_0x2a6770[_0x503f('0x15')]();}else{var _0x3d41fb=_['find'](_0x414121[_0x503f('0x16')],handleFindAgent(_0x5dadf7[_0x503f('0xc')]));if(_0x3d41fb){var _0x5c001c=(_0x5dadf7[_0x503f('0x17')]||0xa)*0x3e8;var _0x5d7887,_0x462d34;var _0x3497eb=seqqueue[_0x503f('0x18')](_0x5c001c);_0x3497eb['id']=_0x30b85e;_0x3497eb['atimeout']=_0x5c001c;_0x3497eb[_0x503f('0x19')]=_0xe26733['channel'];writeLog(_0x30b85e,_0x3d41fb,util[_0x503f('0xa')]('START:%s',_0x5c001c));_0x414121[_0x503f('0x1a')][_0x30b85e]['on'](_0x503f('0x1b'),function(){logger[_0x503f('0x9')]('[%s][AGENT]\x20ROUTING\x20STOPPED',_0x30b85e);clearTimeout(_0x462d34);_0x462d34=undefined;_0x3497eb[_0x503f('0x1c')]();if(_0x414121['rules'][_0x30b85e]){delete _0x414121[_0x503f('0x1a')][_0x30b85e];}_0x2a6770['stop']();});_0x414121[_0x503f('0x1a')][_0x30b85e]['on'](_0x503f('0x1d'),function(){if(_0x414121[_0x503f('0x1a')][_0x30b85e]){delete _0x414121[_0x503f('0x1a')][_0x30b85e];}});_0x462d34=setTimeout(function(){logger[_0x503f('0x9')](_0x503f('0x1e'),_0x30b85e);clearTimeout(_0x462d34);_0x3497eb['close']();_0x2a6770[_0x503f('0x1f')]();},_0x5c001c);strategy[_0x503f('0x20')](_0x3497eb,_0x3d41fb,_0x414121,_0xe26733);}else{logger[_0x503f('0x10')](_0x503f('0x21'),_0x30b85e,_0x5dadf7['name']);_0x2a6770[_0x503f('0x15')]();}}}catch(_0x447237){console['log'](_0x447237);logger[_0x503f('0x10')](_0x503f('0x22'),_0x30b85e,_0x447237['stack']);_0x2a6770[_0x503f('0x15')]();}};};
\ No newline at end of file
git://repos.xcallymotion.com / motion2.git / blobdiff