server/api/userVoiceQueueRt/userVoiceQueueRt.rpc.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 _0x55c8=['randomstring','ioredis','../../mysqldb','../../config/utils','../../config/logger','rpc','jayson/promise','client','http','redis','localhost','./userVoiceQueueRt.socket','register','then','info','UserVoiceQueueRt,\x20%s,\x20%s','request\x20sent','stringify','error','code','message','catch','GetVoiceQueueRtPauses','UserVoiceQueueRt','findAll','options','where','sequelize','COUNT','literal','`paused`\x20=\x201,\x201,\x20null','outboundQueuePauses','debug','lodash','util','moment','bluebird'];(function(_0x4b6420,_0x126201){var _0x37076f=function(_0x3ee471){while(--_0x3ee471){_0x4b6420['push'](_0x4b6420['shift']());}};_0x37076f(++_0x126201);}(_0x55c8,0xff));var _0x855c=function(_0x1cf5e6,_0x110fd9){_0x1cf5e6=_0x1cf5e6-0x0;var _0x342c36=_0x55c8[_0x1cf5e6];return _0x342c36;};'use strict';var _=require(_0x855c('0x0'));var util=require(_0x855c('0x1'));var moment=require(_0x855c('0x2'));var BPromise=require(_0x855c('0x3'));var rs=require(_0x855c('0x4'));var fs=require('fs');var Redis=require(_0x855c('0x5'));var db=require(_0x855c('0x6'))['db'];var utils=require(_0x855c('0x7'));var logger=require(_0x855c('0x8'))(_0x855c('0x9'));var config=require('../../config/environment');var jayson=require(_0x855c('0xa'));var client=jayson[_0x855c('0xb')][_0x855c('0xc')]({'port':0x232a});config[_0x855c('0xd')]=_['defaults'](config['redis'],{'host':_0x855c('0xe'),'port':0x18eb});var socket=require('socket.io-emitter')(new Redis(config['redis']));require(_0x855c('0xf'))[_0x855c('0x10')](socket);function respondWithRpcPromise(_0x28d634,_0x795595,_0x3d43b5){return new BPromise(function(_0x38f0fc,_0x1a6ea8){return client['request'](_0x28d634,_0x3d43b5)[_0x855c('0x11')](function(_0x573a4f){logger[_0x855c('0x12')](_0x855c('0x13'),_0x795595,_0x855c('0x14'));logger['debug']('UserVoiceQueueRt,\x20%s,\x20%s,\x20%s',_0x795595,_0x855c('0x14'),JSON[_0x855c('0x15')](_0x573a4f));if(_0x573a4f['error']){if(_0x573a4f[_0x855c('0x16')][_0x855c('0x17')]===0x1f4){logger[_0x855c('0x16')](_0x855c('0x13'),_0x795595,_0x573a4f[_0x855c('0x16')][_0x855c('0x18')]);return _0x1a6ea8(_0x573a4f[_0x855c('0x16')][_0x855c('0x18')]);}logger[_0x855c('0x16')](_0x855c('0x13'),_0x795595,_0x573a4f[_0x855c('0x16')][_0x855c('0x18')]);return _0x38f0fc(_0x573a4f[_0x855c('0x16')][_0x855c('0x18')]);}else{logger[_0x855c('0x12')](_0x855c('0x13'),_0x795595,_0x855c('0x14'));_0x38f0fc(_0x573a4f['result'][_0x855c('0x18')]);}})[_0x855c('0x19')](function(_0xdc71f9){logger[_0x855c('0x16')](_0x855c('0x13'),_0x795595,_0xdc71f9);_0x1a6ea8(_0xdc71f9);});});}exports[_0x855c('0x1a')]=function(_0x11af7f){var _0x838e81=this;return new Promise(function(_0x598930,_0xbebe2){return db[_0x855c('0x1b')][_0x855c('0x1c')]({'raw':_0x11af7f[_0x855c('0x1d')]?_0x11af7f['options']['raw']===undefined?!![]:![]:!![],'where':_0x11af7f['options']?_0x11af7f[_0x855c('0x1d')][_0x855c('0x1e')]||null:null,'attributes':[[db[_0x855c('0x1f')]['fn'](_0x855c('0x20'),db[_0x855c('0x1f')]['fn']('IF',db[_0x855c('0x1f')][_0x855c('0x21')](_0x855c('0x22')))),_0x855c('0x23')]]})[_0x855c('0x11')](function(_0x59b743){logger[_0x855c('0x12')]('GetVoiceQueueRtPauses',_0x11af7f);logger[_0x855c('0x24')](_0x855c('0x1a'),_0x11af7f,JSON['stringify'](_0x59b743));_0x598930(_0x59b743);})[_0x855c('0x19')](function(_0x273f89){logger[_0x855c('0x16')](_0x855c('0x1a'),_0x273f89[_0x855c('0x18')],_0x11af7f);_0xbebe2(_0x838e81[_0x855c('0x16')](0x1f4,_0x273f89['message']));});});};