server/services/routing/server/applications/agent.js

   1 const a1200_0x2368=['createQueue','atimeout','string','[%s][AGENT]\x20agent\x20not\x20found\x20%s','[%s][AGENT]\x20ROUTING\x20END','rules','find','agent','info','../../../../config/logger','close','log','complete','START:%s','[%s][QUEUE]\x20%s','stack','name','name\x20is\x20a\x20string\x20and\x20it\x20is\x20required','timeout','map','toLowerCase','next','routing','./strategy','[%s][AGENT]\x20ROUTING\x20STOPPED','lodash','number','util','end','validate','format','error','stop','[%s][AGENT][NAME:%s][STATUS:%s]','seq-queue','join','length','channel'];(function(_0x19c9d9,_0x2368a7){const _0x52dcb6=function(_0x198635){while(--_0x198635){_0x19c9d9['push'](_0x19c9d9['shift']());}};_0x52dcb6(++_0x2368a7);}(a1200_0x2368,0x126));const a1200_0x52dc=function(_0x19c9d9,_0x2368a7){_0x19c9d9=_0x19c9d9-0x0;let _0x52dcb6=a1200_0x2368[_0x19c9d9];return _0x52dcb6;};const _0x2e87c3=a1200_0x52dc;'use strict';const schema=require(_0x2e87c3('0x1')),_=require(_0x2e87c3('0x23')),util=require(_0x2e87c3('0x25')),seqqueue=require(_0x2e87c3('0x6')),logger=require(_0x2e87c3('0x13'))(_0x2e87c3('0x20')),strategy=require(_0x2e87c3('0x21')),queue=schema({'name':{'type':_0x2e87c3('0xc'),'required':!![],'message':_0x2e87c3('0x1b')},'timeout':{'type':_0x2e87c3('0x24'),'message':'timeout\x20is\x20a\x20number'}});function writeLog(_0x198635,_0x477e20,_0x467400){const _0x178cf6=_0x2e87c3;return logger[_0x178cf6('0x12')](util[_0x178cf6('0x2')](_0x178cf6('0x5'),_0x198635,_0x477e20['name'],_0x467400));}function handleFindAgent(_0x4b0f64){return function(_0x2c700f){const _0x59c0db=a1200_0x52dc;return _0x2c700f[_0x59c0db('0x1a')][_0x59c0db('0x1e')]()===_0x4b0f64[_0x59c0db('0x1e')]();};}exports['consequence']=function(_0x1d5156,_0x510399,_0xa3743d,_0x37fce1){return function(_0x693404){const _0x5ea99a=a1200_0x52dc;try{const _0x350b58={'name':_0x510399[0x0],'timeout':_0x510399[0x1]},_0x8c0c40=queue['validate'](_0x350b58,{'typecast':!![]});if(_0x8c0c40[_0x5ea99a('0x8')])logger[_0x5ea99a('0x3')]('[%s][AGENT]\x20%s',_0x1d5156,_[_0x5ea99a('0x1d')](_0x8c0c40,'message')[_0x5ea99a('0x7')](',\x20')),_0x693404['stop']();else{const _0x35950c=_[_0x5ea99a('0x10')](_0xa3743d['agents'],handleFindAgent(_0x350b58['name']));if(_0x35950c){const _0x571bd0=(_0x350b58[_0x5ea99a('0x1c')]||0xa)*0x3e8;let _0x3593e2;const _0x1eaef6=seqqueue[_0x5ea99a('0xa')](_0x571bd0);_0x1eaef6['id']=_0x1d5156,_0x1eaef6[_0x5ea99a('0xb')]=_0x571bd0,_0x1eaef6[_0x5ea99a('0x9')]=_0x37fce1['channel'],writeLog(_0x1d5156,_0x35950c,util['format'](_0x5ea99a('0x17'),_0x571bd0)),_0xa3743d[_0x5ea99a('0xf')][_0x1d5156]['on'](_0x5ea99a('0x0'),function(){const _0x25ce8a=_0x5ea99a;logger[_0x25ce8a('0x12')](_0x25ce8a('0x22'),_0x1d5156),clearTimeout(_0x3593e2),_0x3593e2=undefined,_0x1eaef6[_0x25ce8a('0x14')](),_0xa3743d['rules'][_0x1d5156]&&delete _0xa3743d[_0x25ce8a('0xf')][_0x1d5156],_0x693404[_0x25ce8a('0x4')]();}),_0xa3743d[_0x5ea99a('0xf')][_0x1d5156]['on'](_0x5ea99a('0x16'),function(){const _0xea2d6c=_0x5ea99a;_0xa3743d[_0xea2d6c('0xf')][_0x1d5156]&&delete _0xa3743d[_0xea2d6c('0xf')][_0x1d5156];}),_0x3593e2=setTimeout(function(){const _0x4b4e08=_0x5ea99a;logger['info'](_0x4b4e08('0xe'),_0x1d5156),clearTimeout(_0x3593e2),_0x1eaef6['close'](),_0x693404[_0x4b4e08('0x1f')]();},_0x571bd0),strategy[_0x5ea99a('0x11')](_0x1eaef6,_0x35950c,_0xa3743d,_0x37fce1);}else logger[_0x5ea99a('0x3')](_0x5ea99a('0xd'),_0x1d5156,_0x350b58[_0x5ea99a('0x1a')]),_0x693404[_0x5ea99a('0x4')]();}}catch(_0xfaef72){console[_0x5ea99a('0x15')](_0xfaef72),logger[_0x5ea99a('0x3')](_0x5ea99a('0x18'),_0x1d5156,_0xfaef72[_0x5ea99a('0x19')]),_0x693404[_0x5ea99a('0x4')]();}};};