Built motion from commit (unavailable).|2.4.5
[motion2.git] / server / services / routing / model / smsQueue.js
index 20d3b3a..c02c2af 100644 (file)
@@ -15,4 +15,4 @@
 // * treaties. The SOFTWARE PRODUCT is licensed, not sold.                        *
 // *                                                                       *
 // *************************************************************************
-var _0xa946=['sms:queue:%s','emit','exports','lodash','util','ioredis','redis','localhost','name','timeout','strategy','beepall','Agents','mapAgentsId','waiting','md5','updateRouting','updateRealtime','_rr','map','prototype','loggedIn','paused','length','online','smsPause','available','stringify','format'];(function(_0x506f64,_0x395f5a){var _0x389fdb=function(_0x3cf504){while(--_0x3cf504){_0x506f64['push'](_0x506f64['shift']());}};_0x389fdb(++_0x395f5a);}(_0xa946,0x199));var _0x6a94=function(_0x1be1f6,_0x5e7089){_0x1be1f6=_0x1be1f6-0x0;var _0x2bd577=_0xa946[_0x1be1f6];return _0x2bd577;};'use strict';var _=require(_0x6a94('0x0'));var md5=require('md5');var util=require(_0x6a94('0x1'));var Redis=require(_0x6a94('0x2'));var config=require('../../../config/environment');config[_0x6a94('0x3')]=_['defaults'](config[_0x6a94('0x3')],{'host':_0x6a94('0x4'),'port':0x18eb});var io=require('socket.io-emitter')(new Redis(config[_0x6a94('0x3')]));function SmsQueue(_0x1f74f0){this['id']=_0x1f74f0['id']||0x0;this['name']=_0x1f74f0[_0x6a94('0x5')]||'';this['timeout']=_0x1f74f0[_0x6a94('0x6')]||0xa;this[_0x6a94('0x7')]=_0x1f74f0['strategy']||_0x6a94('0x8');this[_0x6a94('0x9')]=_0x1f74f0[_0x6a94('0x9')];this[_0x6a94('0xa')]={};this[_0x6a94('0xb')]=0x0;this[_0x6a94('0xc')]='';this[_0x6a94('0xd')]();this[_0x6a94('0xe')]();}SmsQueue['prototype'][_0x6a94('0xd')]=function(){var _0x17c2dc=this[_0x6a94('0xa')][_0x6a94('0xf')];this[_0x6a94('0xa')]=_[_0x6a94('0x10')](this[_0x6a94('0x9')],'id');this[_0x6a94('0xa')][_0x6a94('0xf')]=_0x17c2dc;};SmsQueue[_0x6a94('0x11')]['updateRealtime']=function(){this[_0x6a94('0x12')]=0x0;this[_0x6a94('0x13')]=0x0;for(var _0x5c8909=0x0;_0x5c8909<this['Agents'][_0x6a94('0x14')];_0x5c8909+=0x1){if(this['Agents'][_0x5c8909][_0x6a94('0x15')]){this[_0x6a94('0x12')]+=0x1;}if(this[_0x6a94('0x9')][_0x5c8909][_0x6a94('0x16')]){this[_0x6a94('0x13')]+=0x1;}}this[_0x6a94('0x17')]=this['loggedIn']-this['paused'];this[_0x6a94('0x17')]=this[_0x6a94('0x17')]>=0x0?this[_0x6a94('0x17')]:0x0;var _0x1a411b={'id':this['id'],'available':this[_0x6a94('0x17')],'loggedIn':this['loggedIn'],'name':this['name'],'paused':this[_0x6a94('0x13')],'waiting':this[_0x6a94('0xb')]};var _0x2f2cd6=md5(JSON[_0x6a94('0x18')](_0x1a411b));if(this[_0x6a94('0xc')]!==_0x2f2cd6){this[_0x6a94('0xc')]=_0x2f2cd6;io['to'](util[_0x6a94('0x19')](_0x6a94('0x1a'),_0x1a411b['name']))[_0x6a94('0x1b')]('sms_queue:save',_0x1a411b);}};module[_0x6a94('0x1c')]=SmsQueue;
\ No newline at end of file
+var _0xc630=['paused','length','smsPause','available','stringify','format','emit','exports','lodash','md5','util','ioredis','redis','defaults','localhost','socket.io-emitter','name','timeout','strategy','beepall','Agents','waiting','updateRealtime','prototype','updateRouting','mapAgentsId','loggedIn'];(function(_0x14add3,_0x13ce8d){var _0x4a174f=function(_0x2b3ed7){while(--_0x2b3ed7){_0x14add3['push'](_0x14add3['shift']());}};_0x4a174f(++_0x13ce8d);}(_0xc630,0x1b8));var _0x0c63=function(_0x3d11be,_0x1b9a8c){_0x3d11be=_0x3d11be-0x0;var _0x4b657b=_0xc630[_0x3d11be];return _0x4b657b;};'use strict';var _=require(_0x0c63('0x0'));var md5=require(_0x0c63('0x1'));var util=require(_0x0c63('0x2'));var Redis=require(_0x0c63('0x3'));var config=require('../../../config/environment');config[_0x0c63('0x4')]=_[_0x0c63('0x5')](config[_0x0c63('0x4')],{'host':_0x0c63('0x6'),'port':0x18eb});var io=require(_0x0c63('0x7'))(new Redis(config[_0x0c63('0x4')]));function SmsQueue(_0x4dde32){this['id']=_0x4dde32['id']||0x0;this[_0x0c63('0x8')]=_0x4dde32[_0x0c63('0x8')]||'';this[_0x0c63('0x9')]=_0x4dde32['timeout']||0xa;this[_0x0c63('0xa')]=_0x4dde32[_0x0c63('0xa')]||_0x0c63('0xb');this[_0x0c63('0xc')]=_0x4dde32['Agents'];this['mapAgentsId']={};this[_0x0c63('0xd')]=0x0;this['md5']='';this['updateRouting']();this[_0x0c63('0xe')]();}SmsQueue[_0x0c63('0xf')][_0x0c63('0x10')]=function(){var _0x26d61e=this['mapAgentsId']['_rr'];this[_0x0c63('0x11')]=_['map'](this[_0x0c63('0xc')],'id');this[_0x0c63('0x11')]['_rr']=_0x26d61e;};SmsQueue['prototype'][_0x0c63('0xe')]=function(){this[_0x0c63('0x12')]=0x0;this[_0x0c63('0x13')]=0x0;for(var _0x33b0c7=0x0;_0x33b0c7<this[_0x0c63('0xc')][_0x0c63('0x14')];_0x33b0c7+=0x1){if(this[_0x0c63('0xc')][_0x33b0c7]['online']){this['loggedIn']+=0x1;}if(this['Agents'][_0x33b0c7][_0x0c63('0x15')]){this['paused']+=0x1;}}this[_0x0c63('0x16')]=this[_0x0c63('0x12')]-this[_0x0c63('0x13')];this[_0x0c63('0x16')]=this[_0x0c63('0x16')]>=0x0?this[_0x0c63('0x16')]:0x0;var _0xa8c7c8={'id':this['id'],'available':this['available'],'loggedIn':this[_0x0c63('0x12')],'name':this['name'],'paused':this[_0x0c63('0x13')],'waiting':this['waiting']};var _0x5429a8=md5(JSON[_0x0c63('0x17')](_0xa8c7c8));if(this['md5']!==_0x5429a8){this[_0x0c63('0x1')]=_0x5429a8;io['to'](util[_0x0c63('0x18')]('sms:queue:%s',_0xa8c7c8['name']))[_0x0c63('0x19')]('sms_queue:save',_0xa8c7c8);}};module[_0x0c63('0x1a')]=SmsQueue;
\ No newline at end of file