server/api/whatsappQueue/whatsappQueue.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 _0xf8e5=['raw','lodash','moment','bluebird','randomstring','../../mysqldb','../../config/logger','rpc','../../config/environment','client','http','redis','localhost','socket.io-emitter','./whatsappQueue.socket','register','request','then','info','WhatsappQueue,\x20%s,\x20%s','request\x20sent','debug','WhatsappQueue,\x20%s,\x20%s,\x20%s','stringify','error','message','result','catch','GetWhatsappQueue','WhatsappQueue','findAll','options','attributes','limit','include','map','model','ShowWhatsappQueue'];(function(_0x207d93,_0x343573){var _0x36b960=function(_0x2f4663){while(--_0x2f4663){_0x207d93['push'](_0x207d93['shift']());}};_0x36b960(++_0x343573);}(_0xf8e5,0x131));var _0x5f8e=function(_0x2519a6,_0x20e9e0){_0x2519a6=_0x2519a6-0x0;var _0x5acf6f=_0xf8e5[_0x2519a6];return _0x5acf6f;};'use strict';var _=require(_0x5f8e('0x0'));var util=require('util');var moment=require(_0x5f8e('0x1'));var BPromise=require(_0x5f8e('0x2'));var rs=require(_0x5f8e('0x3'));var fs=require('fs');var Redis=require('ioredis');var db=require(_0x5f8e('0x4'))['db'];var utils=require('../../config/utils');var logger=require(_0x5f8e('0x5'))(_0x5f8e('0x6'));var config=require(_0x5f8e('0x7'));var jayson=require('jayson/promise');var client=jayson[_0x5f8e('0x8')][_0x5f8e('0x9')]({'port':0x232a});config[_0x5f8e('0xa')]=_['defaults'](config[_0x5f8e('0xa')],{'host':_0x5f8e('0xb'),'port':0x18eb});var socket=require(_0x5f8e('0xc'))(new Redis(config['redis']));require(_0x5f8e('0xd'))[_0x5f8e('0xe')](socket);function respondWithRpcPromise(_0x917111,_0x1992b7,_0x565355){return new BPromise(function(_0x28efbd,_0x66b0c4){return client[_0x5f8e('0xf')](_0x917111,_0x565355)[_0x5f8e('0x10')](function(_0xe13e11){logger[_0x5f8e('0x11')](_0x5f8e('0x12'),_0x1992b7,_0x5f8e('0x13'));logger[_0x5f8e('0x14')](_0x5f8e('0x15'),_0x1992b7,_0x5f8e('0x13'),JSON[_0x5f8e('0x16')](_0xe13e11));if(_0xe13e11['error']){if(_0xe13e11[_0x5f8e('0x17')]['code']===0x1f4){logger[_0x5f8e('0x17')](_0x5f8e('0x12'),_0x1992b7,_0xe13e11[_0x5f8e('0x17')][_0x5f8e('0x18')]);return _0x66b0c4(_0xe13e11['error'][_0x5f8e('0x18')]);}logger['error']('WhatsappQueue,\x20%s,\x20%s',_0x1992b7,_0xe13e11[_0x5f8e('0x17')]['message']);return _0x28efbd(_0xe13e11['error']['message']);}else{logger[_0x5f8e('0x11')](_0x5f8e('0x12'),_0x1992b7,_0x5f8e('0x13'));_0x28efbd(_0xe13e11[_0x5f8e('0x19')][_0x5f8e('0x18')]);}})[_0x5f8e('0x1a')](function(_0x25ff6c){logger[_0x5f8e('0x17')](_0x5f8e('0x12'),_0x1992b7,_0x25ff6c);_0x66b0c4(_0x25ff6c);});});}exports[_0x5f8e('0x1b')]=function(_0x28fb1a){var _0x574370=this;return new Promise(function(_0x29456b,_0x3ca4fd){return db[_0x5f8e('0x1c')][_0x5f8e('0x1d')]({'raw':_0x28fb1a[_0x5f8e('0x1e')]?_0x28fb1a['options']['raw']===undefined?!![]:![]:!![],'where':_0x28fb1a[_0x5f8e('0x1e')]?_0x28fb1a[_0x5f8e('0x1e')]['where']||null:null,'attributes':_0x28fb1a[_0x5f8e('0x1e')]?_0x28fb1a[_0x5f8e('0x1e')][_0x5f8e('0x1f')]||null:null,'limit':_0x28fb1a['options']?_0x28fb1a['options'][_0x5f8e('0x20')]||null:null,'include':_0x28fb1a[_0x5f8e('0x1e')]?_0x28fb1a[_0x5f8e('0x1e')][_0x5f8e('0x21')]?_['map'](_0x28fb1a[_0x5f8e('0x1e')][_0x5f8e('0x21')],function(_0x43aa47){return{'model':db[_0x43aa47['model']],'as':_0x43aa47['as'],'attributes':_0x43aa47[_0x5f8e('0x1f')],'include':_0x43aa47[_0x5f8e('0x21')]?_[_0x5f8e('0x22')](_0x43aa47[_0x5f8e('0x21')],function(_0x2174b7){return{'model':db[_0x2174b7[_0x5f8e('0x23')]],'as':_0x2174b7['as'],'attributes':_0x2174b7[_0x5f8e('0x1f')],'include':_0x2174b7[_0x5f8e('0x21')]?_[_0x5f8e('0x22')](_0x2174b7['include'],function(_0x54320c){return{'model':db[_0x54320c['model']],'as':_0x54320c['as'],'attributes':_0x54320c['attributes']};}):[]};}):[]};}):[]:[]})[_0x5f8e('0x10')](function(_0x1b1cd3){logger[_0x5f8e('0x11')]('GetWhatsappQueue',_0x28fb1a);logger[_0x5f8e('0x14')]('GetWhatsappQueue',_0x28fb1a,JSON[_0x5f8e('0x16')](_0x1b1cd3));_0x29456b(_0x1b1cd3);})['catch'](function(_0x5509ba){logger[_0x5f8e('0x17')]('GetWhatsappQueue',_0x5509ba[_0x5f8e('0x18')],_0x28fb1a);_0x3ca4fd(_0x574370[_0x5f8e('0x17')](0x1f4,_0x5509ba[_0x5f8e('0x18')]));});});};exports[_0x5f8e('0x24')]=function(_0x78463){var _0x585936=this;return new Promise(function(_0x4a04e9,_0x279b9f){return db[_0x5f8e('0x1c')]['find']({'raw':_0x78463[_0x5f8e('0x1e')]?_0x78463[_0x5f8e('0x1e')][_0x5f8e('0x25')]===undefined?!![]:![]:!![],'where':_0x78463[_0x5f8e('0x1e')]?_0x78463[_0x5f8e('0x1e')]['where']||null:null,'attributes':_0x78463[_0x5f8e('0x1e')]?_0x78463['options']['attributes']||null:null,'include':_0x78463[_0x5f8e('0x1e')]?_0x78463[_0x5f8e('0x1e')][_0x5f8e('0x21')]?_['map'](_0x78463[_0x5f8e('0x1e')][_0x5f8e('0x21')],function(_0x4ec402){return{'model':db[_0x4ec402[_0x5f8e('0x23')]],'as':_0x4ec402['as'],'attributes':_0x4ec402[_0x5f8e('0x1f')],'include':_0x4ec402[_0x5f8e('0x21')]?_[_0x5f8e('0x22')](_0x4ec402[_0x5f8e('0x21')],function(_0x493aa6){return{'model':db[_0x493aa6[_0x5f8e('0x23')]],'as':_0x493aa6['as'],'attributes':_0x493aa6[_0x5f8e('0x1f')],'include':_0x493aa6[_0x5f8e('0x21')]?_[_0x5f8e('0x22')](_0x493aa6[_0x5f8e('0x21')],function(_0x27249a){return{'model':db[_0x27249a[_0x5f8e('0x23')]],'as':_0x27249a['as'],'attributes':_0x27249a[_0x5f8e('0x1f')]};}):[]};}):[]};}):[]:[]})['then'](function(_0x270f67){logger[_0x5f8e('0x11')](_0x5f8e('0x24'),_0x78463);logger[_0x5f8e('0x14')](_0x5f8e('0x24'),_0x78463,JSON['stringify'](_0x270f67));_0x4a04e9(_0x270f67);})[_0x5f8e('0x1a')](function(_0x4c5e01){logger[_0x5f8e('0x17')](_0x5f8e('0x24'),_0x4c5e01[_0x5f8e('0x18')],_0x78463);_0x279b9f(_0x585936[_0x5f8e('0x17')](0x1f4,_0x4c5e01[_0x5f8e('0x18')]));});});};