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 _0x2bd0=['SmsQueue,\x20%s,\x20%s','SmsQueue,\x20%s,\x20%s,\x20%s','request\x20sent','stringify','error','code','message','result','catch','GetSmsQueue','SmsQueue','options','where','limit','include','map','model','attributes','find','ShowSmsQueue','debug','lodash','util','bluebird','randomstring','../../mysqldb','../../config/utils','../../config/logger','rpc','../../config/environment','jayson/promise','client','defaults','socket.io-emitter','then','info'];(function(_0x376b45,_0x5964fb){var _0x2341b3=function(_0x5a7f01){while(--_0x5a7f01){_0x376b45['push'](_0x376b45['shift']());}};_0x2341b3(++_0x5964fb);}(_0x2bd0,0xa5));var _0x02bd=function(_0x4e9628,_0x250573){_0x4e9628=_0x4e9628-0x0;var _0x27bc8c=_0x2bd0[_0x4e9628];return _0x27bc8c;};'use strict';var _=require(_0x02bd('0x0'));var util=require(_0x02bd('0x1'));var moment=require('moment');var BPromise=require(_0x02bd('0x2'));var rs=require(_0x02bd('0x3'));var fs=require('fs');var Redis=require('ioredis');var db=require(_0x02bd('0x4'))['db'];var utils=require(_0x02bd('0x5'));var logger=require(_0x02bd('0x6'))(_0x02bd('0x7'));var config=require(_0x02bd('0x8'));var jayson=require(_0x02bd('0x9'));var client=jayson[_0x02bd('0xa')]['http']({'port':0x232a});config['redis']=_[_0x02bd('0xb')](config['redis'],{'host':'localhost','port':0x18eb});var socket=require(_0x02bd('0xc'))(new Redis(config['redis']));require('./smsQueue.socket')['register'](socket);function respondWithRpcPromise(_0x184f7b,_0x1b7b30,_0x34c940){return new BPromise(function(_0x5c9549,_0x55f62d){return client['request'](_0x184f7b,_0x34c940)[_0x02bd('0xd')](function(_0x54915c){logger[_0x02bd('0xe')](_0x02bd('0xf'),_0x1b7b30,'request\x20sent');logger['debug'](_0x02bd('0x10'),_0x1b7b30,_0x02bd('0x11'),JSON[_0x02bd('0x12')](_0x54915c));if(_0x54915c[_0x02bd('0x13')]){if(_0x54915c[_0x02bd('0x13')][_0x02bd('0x14')]===0x1f4){logger[_0x02bd('0x13')](_0x02bd('0xf'),_0x1b7b30,_0x54915c[_0x02bd('0x13')]['message']);return _0x55f62d(_0x54915c['error']['message']);}logger[_0x02bd('0x13')]('SmsQueue,\x20%s,\x20%s',_0x1b7b30,_0x54915c['error'][_0x02bd('0x15')]);return _0x5c9549(_0x54915c[_0x02bd('0x13')][_0x02bd('0x15')]);}else{logger[_0x02bd('0xe')]('SmsQueue,\x20%s,\x20%s',_0x1b7b30,_0x02bd('0x11'));_0x5c9549(_0x54915c[_0x02bd('0x16')][_0x02bd('0x15')]);}})[_0x02bd('0x17')](function(_0x2f4ac3){logger[_0x02bd('0x13')](_0x02bd('0xf'),_0x1b7b30,_0x2f4ac3);_0x55f62d(_0x2f4ac3);});});}exports[_0x02bd('0x18')]=function(_0x208867){var _0x1e09fe=this;return new Promise(function(_0x1c24c1,_0x41f6cb){return db[_0x02bd('0x19')]['findAll']({'raw':_0x208867['options']?_0x208867[_0x02bd('0x1a')]['raw']===undefined?!![]:![]:!![],'where':_0x208867[_0x02bd('0x1a')]?_0x208867['options'][_0x02bd('0x1b')]||null:null,'attributes':_0x208867[_0x02bd('0x1a')]?_0x208867[_0x02bd('0x1a')]['attributes']||null:null,'limit':_0x208867[_0x02bd('0x1a')]?_0x208867[_0x02bd('0x1a')][_0x02bd('0x1c')]||null:null,'include':_0x208867[_0x02bd('0x1a')]?_0x208867[_0x02bd('0x1a')][_0x02bd('0x1d')]?_[_0x02bd('0x1e')](_0x208867[_0x02bd('0x1a')][_0x02bd('0x1d')],function(_0x56424f){return{'model':db[_0x56424f[_0x02bd('0x1f')]],'as':_0x56424f['as'],'attributes':_0x56424f['attributes'],'include':_0x56424f[_0x02bd('0x1d')]?_[_0x02bd('0x1e')](_0x56424f[_0x02bd('0x1d')],function(_0x549c3f){return{'model':db[_0x549c3f[_0x02bd('0x1f')]],'as':_0x549c3f['as'],'attributes':_0x549c3f[_0x02bd('0x20')],'include':_0x549c3f[_0x02bd('0x1d')]?_['map'](_0x549c3f[_0x02bd('0x1d')],function(_0x570e1a){return{'model':db[_0x570e1a[_0x02bd('0x1f')]],'as':_0x570e1a['as'],'attributes':_0x570e1a[_0x02bd('0x20')]};}):[]};}):[]};}):[]:[]})[_0x02bd('0xd')](function(_0x3ffdcc){logger[_0x02bd('0xe')]('GetSmsQueue',_0x208867);logger['debug'](_0x02bd('0x18'),_0x208867,JSON[_0x02bd('0x12')](_0x3ffdcc));_0x1c24c1(_0x3ffdcc);})[_0x02bd('0x17')](function(_0xf62841){logger[_0x02bd('0x13')]('GetSmsQueue',_0xf62841[_0x02bd('0x15')],_0x208867);_0x41f6cb(_0x1e09fe[_0x02bd('0x13')](0x1f4,_0xf62841[_0x02bd('0x15')]));});});};exports['ShowSmsQueue']=function(_0x6c31d6){var _0x4b2219=this;return new Promise(function(_0xc204dd,_0x1d614d){return db[_0x02bd('0x19')][_0x02bd('0x21')]({'raw':_0x6c31d6[_0x02bd('0x1a')]?_0x6c31d6['options']['raw']===undefined?!![]:![]:!![],'where':_0x6c31d6[_0x02bd('0x1a')]?_0x6c31d6[_0x02bd('0x1a')]['where']||null:null,'attributes':_0x6c31d6[_0x02bd('0x1a')]?_0x6c31d6[_0x02bd('0x1a')][_0x02bd('0x20')]||null:null,'include':_0x6c31d6[_0x02bd('0x1a')]?_0x6c31d6[_0x02bd('0x1a')]['include']?_['map'](_0x6c31d6[_0x02bd('0x1a')][_0x02bd('0x1d')],function(_0x5a12c5){return{'model':db[_0x5a12c5[_0x02bd('0x1f')]],'as':_0x5a12c5['as'],'attributes':_0x5a12c5['attributes'],'include':_0x5a12c5[_0x02bd('0x1d')]?_['map'](_0x5a12c5['include'],function(_0xa53522){return{'model':db[_0xa53522['model']],'as':_0xa53522['as'],'attributes':_0xa53522['attributes'],'include':_0xa53522[_0x02bd('0x1d')]?_[_0x02bd('0x1e')](_0xa53522[_0x02bd('0x1d')],function(_0x9f75e9){return{'model':db[_0x9f75e9[_0x02bd('0x1f')]],'as':_0x9f75e9['as'],'attributes':_0x9f75e9[_0x02bd('0x20')]};}):[]};}):[]};}):[]:[]})[_0x02bd('0xd')](function(_0x2f4c86){logger[_0x02bd('0xe')](_0x02bd('0x22'),_0x6c31d6);logger[_0x02bd('0x23')](_0x02bd('0x22'),_0x6c31d6,JSON[_0x02bd('0x12')](_0x2f4c86));_0xc204dd(_0x2f4c86);})[_0x02bd('0x17')](function(_0x22ce8a){logger['error'](_0x02bd('0x22'),_0x22ce8a[_0x02bd('0x15')],_0x6c31d6);_0x1d614d(_0x4b2219['error'](0x1f4,_0x22ce8a['message']));});});};