1 const a1337_0x55b3=['waiting','loggedIn','exports','online','updateRealtime','prototype','length','paused','available','updateRouting','name','emit','beepall','Agents','mail:queue:%s','_rr','timeout','mail_queue:save','strategy','map','mapAgentsId','md5'];(function(_0x4e4a77,_0x4366f3){const _0x55b3a3=function(_0x41305b){while(--_0x41305b){_0x4e4a77['push'](_0x4e4a77['shift']());}};_0x55b3a3(++_0x4366f3);}(a1337_0x55b3,0xad));const a1337_0x4130=function(_0x4e4a77,_0x4366f3){_0x4e4a77=_0x4e4a77-0x14d;let _0x55b3a3=a1337_0x55b3[_0x4e4a77];return _0x55b3a3;};const a1337_0x2769ca=a1337_0x4130;'use strict';const _=require('lodash'),md5=require(a1337_0x2769ca(0x14f)),util=require('util'),{getSocket}=require('../../../rediscache'),io=getSocket();function MailQueue(_0x3f436e){const _0x4f2aa7=a1337_0x2769ca;this['id']=_0x3f436e['id']||0x0,this[_0x4f2aa7(0x15a)]=_0x3f436e[_0x4f2aa7(0x15a)]||'',this[_0x4f2aa7(0x160)]=_0x3f436e['timeout']||0xa,this[_0x4f2aa7(0x162)]=_0x3f436e[_0x4f2aa7(0x162)]||_0x4f2aa7(0x15c),this['Agents']=_0x3f436e[_0x4f2aa7(0x15d)],this[_0x4f2aa7(0x14e)]={},this[_0x4f2aa7(0x150)]=0x0,this[_0x4f2aa7(0x14f)]='',this[_0x4f2aa7(0x159)](),this[_0x4f2aa7(0x154)]();}MailQueue['prototype'][a1337_0x2769ca(0x159)]=function(){const _0x9e4d4d=a1337_0x2769ca,_0x19e29a=this[_0x9e4d4d(0x14e)]['_rr'];this[_0x9e4d4d(0x14e)]=_[_0x9e4d4d(0x14d)](this[_0x9e4d4d(0x15d)],'id'),this[_0x9e4d4d(0x14e)][_0x9e4d4d(0x15f)]=_0x19e29a;},MailQueue[a1337_0x2769ca(0x155)][a1337_0x2769ca(0x154)]=function(){const _0x54ce79=a1337_0x2769ca;this[_0x54ce79(0x151)]=0x0,this['paused']=0x0;for(let _0xdf0fd=0x0;_0xdf0fd<this[_0x54ce79(0x15d)][_0x54ce79(0x156)];_0xdf0fd+=0x1){this[_0x54ce79(0x15d)][_0xdf0fd][_0x54ce79(0x153)]&&(this[_0x54ce79(0x151)]+=0x1),this['Agents'][_0xdf0fd]['mailPause']&&(this[_0x54ce79(0x157)]+=0x1);}this[_0x54ce79(0x158)]=this[_0x54ce79(0x151)]-this[_0x54ce79(0x157)],this['available']=this['available']>=0x0?this['available']:0x0;const _0x23944f={'id':this['id'],'available':this[_0x54ce79(0x158)],'loggedIn':this[_0x54ce79(0x151)],'name':this[_0x54ce79(0x15a)],'paused':this[_0x54ce79(0x157)],'waiting':this[_0x54ce79(0x150)]},_0x492c45=md5(JSON['stringify'](_0x23944f));this['md5']!==_0x492c45&&(this[_0x54ce79(0x14f)]=_0x492c45,io['to'](util['format'](_0x54ce79(0x15e),_0x23944f['name']))[_0x54ce79(0x15b)](_0x54ce79(0x161),_0x23944f));},module[a1337_0x2769ca(0x152)]=MailQueue;
git://repos.xcallymotion.com / motion-next.git / blob