Built motion from commit (unavailable).|2.4.3
[motion2.git] / server / services / routing / model / mailQueue.js
index 375cf28..581618d 100644 (file)
@@ -15,4 +15,4 @@
 // * treaties. The SOFTWARE PRODUCT is licensed, not sold.                        *
 // *                                                                       *
 // *************************************************************************
-var _0x3974=['online','mailPause','available','paused','stringify','mail:queue:%s','lodash','md5','util','redis','defaults','localhost','socket.io-emitter','name','timeout','strategy','beepall','Agents','mapAgentsId','waiting','prototype','updateRouting','_rr','map','loggedIn','length'];(function(_0x9209fa,_0x1705d8){var _0x416655=function(_0x46e315){while(--_0x46e315){_0x9209fa['push'](_0x9209fa['shift']());}};_0x416655(++_0x1705d8);}(_0x3974,0xbc));var _0x4397=function(_0x32b87d,_0x49f56a){_0x32b87d=_0x32b87d-0x0;var _0x2ccbe5=_0x3974[_0x32b87d];return _0x2ccbe5;};'use strict';var _=require(_0x4397('0x0'));var md5=require(_0x4397('0x1'));var util=require(_0x4397('0x2'));var Redis=require('ioredis');var config=require('../../../config/environment');config[_0x4397('0x3')]=_[_0x4397('0x4')](config[_0x4397('0x3')],{'host':_0x4397('0x5'),'port':0x18eb});var io=require(_0x4397('0x6'))(new Redis(config['redis']));function MailQueue(_0x31ab71){this['id']=_0x31ab71['id']||0x0;this[_0x4397('0x7')]=_0x31ab71[_0x4397('0x7')]||'';this[_0x4397('0x8')]=_0x31ab71['timeout']||0xa;this[_0x4397('0x9')]=_0x31ab71[_0x4397('0x9')]||_0x4397('0xa');this[_0x4397('0xb')]=_0x31ab71['Agents'];this[_0x4397('0xc')]={};this[_0x4397('0xd')]=0x0;this[_0x4397('0x1')]='';this['updateRouting']();this['updateRealtime']();}MailQueue[_0x4397('0xe')][_0x4397('0xf')]=function(){var _0x2ddb9c=this['mapAgentsId'][_0x4397('0x10')];this[_0x4397('0xc')]=_[_0x4397('0x11')](this['Agents'],'id');this[_0x4397('0xc')][_0x4397('0x10')]=_0x2ddb9c;};MailQueue[_0x4397('0xe')]['updateRealtime']=function(){this[_0x4397('0x12')]=0x0;this['paused']=0x0;for(var _0x3b7b4a=0x0;_0x3b7b4a<this['Agents'][_0x4397('0x13')];_0x3b7b4a+=0x1){if(this[_0x4397('0xb')][_0x3b7b4a][_0x4397('0x14')]){this[_0x4397('0x12')]+=0x1;}if(this[_0x4397('0xb')][_0x3b7b4a][_0x4397('0x15')]){this['paused']+=0x1;}}this[_0x4397('0x16')]=this[_0x4397('0x12')]-this[_0x4397('0x17')];this[_0x4397('0x16')]=this[_0x4397('0x16')]>=0x0?this[_0x4397('0x16')]:0x0;var _0x35e528={'id':this['id'],'available':this[_0x4397('0x16')],'loggedIn':this[_0x4397('0x12')],'name':this['name'],'paused':this['paused'],'waiting':this[_0x4397('0xd')]};var _0x3a2810=md5(JSON[_0x4397('0x18')](_0x35e528));if(this[_0x4397('0x1')]!==_0x3a2810){this['md5']=_0x3a2810;io['to'](util['format'](_0x4397('0x19'),_0x35e528[_0x4397('0x7')]))['emit']('mail_queue:save',_0x35e528);}};module['exports']=MailQueue;
\ No newline at end of file
+var _0x5785=['prototype','updateRouting','_rr','map','loggedIn','paused','length','online','mailPause','available','waiting','stringify','format','mail:queue:%s','emit','mail_queue:save','exports','lodash','md5','util','ioredis','../../../config/environment','defaults','redis','localhost','socket.io-emitter','name','timeout','strategy','beepall','Agents','mapAgentsId','updateRealtime'];(function(_0x216819,_0x51f9b4){var _0x2e9652=function(_0xc7851d){while(--_0xc7851d){_0x216819['push'](_0x216819['shift']());}};_0x2e9652(++_0x51f9b4);}(_0x5785,0x119));var _0x5578=function(_0x47a349,_0x4699d9){_0x47a349=_0x47a349-0x0;var _0x18ab75=_0x5785[_0x47a349];return _0x18ab75;};'use strict';var _=require(_0x5578('0x0'));var md5=require(_0x5578('0x1'));var util=require(_0x5578('0x2'));var Redis=require(_0x5578('0x3'));var config=require(_0x5578('0x4'));config['redis']=_[_0x5578('0x5')](config[_0x5578('0x6')],{'host':_0x5578('0x7'),'port':0x18eb});var io=require(_0x5578('0x8'))(new Redis(config[_0x5578('0x6')]));function MailQueue(_0x32c82b){this['id']=_0x32c82b['id']||0x0;this[_0x5578('0x9')]=_0x32c82b[_0x5578('0x9')]||'';this[_0x5578('0xa')]=_0x32c82b[_0x5578('0xa')]||0xa;this['strategy']=_0x32c82b[_0x5578('0xb')]||_0x5578('0xc');this[_0x5578('0xd')]=_0x32c82b['Agents'];this[_0x5578('0xe')]={};this['waiting']=0x0;this[_0x5578('0x1')]='';this['updateRouting']();this[_0x5578('0xf')]();}MailQueue[_0x5578('0x10')][_0x5578('0x11')]=function(){var _0x54cd87=this['mapAgentsId'][_0x5578('0x12')];this[_0x5578('0xe')]=_[_0x5578('0x13')](this[_0x5578('0xd')],'id');this[_0x5578('0xe')][_0x5578('0x12')]=_0x54cd87;};MailQueue[_0x5578('0x10')][_0x5578('0xf')]=function(){this[_0x5578('0x14')]=0x0;this[_0x5578('0x15')]=0x0;for(var _0x4f6d2a=0x0;_0x4f6d2a<this[_0x5578('0xd')][_0x5578('0x16')];_0x4f6d2a+=0x1){if(this[_0x5578('0xd')][_0x4f6d2a][_0x5578('0x17')]){this[_0x5578('0x14')]+=0x1;}if(this[_0x5578('0xd')][_0x4f6d2a][_0x5578('0x18')]){this[_0x5578('0x15')]+=0x1;}}this[_0x5578('0x19')]=this[_0x5578('0x14')]-this['paused'];this[_0x5578('0x19')]=this[_0x5578('0x19')]>=0x0?this['available']:0x0;var _0x59fb63={'id':this['id'],'available':this[_0x5578('0x19')],'loggedIn':this[_0x5578('0x14')],'name':this['name'],'paused':this[_0x5578('0x15')],'waiting':this[_0x5578('0x1a')]};var _0x3661a7=md5(JSON[_0x5578('0x1b')](_0x59fb63));if(this[_0x5578('0x1')]!==_0x3661a7){this[_0x5578('0x1')]=_0x3661a7;io['to'](util[_0x5578('0x1c')](_0x5578('0x1d'),_0x59fb63[_0x5578('0x9')]))[_0x5578('0x1e')](_0x5578('0x1f'),_0x59fb63);}};module[_0x5578('0x20')]=MailQueue;
\ No newline at end of file