Built motion from commit (unavailable).|2.4.5
[motion2.git] / server / services / routing / model / mailQueue.js
index 5d48cde..9dda314 100644 (file)
@@ -15,4 +15,4 @@
 // * treaties. The SOFTWARE PRODUCT is licensed, not sold.                        *
 // *                                                                       *
 // *************************************************************************
-var _0xdcd5=['map','_rr','loggedIn','paused','online','available','stringify','format','mail:queue:%s','mail_queue:save','exports','lodash','md5','util','ioredis','../../../config/environment','redis','defaults','localhost','socket.io-emitter','name','timeout','beepall','Agents','waiting','updateRouting','updateRealtime','prototype','mapAgentsId'];(function(_0x3c4062,_0x3767fc){var _0x3f5bf3=function(_0x105e55){while(--_0x105e55){_0x3c4062['push'](_0x3c4062['shift']());}};_0x3f5bf3(++_0x3767fc);}(_0xdcd5,0x110));var _0x5dcd=function(_0xbec8e6,_0x2841b5){_0xbec8e6=_0xbec8e6-0x0;var _0x4aa6f2=_0xdcd5[_0xbec8e6];return _0x4aa6f2;};'use strict';var _=require(_0x5dcd('0x0'));var md5=require(_0x5dcd('0x1'));var util=require(_0x5dcd('0x2'));var Redis=require(_0x5dcd('0x3'));var config=require(_0x5dcd('0x4'));config[_0x5dcd('0x5')]=_[_0x5dcd('0x6')](config['redis'],{'host':_0x5dcd('0x7'),'port':0x18eb});var io=require(_0x5dcd('0x8'))(new Redis(config[_0x5dcd('0x5')]));function MailQueue(_0x37fa3c){this['id']=_0x37fa3c['id']||0x0;this[_0x5dcd('0x9')]=_0x37fa3c[_0x5dcd('0x9')]||'';this[_0x5dcd('0xa')]=_0x37fa3c[_0x5dcd('0xa')]||0xa;this['strategy']=_0x37fa3c['strategy']||_0x5dcd('0xb');this[_0x5dcd('0xc')]=_0x37fa3c[_0x5dcd('0xc')];this['mapAgentsId']={};this[_0x5dcd('0xd')]=0x0;this[_0x5dcd('0x1')]='';this[_0x5dcd('0xe')]();this[_0x5dcd('0xf')]();}MailQueue[_0x5dcd('0x10')][_0x5dcd('0xe')]=function(){var _0x36d681=this['mapAgentsId']['_rr'];this[_0x5dcd('0x11')]=_[_0x5dcd('0x12')](this['Agents'],'id');this[_0x5dcd('0x11')][_0x5dcd('0x13')]=_0x36d681;};MailQueue[_0x5dcd('0x10')][_0x5dcd('0xf')]=function(){this[_0x5dcd('0x14')]=0x0;this[_0x5dcd('0x15')]=0x0;for(var _0x2b66bf=0x0;_0x2b66bf<this[_0x5dcd('0xc')]['length'];_0x2b66bf+=0x1){if(this[_0x5dcd('0xc')][_0x2b66bf][_0x5dcd('0x16')]){this['loggedIn']+=0x1;}if(this[_0x5dcd('0xc')][_0x2b66bf]['mailPause']){this[_0x5dcd('0x15')]+=0x1;}}this[_0x5dcd('0x17')]=this[_0x5dcd('0x14')]-this['paused'];this[_0x5dcd('0x17')]=this[_0x5dcd('0x17')]>=0x0?this[_0x5dcd('0x17')]:0x0;var _0x5074b2={'id':this['id'],'available':this[_0x5dcd('0x17')],'loggedIn':this[_0x5dcd('0x14')],'name':this[_0x5dcd('0x9')],'paused':this['paused'],'waiting':this[_0x5dcd('0xd')]};var _0x191087=md5(JSON[_0x5dcd('0x18')](_0x5074b2));if(this[_0x5dcd('0x1')]!==_0x191087){this['md5']=_0x191087;io['to'](util[_0x5dcd('0x19')](_0x5dcd('0x1a'),_0x5074b2['name']))['emit'](_0x5dcd('0x1b'),_0x5074b2);}};module[_0x5dcd('0x1c')]=MailQueue;
\ No newline at end of file
+var _0x3d49=['util','ioredis','../../../config/environment','defaults','redis','localhost','socket.io-emitter','beepall','Agents','mapAgentsId','waiting','updateRouting','updateRealtime','prototype','_rr','loggedIn','paused','length','online','available','name','format','mail:queue:%s','mail_queue:save','exports','md5'];(function(_0x271c8d,_0x3669c3){var _0x2db3a1=function(_0xf9f978){while(--_0xf9f978){_0x271c8d['push'](_0x271c8d['shift']());}};_0x2db3a1(++_0x3669c3);}(_0x3d49,0x151));var _0x93d4=function(_0x2b365f,_0x17aa37){_0x2b365f=_0x2b365f-0x0;var _0x26b060=_0x3d49[_0x2b365f];return _0x26b060;};'use strict';var _=require('lodash');var md5=require(_0x93d4('0x0'));var util=require(_0x93d4('0x1'));var Redis=require(_0x93d4('0x2'));var config=require(_0x93d4('0x3'));config['redis']=_[_0x93d4('0x4')](config[_0x93d4('0x5')],{'host':_0x93d4('0x6'),'port':0x18eb});var io=require(_0x93d4('0x7'))(new Redis(config[_0x93d4('0x5')]));function MailQueue(_0x3ab9f8){this['id']=_0x3ab9f8['id']||0x0;this['name']=_0x3ab9f8['name']||'';this['timeout']=_0x3ab9f8['timeout']||0xa;this['strategy']=_0x3ab9f8['strategy']||_0x93d4('0x8');this[_0x93d4('0x9')]=_0x3ab9f8[_0x93d4('0x9')];this[_0x93d4('0xa')]={};this[_0x93d4('0xb')]=0x0;this[_0x93d4('0x0')]='';this[_0x93d4('0xc')]();this[_0x93d4('0xd')]();}MailQueue[_0x93d4('0xe')][_0x93d4('0xc')]=function(){var _0xc57e31=this[_0x93d4('0xa')]['_rr'];this[_0x93d4('0xa')]=_['map'](this[_0x93d4('0x9')],'id');this[_0x93d4('0xa')][_0x93d4('0xf')]=_0xc57e31;};MailQueue[_0x93d4('0xe')]['updateRealtime']=function(){this[_0x93d4('0x10')]=0x0;this[_0x93d4('0x11')]=0x0;for(var _0x521a7d=0x0;_0x521a7d<this[_0x93d4('0x9')][_0x93d4('0x12')];_0x521a7d+=0x1){if(this[_0x93d4('0x9')][_0x521a7d][_0x93d4('0x13')]){this[_0x93d4('0x10')]+=0x1;}if(this['Agents'][_0x521a7d]['mailPause']){this[_0x93d4('0x11')]+=0x1;}}this['available']=this[_0x93d4('0x10')]-this[_0x93d4('0x11')];this[_0x93d4('0x14')]=this[_0x93d4('0x14')]>=0x0?this[_0x93d4('0x14')]:0x0;var _0x266e0a={'id':this['id'],'available':this['available'],'loggedIn':this[_0x93d4('0x10')],'name':this[_0x93d4('0x15')],'paused':this[_0x93d4('0x11')],'waiting':this['waiting']};var _0x74d9c1=md5(JSON['stringify'](_0x266e0a));if(this[_0x93d4('0x0')]!==_0x74d9c1){this[_0x93d4('0x0')]=_0x74d9c1;io['to'](util[_0x93d4('0x16')](_0x93d4('0x17'),_0x266e0a[_0x93d4('0x15')]))['emit'](_0x93d4('0x18'),_0x266e0a);}};module[_0x93d4('0x19')]=MailQueue;
\ No newline at end of file