server/services/routing/model/smsQueue.js

   1 // *************************************************************************
   2 // *                                                                       *
   3 // * xCALLY Motion -  The Omnichannel Contact Center                       *
   4 // * Copyright (c) Xenialab s.r.l. All Rights Reserved                     *
   5 // *                                                                       *
   6 // *************************************************************************
   7 // *                                                                       *
   8 // * Email: info@xcally.com                                                *
   9 // * Website: https://www.xcally.com                                       *
  10 // *                                                                       *
  11 // *************************************************************************
  12 // *                                                                       *
  13 // * The SOFTWARE PRODUCT is protected by copyright laws and international *
  14 // * copyright treaties, as well as other intellectual property laws and   *
  15 // * treaties. The SOFTWARE PRODUCT is licensed, not sold.                         *
  16 // *                                                                       *
  17 // *************************************************************************
  18 var _0x6953=['name','timeout','strategy','Agents','mapAgentsId','updateRouting','prototype','_rr','updateRealtime','loggedIn','paused','length','smsPause','available','stringify','format','sms:queue:%s','emit','sms_queue:save','exports','lodash','md5','redis','localhost','socket.io-emitter'];(function(_0x594622,_0x7c8ce6){var _0x397608=function(_0x512211){while(--_0x512211){_0x594622['push'](_0x594622['shift']());}};_0x397608(++_0x7c8ce6);}(_0x6953,0x91));var _0x3695=function(_0xd89691,_0x3ff428){_0xd89691=_0xd89691-0x0;var _0x5afbad=_0x6953[_0xd89691];return _0x5afbad;};'use strict';var _=require(_0x3695('0x0'));var md5=require(_0x3695('0x1'));var util=require('util');var Redis=require('ioredis');var config=require('../../../config/environment');config[_0x3695('0x2')]=_['defaults'](config[_0x3695('0x2')],{'host':_0x3695('0x3'),'port':0x18eb});var io=require(_0x3695('0x4'))(new Redis(config['redis']));function SmsQueue(_0xd0f9a5){this['id']=_0xd0f9a5['id']||0x0;this['name']=_0xd0f9a5[_0x3695('0x5')]||'';this[_0x3695('0x6')]=_0xd0f9a5[_0x3695('0x6')]||0xa;this[_0x3695('0x7')]=_0xd0f9a5[_0x3695('0x7')]||'beepall';this[_0x3695('0x8')]=_0xd0f9a5['Agents'];this[_0x3695('0x9')]={};this['waiting']=0x0;this['md5']='';this[_0x3695('0xa')]();this['updateRealtime']();}SmsQueue[_0x3695('0xb')][_0x3695('0xa')]=function(){var _0x2a7ab7=this[_0x3695('0x9')][_0x3695('0xc')];this[_0x3695('0x9')]=_['map'](this[_0x3695('0x8')],'id');this[_0x3695('0x9')][_0x3695('0xc')]=_0x2a7ab7;};SmsQueue[_0x3695('0xb')][_0x3695('0xd')]=function(){this[_0x3695('0xe')]=0x0;this[_0x3695('0xf')]=0x0;for(var _0x4df429=0x0;_0x4df429<this[_0x3695('0x8')][_0x3695('0x10')];_0x4df429+=0x1){if(this[_0x3695('0x8')][_0x4df429]['online']){this[_0x3695('0xe')]+=0x1;}if(this[_0x3695('0x8')][_0x4df429][_0x3695('0x11')]){this[_0x3695('0xf')]+=0x1;}}this[_0x3695('0x12')]=this[_0x3695('0xe')]-this[_0x3695('0xf')];this['available']=this[_0x3695('0x12')]>=0x0?this['available']:0x0;var _0x1082db={'id':this['id'],'available':this[_0x3695('0x12')],'loggedIn':this[_0x3695('0xe')],'name':this[_0x3695('0x5')],'paused':this[_0x3695('0xf')],'waiting':this['waiting']};var _0x1bb921=md5(JSON[_0x3695('0x13')](_0x1082db));if(this[_0x3695('0x1')]!==_0x1bb921){this[_0x3695('0x1')]=_0x1bb921;io['to'](util[_0x3695('0x14')](_0x3695('0x15'),_0x1082db[_0x3695('0x5')]))[_0x3695('0x16')](_0x3695('0x17'),_0x1082db);}};module[_0x3695('0x18')]=SmsQueue;