Built motion from commit f7863d46.|2.5.41

[motion2.git] / server / services / routing / model / mailQueue.js

diff --git a/server/services/routing/model/mailQueue.js b/server/services/routing/model/mailQueue.js
index 239b542..88014d1 100644 (file)
--- a/server/services/routing/model/mailQueue.js
+++ b/server/services/routing/model/mailQueue.js
@@ -15,4 +15,4 @@
 // * treaties. The SOFTWARE PRODUCT is licensed, not sold.                        *
 // *                                                                       *
 // *************************************************************************
-var _0xb24a=['redis','localhost','socket.io-emitter','name','timeout','strategy','beepall','mapAgentsId','updateRouting','updateRealtime','prototype','map','_rr','loggedIn','paused','Agents','length','online','mailPause','available','waiting','stringify','mail:queue:%s','emit','mail_queue:save','md5','util','../../../config/environment','defaults'];(function(_0x1ce05f,_0xe4d511){var _0x493e80=function(_0x230a52){while(--_0x230a52){_0x1ce05f['push'](_0x1ce05f['shift']());}};_0x493e80(++_0xe4d511);}(_0xb24a,0x70));var _0xab24=function(_0x4b8156,_0x437af2){_0x4b8156=_0x4b8156-0x0;var _0x4a819c=_0xb24a[_0x4b8156];return _0x4a819c;};'use strict';var _=require('lodash');var md5=require(_0xab24('0x0'));var util=require(_0xab24('0x1'));var Redis=require('ioredis');var config=require(_0xab24('0x2'));config['redis']=_[_0xab24('0x3')](config[_0xab24('0x4')],{'host':_0xab24('0x5'),'port':0x18eb});var io=require(_0xab24('0x6'))(new Redis(config[_0xab24('0x4')]));function MailQueue(_0x2ac875){this['id']=_0x2ac875['id']||0x0;this[_0xab24('0x7')]=_0x2ac875['name']||'';this[_0xab24('0x8')]=_0x2ac875[_0xab24('0x8')]||0xa;this[_0xab24('0x9')]=_0x2ac875[_0xab24('0x9')]||_0xab24('0xa');this['Agents']=_0x2ac875['Agents'];this[_0xab24('0xb')]={};this['waiting']=0x0;this['md5']='';this[_0xab24('0xc')]();this[_0xab24('0xd')]();}MailQueue[_0xab24('0xe')][_0xab24('0xc')]=function(){var _0x1dc33f=this[_0xab24('0xb')]['_rr'];this['mapAgentsId']=_[_0xab24('0xf')](this['Agents'],'id');this['mapAgentsId'][_0xab24('0x10')]=_0x1dc33f;};MailQueue[_0xab24('0xe')][_0xab24('0xd')]=function(){this[_0xab24('0x11')]=0x0;this[_0xab24('0x12')]=0x0;for(var _0x31f0ac=0x0;_0x31f0ac<this[_0xab24('0x13')][_0xab24('0x14')];_0x31f0ac+=0x1){if(this[_0xab24('0x13')][_0x31f0ac][_0xab24('0x15')]){this[_0xab24('0x11')]+=0x1;}if(this[_0xab24('0x13')][_0x31f0ac][_0xab24('0x16')]){this[_0xab24('0x12')]+=0x1;}}this['available']=this[_0xab24('0x11')]-this[_0xab24('0x12')];this['available']=this[_0xab24('0x17')]>=0x0?this['available']:0x0;var _0x3ece7c={'id':this['id'],'available':this[_0xab24('0x17')],'loggedIn':this['loggedIn'],'name':this[_0xab24('0x7')],'paused':this[_0xab24('0x12')],'waiting':this[_0xab24('0x18')]};var _0x298683=md5(JSON[_0xab24('0x19')](_0x3ece7c));if(this[_0xab24('0x0')]!==_0x298683){this['md5']=_0x298683;io['to'](util['format'](_0xab24('0x1a'),_0x3ece7c[_0xab24('0x7')]))[_0xab24('0x1b')](_0xab24('0x1c'),_0x3ece7c);}};module['exports']=MailQueue;
\ No newline at end of file
+var _0x09d7=['name','timeout','strategy','beepall','Agents','waiting','prototype','updateRouting','mapAgentsId','_rr','loggedIn','length','mailPause','paused','available','format','mail:queue:%s','emit','exports','lodash','md5','util','ioredis','../../../config/environment','defaults','localhost'];(function(_0x1d1779,_0x284147){var _0x2377e9=function(_0x299f6f){while(--_0x299f6f){_0x1d1779['push'](_0x1d1779['shift']());}};_0x2377e9(++_0x284147);}(_0x09d7,0x14b));var _0x709d=function(_0x309054,_0x2ba3dd){_0x309054=_0x309054-0x0;var _0x3e5998=_0x09d7[_0x309054];return _0x3e5998;};'use strict';var _=require(_0x709d('0x0'));var md5=require(_0x709d('0x1'));var util=require(_0x709d('0x2'));var Redis=require(_0x709d('0x3'));var config=require(_0x709d('0x4'));config['redis']=_[_0x709d('0x5')](config['redis'],{'host':_0x709d('0x6'),'port':0x18eb});var io=require('socket.io-emitter')(new Redis(config['redis']));function MailQueue(_0x25ce70){this['id']=_0x25ce70['id']||0x0;this[_0x709d('0x7')]=_0x25ce70[_0x709d('0x7')]||'';this[_0x709d('0x8')]=_0x25ce70['timeout']||0xa;this[_0x709d('0x9')]=_0x25ce70[_0x709d('0x9')]||_0x709d('0xa');this[_0x709d('0xb')]=_0x25ce70['Agents'];this['mapAgentsId']={};this[_0x709d('0xc')]=0x0;this[_0x709d('0x1')]='';this['updateRouting']();this['updateRealtime']();}MailQueue[_0x709d('0xd')][_0x709d('0xe')]=function(){var _0x50476d=this[_0x709d('0xf')][_0x709d('0x10')];this[_0x709d('0xf')]=_['map'](this[_0x709d('0xb')],'id');this['mapAgentsId'][_0x709d('0x10')]=_0x50476d;};MailQueue['prototype']['updateRealtime']=function(){this[_0x709d('0x11')]=0x0;this['paused']=0x0;for(var _0x36ba81=0x0;_0x36ba81<this[_0x709d('0xb')][_0x709d('0x12')];_0x36ba81+=0x1){if(this[_0x709d('0xb')][_0x36ba81]['online']){this[_0x709d('0x11')]+=0x1;}if(this[_0x709d('0xb')][_0x36ba81][_0x709d('0x13')]){this[_0x709d('0x14')]+=0x1;}}this[_0x709d('0x15')]=this['loggedIn']-this[_0x709d('0x14')];this[_0x709d('0x15')]=this[_0x709d('0x15')]>=0x0?this[_0x709d('0x15')]:0x0;var _0x3317d0={'id':this['id'],'available':this[_0x709d('0x15')],'loggedIn':this[_0x709d('0x11')],'name':this['name'],'paused':this[_0x709d('0x14')],'waiting':this[_0x709d('0xc')]};var _0xc70a3c=md5(JSON['stringify'](_0x3317d0));if(this[_0x709d('0x1')]!==_0xc70a3c){this['md5']=_0xc70a3c;io['to'](util[_0x709d('0x16')](_0x709d('0x17'),_0x3317d0[_0x709d('0x7')]))[_0x709d('0x18')]('mail_queue:save',_0x3317d0);}};module[_0x709d('0x19')]=MailQueue;
\ No newline at end of file