// * treaties. The SOFTWARE PRODUCT is licensed, not sold. *
// * *
// *************************************************************************
-var _0xa9e0=['agents','name','atimeout','channel','rules','[%s][AGENT]\x20ROUTING\x20STOPPED','close','[%s][AGENT]\x20ROUTING\x20END','next','agent','log','stringify','validate','lodash','util','routing','string','name\x20is\x20a\x20string\x20and\x20it\x20is\x20required','number','timeout\x20is\x20a\x20number','info','format','toLowerCase','consequence','length','error','[%s][AGENT]\x20%s','map','message','stop','find'];(function(_0x58088b,_0x3df595){var _0x4622aa=function(_0x2e3045){while(--_0x2e3045){_0x58088b['push'](_0x58088b['shift']());}};_0x4622aa(++_0x3df595);}(_0xa9e0,0x123));var _0x0a9e=function(_0x220dbb,_0x99328d){_0x220dbb=_0x220dbb-0x0;var _0x2b77de=_0xa9e0[_0x220dbb];return _0x2b77de;};'use strict';var schema=require(_0x0a9e('0x0'));var _=require(_0x0a9e('0x1'));var util=require(_0x0a9e('0x2'));var seqqueue=require('seq-queue');var logger=require('../../../../config/logger')(_0x0a9e('0x3'));var strategy=require('./strategy');var queue=schema({'name':{'type':_0x0a9e('0x4'),'required':!![],'message':_0x0a9e('0x5')},'timeout':{'type':_0x0a9e('0x6'),'message':_0x0a9e('0x7')}});function writeLog(_0x981158,_0x57b080,_0x219af0){return logger[_0x0a9e('0x8')](util[_0x0a9e('0x9')]('[%s][AGENT][NAME:%s][STATUS:%s]',_0x981158,_0x57b080['name'],_0x219af0));}function handleFindAgent(_0xe42b77){return function(_0x56465b){return _0x56465b['name'][_0x0a9e('0xa')]()===_0xe42b77[_0x0a9e('0xa')]();};}exports[_0x0a9e('0xb')]=function(_0x3ab53f,_0xfeb75b,_0xbd1168,_0x4a4c56){return function(_0x50dfb2){try{var _0x527cdd={'name':_0xfeb75b[0x0],'timeout':_0xfeb75b[0x1]};var _0x4cfe67=queue[_0x0a9e('0x0')](_0x527cdd,{'typecast':!![]});if(_0x4cfe67[_0x0a9e('0xc')]){logger[_0x0a9e('0xd')](_0x0a9e('0xe'),_0x3ab53f,_[_0x0a9e('0xf')](_0x4cfe67,_0x0a9e('0x10'))['join'](',\x20'));_0x50dfb2[_0x0a9e('0x11')]();}else{var _0x239b12=_[_0x0a9e('0x12')](_0xbd1168[_0x0a9e('0x13')],handleFindAgent(_0x527cdd[_0x0a9e('0x14')]));if(_0x239b12){var _0x4d5611=(_0x527cdd['timeout']||0xa)*0x3e8;var _0x22dccb,_0x5d0880;var _0x1985b6=seqqueue['createQueue'](_0x4d5611);_0x1985b6['id']=_0x3ab53f;_0x1985b6[_0x0a9e('0x15')]=_0x4d5611;_0x1985b6[_0x0a9e('0x16')]=_0x4a4c56['channel'];writeLog(_0x3ab53f,_0x239b12,util[_0x0a9e('0x9')]('START:%s',_0x4d5611));_0x22dccb=setInterval(function(){if(_0xbd1168[_0x0a9e('0x17')]&&!_0xbd1168[_0x0a9e('0x17')][_0x3ab53f]){logger[_0x0a9e('0x8')](_0x0a9e('0x18'),_0x3ab53f);clearInterval(_0x22dccb);clearTimeout(_0x5d0880);_0x5d0880=undefined;_0x1985b6[_0x0a9e('0x19')](!![]);_0x50dfb2[_0x0a9e('0x11')]();}},0x3e8);_0x5d0880=setTimeout(function(){logger[_0x0a9e('0x8')](_0x0a9e('0x1a'),_0x3ab53f);clearInterval(_0x22dccb);_0x22dccb=undefined;_0x1985b6[_0x0a9e('0x19')](!![]);_0x50dfb2[_0x0a9e('0x1b')]();},_0x4d5611);strategy[_0x0a9e('0x1c')](_0x1985b6,_0x239b12,_0xbd1168,_0x4a4c56);}else{logger[_0x0a9e('0xd')]('[%s][AGENT]\x20agent\x20not\x20found\x20%s',_0x3ab53f,_0x527cdd[_0x0a9e('0x14')]);_0x50dfb2[_0x0a9e('0x11')]();}}}catch(_0x53682f){console[_0x0a9e('0x1d')](_0x53682f);logger['error']('[%s][QUEUE]\x20%s',_0x3ab53f,JSON[_0x0a9e('0x1e')](_0x53682f));_0x50dfb2[_0x0a9e('0x11')]();}};};
\ No newline at end of file
+var _0xb10b=['[%s][QUEUE]\x20%s','stringify','validate','util','seq-queue','../../../../config/logger','./strategy','string','name\x20is\x20a\x20string\x20and\x20it\x20is\x20required','number','timeout\x20is\x20a\x20number','info','[%s][AGENT][NAME:%s][STATUS:%s]','name','toLowerCase','consequence','length','error','[%s][AGENT]\x20%s','map','message','join','find','agents','timeout','createQueue','channel','format','START:%s','rules','[%s][AGENT]\x20ROUTING\x20STOPPED','close','stop','[%s][AGENT]\x20ROUTING\x20END','next','agent','[%s][AGENT]\x20agent\x20not\x20found\x20%s'];(function(_0x513aa5,_0x1fba79){var _0x1a1a7c=function(_0x240e3f){while(--_0x240e3f){_0x513aa5['push'](_0x513aa5['shift']());}};_0x1a1a7c(++_0x1fba79);}(_0xb10b,0x12a));var _0xbb10=function(_0x206fc3,_0x251f21){_0x206fc3=_0x206fc3-0x0;var _0xea0c75=_0xb10b[_0x206fc3];return _0xea0c75;};'use strict';var schema=require(_0xbb10('0x0'));var _=require('lodash');var util=require(_0xbb10('0x1'));var seqqueue=require(_0xbb10('0x2'));var logger=require(_0xbb10('0x3'))('routing');var strategy=require(_0xbb10('0x4'));var queue=schema({'name':{'type':_0xbb10('0x5'),'required':!![],'message':_0xbb10('0x6')},'timeout':{'type':_0xbb10('0x7'),'message':_0xbb10('0x8')}});function writeLog(_0x312b72,_0x481979,_0x328583){return logger[_0xbb10('0x9')](util['format'](_0xbb10('0xa'),_0x312b72,_0x481979[_0xbb10('0xb')],_0x328583));}function handleFindAgent(_0x21370f){return function(_0x1c3ee5){return _0x1c3ee5[_0xbb10('0xb')][_0xbb10('0xc')]()===_0x21370f[_0xbb10('0xc')]();};}exports[_0xbb10('0xd')]=function(_0x5ab04a,_0x4e47f8,_0x20bd61,_0x118a74){return function(_0xce64f3){try{var _0x5e136d={'name':_0x4e47f8[0x0],'timeout':_0x4e47f8[0x1]};var _0x408248=queue['validate'](_0x5e136d,{'typecast':!![]});if(_0x408248[_0xbb10('0xe')]){logger[_0xbb10('0xf')](_0xbb10('0x10'),_0x5ab04a,_[_0xbb10('0x11')](_0x408248,_0xbb10('0x12'))[_0xbb10('0x13')](',\x20'));_0xce64f3['stop']();}else{var _0x26e021=_[_0xbb10('0x14')](_0x20bd61[_0xbb10('0x15')],handleFindAgent(_0x5e136d[_0xbb10('0xb')]));if(_0x26e021){var _0x3df17b=(_0x5e136d[_0xbb10('0x16')]||0xa)*0x3e8;var _0x24a57b,_0x36b5e8;var _0x3e26f4=seqqueue[_0xbb10('0x17')](_0x3df17b);_0x3e26f4['id']=_0x5ab04a;_0x3e26f4['atimeout']=_0x3df17b;_0x3e26f4[_0xbb10('0x18')]=_0x118a74[_0xbb10('0x18')];writeLog(_0x5ab04a,_0x26e021,util[_0xbb10('0x19')](_0xbb10('0x1a'),_0x3df17b));_0x24a57b=setInterval(function(){if(_0x20bd61[_0xbb10('0x1b')]&&!_0x20bd61[_0xbb10('0x1b')][_0x5ab04a]){logger[_0xbb10('0x9')](_0xbb10('0x1c'),_0x5ab04a);clearInterval(_0x24a57b);clearTimeout(_0x36b5e8);_0x36b5e8=undefined;_0x3e26f4[_0xbb10('0x1d')](!![]);_0xce64f3[_0xbb10('0x1e')]();}},0x3e8);_0x36b5e8=setTimeout(function(){logger['info'](_0xbb10('0x1f'),_0x5ab04a);clearInterval(_0x24a57b);_0x24a57b=undefined;_0x3e26f4[_0xbb10('0x1d')](!![]);_0xce64f3[_0xbb10('0x20')]();},_0x3df17b);strategy[_0xbb10('0x21')](_0x3e26f4,_0x26e021,_0x20bd61,_0x118a74);}else{logger[_0xbb10('0xf')](_0xbb10('0x22'),_0x5ab04a,_0x5e136d['name']);_0xce64f3[_0xbb10('0x1e')]();}}}catch(_0x12ef77){console['log'](_0x12ef77);logger['error'](_0xbb10('0x23'),_0x5ab04a,JSON[_0xbb10('0x24')](_0x12ef77));_0xce64f3[_0xbb10('0x1e')]();}};};
\ No newline at end of file
git://repos.xcallymotion.com / motion2.git / blobdiff