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

   1 const a1199_0x1386=['agents','format','validate','consequence','next','agent','map','[%s][AGENT]\x20ROUTING\x20STOPPED','stack','name\x20is\x20a\x20string\x20and\x20it\x20is\x20required','./strategy','[%s][QUEUE]\x20%s','string','error','channel','[%s][AGENT]\x20ROUTING\x20END','[%s][AGENT]\x20%s','rules','name','toLowerCase','number','find','join','end','atimeout','stop','../../../../config/logger','message','log','[%s][AGENT][NAME:%s][STATUS:%s]','length','info','seq-queue','close'];(function(_0x489030,_0x138641){const _0x257d55=function(_0xc92c12){while(--_0xc92c12){_0x489030['push'](_0x489030['shift']());}};_0x257d55(++_0x138641);}(a1199_0x1386,0xf8));const a1199_0x257d=function(_0x489030,_0x138641){_0x489030=_0x489030-0x0;let _0x257d55=a1199_0x1386[_0x489030];return _0x257d55;};const _0x163f5f=a1199_0x257d;'use strict';const schema=require('validate'),_=require('lodash'),util=require('util'),seqqueue=require(_0x163f5f('0x16')),logger=require(_0x163f5f('0x10'))('routing'),strategy=require(_0x163f5f('0x0')),queue=schema({'name':{'type':_0x163f5f('0x2'),'required':!![],'message':_0x163f5f('0x21')},'timeout':{'type':_0x163f5f('0xa'),'message':'timeout\x20is\x20a\x20number'}});function writeLog(_0xc92c12,_0x4fee57,_0x5a6e84){const _0x5c3ff0=_0x163f5f;return logger[_0x5c3ff0('0x15')](util[_0x5c3ff0('0x19')](_0x5c3ff0('0x13'),_0xc92c12,_0x4fee57[_0x5c3ff0('0x8')],_0x5a6e84));}function handleFindAgent(_0x518896){return function(_0xc249c){const _0x5667af=a1199_0x257d;return _0xc249c[_0x5667af('0x8')][_0x5667af('0x9')]()===_0x518896[_0x5667af('0x9')]();};}exports[_0x163f5f('0x1b')]=function(_0x35ed46,_0x439d99,_0xcec4af,_0x543ead){return function(_0x298d9e){const _0x3f8d98=a1199_0x257d;try{const _0x2534ec={'name':_0x439d99[0x0],'timeout':_0x439d99[0x1]},_0xe81e49=queue[_0x3f8d98('0x1a')](_0x2534ec,{'typecast':!![]});if(_0xe81e49[_0x3f8d98('0x14')])logger[_0x3f8d98('0x3')](_0x3f8d98('0x6'),_0x35ed46,_[_0x3f8d98('0x1e')](_0xe81e49,_0x3f8d98('0x11'))[_0x3f8d98('0xc')](',\x20')),_0x298d9e[_0x3f8d98('0xf')]();else{const _0x3ec084=_[_0x3f8d98('0xb')](_0xcec4af[_0x3f8d98('0x18')],handleFindAgent(_0x2534ec[_0x3f8d98('0x8')]));if(_0x3ec084){const _0x584ddc=(_0x2534ec['timeout']||0xa)*0x3e8;let _0x3082cf;const _0x3dc2ee=seqqueue['createQueue'](_0x584ddc);_0x3dc2ee['id']=_0x35ed46,_0x3dc2ee[_0x3f8d98('0xe')]=_0x584ddc,_0x3dc2ee[_0x3f8d98('0x4')]=_0x543ead['channel'],writeLog(_0x35ed46,_0x3ec084,util['format']('START:%s',_0x584ddc)),_0xcec4af['rules'][_0x35ed46]['on'](_0x3f8d98('0xd'),function(){const _0x895426=_0x3f8d98;logger['info'](_0x895426('0x1f'),_0x35ed46),clearTimeout(_0x3082cf),_0x3082cf=undefined,_0x3dc2ee[_0x895426('0x17')](),_0xcec4af[_0x895426('0x7')][_0x35ed46]&&delete _0xcec4af[_0x895426('0x7')][_0x35ed46],_0x298d9e[_0x895426('0xf')]();}),_0xcec4af[_0x3f8d98('0x7')][_0x35ed46]['on']('complete',function(){const _0x444392=_0x3f8d98;_0xcec4af['rules'][_0x35ed46]&&delete _0xcec4af[_0x444392('0x7')][_0x35ed46];}),_0x3082cf=setTimeout(function(){const _0x53c168=_0x3f8d98;logger['info'](_0x53c168('0x5'),_0x35ed46),clearTimeout(_0x3082cf),_0x3dc2ee[_0x53c168('0x17')](),_0x298d9e[_0x53c168('0x1c')]();},_0x584ddc),strategy[_0x3f8d98('0x1d')](_0x3dc2ee,_0x3ec084,_0xcec4af,_0x543ead);}else logger[_0x3f8d98('0x3')]('[%s][AGENT]\x20agent\x20not\x20found\x20%s',_0x35ed46,_0x2534ec[_0x3f8d98('0x8')]),_0x298d9e[_0x3f8d98('0xf')]();}}catch(_0x4a9c7b){console[_0x3f8d98('0x12')](_0x4a9c7b),logger[_0x3f8d98('0x3')](_0x3f8d98('0x1'),_0x35ed46,_0x4a9c7b[_0x3f8d98('0x20')]),_0x298d9e[_0x3f8d98('0xf')]();}};};