Built motion from commit ded33658aad58fc8de845a8299a9db59a88cc353. Version 3.0.0...
[motion-next.git] / server / services / routing / server / applications / strategy / agent.js
index 003bd0a..9e895d3 100644 (file)
@@ -1 +1 @@
-const a1209_0x3c9d=['[%s][AGENT]\x20agent\x20skipped,\x20unknown\x20id\x20%s','uuid','busy','handleRun','[%s][AGENT]\x20timeout\x20with\x20%s','exports','TIMEOUT','agents','agent','info','isAgentAvailable','../../../../../config/logger','forcedOwnership','push','showNotification','routing','handleTimeout','STOP','writeLog','handleDrained','isNil','realtime','prototype','notificationId','busyQueue','squeue','timeout','[%s][AGENT]\x20try\x20with\x20%s',':FORCED','bind','drained'];(function(_0x1ea4ba,_0x3c9d08){const _0x5f1b84=function(_0x1c7f9f){while(--_0x1c7f9f){_0x1ea4ba['push'](_0x1ea4ba['shift']());}};_0x5f1b84(++_0x3c9d08);}(a1209_0x3c9d,0xea));const a1209_0x5f1b=function(_0x1ea4ba,_0x3c9d08){_0x1ea4ba=_0x1ea4ba-0x0;let _0x5f1b84=a1209_0x3c9d[_0x1ea4ba];return _0x5f1b84;};const _0xcdb6ca=a1209_0x5f1b;'use strict';const _=require('lodash'),uuid=require(_0xcdb6ca('0xf')),util=require('./util'),logger=require(_0xcdb6ca('0x19'))(_0xcdb6ca('0x1d')),Agent=function(_0x1c7f9f,_0xe6e670,_0x4deef8,_0x2828a7){const _0x23d176=_0xcdb6ca;this[_0x23d176('0x6')]=uuid['v4'](),this[_0x23d176('0x8')]=_0x1c7f9f,this['agent']=_0xe6e670,this[_0x23d176('0x4')]=_0x4deef8,this[_0x23d176('0x1d')]=_0x2828a7,this[_0x23d176('0x8')]['push'](this[_0x23d176('0x11')][_0x23d176('0xc')](this),this['handleTimeout']['bind'](this)),this[_0x23d176('0x8')]['on'](_0x23d176('0x9'),this[_0x23d176('0x1e')]['bind'](this)),this[_0x23d176('0x8')]['on'](_0x23d176('0xd'),this[_0x23d176('0x2')]['bind'](this));};Agent[_0xcdb6ca('0x5')][_0xcdb6ca('0x1b')]=function(){const _0x43c258=_0xcdb6ca;this[_0x43c258('0x8')][_0x43c258('0x1b')](this[_0x43c258('0x11')][_0x43c258('0xc')](this),this[_0x43c258('0x1e')][_0x43c258('0xc')](this));},Agent[_0xcdb6ca('0x5')][_0xcdb6ca('0x2')]=function(){const _0x14f846=_0xcdb6ca;this[_0x14f846('0x1e')](!![]);},Agent[_0xcdb6ca('0x5')][_0xcdb6ca('0x11')]=function(){const _0x14c060=_0xcdb6ca;logger['info'](_0x14c060('0xa'),this[_0x14c060('0x8')]['id'],this[_0x14c060('0x16')]['id']),_[_0x14c060('0x3')](this[_0x14c060('0x4')]['agents'][this[_0x14c060('0x16')]['id']])?(logger[_0x14c060('0x17')](_0x14c060('0xe'),this[_0x14c060('0x8')]['id'],this[_0x14c060('0x16')]['id']),setTimeout(this[_0x14c060('0x1b')][_0x14c060('0xc')](this),0x3e8)):this[_0x14c060('0x1d')]['forcedOwnership']||util[_0x14c060('0x18')](this['squeue']['id'],this['realtime']['agents'][this[_0x14c060('0x16')]['id']],this[_0x14c060('0x8')]['channel'],![])?(this['realtime'][_0x14c060('0x15')][this['agent']['id']][_0x14c060('0x10')]=!![],this[_0x14c060('0x4')][_0x14c060('0x15')][this[_0x14c060('0x16')]['id']][_0x14c060('0x7')]=undefined,util[_0x14c060('0x1c')](this['notificationId'],this['squeue']['id'],this[_0x14c060('0x4')][_0x14c060('0x15')][this[_0x14c060('0x16')]['id']],null,this[_0x14c060('0x1d')]),util['writeLog'](this[_0x14c060('0x8')]['id'],this[_0x14c060('0x4')][_0x14c060('0x15')][this[_0x14c060('0x16')]['id']],'RINGING'+(this[_0x14c060('0x1d')][_0x14c060('0x1a')]?_0x14c060('0xb'):''))):(logger['info']('[%s][AGENT]\x20agent\x20%s\x20is\x20not\x20available',this[_0x14c060('0x8')]['id'],this['agent']['id']),setTimeout(this[_0x14c060('0x1b')][_0x14c060('0xc')](this),0x3e8));},Agent['prototype'][_0xcdb6ca('0x1e')]=function(_0x22923b){const _0x2ecdb5=_0xcdb6ca;if(_[_0x2ecdb5('0x3')](this[_0x2ecdb5('0x4')]['agents'][this['agent']['id']]))return logger['info'](_0x2ecdb5('0xe'),this[_0x2ecdb5('0x8')]['id'],this[_0x2ecdb5('0x16')]['id']);else logger[_0x2ecdb5('0x17')](_0x2ecdb5('0x12'),this['squeue']['id'],this[_0x2ecdb5('0x16')]['id']),util['hideNotification'](this['notificationId'],this[_0x2ecdb5('0x8')]['id'],this[_0x2ecdb5('0x4')][_0x2ecdb5('0x15')][this[_0x2ecdb5('0x16')]['id']],null,this[_0x2ecdb5('0x1d')]),this[_0x2ecdb5('0x4')]['agents'][this[_0x2ecdb5('0x16')]['id']][_0x2ecdb5('0x10')]=![],this[_0x2ecdb5('0x4')][_0x2ecdb5('0x15')][this[_0x2ecdb5('0x16')]['id']][_0x2ecdb5('0x7')]=undefined,util[_0x2ecdb5('0x1')](this[_0x2ecdb5('0x8')]['id'],this['realtime']['agents'][this[_0x2ecdb5('0x16')]['id']],_0x22923b?_0x2ecdb5('0x0'):_0x2ecdb5('0x14'));!_0x22923b&&setTimeout(this[_0x2ecdb5('0x1b')][_0x2ecdb5('0xc')](this),0x3e8);};function agent(_0x3ce76e,_0x640461,_0x128f24,_0x286893){return new Agent(_0x3ce76e,_0x640461,_0x128f24,_0x286893);}module[_0xcdb6ca('0x13')]=agent;
\ No newline at end of file
+const a1209_0x54d4=['drained','showNotification','realtime','[%s][AGENT]\x20try\x20with\x20%s','TIMEOUT','busyQueue','prototype','handleDrained','timeout','STOP','notificationId','isNil','RINGING','forcedOwnership','push','squeue','[%s][AGENT]\x20timeout\x20with\x20%s','[%s][AGENT]\x20agent\x20%s\x20is\x20not\x20available','handleTimeout','routing','info','exports','writeLog','[%s][AGENT]\x20agent\x20skipped,\x20unknown\x20id\x20%s','agent','agents','handleRun','uuid','busy','isAgentAvailable','bind','../../../../../config/logger'];(function(_0x378523,_0x54d42c){const _0x7fb845=function(_0x2c75aa){while(--_0x2c75aa){_0x378523['push'](_0x378523['shift']());}};_0x7fb845(++_0x54d42c);}(a1209_0x54d4,0x10c));const a1209_0x7fb8=function(_0x378523,_0x54d42c){_0x378523=_0x378523-0x0;let _0x7fb845=a1209_0x54d4[_0x378523];return _0x7fb845;};const _0x4aab3c=a1209_0x7fb8;'use strict';const _=require('lodash'),uuid=require(_0x4aab3c('0xf')),util=require('./util'),logger=require(_0x4aab3c('0x13'))(_0x4aab3c('0x7')),Agent=function(_0x2c75aa,_0x337df6,_0x573aec,_0x34abb2){const _0x514cf5=_0x4aab3c;this['notificationId']=uuid['v4'](),this[_0x514cf5('0x3')]=_0x2c75aa,this[_0x514cf5('0xc')]=_0x337df6,this[_0x514cf5('0x16')]=_0x573aec,this[_0x514cf5('0x7')]=_0x34abb2,this[_0x514cf5('0x3')][_0x514cf5('0x2')](this[_0x514cf5('0xe')]['bind'](this),this[_0x514cf5('0x6')]['bind'](this)),this[_0x514cf5('0x3')]['on'](_0x514cf5('0x1c'),this[_0x514cf5('0x6')][_0x514cf5('0x12')](this)),this[_0x514cf5('0x3')]['on'](_0x514cf5('0x14'),this[_0x514cf5('0x1b')]['bind'](this));};Agent[_0x4aab3c('0x1a')][_0x4aab3c('0x2')]=function(){const _0x3d50=_0x4aab3c;this[_0x3d50('0x3')][_0x3d50('0x2')](this[_0x3d50('0xe')]['bind'](this),this['handleTimeout'][_0x3d50('0x12')](this));},Agent[_0x4aab3c('0x1a')]['handleDrained']=function(){const _0x2fba31=_0x4aab3c;this[_0x2fba31('0x6')](!![]);},Agent[_0x4aab3c('0x1a')][_0x4aab3c('0xe')]=function(){const _0x252cb5=_0x4aab3c;logger['info'](_0x252cb5('0x17'),this['squeue']['id'],this[_0x252cb5('0xc')]['id']),_['isNil'](this[_0x252cb5('0x16')][_0x252cb5('0xd')][this[_0x252cb5('0xc')]['id']])?(logger[_0x252cb5('0x8')](_0x252cb5('0xb'),this[_0x252cb5('0x3')]['id'],this[_0x252cb5('0xc')]['id']),setTimeout(this['push'][_0x252cb5('0x12')](this),0x3e8)):this[_0x252cb5('0x7')][_0x252cb5('0x1')]||util[_0x252cb5('0x11')](this[_0x252cb5('0x3')]['id'],this['realtime']['agents'][this[_0x252cb5('0xc')]['id']],this['squeue']['channel'],![])?(this['realtime'][_0x252cb5('0xd')][this['agent']['id']][_0x252cb5('0x10')]=!![],this['realtime'][_0x252cb5('0xd')][this[_0x252cb5('0xc')]['id']][_0x252cb5('0x19')]=undefined,util[_0x252cb5('0x15')](this[_0x252cb5('0x1e')],this[_0x252cb5('0x3')]['id'],this['realtime']['agents'][this[_0x252cb5('0xc')]['id']],null,this[_0x252cb5('0x7')]),util[_0x252cb5('0xa')](this['squeue']['id'],this[_0x252cb5('0x16')][_0x252cb5('0xd')][this[_0x252cb5('0xc')]['id']],_0x252cb5('0x0')+(this['routing'][_0x252cb5('0x1')]?':FORCED':''))):(logger[_0x252cb5('0x8')](_0x252cb5('0x5'),this[_0x252cb5('0x3')]['id'],this['agent']['id']),setTimeout(this[_0x252cb5('0x2')]['bind'](this),0x3e8));},Agent['prototype']['handleTimeout']=function(_0x42ce37){const _0x18a475=_0x4aab3c;if(_[_0x18a475('0x1f')](this[_0x18a475('0x16')][_0x18a475('0xd')][this[_0x18a475('0xc')]['id']]))return logger[_0x18a475('0x8')]('[%s][AGENT]\x20agent\x20skipped,\x20unknown\x20id\x20%s',this['squeue']['id'],this['agent']['id']);else logger[_0x18a475('0x8')](_0x18a475('0x4'),this[_0x18a475('0x3')]['id'],this[_0x18a475('0xc')]['id']),util['hideNotification'](this['notificationId'],this[_0x18a475('0x3')]['id'],this[_0x18a475('0x16')]['agents'][this[_0x18a475('0xc')]['id']],null,this[_0x18a475('0x7')]),this[_0x18a475('0x16')][_0x18a475('0xd')][this[_0x18a475('0xc')]['id']][_0x18a475('0x10')]=![],this[_0x18a475('0x16')][_0x18a475('0xd')][this['agent']['id']]['busyQueue']=undefined,util['writeLog'](this['squeue']['id'],this['realtime'][_0x18a475('0xd')][this[_0x18a475('0xc')]['id']],_0x42ce37?_0x18a475('0x1d'):_0x18a475('0x18'));!_0x42ce37&&setTimeout(this[_0x18a475('0x2')]['bind'](this),0x3e8);};function agent(_0x5bf6aa,_0x4af987,_0x563a16,_0x22e29d){return new Agent(_0x5bf6aa,_0x4af987,_0x563a16,_0x22e29d);}module[_0x4aab3c('0x9')]=agent;
\ No newline at end of file