Built motion from commit 459747fdfe53bbf13fbede61eeaffea1f1438f86. Version 3.0.0...
[motion-next.git] / server / services / routing / model / mailQueue.js
index 5e0fe4d..e596cb3 100644 (file)
@@ -1 +1 @@
-const a1168_0x491c=['mailPause','paused','available','beepall','prototype','name','../../../rediscache','strategy','exports','md5','loggedIn','stringify','length','mapAgentsId','updateRealtime','format','updateRouting','waiting','mail_queue:save','_rr','mail:queue:%s','Agents','emit'];(function(_0x599539,_0x491c96){const _0x4e6eaf=function(_0xd4e5c3){while(--_0xd4e5c3){_0x599539['push'](_0x599539['shift']());}};_0x4e6eaf(++_0x491c96);}(a1168_0x491c,0x116));const a1168_0x4e6e=function(_0x599539,_0x491c96){_0x599539=_0x599539-0x0;let _0x4e6eaf=a1168_0x491c[_0x599539];return _0x4e6eaf;};const _0x38df84=a1168_0x4e6e;'use strict';const _=require('lodash'),md5=require(_0x38df84('0x7')),util=require('util'),{getSocket}=require(_0x38df84('0x4')),io=getSocket();function MailQueue(_0xd4e5c3){const _0x2bff22=_0x38df84;this['id']=_0xd4e5c3['id']||0x0,this[_0x2bff22('0x3')]=_0xd4e5c3[_0x2bff22('0x3')]||'',this['timeout']=_0xd4e5c3['timeout']||0xa,this[_0x2bff22('0x5')]=_0xd4e5c3[_0x2bff22('0x5')]||_0x2bff22('0x1'),this[_0x2bff22('0x13')]=_0xd4e5c3[_0x2bff22('0x13')],this[_0x2bff22('0xb')]={},this[_0x2bff22('0xf')]=0x0,this[_0x2bff22('0x7')]='',this['updateRouting'](),this[_0x2bff22('0xc')]();}MailQueue['prototype'][_0x38df84('0xe')]=function(){const _0x2fc0bd=_0x38df84,_0xcf5fd9=this['mapAgentsId'][_0x2fc0bd('0x11')];this['mapAgentsId']=_['map'](this['Agents'],'id'),this['mapAgentsId'][_0x2fc0bd('0x11')]=_0xcf5fd9;},MailQueue[_0x38df84('0x2')]['updateRealtime']=function(){const _0x1b709d=_0x38df84;this[_0x1b709d('0x8')]=0x0,this[_0x1b709d('0x16')]=0x0;for(let _0x178331=0x0;_0x178331<this['Agents'][_0x1b709d('0xa')];_0x178331+=0x1){this[_0x1b709d('0x13')][_0x178331]['online']&&(this['loggedIn']+=0x1),this[_0x1b709d('0x13')][_0x178331][_0x1b709d('0x15')]&&(this[_0x1b709d('0x16')]+=0x1);}this[_0x1b709d('0x0')]=this[_0x1b709d('0x8')]-this['paused'],this['available']=this[_0x1b709d('0x0')]>=0x0?this['available']:0x0;const _0x55c31d={'id':this['id'],'available':this[_0x1b709d('0x0')],'loggedIn':this[_0x1b709d('0x8')],'name':this[_0x1b709d('0x3')],'paused':this[_0x1b709d('0x16')],'waiting':this[_0x1b709d('0xf')]},_0x497204=md5(JSON[_0x1b709d('0x9')](_0x55c31d));this[_0x1b709d('0x7')]!==_0x497204&&(this[_0x1b709d('0x7')]=_0x497204,io['to'](util[_0x1b709d('0xd')](_0x1b709d('0x12'),_0x55c31d[_0x1b709d('0x3')]))[_0x1b709d('0x14')](_0x1b709d('0x10'),_0x55c31d));},module[_0x38df84('0x6')]=MailQueue;
\ No newline at end of file
+const a1168_0x104b=['stringify','exports','mail:queue:%s','format','updateRealtime','emit','name','lodash','updateRouting','beepall','mapAgentsId','Agents','waiting','timeout','paused','online','md5','../../../rediscache','mail_queue:save','loggedIn','util','strategy','mailPause','available','map'];(function(_0x5978cc,_0x104b89){const _0x3f6f0f=function(_0x48998f){while(--_0x48998f){_0x5978cc['push'](_0x5978cc['shift']());}};_0x3f6f0f(++_0x104b89);}(a1168_0x104b,0x9a));const a1168_0x3f6f=function(_0x5978cc,_0x104b89){_0x5978cc=_0x5978cc-0x0;let _0x3f6f0f=a1168_0x104b[_0x5978cc];return _0x3f6f0f;};const _0xc981c1=a1168_0x3f6f;'use strict';const _=require(_0xc981c1('0x3')),md5=require(_0xc981c1('0xc')),util=require(_0xc981c1('0x10')),{getSocket}=require(_0xc981c1('0xd')),io=getSocket();function MailQueue(_0x48998f){const _0x118b90=_0xc981c1;this['id']=_0x48998f['id']||0x0,this[_0x118b90('0x2')]=_0x48998f[_0x118b90('0x2')]||'',this[_0x118b90('0x9')]=_0x48998f[_0x118b90('0x9')]||0xa,this['strategy']=_0x48998f[_0x118b90('0x11')]||_0x118b90('0x5'),this['Agents']=_0x48998f[_0x118b90('0x7')],this['mapAgentsId']={},this[_0x118b90('0x8')]=0x0,this[_0x118b90('0xc')]='',this['updateRouting'](),this[_0x118b90('0x0')]();}MailQueue['prototype'][_0xc981c1('0x4')]=function(){const _0x99fe8a=_0xc981c1,_0x8a2eac=this[_0x99fe8a('0x6')]['_rr'];this['mapAgentsId']=_[_0x99fe8a('0x14')](this['Agents'],'id'),this['mapAgentsId']['_rr']=_0x8a2eac;},MailQueue['prototype']['updateRealtime']=function(){const _0x4a645b=_0xc981c1;this['loggedIn']=0x0,this['paused']=0x0;for(let _0x528abc=0x0;_0x528abc<this[_0x4a645b('0x7')]['length'];_0x528abc+=0x1){this[_0x4a645b('0x7')][_0x528abc][_0x4a645b('0xb')]&&(this[_0x4a645b('0xf')]+=0x1),this[_0x4a645b('0x7')][_0x528abc][_0x4a645b('0x12')]&&(this['paused']+=0x1);}this['available']=this['loggedIn']-this[_0x4a645b('0xa')],this[_0x4a645b('0x13')]=this[_0x4a645b('0x13')]>=0x0?this[_0x4a645b('0x13')]:0x0;const _0x1f702e={'id':this['id'],'available':this[_0x4a645b('0x13')],'loggedIn':this[_0x4a645b('0xf')],'name':this[_0x4a645b('0x2')],'paused':this[_0x4a645b('0xa')],'waiting':this[_0x4a645b('0x8')]},_0x11d5af=md5(JSON[_0x4a645b('0x15')](_0x1f702e));this[_0x4a645b('0xc')]!==_0x11d5af&&(this[_0x4a645b('0xc')]=_0x11d5af,io['to'](util[_0x4a645b('0x18')](_0x4a645b('0x17'),_0x1f702e[_0x4a645b('0x2')]))[_0x4a645b('0x1')](_0x4a645b('0xe'),_0x1f702e));},module[_0xc981c1('0x16')]=MailQueue;
\ No newline at end of file