// * treaties. The SOFTWARE PRODUCT is licensed, not sold. *
// * *
// *************************************************************************
-var _0xd0b2=['rules','close','stop','[%s][AGENT]\x20ROUTING\x20END','next','agent','log','[%s][QUEUE]\x20%s','validate','util','seq-queue','routing','string','info','format','[%s][AGENT][NAME:%s][STATUS:%s]','name','toLowerCase','length','error','[%s][AGENT]\x20%s','map','message','createQueue','atimeout','channel','START:%s'];(function(_0x583fc5,_0x302d7b){var _0x5e9b67=function(_0x4aa2e3){while(--_0x4aa2e3){_0x583fc5['push'](_0x583fc5['shift']());}};_0x5e9b67(++_0x302d7b);}(_0xd0b2,0x74));var _0x2d0b=function(_0x3b5a76,_0x26fe37){_0x3b5a76=_0x3b5a76-0x0;var _0x2aa1e4=_0xd0b2[_0x3b5a76];return _0x2aa1e4;};'use strict';var schema=require(_0x2d0b('0x0'));var _=require('lodash');var util=require(_0x2d0b('0x1'));var seqqueue=require(_0x2d0b('0x2'));var logger=require('../../../../config/logger')(_0x2d0b('0x3'));var strategy=require('./strategy');var queue=schema({'name':{'type':_0x2d0b('0x4'),'required':!![],'message':'name\x20is\x20a\x20string\x20and\x20it\x20is\x20required'},'timeout':{'type':'number','message':'timeout\x20is\x20a\x20number'}});function writeLog(_0x4fcec1,_0x3761e5,_0x37ace0){return logger[_0x2d0b('0x5')](util[_0x2d0b('0x6')](_0x2d0b('0x7'),_0x4fcec1,_0x3761e5['name'],_0x37ace0));}function handleFindAgent(_0x53e062){return function(_0x3432da){return _0x3432da[_0x2d0b('0x8')][_0x2d0b('0x9')]()===_0x53e062[_0x2d0b('0x9')]();};}exports['consequence']=function(_0x2d171a,_0x494efc,_0x500fc9,_0x5afc35){return function(_0xc54ef3){try{var _0x2e8725={'name':_0x494efc[0x0],'timeout':_0x494efc[0x1]};var _0x55fcae=queue[_0x2d0b('0x0')](_0x2e8725,{'typecast':!![]});if(_0x55fcae[_0x2d0b('0xa')]){logger[_0x2d0b('0xb')](_0x2d0b('0xc'),_0x2d171a,_[_0x2d0b('0xd')](_0x55fcae,_0x2d0b('0xe'))['join'](',\x20'));_0xc54ef3['stop']();}else{var _0x5adb33=_['find'](_0x500fc9['agents'],handleFindAgent(_0x2e8725[_0x2d0b('0x8')]));if(_0x5adb33){var _0xba738e=(_0x2e8725['timeout']||0xa)*0x3e8;var _0x5f3259,_0x556c2a;var _0x422326=seqqueue[_0x2d0b('0xf')](_0xba738e);_0x422326['id']=_0x2d171a;_0x422326[_0x2d0b('0x10')]=_0xba738e;_0x422326[_0x2d0b('0x11')]=_0x5afc35[_0x2d0b('0x11')];writeLog(_0x2d171a,_0x5adb33,util[_0x2d0b('0x6')](_0x2d0b('0x12'),_0xba738e));_0x500fc9[_0x2d0b('0x13')][_0x2d171a]['on']('end',function(){logger['info']('[%s][AGENT]\x20ROUTING\x20STOPPED',_0x2d171a);clearTimeout(_0x556c2a);_0x556c2a=undefined;_0x422326[_0x2d0b('0x14')]();if(_0x500fc9['rules'][_0x2d171a]){delete _0x500fc9[_0x2d0b('0x13')][_0x2d171a];}_0xc54ef3[_0x2d0b('0x15')]();});_0x500fc9[_0x2d0b('0x13')][_0x2d171a]['on']('complete',function(){if(_0x500fc9[_0x2d0b('0x13')][_0x2d171a]){delete _0x500fc9[_0x2d0b('0x13')][_0x2d171a];}});_0x556c2a=setTimeout(function(){logger[_0x2d0b('0x5')](_0x2d0b('0x16'),_0x2d171a);clearTimeout(_0x556c2a);_0x422326['close']();_0xc54ef3[_0x2d0b('0x17')]();},_0xba738e);strategy[_0x2d0b('0x18')](_0x422326,_0x5adb33,_0x500fc9,_0x5afc35);}else{logger['error']('[%s][AGENT]\x20agent\x20not\x20found\x20%s',_0x2d171a,_0x2e8725['name']);_0xc54ef3[_0x2d0b('0x15')]();}}}catch(_0x3e724e){console[_0x2d0b('0x19')](_0x3e724e);logger[_0x2d0b('0xb')](_0x2d0b('0x1a'),_0x2d171a,_0x3e724e['stack']);_0xc54ef3[_0x2d0b('0x15')]();}};};
\ No newline at end of file
+var _0xebab=['routing','string','number','info','format','[%s][AGENT][NAME:%s][STATUS:%s]','name','consequence','length','[%s][AGENT]\x20%s','map','message','join','stop','find','agents','timeout','createQueue','atimeout','channel','START:%s','rules','end','[%s][AGENT]\x20ROUTING\x20STOPPED','close','complete','next','agent','error','[%s][AGENT]\x20agent\x20not\x20found\x20%s','log','[%s][QUEUE]\x20%s','stack','validate','lodash','util','../../../../config/logger'];(function(_0x3efd24,_0x307e53){var _0x5df6f2=function(_0x52503d){while(--_0x52503d){_0x3efd24['push'](_0x3efd24['shift']());}};_0x5df6f2(++_0x307e53);}(_0xebab,0x124));var _0xbeba=function(_0xab1e97,_0x4d772d){_0xab1e97=_0xab1e97-0x0;var _0x1f16dd=_0xebab[_0xab1e97];return _0x1f16dd;};'use strict';var schema=require(_0xbeba('0x0'));var _=require(_0xbeba('0x1'));var util=require(_0xbeba('0x2'));var seqqueue=require('seq-queue');var logger=require(_0xbeba('0x3'))(_0xbeba('0x4'));var strategy=require('./strategy');var queue=schema({'name':{'type':_0xbeba('0x5'),'required':!![],'message':'name\x20is\x20a\x20string\x20and\x20it\x20is\x20required'},'timeout':{'type':_0xbeba('0x6'),'message':'timeout\x20is\x20a\x20number'}});function writeLog(_0x42641f,_0x177443,_0x294018){return logger[_0xbeba('0x7')](util[_0xbeba('0x8')](_0xbeba('0x9'),_0x42641f,_0x177443[_0xbeba('0xa')],_0x294018));}function handleFindAgent(_0x209568){return function(_0x38b31a){return _0x38b31a[_0xbeba('0xa')]['toLowerCase']()===_0x209568['toLowerCase']();};}exports[_0xbeba('0xb')]=function(_0x2f8dab,_0x13c2b5,_0x1f4f1f,_0x59259b){return function(_0x19898b){try{var _0x1a2346={'name':_0x13c2b5[0x0],'timeout':_0x13c2b5[0x1]};var _0x2a28b9=queue[_0xbeba('0x0')](_0x1a2346,{'typecast':!![]});if(_0x2a28b9[_0xbeba('0xc')]){logger['error'](_0xbeba('0xd'),_0x2f8dab,_[_0xbeba('0xe')](_0x2a28b9,_0xbeba('0xf'))[_0xbeba('0x10')](',\x20'));_0x19898b[_0xbeba('0x11')]();}else{var _0x7513fc=_[_0xbeba('0x12')](_0x1f4f1f[_0xbeba('0x13')],handleFindAgent(_0x1a2346[_0xbeba('0xa')]));if(_0x7513fc){var _0x33916a=(_0x1a2346[_0xbeba('0x14')]||0xa)*0x3e8;var _0x1d66f0,_0x1ddfef;var _0x25f6ae=seqqueue[_0xbeba('0x15')](_0x33916a);_0x25f6ae['id']=_0x2f8dab;_0x25f6ae[_0xbeba('0x16')]=_0x33916a;_0x25f6ae['channel']=_0x59259b[_0xbeba('0x17')];writeLog(_0x2f8dab,_0x7513fc,util[_0xbeba('0x8')](_0xbeba('0x18'),_0x33916a));_0x1f4f1f[_0xbeba('0x19')][_0x2f8dab]['on'](_0xbeba('0x1a'),function(){logger['info'](_0xbeba('0x1b'),_0x2f8dab);clearTimeout(_0x1ddfef);_0x1ddfef=undefined;_0x25f6ae[_0xbeba('0x1c')]();if(_0x1f4f1f[_0xbeba('0x19')][_0x2f8dab]){delete _0x1f4f1f[_0xbeba('0x19')][_0x2f8dab];}_0x19898b['stop']();});_0x1f4f1f['rules'][_0x2f8dab]['on'](_0xbeba('0x1d'),function(){if(_0x1f4f1f['rules'][_0x2f8dab]){delete _0x1f4f1f['rules'][_0x2f8dab];}});_0x1ddfef=setTimeout(function(){logger['info']('[%s][AGENT]\x20ROUTING\x20END',_0x2f8dab);clearTimeout(_0x1ddfef);_0x25f6ae['close']();_0x19898b[_0xbeba('0x1e')]();},_0x33916a);strategy[_0xbeba('0x1f')](_0x25f6ae,_0x7513fc,_0x1f4f1f,_0x59259b);}else{logger[_0xbeba('0x20')](_0xbeba('0x21'),_0x2f8dab,_0x1a2346[_0xbeba('0xa')]);_0x19898b['stop']();}}}catch(_0x2c32a3){console[_0xbeba('0x22')](_0x2c32a3);logger['error'](_0xbeba('0x23'),_0x2f8dab,_0x2c32a3[_0xbeba('0x24')]);_0x19898b[_0xbeba('0x11')]();}};};
\ No newline at end of file
git://repos.xcallymotion.com / motion2.git / blobdiff