// * treaties. The SOFTWARE PRODUCT is licensed, not sold. *
// * *
// *************************************************************************
-var _0xa2dd=['name\x20is\x20a\x20string\x20and\x20it\x20is\x20required','number','timeout\x20is\x20a\x20number','info','format','name','toLowerCase','consequence','length','error','[%s][AGENT]\x20%s','map','join','stop','find','agents','createQueue','atimeout','channel','START:%s','rules','end','[%s][AGENT]\x20ROUTING\x20STOPPED','close','[%s][AGENT]\x20agent\x20not\x20found\x20%s','log','[%s][QUEUE]\x20%s','stack','validate','lodash','util','seq-queue','routing','./strategy','string'];(function(_0x15bdee,_0x1db4db){var _0x11ac81=function(_0xd89de0){while(--_0xd89de0){_0x15bdee['push'](_0x15bdee['shift']());}};_0x11ac81(++_0x1db4db);}(_0xa2dd,0x111));var _0xda2d=function(_0x240abf,_0x22fb79){_0x240abf=_0x240abf-0x0;var _0xd2b890=_0xa2dd[_0x240abf];return _0xd2b890;};'use strict';var schema=require(_0xda2d('0x0'));var _=require(_0xda2d('0x1'));var util=require(_0xda2d('0x2'));var seqqueue=require(_0xda2d('0x3'));var logger=require('../../../../config/logger')(_0xda2d('0x4'));var strategy=require(_0xda2d('0x5'));var queue=schema({'name':{'type':_0xda2d('0x6'),'required':!![],'message':_0xda2d('0x7')},'timeout':{'type':_0xda2d('0x8'),'message':_0xda2d('0x9')}});function writeLog(_0x19c644,_0x15acbe,_0x1416ce){return logger[_0xda2d('0xa')](util[_0xda2d('0xb')]('[%s][AGENT][NAME:%s][STATUS:%s]',_0x19c644,_0x15acbe['name'],_0x1416ce));}function handleFindAgent(_0x56fe7e){return function(_0x53b845){return _0x53b845[_0xda2d('0xc')][_0xda2d('0xd')]()===_0x56fe7e[_0xda2d('0xd')]();};}exports[_0xda2d('0xe')]=function(_0x3a110d,_0x3bb62e,_0x10794e,_0x45ce64){return function(_0x4d4d98){try{var _0x4a401a={'name':_0x3bb62e[0x0],'timeout':_0x3bb62e[0x1]};var _0x4cf210=queue[_0xda2d('0x0')](_0x4a401a,{'typecast':!![]});if(_0x4cf210[_0xda2d('0xf')]){logger[_0xda2d('0x10')](_0xda2d('0x11'),_0x3a110d,_[_0xda2d('0x12')](_0x4cf210,'message')[_0xda2d('0x13')](',\x20'));_0x4d4d98[_0xda2d('0x14')]();}else{var _0x43010e=_[_0xda2d('0x15')](_0x10794e[_0xda2d('0x16')],handleFindAgent(_0x4a401a[_0xda2d('0xc')]));if(_0x43010e){var _0x44b83a=(_0x4a401a['timeout']||0xa)*0x3e8;var _0x2ef856,_0x52ff64;var _0x1c22ad=seqqueue[_0xda2d('0x17')](_0x44b83a);_0x1c22ad['id']=_0x3a110d;_0x1c22ad[_0xda2d('0x18')]=_0x44b83a;_0x1c22ad[_0xda2d('0x19')]=_0x45ce64['channel'];writeLog(_0x3a110d,_0x43010e,util['format'](_0xda2d('0x1a'),_0x44b83a));_0x10794e[_0xda2d('0x1b')][_0x3a110d]['on'](_0xda2d('0x1c'),function(){logger[_0xda2d('0xa')](_0xda2d('0x1d'),_0x3a110d);clearTimeout(_0x52ff64);_0x52ff64=undefined;_0x1c22ad[_0xda2d('0x1e')]();if(_0x10794e[_0xda2d('0x1b')][_0x3a110d]){delete _0x10794e[_0xda2d('0x1b')][_0x3a110d];}_0x4d4d98[_0xda2d('0x14')]();});_0x10794e[_0xda2d('0x1b')][_0x3a110d]['on']('complete',function(){if(_0x10794e[_0xda2d('0x1b')][_0x3a110d]){delete _0x10794e[_0xda2d('0x1b')][_0x3a110d];}});_0x52ff64=setTimeout(function(){logger[_0xda2d('0xa')]('[%s][AGENT]\x20ROUTING\x20END',_0x3a110d);clearTimeout(_0x52ff64);_0x1c22ad['close']();_0x4d4d98['next']();},_0x44b83a);strategy['agent'](_0x1c22ad,_0x43010e,_0x10794e,_0x45ce64);}else{logger['error'](_0xda2d('0x1f'),_0x3a110d,_0x4a401a['name']);_0x4d4d98[_0xda2d('0x14')]();}}}catch(_0x3231b1){console[_0xda2d('0x20')](_0x3231b1);logger[_0xda2d('0x10')](_0xda2d('0x21'),_0x3a110d,_0x3231b1[_0xda2d('0x22')]);_0x4d4d98[_0xda2d('0x14')]();}};};
\ No newline at end of file
+var _0x0888=['message','join','stop','find','agents','timeout','createQueue','channel','START:%s','rules','end','[%s][AGENT]\x20ROUTING\x20STOPPED','complete','[%s][AGENT]\x20ROUTING\x20END','close','next','[%s][AGENT]\x20agent\x20not\x20found\x20%s','log','[%s][QUEUE]\x20%s','stack','lodash','util','seq-queue','../../../../config/logger','routing','./strategy','string','number','timeout\x20is\x20a\x20number','info','format','[%s][AGENT][NAME:%s][STATUS:%s]','toLowerCase','consequence','length','error','[%s][AGENT]\x20%s','map'];(function(_0x4b2436,_0x452299){var _0x4f5ab2=function(_0x5c6679){while(--_0x5c6679){_0x4b2436['push'](_0x4b2436['shift']());}};_0x4f5ab2(++_0x452299);}(_0x0888,0xf8));var _0x8088=function(_0x1eca98,_0x20a86e){_0x1eca98=_0x1eca98-0x0;var _0x4f3bcf=_0x0888[_0x1eca98];return _0x4f3bcf;};'use strict';var schema=require('validate');var _=require(_0x8088('0x0'));var util=require(_0x8088('0x1'));var seqqueue=require(_0x8088('0x2'));var logger=require(_0x8088('0x3'))(_0x8088('0x4'));var strategy=require(_0x8088('0x5'));var queue=schema({'name':{'type':_0x8088('0x6'),'required':!![],'message':'name\x20is\x20a\x20string\x20and\x20it\x20is\x20required'},'timeout':{'type':_0x8088('0x7'),'message':_0x8088('0x8')}});function writeLog(_0x1a46d4,_0x2b8ba3,_0x499227){return logger[_0x8088('0x9')](util[_0x8088('0xa')](_0x8088('0xb'),_0x1a46d4,_0x2b8ba3['name'],_0x499227));}function handleFindAgent(_0x27d686){return function(_0x4fb3b5){return _0x4fb3b5['name'][_0x8088('0xc')]()===_0x27d686['toLowerCase']();};}exports[_0x8088('0xd')]=function(_0x4382cb,_0x1e6738,_0x2cd7f9,_0x2c6459){return function(_0x47e067){try{var _0x5b397b={'name':_0x1e6738[0x0],'timeout':_0x1e6738[0x1]};var _0x2bca52=queue['validate'](_0x5b397b,{'typecast':!![]});if(_0x2bca52[_0x8088('0xe')]){logger[_0x8088('0xf')](_0x8088('0x10'),_0x4382cb,_[_0x8088('0x11')](_0x2bca52,_0x8088('0x12'))[_0x8088('0x13')](',\x20'));_0x47e067[_0x8088('0x14')]();}else{var _0x294d64=_[_0x8088('0x15')](_0x2cd7f9[_0x8088('0x16')],handleFindAgent(_0x5b397b['name']));if(_0x294d64){var _0x3b80b5=(_0x5b397b[_0x8088('0x17')]||0xa)*0x3e8;var _0x447bc2,_0x1bc6bd;var _0x231b1f=seqqueue[_0x8088('0x18')](_0x3b80b5);_0x231b1f['id']=_0x4382cb;_0x231b1f['atimeout']=_0x3b80b5;_0x231b1f[_0x8088('0x19')]=_0x2c6459[_0x8088('0x19')];writeLog(_0x4382cb,_0x294d64,util[_0x8088('0xa')](_0x8088('0x1a'),_0x3b80b5));_0x2cd7f9[_0x8088('0x1b')][_0x4382cb]['on'](_0x8088('0x1c'),function(){logger['info'](_0x8088('0x1d'),_0x4382cb);clearTimeout(_0x1bc6bd);_0x1bc6bd=undefined;_0x231b1f['close']();if(_0x2cd7f9[_0x8088('0x1b')][_0x4382cb]){delete _0x2cd7f9[_0x8088('0x1b')][_0x4382cb];}_0x47e067['stop']();});_0x2cd7f9['rules'][_0x4382cb]['on'](_0x8088('0x1e'),function(){if(_0x2cd7f9['rules'][_0x4382cb]){delete _0x2cd7f9[_0x8088('0x1b')][_0x4382cb];}});_0x1bc6bd=setTimeout(function(){logger[_0x8088('0x9')](_0x8088('0x1f'),_0x4382cb);clearTimeout(_0x1bc6bd);_0x231b1f[_0x8088('0x20')]();_0x47e067[_0x8088('0x21')]();},_0x3b80b5);strategy['agent'](_0x231b1f,_0x294d64,_0x2cd7f9,_0x2c6459);}else{logger['error'](_0x8088('0x22'),_0x4382cb,_0x5b397b['name']);_0x47e067[_0x8088('0x14')]();}}}catch(_0x556027){console[_0x8088('0x23')](_0x556027);logger[_0x8088('0xf')](_0x8088('0x24'),_0x4382cb,_0x556027[_0x8088('0x25')]);_0x47e067[_0x8088('0x14')]();}};};
\ No newline at end of file
git://repos.xcallymotion.com / motion2.git / blobdiff