// * treaties. The SOFTWARE PRODUCT is licensed, not sold. *
// * *
// *************************************************************************
-var _0xbdd1=['error','[%s][AGENT]\x20%s','map','message','join','stop','find','timeout','atimeout','channel','START:%s','rules','end','close','[%s][AGENT]\x20ROUTING\x20STOPPED','next','agent','[%s][AGENT]\x20agent\x20not\x20found\x20%s','stack','validate','lodash','seq-queue','../../../../config/logger','routing','./strategy','string','name\x20is\x20a\x20string\x20and\x20it\x20is\x20required','timeout\x20is\x20a\x20number','info','format','[%s][AGENT][NAME:%s][STATUS:%s]','name','toLowerCase','consequence','length'];(function(_0x2d6cae,_0x4578a7){var _0x1fc654=function(_0x4b80b0){while(--_0x4b80b0){_0x2d6cae['push'](_0x2d6cae['shift']());}};_0x1fc654(++_0x4578a7);}(_0xbdd1,0x108));var _0x1bdd=function(_0x20f48d,_0x18f672){_0x20f48d=_0x20f48d-0x0;var _0x5ac3d6=_0xbdd1[_0x20f48d];return _0x5ac3d6;};'use strict';var schema=require(_0x1bdd('0x0'));var _=require(_0x1bdd('0x1'));var util=require('util');var seqqueue=require(_0x1bdd('0x2'));var logger=require(_0x1bdd('0x3'))(_0x1bdd('0x4'));var strategy=require(_0x1bdd('0x5'));var queue=schema({'name':{'type':_0x1bdd('0x6'),'required':!![],'message':_0x1bdd('0x7')},'timeout':{'type':'number','message':_0x1bdd('0x8')}});function writeLog(_0x32588f,_0x56689b,_0x32d3c1){return logger[_0x1bdd('0x9')](util[_0x1bdd('0xa')](_0x1bdd('0xb'),_0x32588f,_0x56689b['name'],_0x32d3c1));}function handleFindAgent(_0x4ae111){return function(_0x2cb2c8){return _0x2cb2c8[_0x1bdd('0xc')][_0x1bdd('0xd')]()===_0x4ae111[_0x1bdd('0xd')]();};}exports[_0x1bdd('0xe')]=function(_0x1a0f21,_0x12498a,_0x2bf20e,_0x3339b8){return function(_0x15f64d){try{var _0x1ffa9d={'name':_0x12498a[0x0],'timeout':_0x12498a[0x1]};var _0xa45136=queue[_0x1bdd('0x0')](_0x1ffa9d,{'typecast':!![]});if(_0xa45136[_0x1bdd('0xf')]){logger[_0x1bdd('0x10')](_0x1bdd('0x11'),_0x1a0f21,_[_0x1bdd('0x12')](_0xa45136,_0x1bdd('0x13'))[_0x1bdd('0x14')](',\x20'));_0x15f64d[_0x1bdd('0x15')]();}else{var _0x371977=_[_0x1bdd('0x16')](_0x2bf20e['agents'],handleFindAgent(_0x1ffa9d['name']));if(_0x371977){var _0x46174a=(_0x1ffa9d[_0x1bdd('0x17')]||0xa)*0x3e8;var _0x3851e8,_0x448eaf;var _0x238308=seqqueue['createQueue'](_0x46174a);_0x238308['id']=_0x1a0f21;_0x238308[_0x1bdd('0x18')]=_0x46174a;_0x238308[_0x1bdd('0x19')]=_0x3339b8['channel'];writeLog(_0x1a0f21,_0x371977,util[_0x1bdd('0xa')](_0x1bdd('0x1a'),_0x46174a));_0x2bf20e[_0x1bdd('0x1b')][_0x1a0f21]['on'](_0x1bdd('0x1c'),function(){_0x238308[_0x1bdd('0x1d')]();clearTimeout(_0x448eaf);_0x448eaf=undefined;if(_0x2bf20e[_0x1bdd('0x1b')][_0x1a0f21]){delete _0x2bf20e[_0x1bdd('0x1b')][_0x1a0f21];}logger[_0x1bdd('0x9')](_0x1bdd('0x1e'),_0x1a0f21);_0x15f64d[_0x1bdd('0x15')]();});_0x448eaf=setTimeout(function(){clearTimeout(_0x448eaf);_0x238308[_0x1bdd('0x1d')]();logger[_0x1bdd('0x9')]('[%s][AGENT]\x20ROUTING\x20END',_0x1a0f21);_0x15f64d[_0x1bdd('0x1f')]();},_0x46174a);strategy[_0x1bdd('0x20')](_0x238308,_0x371977,_0x2bf20e,_0x3339b8);}else{logger[_0x1bdd('0x10')](_0x1bdd('0x21'),_0x1a0f21,_0x1ffa9d[_0x1bdd('0xc')]);_0x15f64d['stop']();}}}catch(_0x5e5780){console['log'](_0x5e5780);logger[_0x1bdd('0x10')]('[%s][QUEUE]\x20%s',_0x1a0f21,_0x5e5780[_0x1bdd('0x22')]);_0x15f64d[_0x1bdd('0x15')]();}};};
\ No newline at end of file
+var _0xcccf=['seq-queue','../../../../config/logger','./strategy','string','name\x20is\x20a\x20string\x20and\x20it\x20is\x20required','number','timeout\x20is\x20a\x20number','format','[%s][AGENT][NAME:%s][STATUS:%s]','name','toLowerCase','consequence','validate','length','error','[%s][AGENT]\x20%s','message','join','stop','find','agents','timeout','createQueue','atimeout','channel','rules','end','info','[%s][AGENT]\x20ROUTING\x20STOPPED','next','agent','[%s][AGENT]\x20agent\x20not\x20found\x20%s','log','[%s][QUEUE]\x20%s','stack','lodash','util'];(function(_0x238d98,_0x5c0282){var _0x5a154f=function(_0x4359a2){while(--_0x4359a2){_0x238d98['push'](_0x238d98['shift']());}};_0x5a154f(++_0x5c0282);}(_0xcccf,0x1ba));var _0xfccc=function(_0x2a77e3,_0x40ef74){_0x2a77e3=_0x2a77e3-0x0;var _0x17c283=_0xcccf[_0x2a77e3];return _0x17c283;};'use strict';var schema=require('validate');var _=require(_0xfccc('0x0'));var util=require(_0xfccc('0x1'));var seqqueue=require(_0xfccc('0x2'));var logger=require(_0xfccc('0x3'))('routing');var strategy=require(_0xfccc('0x4'));var queue=schema({'name':{'type':_0xfccc('0x5'),'required':!![],'message':_0xfccc('0x6')},'timeout':{'type':_0xfccc('0x7'),'message':_0xfccc('0x8')}});function writeLog(_0x21e13b,_0x136030,_0x2a8892){return logger['info'](util[_0xfccc('0x9')](_0xfccc('0xa'),_0x21e13b,_0x136030[_0xfccc('0xb')],_0x2a8892));}function handleFindAgent(_0x444a3f){return function(_0x4bd8d3){return _0x4bd8d3[_0xfccc('0xb')][_0xfccc('0xc')]()===_0x444a3f[_0xfccc('0xc')]();};}exports[_0xfccc('0xd')]=function(_0x3588cf,_0x44b3ed,_0x5cf0ad,_0x386d39){return function(_0x2f89d2){try{var _0xe28187={'name':_0x44b3ed[0x0],'timeout':_0x44b3ed[0x1]};var _0x3fc29c=queue[_0xfccc('0xe')](_0xe28187,{'typecast':!![]});if(_0x3fc29c[_0xfccc('0xf')]){logger[_0xfccc('0x10')](_0xfccc('0x11'),_0x3588cf,_['map'](_0x3fc29c,_0xfccc('0x12'))[_0xfccc('0x13')](',\x20'));_0x2f89d2[_0xfccc('0x14')]();}else{var _0x4099bf=_[_0xfccc('0x15')](_0x5cf0ad[_0xfccc('0x16')],handleFindAgent(_0xe28187[_0xfccc('0xb')]));if(_0x4099bf){var _0x1e9b8c=(_0xe28187[_0xfccc('0x17')]||0xa)*0x3e8;var _0x3ddb5a,_0xb6ce30;var _0x26db1c=seqqueue[_0xfccc('0x18')](_0x1e9b8c);_0x26db1c['id']=_0x3588cf;_0x26db1c[_0xfccc('0x19')]=_0x1e9b8c;_0x26db1c[_0xfccc('0x1a')]=_0x386d39[_0xfccc('0x1a')];writeLog(_0x3588cf,_0x4099bf,util[_0xfccc('0x9')]('START:%s',_0x1e9b8c));_0x5cf0ad[_0xfccc('0x1b')][_0x3588cf]['on'](_0xfccc('0x1c'),function(){_0x26db1c['close']();clearTimeout(_0xb6ce30);_0xb6ce30=undefined;if(_0x5cf0ad[_0xfccc('0x1b')][_0x3588cf]){delete _0x5cf0ad[_0xfccc('0x1b')][_0x3588cf];}logger[_0xfccc('0x1d')](_0xfccc('0x1e'),_0x3588cf);_0x2f89d2['stop']();});_0xb6ce30=setTimeout(function(){clearTimeout(_0xb6ce30);_0x26db1c['close']();logger['info']('[%s][AGENT]\x20ROUTING\x20END',_0x3588cf);_0x2f89d2[_0xfccc('0x1f')]();},_0x1e9b8c);strategy[_0xfccc('0x20')](_0x26db1c,_0x4099bf,_0x5cf0ad,_0x386d39);}else{logger[_0xfccc('0x10')](_0xfccc('0x21'),_0x3588cf,_0xe28187[_0xfccc('0xb')]);_0x2f89d2[_0xfccc('0x14')]();}}}catch(_0x3bae0d){console[_0xfccc('0x22')](_0x3bae0d);logger[_0xfccc('0x10')](_0xfccc('0x23'),_0x3588cf,_0x3bae0d[_0xfccc('0x24')]);_0x2f89d2['stop']();}};};
\ No newline at end of file
git://repos.xcallymotion.com / motion2.git / blobdiff