Built motion from commit (unavailable).|2.5.14
[motion2.git] / server / services / routing / model / mailQueue.js
index 7213074..e960e50 100644 (file)
@@ -15,4 +15,4 @@
 // * treaties. The SOFTWARE PRODUCT is licensed, not sold.                        *
 // *                                                                       *
 // *************************************************************************
-var _0xb458=['online','mailPause','available','stringify','format','mail:queue:%s','emit','mail_queue:save','lodash','md5','util','redis','localhost','socket.io-emitter','name','timeout','strategy','Agents','mapAgentsId','waiting','updateRouting','updateRealtime','prototype','_rr','map','loggedIn','paused','length'];(function(_0x14234c,_0x56cc41){var _0x5e45b0=function(_0x30ec6d){while(--_0x30ec6d){_0x14234c['push'](_0x14234c['shift']());}};_0x5e45b0(++_0x56cc41);}(_0xb458,0x94));var _0x8b45=function(_0x5862e3,_0x36f95d){_0x5862e3=_0x5862e3-0x0;var _0x3b4a58=_0xb458[_0x5862e3];return _0x3b4a58;};'use strict';var _=require(_0x8b45('0x0'));var md5=require(_0x8b45('0x1'));var util=require(_0x8b45('0x2'));var Redis=require('ioredis');var config=require('../../../config/environment');config[_0x8b45('0x3')]=_['defaults'](config[_0x8b45('0x3')],{'host':_0x8b45('0x4'),'port':0x18eb});var io=require(_0x8b45('0x5'))(new Redis(config[_0x8b45('0x3')]));function MailQueue(_0x510b9b){this['id']=_0x510b9b['id']||0x0;this[_0x8b45('0x6')]=_0x510b9b[_0x8b45('0x6')]||'';this[_0x8b45('0x7')]=_0x510b9b[_0x8b45('0x7')]||0xa;this[_0x8b45('0x8')]=_0x510b9b['strategy']||'beepall';this[_0x8b45('0x9')]=_0x510b9b[_0x8b45('0x9')];this[_0x8b45('0xa')]={};this[_0x8b45('0xb')]=0x0;this[_0x8b45('0x1')]='';this[_0x8b45('0xc')]();this[_0x8b45('0xd')]();}MailQueue[_0x8b45('0xe')]['updateRouting']=function(){var _0x3cac06=this[_0x8b45('0xa')][_0x8b45('0xf')];this[_0x8b45('0xa')]=_[_0x8b45('0x10')](this[_0x8b45('0x9')],'id');this['mapAgentsId'][_0x8b45('0xf')]=_0x3cac06;};MailQueue[_0x8b45('0xe')][_0x8b45('0xd')]=function(){this[_0x8b45('0x11')]=0x0;this[_0x8b45('0x12')]=0x0;for(var _0x5f0f74=0x0;_0x5f0f74<this[_0x8b45('0x9')][_0x8b45('0x13')];_0x5f0f74+=0x1){if(this[_0x8b45('0x9')][_0x5f0f74][_0x8b45('0x14')]){this[_0x8b45('0x11')]+=0x1;}if(this[_0x8b45('0x9')][_0x5f0f74][_0x8b45('0x15')]){this['paused']+=0x1;}}this['available']=this[_0x8b45('0x11')]-this[_0x8b45('0x12')];this[_0x8b45('0x16')]=this['available']>=0x0?this['available']:0x0;var _0x521bc2={'id':this['id'],'available':this[_0x8b45('0x16')],'loggedIn':this[_0x8b45('0x11')],'name':this[_0x8b45('0x6')],'paused':this['paused'],'waiting':this[_0x8b45('0xb')]};var _0x2b1a81=md5(JSON[_0x8b45('0x17')](_0x521bc2));if(this[_0x8b45('0x1')]!==_0x2b1a81){this[_0x8b45('0x1')]=_0x2b1a81;io['to'](util[_0x8b45('0x18')](_0x8b45('0x19'),_0x521bc2[_0x8b45('0x6')]))[_0x8b45('0x1a')](_0x8b45('0x1b'),_0x521bc2);}};module['exports']=MailQueue;
\ No newline at end of file
+var _0x9ad9=['util','ioredis','../../../config/environment','redis','defaults','localhost','socket.io-emitter','name','timeout','strategy','beepall','Agents','mapAgentsId','waiting','md5','prototype','_rr','updateRealtime','loggedIn','paused','length','online','available','format','emit','mail_queue:save','lodash'];(function(_0x7e2eb0,_0x17cd58){var _0xd92de4=function(_0x5d005b){while(--_0x5d005b){_0x7e2eb0['push'](_0x7e2eb0['shift']());}};_0xd92de4(++_0x17cd58);}(_0x9ad9,0xbc));var _0x99ad=function(_0x2650de,_0x12c23e){_0x2650de=_0x2650de-0x0;var _0x2db8c0=_0x9ad9[_0x2650de];return _0x2db8c0;};'use strict';var _=require(_0x99ad('0x0'));var md5=require('md5');var util=require(_0x99ad('0x1'));var Redis=require(_0x99ad('0x2'));var config=require(_0x99ad('0x3'));config[_0x99ad('0x4')]=_[_0x99ad('0x5')](config['redis'],{'host':_0x99ad('0x6'),'port':0x18eb});var io=require(_0x99ad('0x7'))(new Redis(config[_0x99ad('0x4')]));function MailQueue(_0x25a580){this['id']=_0x25a580['id']||0x0;this['name']=_0x25a580[_0x99ad('0x8')]||'';this[_0x99ad('0x9')]=_0x25a580[_0x99ad('0x9')]||0xa;this[_0x99ad('0xa')]=_0x25a580[_0x99ad('0xa')]||_0x99ad('0xb');this[_0x99ad('0xc')]=_0x25a580[_0x99ad('0xc')];this[_0x99ad('0xd')]={};this[_0x99ad('0xe')]=0x0;this[_0x99ad('0xf')]='';this['updateRouting']();this['updateRealtime']();}MailQueue[_0x99ad('0x10')]['updateRouting']=function(){var _0x3221c8=this[_0x99ad('0xd')][_0x99ad('0x11')];this['mapAgentsId']=_['map'](this['Agents'],'id');this['mapAgentsId'][_0x99ad('0x11')]=_0x3221c8;};MailQueue[_0x99ad('0x10')][_0x99ad('0x12')]=function(){this[_0x99ad('0x13')]=0x0;this[_0x99ad('0x14')]=0x0;for(var _0x88a2f8=0x0;_0x88a2f8<this[_0x99ad('0xc')][_0x99ad('0x15')];_0x88a2f8+=0x1){if(this['Agents'][_0x88a2f8][_0x99ad('0x16')]){this['loggedIn']+=0x1;}if(this[_0x99ad('0xc')][_0x88a2f8]['mailPause']){this['paused']+=0x1;}}this[_0x99ad('0x17')]=this[_0x99ad('0x13')]-this['paused'];this[_0x99ad('0x17')]=this[_0x99ad('0x17')]>=0x0?this[_0x99ad('0x17')]:0x0;var _0x1b7aee={'id':this['id'],'available':this['available'],'loggedIn':this[_0x99ad('0x13')],'name':this[_0x99ad('0x8')],'paused':this['paused'],'waiting':this[_0x99ad('0xe')]};var _0x104b06=md5(JSON['stringify'](_0x1b7aee));if(this[_0x99ad('0xf')]!==_0x104b06){this['md5']=_0x104b06;io['to'](util[_0x99ad('0x18')]('mail:queue:%s',_0x1b7aee['name']))[_0x99ad('0x19')](_0x99ad('0x1a'),_0x1b7aee);}};module['exports']=MailQueue;
\ No newline at end of file