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 _0x228a=['util','moment','bluebird','randomstring','../../mysqldb','../../config/utils','rpc','../../config/environment','jayson/promise','client','http','redis','defaults','localhost','./smsQueue.socket','request','info','SmsQueue,\x20%s,\x20%s','debug','stringify','error','code','message','request\x20sent','result','catch','findAll','options','raw','where','limit','map','model','attributes','include','then','GetSmsQueue','ShowSmsQueue','SmsQueue','lodash'];(function(_0x388578,_0x1df11e){var _0x95e762=function(_0x518964){while(--_0x518964){_0x388578['push'](_0x388578['shift']());}};_0x95e762(++_0x1df11e);}(_0x228a,0xef));var _0xa228=function(_0x4f4446,_0x3e530d){_0x4f4446=_0x4f4446-0x0;var _0x265646=_0x228a[_0x4f4446];return _0x265646;};'use strict';var _=require(_0xa228('0x0'));var util=require(_0xa228('0x1'));var moment=require(_0xa228('0x2'));var BPromise=require(_0xa228('0x3'));var rs=require(_0xa228('0x4'));var fs=require('fs');var Redis=require('ioredis');var db=require(_0xa228('0x5'))['db'];var utils=require(_0xa228('0x6'));var logger=require('../../config/logger')(_0xa228('0x7'));var config=require(_0xa228('0x8'));var jayson=require(_0xa228('0x9'));var client=jayson[_0xa228('0xa')][_0xa228('0xb')]({'port':0x232a});config[_0xa228('0xc')]=_[_0xa228('0xd')](config[_0xa228('0xc')],{'host':_0xa228('0xe'),'port':0x18eb});var socket=require('socket.io-emitter')(new Redis(config[_0xa228('0xc')]));require(_0xa228('0xf'))['register'](socket);function respondWithRpcPromise(_0x30bc93,_0x472c23,_0x5a3c9b){return new BPromise(function(_0x1e2018,_0x45fe47){return client[_0xa228('0x10')](_0x30bc93,_0x5a3c9b)['then'](function(_0x403dc1){logger[_0xa228('0x11')](_0xa228('0x12'),_0x472c23,'request\x20sent');logger[_0xa228('0x13')]('SmsQueue,\x20%s,\x20%s,\x20%s',_0x472c23,'request\x20sent',JSON[_0xa228('0x14')](_0x403dc1));if(_0x403dc1[_0xa228('0x15')]){if(_0x403dc1[_0xa228('0x15')][_0xa228('0x16')]===0x1f4){logger['error'](_0xa228('0x12'),_0x472c23,_0x403dc1['error'][_0xa228('0x17')]);return _0x45fe47(_0x403dc1[_0xa228('0x15')][_0xa228('0x17')]);}logger['error'](_0xa228('0x12'),_0x472c23,_0x403dc1['error']['message']);return _0x1e2018(_0x403dc1['error'][_0xa228('0x17')]);}else{logger['info'](_0xa228('0x12'),_0x472c23,_0xa228('0x18'));_0x1e2018(_0x403dc1[_0xa228('0x19')][_0xa228('0x17')]);}})[_0xa228('0x1a')](function(_0x54860c){logger['error'](_0xa228('0x12'),_0x472c23,_0x54860c);_0x45fe47(_0x54860c);});});}exports['GetSmsQueue']=function(_0xfb40fb){var _0x314bbf=this;return new Promise(function(_0x3cecee,_0x2844ed){return db['SmsQueue'][_0xa228('0x1b')]({'raw':_0xfb40fb['options']?_0xfb40fb[_0xa228('0x1c')][_0xa228('0x1d')]===undefined?!![]:![]:!![],'where':_0xfb40fb['options']?_0xfb40fb[_0xa228('0x1c')][_0xa228('0x1e')]||null:null,'attributes':_0xfb40fb[_0xa228('0x1c')]?_0xfb40fb[_0xa228('0x1c')]['attributes']||null:null,'limit':_0xfb40fb[_0xa228('0x1c')]?_0xfb40fb[_0xa228('0x1c')][_0xa228('0x1f')]||null:null,'include':_0xfb40fb['options']?_0xfb40fb[_0xa228('0x1c')]['include']?_[_0xa228('0x20')](_0xfb40fb[_0xa228('0x1c')]['include'],function(_0x43382e){return{'model':db[_0x43382e[_0xa228('0x21')]],'as':_0x43382e['as'],'attributes':_0x43382e[_0xa228('0x22')],'include':_0x43382e[_0xa228('0x23')]?_[_0xa228('0x20')](_0x43382e[_0xa228('0x23')],function(_0x58e895){return{'model':db[_0x58e895['model']],'as':_0x58e895['as'],'attributes':_0x58e895[_0xa228('0x22')],'include':_0x58e895[_0xa228('0x23')]?_['map'](_0x58e895[_0xa228('0x23')],function(_0x362342){return{'model':db[_0x362342[_0xa228('0x21')]],'as':_0x362342['as'],'attributes':_0x362342['attributes']};}):[]};}):[]};}):[]:[]})[_0xa228('0x24')](function(_0xb209ec){logger['info'](_0xa228('0x25'),_0xfb40fb);logger[_0xa228('0x13')](_0xa228('0x25'),_0xfb40fb,JSON[_0xa228('0x14')](_0xb209ec));_0x3cecee(_0xb209ec);})[_0xa228('0x1a')](function(_0x394d07){logger[_0xa228('0x15')](_0xa228('0x25'),_0x394d07[_0xa228('0x17')],_0xfb40fb);_0x2844ed(_0x314bbf['error'](0x1f4,_0x394d07[_0xa228('0x17')]));});});};exports[_0xa228('0x26')]=function(_0x36e813){var _0x1e8e25=this;return new Promise(function(_0x2bf11,_0x324d48){return db[_0xa228('0x27')]['find']({'raw':_0x36e813['options']?_0x36e813[_0xa228('0x1c')][_0xa228('0x1d')]===undefined?!![]:![]:!![],'where':_0x36e813['options']?_0x36e813[_0xa228('0x1c')][_0xa228('0x1e')]||null:null,'attributes':_0x36e813['options']?_0x36e813[_0xa228('0x1c')][_0xa228('0x22')]||null:null,'include':_0x36e813[_0xa228('0x1c')]?_0x36e813[_0xa228('0x1c')][_0xa228('0x23')]?_[_0xa228('0x20')](_0x36e813[_0xa228('0x1c')][_0xa228('0x23')],function(_0x22d6cf){return{'model':db[_0x22d6cf[_0xa228('0x21')]],'as':_0x22d6cf['as'],'attributes':_0x22d6cf[_0xa228('0x22')],'include':_0x22d6cf[_0xa228('0x23')]?_[_0xa228('0x20')](_0x22d6cf[_0xa228('0x23')],function(_0x5d2568){return{'model':db[_0x5d2568[_0xa228('0x21')]],'as':_0x5d2568['as'],'attributes':_0x5d2568['attributes'],'include':_0x5d2568[_0xa228('0x23')]?_['map'](_0x5d2568['include'],function(_0x31cfa2){return{'model':db[_0x31cfa2[_0xa228('0x21')]],'as':_0x31cfa2['as'],'attributes':_0x31cfa2[_0xa228('0x22')]};}):[]};}):[]};}):[]:[]})[_0xa228('0x24')](function(_0xe0126a){logger[_0xa228('0x11')](_0xa228('0x26'),_0x36e813);logger[_0xa228('0x13')](_0xa228('0x26'),_0x36e813,JSON[_0xa228('0x14')](_0xe0126a));_0x2bf11(_0xe0126a);})[_0xa228('0x1a')](function(_0xa6a185){logger[_0xa228('0x15')](_0xa228('0x26'),_0xa6a185[_0xa228('0x17')],_0x36e813);_0x324d48(_0x1e8e25['error'](0x1f4,_0xa6a185[_0xa228('0x17')]));});});};