server/api/smsQueue/smsQueue.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 _0xe7a6=['bluebird','randomstring','ioredis','../../mysqldb','../../config/utils','rpc','../../config/environment','jayson/promise','client','redis','defaults','localhost','./smsQueue.socket','register','request','info','SmsQueue,\x20%s,\x20%s','request\x20sent','debug','SmsQueue,\x20%s,\x20%s,\x20%s','stringify','code','error','message','result','catch','GetSmsQueue','findAll','options','raw','where','include','map','attributes','model','ShowSmsQueue','then','moment'];(function(_0xb5fa31,_0x301b22){var _0x30de98=function(_0x2d96cd){while(--_0x2d96cd){_0xb5fa31['push'](_0xb5fa31['shift']());}};_0x30de98(++_0x301b22);}(_0xe7a6,0x1ed));var _0x6e7a=function(_0x57b54c,_0x54ce0d){_0x57b54c=_0x57b54c-0x0;var _0x59cc19=_0xe7a6[_0x57b54c];return _0x59cc19;};'use strict';var _=require('lodash');var util=require('util');var moment=require(_0x6e7a('0x0'));var BPromise=require(_0x6e7a('0x1'));var rs=require(_0x6e7a('0x2'));var fs=require('fs');var Redis=require(_0x6e7a('0x3'));var db=require(_0x6e7a('0x4'))['db'];var utils=require(_0x6e7a('0x5'));var logger=require('../../config/logger')(_0x6e7a('0x6'));var config=require(_0x6e7a('0x7'));var jayson=require(_0x6e7a('0x8'));var client=jayson[_0x6e7a('0x9')]['http']({'port':0x232a});config[_0x6e7a('0xa')]=_[_0x6e7a('0xb')](config[_0x6e7a('0xa')],{'host':_0x6e7a('0xc'),'port':0x18eb});var socket=require('socket.io-emitter')(new Redis(config['redis']));require(_0x6e7a('0xd'))[_0x6e7a('0xe')](socket);function respondWithRpcPromise(_0x1b9880,_0x3805dd,_0x41d431){return new BPromise(function(_0x54cf99,_0x40041c){return client[_0x6e7a('0xf')](_0x1b9880,_0x41d431)['then'](function(_0x222852){logger[_0x6e7a('0x10')](_0x6e7a('0x11'),_0x3805dd,_0x6e7a('0x12'));logger[_0x6e7a('0x13')](_0x6e7a('0x14'),_0x3805dd,_0x6e7a('0x12'),JSON[_0x6e7a('0x15')](_0x222852));if(_0x222852['error']){if(_0x222852['error'][_0x6e7a('0x16')]===0x1f4){logger[_0x6e7a('0x17')](_0x6e7a('0x11'),_0x3805dd,_0x222852[_0x6e7a('0x17')][_0x6e7a('0x18')]);return _0x40041c(_0x222852['error'][_0x6e7a('0x18')]);}logger['error']('SmsQueue,\x20%s,\x20%s',_0x3805dd,_0x222852[_0x6e7a('0x17')][_0x6e7a('0x18')]);return _0x54cf99(_0x222852[_0x6e7a('0x17')][_0x6e7a('0x18')]);}else{logger[_0x6e7a('0x10')](_0x6e7a('0x11'),_0x3805dd,_0x6e7a('0x12'));_0x54cf99(_0x222852[_0x6e7a('0x19')]['message']);}})[_0x6e7a('0x1a')](function(_0x5074bc){logger[_0x6e7a('0x17')](_0x6e7a('0x11'),_0x3805dd,_0x5074bc);_0x40041c(_0x5074bc);});});}exports[_0x6e7a('0x1b')]=function(_0x1475fd){var _0x30f779=this;return new Promise(function(_0xd0cb17,_0x4d2c17){return db['SmsQueue'][_0x6e7a('0x1c')]({'raw':_0x1475fd[_0x6e7a('0x1d')]?_0x1475fd[_0x6e7a('0x1d')][_0x6e7a('0x1e')]===undefined?!![]:![]:!![],'where':_0x1475fd[_0x6e7a('0x1d')]?_0x1475fd['options'][_0x6e7a('0x1f')]||null:null,'attributes':_0x1475fd[_0x6e7a('0x1d')]?_0x1475fd[_0x6e7a('0x1d')]['attributes']||null:null,'limit':_0x1475fd['options']?_0x1475fd['options']['limit']||null:null,'include':_0x1475fd[_0x6e7a('0x1d')]?_0x1475fd[_0x6e7a('0x1d')][_0x6e7a('0x20')]?_[_0x6e7a('0x21')](_0x1475fd[_0x6e7a('0x1d')][_0x6e7a('0x20')],function(_0x419817){return{'model':db[_0x419817['model']],'as':_0x419817['as'],'attributes':_0x419817[_0x6e7a('0x22')],'include':_0x419817[_0x6e7a('0x20')]?_[_0x6e7a('0x21')](_0x419817[_0x6e7a('0x20')],function(_0x29b55e){return{'model':db[_0x29b55e[_0x6e7a('0x23')]],'as':_0x29b55e['as'],'attributes':_0x29b55e[_0x6e7a('0x22')],'include':_0x29b55e[_0x6e7a('0x20')]?_[_0x6e7a('0x21')](_0x29b55e[_0x6e7a('0x20')],function(_0x290359){return{'model':db[_0x290359['model']],'as':_0x290359['as'],'attributes':_0x290359[_0x6e7a('0x22')]};}):[]};}):[]};}):[]:[]})['then'](function(_0x3ef569){logger[_0x6e7a('0x10')](_0x6e7a('0x1b'),_0x1475fd);logger[_0x6e7a('0x13')](_0x6e7a('0x1b'),_0x1475fd,JSON[_0x6e7a('0x15')](_0x3ef569));_0xd0cb17(_0x3ef569);})['catch'](function(_0x43e777){logger['error'](_0x6e7a('0x1b'),_0x43e777['message'],_0x1475fd);_0x4d2c17(_0x30f779[_0x6e7a('0x17')](0x1f4,_0x43e777[_0x6e7a('0x18')]));});});};exports[_0x6e7a('0x24')]=function(_0x5af97a){var _0x1838d9=this;return new Promise(function(_0x5bbc15,_0x3ca355){return db['SmsQueue']['find']({'raw':_0x5af97a[_0x6e7a('0x1d')]?_0x5af97a[_0x6e7a('0x1d')]['raw']===undefined?!![]:![]:!![],'where':_0x5af97a[_0x6e7a('0x1d')]?_0x5af97a['options']['where']||null:null,'attributes':_0x5af97a['options']?_0x5af97a[_0x6e7a('0x1d')][_0x6e7a('0x22')]||null:null,'include':_0x5af97a[_0x6e7a('0x1d')]?_0x5af97a[_0x6e7a('0x1d')][_0x6e7a('0x20')]?_[_0x6e7a('0x21')](_0x5af97a[_0x6e7a('0x1d')][_0x6e7a('0x20')],function(_0x1e17f2){return{'model':db[_0x1e17f2[_0x6e7a('0x23')]],'as':_0x1e17f2['as'],'attributes':_0x1e17f2[_0x6e7a('0x22')],'include':_0x1e17f2[_0x6e7a('0x20')]?_[_0x6e7a('0x21')](_0x1e17f2[_0x6e7a('0x20')],function(_0x1a3185){return{'model':db[_0x1a3185[_0x6e7a('0x23')]],'as':_0x1a3185['as'],'attributes':_0x1a3185[_0x6e7a('0x22')],'include':_0x1a3185[_0x6e7a('0x20')]?_['map'](_0x1a3185[_0x6e7a('0x20')],function(_0x2fbe5f){return{'model':db[_0x2fbe5f[_0x6e7a('0x23')]],'as':_0x2fbe5f['as'],'attributes':_0x2fbe5f[_0x6e7a('0x22')]};}):[]};}):[]};}):[]:[]})[_0x6e7a('0x25')](function(_0x540b21){logger[_0x6e7a('0x10')](_0x6e7a('0x24'),_0x5af97a);logger[_0x6e7a('0x13')]('ShowSmsQueue',_0x5af97a,JSON[_0x6e7a('0x15')](_0x540b21));_0x5bbc15(_0x540b21);})[_0x6e7a('0x1a')](function(_0x1a7a10){logger['error'](_0x6e7a('0x24'),_0x1a7a10[_0x6e7a('0x18')],_0x5af97a);_0x3ca355(_0x1838d9[_0x6e7a('0x17')](0x1f4,_0x1a7a10['message']));});});};