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 _0xc4e1=['find','where','moment','bluebird','ioredis','../../config/utils','../../config/logger','rpc','../../config/environment','jayson/promise','client','http','redis','defaults','localhost','socket.io-emitter','./whatsappQueue.socket','register','request','then','info','WhatsappQueue,\x20%s,\x20%s','request\x20sent','debug','stringify','error','code','message','result','catch','WhatsappQueue','findAll','raw','options','attributes','limit','include','map','model','GetWhatsappQueue','ShowWhatsappQueue'];(function(_0x5471ec,_0x1ce81a){var _0x121d4c=function(_0xefb655){while(--_0xefb655){_0x5471ec['push'](_0x5471ec['shift']());}};_0x121d4c(++_0x1ce81a);}(_0xc4e1,0x19c));var _0x1c4e=function(_0x4a6d73,_0x12482f){_0x4a6d73=_0x4a6d73-0x0;var _0x5e904b=_0xc4e1[_0x4a6d73];return _0x5e904b;};'use strict';var _=require('lodash');var util=require('util');var moment=require(_0x1c4e('0x0'));var BPromise=require(_0x1c4e('0x1'));var rs=require('randomstring');var fs=require('fs');var Redis=require(_0x1c4e('0x2'));var db=require('../../mysqldb')['db'];var utils=require(_0x1c4e('0x3'));var logger=require(_0x1c4e('0x4'))(_0x1c4e('0x5'));var config=require(_0x1c4e('0x6'));var jayson=require(_0x1c4e('0x7'));var client=jayson[_0x1c4e('0x8')][_0x1c4e('0x9')]({'port':0x232a});config[_0x1c4e('0xa')]=_[_0x1c4e('0xb')](config[_0x1c4e('0xa')],{'host':_0x1c4e('0xc'),'port':0x18eb});var socket=require(_0x1c4e('0xd'))(new Redis(config['redis']));require(_0x1c4e('0xe'))[_0x1c4e('0xf')](socket);function respondWithRpcPromise(_0x22dbb2,_0x141948,_0x2ef440){return new BPromise(function(_0x4ba533,_0x10d447){return client[_0x1c4e('0x10')](_0x22dbb2,_0x2ef440)[_0x1c4e('0x11')](function(_0x4580c9){logger[_0x1c4e('0x12')](_0x1c4e('0x13'),_0x141948,_0x1c4e('0x14'));logger[_0x1c4e('0x15')]('WhatsappQueue,\x20%s,\x20%s,\x20%s',_0x141948,'request\x20sent',JSON[_0x1c4e('0x16')](_0x4580c9));if(_0x4580c9[_0x1c4e('0x17')]){if(_0x4580c9[_0x1c4e('0x17')][_0x1c4e('0x18')]===0x1f4){logger[_0x1c4e('0x17')](_0x1c4e('0x13'),_0x141948,_0x4580c9['error'][_0x1c4e('0x19')]);return _0x10d447(_0x4580c9[_0x1c4e('0x17')][_0x1c4e('0x19')]);}logger['error'](_0x1c4e('0x13'),_0x141948,_0x4580c9[_0x1c4e('0x17')][_0x1c4e('0x19')]);return _0x4ba533(_0x4580c9[_0x1c4e('0x17')][_0x1c4e('0x19')]);}else{logger[_0x1c4e('0x12')](_0x1c4e('0x13'),_0x141948,'request\x20sent');_0x4ba533(_0x4580c9[_0x1c4e('0x1a')][_0x1c4e('0x19')]);}})[_0x1c4e('0x1b')](function(_0x1ee910){logger['error'](_0x1c4e('0x13'),_0x141948,_0x1ee910);_0x10d447(_0x1ee910);});});}exports['GetWhatsappQueue']=function(_0x2b1bf1){var _0x447ab5=this;return new Promise(function(_0x1e2f61,_0x2a2a87){return db[_0x1c4e('0x1c')][_0x1c4e('0x1d')]({'raw':_0x2b1bf1['options']?_0x2b1bf1['options'][_0x1c4e('0x1e')]===undefined?!![]:![]:!![],'where':_0x2b1bf1[_0x1c4e('0x1f')]?_0x2b1bf1[_0x1c4e('0x1f')]['where']||null:null,'attributes':_0x2b1bf1[_0x1c4e('0x1f')]?_0x2b1bf1[_0x1c4e('0x1f')][_0x1c4e('0x20')]||null:null,'limit':_0x2b1bf1[_0x1c4e('0x1f')]?_0x2b1bf1[_0x1c4e('0x1f')][_0x1c4e('0x21')]||null:null,'include':_0x2b1bf1[_0x1c4e('0x1f')]?_0x2b1bf1[_0x1c4e('0x1f')][_0x1c4e('0x22')]?_[_0x1c4e('0x23')](_0x2b1bf1[_0x1c4e('0x1f')]['include'],function(_0xd9b3bf){return{'model':db[_0xd9b3bf[_0x1c4e('0x24')]],'as':_0xd9b3bf['as'],'attributes':_0xd9b3bf[_0x1c4e('0x20')],'include':_0xd9b3bf[_0x1c4e('0x22')]?_['map'](_0xd9b3bf[_0x1c4e('0x22')],function(_0x455b44){return{'model':db[_0x455b44[_0x1c4e('0x24')]],'as':_0x455b44['as'],'attributes':_0x455b44['attributes'],'include':_0x455b44[_0x1c4e('0x22')]?_[_0x1c4e('0x23')](_0x455b44[_0x1c4e('0x22')],function(_0x292d61){return{'model':db[_0x292d61[_0x1c4e('0x24')]],'as':_0x292d61['as'],'attributes':_0x292d61[_0x1c4e('0x20')]};}):[]};}):[]};}):[]:[]})[_0x1c4e('0x11')](function(_0x1aaff8){logger[_0x1c4e('0x12')](_0x1c4e('0x25'),_0x2b1bf1);logger['debug']('GetWhatsappQueue',_0x2b1bf1,JSON[_0x1c4e('0x16')](_0x1aaff8));_0x1e2f61(_0x1aaff8);})[_0x1c4e('0x1b')](function(_0x8b9ebb){logger[_0x1c4e('0x17')]('GetWhatsappQueue',_0x8b9ebb[_0x1c4e('0x19')],_0x2b1bf1);_0x2a2a87(_0x447ab5[_0x1c4e('0x17')](0x1f4,_0x8b9ebb['message']));});});};exports[_0x1c4e('0x26')]=function(_0x12fc93){var _0x13962f=this;return new Promise(function(_0x3f6ebc,_0x173491){return db[_0x1c4e('0x1c')][_0x1c4e('0x27')]({'raw':_0x12fc93[_0x1c4e('0x1f')]?_0x12fc93[_0x1c4e('0x1f')][_0x1c4e('0x1e')]===undefined?!![]:![]:!![],'where':_0x12fc93['options']?_0x12fc93['options'][_0x1c4e('0x28')]||null:null,'attributes':_0x12fc93['options']?_0x12fc93[_0x1c4e('0x1f')][_0x1c4e('0x20')]||null:null,'include':_0x12fc93[_0x1c4e('0x1f')]?_0x12fc93[_0x1c4e('0x1f')][_0x1c4e('0x22')]?_['map'](_0x12fc93[_0x1c4e('0x1f')][_0x1c4e('0x22')],function(_0x225b0c){return{'model':db[_0x225b0c[_0x1c4e('0x24')]],'as':_0x225b0c['as'],'attributes':_0x225b0c[_0x1c4e('0x20')],'include':_0x225b0c[_0x1c4e('0x22')]?_[_0x1c4e('0x23')](_0x225b0c['include'],function(_0xf498a){return{'model':db[_0xf498a[_0x1c4e('0x24')]],'as':_0xf498a['as'],'attributes':_0xf498a['attributes'],'include':_0xf498a[_0x1c4e('0x22')]?_['map'](_0xf498a['include'],function(_0x12d116){return{'model':db[_0x12d116['model']],'as':_0x12d116['as'],'attributes':_0x12d116['attributes']};}):[]};}):[]};}):[]:[]})['then'](function(_0x1dd084){logger[_0x1c4e('0x12')](_0x1c4e('0x26'),_0x12fc93);logger[_0x1c4e('0x15')](_0x1c4e('0x26'),_0x12fc93,JSON[_0x1c4e('0x16')](_0x1dd084));_0x3f6ebc(_0x1dd084);})[_0x1c4e('0x1b')](function(_0x112553){logger[_0x1c4e('0x17')](_0x1c4e('0x26'),_0x112553[_0x1c4e('0x19')],_0x12fc93);_0x173491(_0x13962f['error'](0x1f4,_0x112553[_0x1c4e('0x19')]));});});};