// * treaties. The SOFTWARE PRODUCT is licensed, not sold. *
// * *
// *************************************************************************
-var _0x563e=['[%s][QUEUE]\x20%s','stack','validate','lodash','util','seq-queue','../../../../config/logger','routing','./strategy','name\x20is\x20a\x20string\x20and\x20it\x20is\x20required','number','timeout\x20is\x20a\x20number','info','[%s][AGENT][NAME:%s][STATUS:%s]','name','toLowerCase','consequence','error','[%s][AGENT]\x20%s','message','stop','find','timeout','atimeout','channel','format','START:%s','rules','end','[%s][AGENT]\x20ROUTING\x20STOPPED','close','[%s][AGENT]\x20ROUTING\x20END','next','agent','[%s][AGENT]\x20agent\x20not\x20found\x20%s','log'];(function(_0x1a7ac0,_0x5798be){var _0x5f1f6b=function(_0x4dc588){while(--_0x4dc588){_0x1a7ac0['push'](_0x1a7ac0['shift']());}};_0x5f1f6b(++_0x5798be);}(_0x563e,0x6e));var _0xe563=function(_0x26d9b3,_0x591f4e){_0x26d9b3=_0x26d9b3-0x0;var _0x15c226=_0x563e[_0x26d9b3];return _0x15c226;};'use strict';var schema=require(_0xe563('0x0'));var _=require(_0xe563('0x1'));var util=require(_0xe563('0x2'));var seqqueue=require(_0xe563('0x3'));var logger=require(_0xe563('0x4'))(_0xe563('0x5'));var strategy=require(_0xe563('0x6'));var queue=schema({'name':{'type':'string','required':!![],'message':_0xe563('0x7')},'timeout':{'type':_0xe563('0x8'),'message':_0xe563('0x9')}});function writeLog(_0x23fb74,_0x1f64a1,_0xe05464){return logger[_0xe563('0xa')](util['format'](_0xe563('0xb'),_0x23fb74,_0x1f64a1[_0xe563('0xc')],_0xe05464));}function handleFindAgent(_0x53a8a4){return function(_0x3ba0a5){return _0x3ba0a5[_0xe563('0xc')][_0xe563('0xd')]()===_0x53a8a4['toLowerCase']();};}exports[_0xe563('0xe')]=function(_0x343916,_0x3f5068,_0x4eb403,_0xfbfa39){return function(_0x2a5937){try{var _0x33a638={'name':_0x3f5068[0x0],'timeout':_0x3f5068[0x1]};var _0x13e217=queue[_0xe563('0x0')](_0x33a638,{'typecast':!![]});if(_0x13e217['length']){logger[_0xe563('0xf')](_0xe563('0x10'),_0x343916,_['map'](_0x13e217,_0xe563('0x11'))['join'](',\x20'));_0x2a5937[_0xe563('0x12')]();}else{var _0x37dcc9=_[_0xe563('0x13')](_0x4eb403['agents'],handleFindAgent(_0x33a638['name']));if(_0x37dcc9){var _0x11c706=(_0x33a638[_0xe563('0x14')]||0xa)*0x3e8;var _0xffe39b,_0x989f42;var _0x4e4dba=seqqueue['createQueue'](_0x11c706);_0x4e4dba['id']=_0x343916;_0x4e4dba[_0xe563('0x15')]=_0x11c706;_0x4e4dba[_0xe563('0x16')]=_0xfbfa39[_0xe563('0x16')];writeLog(_0x343916,_0x37dcc9,util[_0xe563('0x17')](_0xe563('0x18'),_0x11c706));_0x4eb403[_0xe563('0x19')][_0x343916]['on'](_0xe563('0x1a'),function(){logger[_0xe563('0xa')](_0xe563('0x1b'),_0x343916);clearTimeout(_0x989f42);_0x989f42=undefined;_0x4e4dba[_0xe563('0x1c')]();if(_0x4eb403[_0xe563('0x19')][_0x343916]){delete _0x4eb403[_0xe563('0x19')][_0x343916];}_0x2a5937[_0xe563('0x12')]();});_0x4eb403[_0xe563('0x19')][_0x343916]['on']('complete',function(){if(_0x4eb403[_0xe563('0x19')][_0x343916]){delete _0x4eb403['rules'][_0x343916];}});_0x989f42=setTimeout(function(){logger[_0xe563('0xa')](_0xe563('0x1d'),_0x343916);clearTimeout(_0x989f42);_0x4e4dba['close']();_0x2a5937[_0xe563('0x1e')]();},_0x11c706);strategy[_0xe563('0x1f')](_0x4e4dba,_0x37dcc9,_0x4eb403,_0xfbfa39);}else{logger[_0xe563('0xf')](_0xe563('0x20'),_0x343916,_0x33a638[_0xe563('0xc')]);_0x2a5937[_0xe563('0x12')]();}}}catch(_0x13699c){console[_0xe563('0x21')](_0x13699c);logger[_0xe563('0xf')](_0xe563('0x22'),_0x343916,_0x13699c[_0xe563('0x23')]);_0x2a5937[_0xe563('0x12')]();}};};
\ No newline at end of file
+var _0xad7f=['end','[%s][AGENT]\x20ROUTING\x20STOPPED','close','complete','[%s][AGENT]\x20ROUTING\x20END','next','agent','[%s][AGENT]\x20agent\x20not\x20found\x20%s','log','[%s][QUEUE]\x20%s','lodash','seq-queue','../../../../config/logger','routing','string','name\x20is\x20a\x20string\x20and\x20it\x20is\x20required','number','info','[%s][AGENT][NAME:%s][STATUS:%s]','name','toLowerCase','validate','length','error','[%s][AGENT]\x20%s','map','message','join','stop','find','agents','timeout','createQueue','atimeout','channel','START:%s','rules'];(function(_0x3d9473,_0x312025){var _0x5a8289=function(_0x294cbe){while(--_0x294cbe){_0x3d9473['push'](_0x3d9473['shift']());}};_0x5a8289(++_0x312025);}(_0xad7f,0x157));var _0xfad7=function(_0x4978de,_0x5912e4){_0x4978de=_0x4978de-0x0;var _0x675221=_0xad7f[_0x4978de];return _0x675221;};'use strict';var schema=require('validate');var _=require(_0xfad7('0x0'));var util=require('util');var seqqueue=require(_0xfad7('0x1'));var logger=require(_0xfad7('0x2'))(_0xfad7('0x3'));var strategy=require('./strategy');var queue=schema({'name':{'type':_0xfad7('0x4'),'required':!![],'message':_0xfad7('0x5')},'timeout':{'type':_0xfad7('0x6'),'message':'timeout\x20is\x20a\x20number'}});function writeLog(_0x5b4c5a,_0x46ff77,_0x21cfeb){return logger[_0xfad7('0x7')](util['format'](_0xfad7('0x8'),_0x5b4c5a,_0x46ff77[_0xfad7('0x9')],_0x21cfeb));}function handleFindAgent(_0x1d5d33){return function(_0x4a665f){return _0x4a665f[_0xfad7('0x9')][_0xfad7('0xa')]()===_0x1d5d33['toLowerCase']();};}exports['consequence']=function(_0x2334a4,_0x32c4e4,_0x4e1c0e,_0x4e0873){return function(_0x35a6e6){try{var _0x123ab5={'name':_0x32c4e4[0x0],'timeout':_0x32c4e4[0x1]};var _0x4e348a=queue[_0xfad7('0xb')](_0x123ab5,{'typecast':!![]});if(_0x4e348a[_0xfad7('0xc')]){logger[_0xfad7('0xd')](_0xfad7('0xe'),_0x2334a4,_[_0xfad7('0xf')](_0x4e348a,_0xfad7('0x10'))[_0xfad7('0x11')](',\x20'));_0x35a6e6[_0xfad7('0x12')]();}else{var _0x1cbfef=_[_0xfad7('0x13')](_0x4e1c0e[_0xfad7('0x14')],handleFindAgent(_0x123ab5[_0xfad7('0x9')]));if(_0x1cbfef){var _0x78c339=(_0x123ab5[_0xfad7('0x15')]||0xa)*0x3e8;var _0x59bca7,_0x374282;var _0x3bebb1=seqqueue[_0xfad7('0x16')](_0x78c339);_0x3bebb1['id']=_0x2334a4;_0x3bebb1[_0xfad7('0x17')]=_0x78c339;_0x3bebb1[_0xfad7('0x18')]=_0x4e0873[_0xfad7('0x18')];writeLog(_0x2334a4,_0x1cbfef,util['format'](_0xfad7('0x19'),_0x78c339));_0x4e1c0e[_0xfad7('0x1a')][_0x2334a4]['on'](_0xfad7('0x1b'),function(){logger[_0xfad7('0x7')](_0xfad7('0x1c'),_0x2334a4);clearTimeout(_0x374282);_0x374282=undefined;_0x3bebb1[_0xfad7('0x1d')]();if(_0x4e1c0e[_0xfad7('0x1a')][_0x2334a4]){delete _0x4e1c0e[_0xfad7('0x1a')][_0x2334a4];}_0x35a6e6['stop']();});_0x4e1c0e[_0xfad7('0x1a')][_0x2334a4]['on'](_0xfad7('0x1e'),function(){if(_0x4e1c0e[_0xfad7('0x1a')][_0x2334a4]){delete _0x4e1c0e['rules'][_0x2334a4];}});_0x374282=setTimeout(function(){logger['info'](_0xfad7('0x1f'),_0x2334a4);clearTimeout(_0x374282);_0x3bebb1[_0xfad7('0x1d')]();_0x35a6e6[_0xfad7('0x20')]();},_0x78c339);strategy[_0xfad7('0x21')](_0x3bebb1,_0x1cbfef,_0x4e1c0e,_0x4e0873);}else{logger['error'](_0xfad7('0x22'),_0x2334a4,_0x123ab5[_0xfad7('0x9')]);_0x35a6e6[_0xfad7('0x12')]();}}}catch(_0x47069f){console[_0xfad7('0x23')](_0x47069f);logger['error'](_0xfad7('0x24'),_0x2334a4,_0x47069f['stack']);_0x35a6e6['stop']();}};};
\ No newline at end of file
git://repos.xcallymotion.com / motion2.git / blobdiff