Built motion from commit (unavailable).|2.5.4
[motion2.git] / server / services / routing / model / mailQueue.js
index 691286b..3951211 100644 (file)
@@ -15,4 +15,4 @@
 // * treaties. The SOFTWARE PRODUCT is licensed, not sold.                        *
 // *                                                                       *
 // *************************************************************************
-var _0xa208=['redis','defaults','localhost','socket.io-emitter','name','timeout','strategy','beepall','Agents','updateRouting','updateRealtime','prototype','mapAgentsId','_rr','map','loggedIn','paused','length','mailPause','available','waiting','stringify','format','mail:queue:%s','emit','mail_queue:save','exports','lodash','md5','util','../../../config/environment'];(function(_0x524277,_0x2b0cad){var _0x2b9d18=function(_0x432ead){while(--_0x432ead){_0x524277['push'](_0x524277['shift']());}};_0x2b9d18(++_0x2b0cad);}(_0xa208,0x18f));var _0x8a20=function(_0x1e3c16,_0x372caa){_0x1e3c16=_0x1e3c16-0x0;var _0x47a0c9=_0xa208[_0x1e3c16];return _0x47a0c9;};'use strict';var _=require(_0x8a20('0x0'));var md5=require(_0x8a20('0x1'));var util=require(_0x8a20('0x2'));var Redis=require('ioredis');var config=require(_0x8a20('0x3'));config[_0x8a20('0x4')]=_[_0x8a20('0x5')](config['redis'],{'host':_0x8a20('0x6'),'port':0x18eb});var io=require(_0x8a20('0x7'))(new Redis(config[_0x8a20('0x4')]));function MailQueue(_0xa40cfd){this['id']=_0xa40cfd['id']||0x0;this[_0x8a20('0x8')]=_0xa40cfd[_0x8a20('0x8')]||'';this[_0x8a20('0x9')]=_0xa40cfd[_0x8a20('0x9')]||0xa;this['strategy']=_0xa40cfd[_0x8a20('0xa')]||_0x8a20('0xb');this['Agents']=_0xa40cfd[_0x8a20('0xc')];this['mapAgentsId']={};this['waiting']=0x0;this[_0x8a20('0x1')]='';this[_0x8a20('0xd')]();this[_0x8a20('0xe')]();}MailQueue[_0x8a20('0xf')][_0x8a20('0xd')]=function(){var _0x2745c8=this[_0x8a20('0x10')][_0x8a20('0x11')];this[_0x8a20('0x10')]=_[_0x8a20('0x12')](this[_0x8a20('0xc')],'id');this[_0x8a20('0x10')]['_rr']=_0x2745c8;};MailQueue[_0x8a20('0xf')]['updateRealtime']=function(){this[_0x8a20('0x13')]=0x0;this[_0x8a20('0x14')]=0x0;for(var _0x52148e=0x0;_0x52148e<this[_0x8a20('0xc')][_0x8a20('0x15')];_0x52148e+=0x1){if(this['Agents'][_0x52148e]['online']){this[_0x8a20('0x13')]+=0x1;}if(this[_0x8a20('0xc')][_0x52148e][_0x8a20('0x16')]){this[_0x8a20('0x14')]+=0x1;}}this[_0x8a20('0x17')]=this['loggedIn']-this[_0x8a20('0x14')];this['available']=this['available']>=0x0?this[_0x8a20('0x17')]:0x0;var _0x551b14={'id':this['id'],'available':this[_0x8a20('0x17')],'loggedIn':this[_0x8a20('0x13')],'name':this['name'],'paused':this[_0x8a20('0x14')],'waiting':this[_0x8a20('0x18')]};var _0x40d8ca=md5(JSON[_0x8a20('0x19')](_0x551b14));if(this['md5']!==_0x40d8ca){this[_0x8a20('0x1')]=_0x40d8ca;io['to'](util[_0x8a20('0x1a')](_0x8a20('0x1b'),_0x551b14[_0x8a20('0x8')]))[_0x8a20('0x1c')](_0x8a20('0x1d'),_0x551b14);}};module[_0x8a20('0x1e')]=MailQueue;
\ No newline at end of file
+var _0xf604=['loggedIn','paused','online','available','waiting','stringify','format','mail:queue:%s','mail_queue:save','exports','lodash','md5','util','ioredis','../../../config/environment','defaults','redis','name','timeout','strategy','beepall','Agents','mapAgentsId','updateRouting','updateRealtime','prototype','_rr','map'];(function(_0x245bd2,_0x1c5a6f){var _0x35c770=function(_0x360818){while(--_0x360818){_0x245bd2['push'](_0x245bd2['shift']());}};_0x35c770(++_0x1c5a6f);}(_0xf604,0x122));var _0x4f60=function(_0x46bec2,_0x36cde0){_0x46bec2=_0x46bec2-0x0;var _0x39b857=_0xf604[_0x46bec2];return _0x39b857;};'use strict';var _=require(_0x4f60('0x0'));var md5=require(_0x4f60('0x1'));var util=require(_0x4f60('0x2'));var Redis=require(_0x4f60('0x3'));var config=require(_0x4f60('0x4'));config['redis']=_[_0x4f60('0x5')](config[_0x4f60('0x6')],{'host':'localhost','port':0x18eb});var io=require('socket.io-emitter')(new Redis(config[_0x4f60('0x6')]));function MailQueue(_0x5a37dc){this['id']=_0x5a37dc['id']||0x0;this[_0x4f60('0x7')]=_0x5a37dc[_0x4f60('0x7')]||'';this[_0x4f60('0x8')]=_0x5a37dc[_0x4f60('0x8')]||0xa;this[_0x4f60('0x9')]=_0x5a37dc[_0x4f60('0x9')]||_0x4f60('0xa');this[_0x4f60('0xb')]=_0x5a37dc[_0x4f60('0xb')];this[_0x4f60('0xc')]={};this['waiting']=0x0;this[_0x4f60('0x1')]='';this[_0x4f60('0xd')]();this[_0x4f60('0xe')]();}MailQueue[_0x4f60('0xf')][_0x4f60('0xd')]=function(){var _0x171f37=this['mapAgentsId'][_0x4f60('0x10')];this['mapAgentsId']=_[_0x4f60('0x11')](this[_0x4f60('0xb')],'id');this[_0x4f60('0xc')][_0x4f60('0x10')]=_0x171f37;};MailQueue['prototype'][_0x4f60('0xe')]=function(){this[_0x4f60('0x12')]=0x0;this[_0x4f60('0x13')]=0x0;for(var _0x40332f=0x0;_0x40332f<this[_0x4f60('0xb')]['length'];_0x40332f+=0x1){if(this[_0x4f60('0xb')][_0x40332f][_0x4f60('0x14')]){this[_0x4f60('0x12')]+=0x1;}if(this['Agents'][_0x40332f]['mailPause']){this[_0x4f60('0x13')]+=0x1;}}this[_0x4f60('0x15')]=this[_0x4f60('0x12')]-this['paused'];this[_0x4f60('0x15')]=this[_0x4f60('0x15')]>=0x0?this[_0x4f60('0x15')]:0x0;var _0x43c357={'id':this['id'],'available':this[_0x4f60('0x15')],'loggedIn':this[_0x4f60('0x12')],'name':this['name'],'paused':this[_0x4f60('0x13')],'waiting':this[_0x4f60('0x16')]};var _0x4ba26d=md5(JSON[_0x4f60('0x17')](_0x43c357));if(this['md5']!==_0x4ba26d){this[_0x4f60('0x1')]=_0x4ba26d;io['to'](util[_0x4f60('0x18')](_0x4f60('0x19'),_0x43c357[_0x4f60('0x7')]))['emit'](_0x4f60('0x1a'),_0x43c357);}};module[_0x4f60('0x1b')]=MailQueue;
\ No newline at end of file