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 _0xbd40=['lodash','util','moment','bluebird','randomstring','ioredis','../../mysqldb','../../config/utils','../../config/logger','../../config/environment','jayson/promise','client','http','redis','defaults','localhost','socket.io-emitter','register','request','then','WhatsappQueue,\x20%s,\x20%s','request\x20sent','debug','stringify','error','code','message','info','result','catch','GetWhatsappQueue','WhatsappQueue','options','raw','attributes','limit','include','map','model','ShowWhatsappQueue','where'];(function(_0x52ea08,_0x15d935){var _0x28d546=function(_0x4a3aa7){while(--_0x4a3aa7){_0x52ea08['push'](_0x52ea08['shift']());}};_0x28d546(++_0x15d935);}(_0xbd40,0x1ec));var _0x0bd4=function(_0xf92345,_0x3e945b){_0xf92345=_0xf92345-0x0;var _0x11e908=_0xbd40[_0xf92345];return _0x11e908;};'use strict';var _=require(_0x0bd4('0x0'));var util=require(_0x0bd4('0x1'));var moment=require(_0x0bd4('0x2'));var BPromise=require(_0x0bd4('0x3'));var rs=require(_0x0bd4('0x4'));var fs=require('fs');var Redis=require(_0x0bd4('0x5'));var db=require(_0x0bd4('0x6'))['db'];var utils=require(_0x0bd4('0x7'));var logger=require(_0x0bd4('0x8'))('rpc');var config=require(_0x0bd4('0x9'));var jayson=require(_0x0bd4('0xa'));var client=jayson[_0x0bd4('0xb')][_0x0bd4('0xc')]({'port':0x232a});config[_0x0bd4('0xd')]=_[_0x0bd4('0xe')](config[_0x0bd4('0xd')],{'host':_0x0bd4('0xf'),'port':0x18eb});var socket=require(_0x0bd4('0x10'))(new Redis(config[_0x0bd4('0xd')]));require('./whatsappQueue.socket')[_0x0bd4('0x11')](socket);function respondWithRpcPromise(_0x2482b3,_0x257d60,_0x1e585f){return new BPromise(function(_0x5272df,_0x1bc2fd){return client[_0x0bd4('0x12')](_0x2482b3,_0x1e585f)[_0x0bd4('0x13')](function(_0x34742d){logger['info'](_0x0bd4('0x14'),_0x257d60,_0x0bd4('0x15'));logger[_0x0bd4('0x16')]('WhatsappQueue,\x20%s,\x20%s,\x20%s',_0x257d60,_0x0bd4('0x15'),JSON[_0x0bd4('0x17')](_0x34742d));if(_0x34742d[_0x0bd4('0x18')]){if(_0x34742d['error'][_0x0bd4('0x19')]===0x1f4){logger['error'](_0x0bd4('0x14'),_0x257d60,_0x34742d[_0x0bd4('0x18')][_0x0bd4('0x1a')]);return _0x1bc2fd(_0x34742d[_0x0bd4('0x18')][_0x0bd4('0x1a')]);}logger['error']('WhatsappQueue,\x20%s,\x20%s',_0x257d60,_0x34742d[_0x0bd4('0x18')][_0x0bd4('0x1a')]);return _0x5272df(_0x34742d[_0x0bd4('0x18')][_0x0bd4('0x1a')]);}else{logger[_0x0bd4('0x1b')](_0x0bd4('0x14'),_0x257d60,_0x0bd4('0x15'));_0x5272df(_0x34742d[_0x0bd4('0x1c')][_0x0bd4('0x1a')]);}})[_0x0bd4('0x1d')](function(_0x16e365){logger[_0x0bd4('0x18')](_0x0bd4('0x14'),_0x257d60,_0x16e365);_0x1bc2fd(_0x16e365);});});}exports[_0x0bd4('0x1e')]=function(_0x20325f){var _0x2d4cc8=this;return new Promise(function(_0x5b392d,_0x50013b){return db[_0x0bd4('0x1f')]['findAll']({'raw':_0x20325f['options']?_0x20325f[_0x0bd4('0x20')][_0x0bd4('0x21')]===undefined?!![]:![]:!![],'where':_0x20325f[_0x0bd4('0x20')]?_0x20325f[_0x0bd4('0x20')]['where']||null:null,'attributes':_0x20325f[_0x0bd4('0x20')]?_0x20325f['options'][_0x0bd4('0x22')]||null:null,'limit':_0x20325f['options']?_0x20325f[_0x0bd4('0x20')][_0x0bd4('0x23')]||null:null,'include':_0x20325f[_0x0bd4('0x20')]?_0x20325f[_0x0bd4('0x20')][_0x0bd4('0x24')]?_[_0x0bd4('0x25')](_0x20325f[_0x0bd4('0x20')][_0x0bd4('0x24')],function(_0x2b9239){return{'model':db[_0x2b9239[_0x0bd4('0x26')]],'as':_0x2b9239['as'],'attributes':_0x2b9239[_0x0bd4('0x22')],'include':_0x2b9239[_0x0bd4('0x24')]?_[_0x0bd4('0x25')](_0x2b9239[_0x0bd4('0x24')],function(_0x1c057d){return{'model':db[_0x1c057d[_0x0bd4('0x26')]],'as':_0x1c057d['as'],'attributes':_0x1c057d['attributes'],'include':_0x1c057d[_0x0bd4('0x24')]?_[_0x0bd4('0x25')](_0x1c057d[_0x0bd4('0x24')],function(_0x434920){return{'model':db[_0x434920['model']],'as':_0x434920['as'],'attributes':_0x434920[_0x0bd4('0x22')]};}):[]};}):[]};}):[]:[]})['then'](function(_0x169589){logger['info']('GetWhatsappQueue',_0x20325f);logger[_0x0bd4('0x16')](_0x0bd4('0x1e'),_0x20325f,JSON[_0x0bd4('0x17')](_0x169589));_0x5b392d(_0x169589);})[_0x0bd4('0x1d')](function(_0x37a286){logger['error'](_0x0bd4('0x1e'),_0x37a286[_0x0bd4('0x1a')],_0x20325f);_0x50013b(_0x2d4cc8[_0x0bd4('0x18')](0x1f4,_0x37a286[_0x0bd4('0x1a')]));});});};exports[_0x0bd4('0x27')]=function(_0x3a04f2){var _0x2fc736=this;return new Promise(function(_0x2b86a7,_0x34312c){return db[_0x0bd4('0x1f')]['find']({'raw':_0x3a04f2[_0x0bd4('0x20')]?_0x3a04f2[_0x0bd4('0x20')][_0x0bd4('0x21')]===undefined?!![]:![]:!![],'where':_0x3a04f2[_0x0bd4('0x20')]?_0x3a04f2[_0x0bd4('0x20')][_0x0bd4('0x28')]||null:null,'attributes':_0x3a04f2[_0x0bd4('0x20')]?_0x3a04f2[_0x0bd4('0x20')][_0x0bd4('0x22')]||null:null,'include':_0x3a04f2['options']?_0x3a04f2[_0x0bd4('0x20')][_0x0bd4('0x24')]?_['map'](_0x3a04f2[_0x0bd4('0x20')][_0x0bd4('0x24')],function(_0x331263){return{'model':db[_0x331263[_0x0bd4('0x26')]],'as':_0x331263['as'],'attributes':_0x331263[_0x0bd4('0x22')],'include':_0x331263['include']?_[_0x0bd4('0x25')](_0x331263[_0x0bd4('0x24')],function(_0x1dd85e){return{'model':db[_0x1dd85e['model']],'as':_0x1dd85e['as'],'attributes':_0x1dd85e[_0x0bd4('0x22')],'include':_0x1dd85e[_0x0bd4('0x24')]?_['map'](_0x1dd85e['include'],function(_0x219d9b){return{'model':db[_0x219d9b[_0x0bd4('0x26')]],'as':_0x219d9b['as'],'attributes':_0x219d9b[_0x0bd4('0x22')]};}):[]};}):[]};}):[]:[]})['then'](function(_0x5e63a9){logger[_0x0bd4('0x1b')](_0x0bd4('0x27'),_0x3a04f2);logger[_0x0bd4('0x16')](_0x0bd4('0x27'),_0x3a04f2,JSON[_0x0bd4('0x17')](_0x5e63a9));_0x2b86a7(_0x5e63a9);})[_0x0bd4('0x1d')](function(_0x28eb97){logger[_0x0bd4('0x18')](_0x0bd4('0x27'),_0x28eb97[_0x0bd4('0x1a')],_0x3a04f2);_0x34312c(_0x2fc736['error'](0x1f4,_0x28eb97[_0x0bd4('0x1a')]));});});};