Built motion from commit (unavailable).|2.0.84
[motion2.git] / server / services / routing / model / openchannelQueue.js
index ae1db27..7291b87 100644 (file)
@@ -15,4 +15,4 @@
 // * treaties. The SOFTWARE PRODUCT is licensed, not sold.                        *
 // *                                                                       *
 // *************************************************************************
-var _0x8a39=['mapAgentsId','md5','updateRouting','updateRealtime','prototype','_rr','map','paused','length','openchannelPause','available','loggedIn','waiting','format','openchannel:queue:%s','emit','exports','util','../../../config/environment','redis','localhost','socket.io-emitter','name','timeout','strategy','Agents'];(function(_0x2f01e5,_0x281a09){var _0x44a02f=function(_0xd99116){while(--_0xd99116){_0x2f01e5['push'](_0x2f01e5['shift']());}};_0x44a02f(++_0x281a09);}(_0x8a39,0x17d));var _0x98a3=function(_0x3dd15e,_0x1f0015){_0x3dd15e=_0x3dd15e-0x0;var _0x231fd0=_0x8a39[_0x3dd15e];return _0x231fd0;};'use strict';var _=require('lodash');var md5=require('md5');var util=require(_0x98a3('0x0'));var config=require(_0x98a3('0x1'));config[_0x98a3('0x2')]=_['defaults'](config[_0x98a3('0x2')],{'host':_0x98a3('0x3'),'port':0x18eb});var io=require(_0x98a3('0x4'))(config[_0x98a3('0x2')]);function OpenchannelQueue(_0x48109f){this['id']=_0x48109f['id']||0x0;this[_0x98a3('0x5')]=_0x48109f[_0x98a3('0x5')]||'';this[_0x98a3('0x6')]=_0x48109f[_0x98a3('0x6')]||0xa;this[_0x98a3('0x7')]=_0x48109f[_0x98a3('0x7')]||'beepall';this[_0x98a3('0x8')]=_0x48109f[_0x98a3('0x8')];this[_0x98a3('0x9')]={};this['waiting']=0x0;this[_0x98a3('0xa')]='';this[_0x98a3('0xb')]();this[_0x98a3('0xc')]();}OpenchannelQueue[_0x98a3('0xd')][_0x98a3('0xb')]=function(){var _0x34e4db=this[_0x98a3('0x9')][_0x98a3('0xe')];this[_0x98a3('0x9')]=_[_0x98a3('0xf')](this['Agents'],'id');this[_0x98a3('0x9')][_0x98a3('0xe')]=_0x34e4db;};OpenchannelQueue['prototype'][_0x98a3('0xc')]=function(){this['loggedIn']=0x0;this[_0x98a3('0x10')]=0x0;for(var _0x4d0527=0x0;_0x4d0527<this[_0x98a3('0x8')][_0x98a3('0x11')];_0x4d0527+=0x1){if(this[_0x98a3('0x8')][_0x4d0527]['online']){this['loggedIn']+=0x1;}if(this[_0x98a3('0x8')][_0x4d0527][_0x98a3('0x12')]){this[_0x98a3('0x10')]+=0x1;}}this[_0x98a3('0x13')]=this[_0x98a3('0x14')]-this['paused'];this['available']=this[_0x98a3('0x13')]>=0x0?this[_0x98a3('0x13')]:0x0;var _0x5fb0be={'id':this['id'],'available':this[_0x98a3('0x13')],'loggedIn':this['loggedIn'],'name':this[_0x98a3('0x5')],'paused':this[_0x98a3('0x10')],'waiting':this[_0x98a3('0x15')]};var _0x3e100d=md5(JSON['stringify'](_0x5fb0be));if(this['md5']!==_0x3e100d){this[_0x98a3('0xa')]=_0x3e100d;io['to'](util[_0x98a3('0x16')](_0x98a3('0x17'),_0x5fb0be[_0x98a3('0x5')]))[_0x98a3('0x18')]('openchannel_queue:save',_0x5fb0be);}};module[_0x98a3('0x19')]=OpenchannelQueue;
\ No newline at end of file
+var _0x29a0=['mapAgentsId','waiting','updateRouting','updateRealtime','prototype','_rr','map','loggedIn','online','paused','available','stringify','format','emit','openchannel_queue:save','md5','util','ioredis','redis','defaults','localhost','name','timeout','beepall','Agents'];(function(_0x37d3e0,_0x51d1f4){var _0x5512a3=function(_0x496e6b){while(--_0x496e6b){_0x37d3e0['push'](_0x37d3e0['shift']());}};_0x5512a3(++_0x51d1f4);}(_0x29a0,0x8c));var _0x029a=function(_0x36dd24,_0x53bf96){_0x36dd24=_0x36dd24-0x0;var _0xe95e18=_0x29a0[_0x36dd24];return _0xe95e18;};'use strict';var _=require('lodash');var md5=require(_0x029a('0x0'));var util=require(_0x029a('0x1'));var Redis=require(_0x029a('0x2'));var config=require('../../../config/environment');config[_0x029a('0x3')]=_[_0x029a('0x4')](config[_0x029a('0x3')],{'host':_0x029a('0x5'),'port':0x18eb});var io=require('socket.io-emitter')(new Redis(config['redis']));function OpenchannelQueue(_0x302526){this['id']=_0x302526['id']||0x0;this[_0x029a('0x6')]=_0x302526[_0x029a('0x6')]||'';this[_0x029a('0x7')]=_0x302526[_0x029a('0x7')]||0xa;this['strategy']=_0x302526['strategy']||_0x029a('0x8');this[_0x029a('0x9')]=_0x302526['Agents'];this[_0x029a('0xa')]={};this[_0x029a('0xb')]=0x0;this[_0x029a('0x0')]='';this[_0x029a('0xc')]();this[_0x029a('0xd')]();}OpenchannelQueue[_0x029a('0xe')][_0x029a('0xc')]=function(){var _0x2ff3ec=this['mapAgentsId'][_0x029a('0xf')];this[_0x029a('0xa')]=_[_0x029a('0x10')](this[_0x029a('0x9')],'id');this[_0x029a('0xa')][_0x029a('0xf')]=_0x2ff3ec;};OpenchannelQueue[_0x029a('0xe')][_0x029a('0xd')]=function(){this[_0x029a('0x11')]=0x0;this['paused']=0x0;for(var _0x1cb71a=0x0;_0x1cb71a<this[_0x029a('0x9')]['length'];_0x1cb71a+=0x1){if(this['Agents'][_0x1cb71a][_0x029a('0x12')]){this['loggedIn']+=0x1;}if(this[_0x029a('0x9')][_0x1cb71a]['openchannelPause']){this[_0x029a('0x13')]+=0x1;}}this[_0x029a('0x14')]=this[_0x029a('0x11')]-this['paused'];this[_0x029a('0x14')]=this[_0x029a('0x14')]>=0x0?this[_0x029a('0x14')]:0x0;var _0x4ea2df={'id':this['id'],'available':this[_0x029a('0x14')],'loggedIn':this[_0x029a('0x11')],'name':this[_0x029a('0x6')],'paused':this['paused'],'waiting':this[_0x029a('0xb')]};var _0x3d689e=md5(JSON[_0x029a('0x15')](_0x4ea2df));if(this[_0x029a('0x0')]!==_0x3d689e){this[_0x029a('0x0')]=_0x3d689e;io['to'](util[_0x029a('0x16')]('openchannel:queue:%s',_0x4ea2df['name']))[_0x029a('0x17')](_0x029a('0x18'),_0x4ea2df);}};module['exports']=OpenchannelQueue;
\ No newline at end of file