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 _0x037e=['result','catch','GetWhatsappQueue','WhatsappQueue','findAll','options','raw','where','attributes','limit','include','map','model','then','ShowWhatsappQueue','find','stringify','util','bluebird','randomstring','ioredis','../../config/utils','rpc','../../config/environment','client','http','redis','localhost','socket.io-emitter','./whatsappQueue.socket','request','info','WhatsappQueue,\x20%s,\x20%s','request\x20sent','debug','WhatsappQueue,\x20%s,\x20%s,\x20%s','error','code','message'];(function(_0x462753,_0x18db45){var _0x241048=function(_0x165ef6){while(--_0x165ef6){_0x462753['push'](_0x462753['shift']());}};_0x241048(++_0x18db45);}(_0x037e,0x197));var _0xe037=function(_0x20a584,_0xe384a5){_0x20a584=_0x20a584-0x0;var _0x4b41a8=_0x037e[_0x20a584];return _0x4b41a8;};'use strict';var _=require('lodash');var util=require(_0xe037('0x0'));var moment=require('moment');var BPromise=require(_0xe037('0x1'));var rs=require(_0xe037('0x2'));var fs=require('fs');var Redis=require(_0xe037('0x3'));var db=require('../../mysqldb')['db'];var utils=require(_0xe037('0x4'));var logger=require('../../config/logger')(_0xe037('0x5'));var config=require(_0xe037('0x6'));var jayson=require('jayson/promise');var client=jayson[_0xe037('0x7')][_0xe037('0x8')]({'port':0x232a});config[_0xe037('0x9')]=_['defaults'](config[_0xe037('0x9')],{'host':_0xe037('0xa'),'port':0x18eb});var socket=require(_0xe037('0xb'))(new Redis(config[_0xe037('0x9')]));require(_0xe037('0xc'))['register'](socket);function respondWithRpcPromise(_0x856fa5,_0x5b6a3e,_0x32a785){return new BPromise(function(_0x3dd295,_0x203712){return client[_0xe037('0xd')](_0x856fa5,_0x32a785)['then'](function(_0x5620c6){logger[_0xe037('0xe')](_0xe037('0xf'),_0x5b6a3e,_0xe037('0x10'));logger[_0xe037('0x11')](_0xe037('0x12'),_0x5b6a3e,'request\x20sent',JSON['stringify'](_0x5620c6));if(_0x5620c6[_0xe037('0x13')]){if(_0x5620c6[_0xe037('0x13')][_0xe037('0x14')]===0x1f4){logger['error'](_0xe037('0xf'),_0x5b6a3e,_0x5620c6['error'][_0xe037('0x15')]);return _0x203712(_0x5620c6['error'][_0xe037('0x15')]);}logger[_0xe037('0x13')](_0xe037('0xf'),_0x5b6a3e,_0x5620c6[_0xe037('0x13')][_0xe037('0x15')]);return _0x3dd295(_0x5620c6[_0xe037('0x13')][_0xe037('0x15')]);}else{logger[_0xe037('0xe')]('WhatsappQueue,\x20%s,\x20%s',_0x5b6a3e,'request\x20sent');_0x3dd295(_0x5620c6[_0xe037('0x16')][_0xe037('0x15')]);}})[_0xe037('0x17')](function(_0x5c1ad2){logger[_0xe037('0x13')]('WhatsappQueue,\x20%s,\x20%s',_0x5b6a3e,_0x5c1ad2);_0x203712(_0x5c1ad2);});});}exports[_0xe037('0x18')]=function(_0xf612d7){var _0x322cba=this;return new Promise(function(_0x7654a7,_0x33a34f){return db[_0xe037('0x19')][_0xe037('0x1a')]({'raw':_0xf612d7[_0xe037('0x1b')]?_0xf612d7['options'][_0xe037('0x1c')]===undefined?!![]:![]:!![],'where':_0xf612d7['options']?_0xf612d7[_0xe037('0x1b')][_0xe037('0x1d')]||null:null,'attributes':_0xf612d7[_0xe037('0x1b')]?_0xf612d7[_0xe037('0x1b')][_0xe037('0x1e')]||null:null,'limit':_0xf612d7['options']?_0xf612d7[_0xe037('0x1b')][_0xe037('0x1f')]||null:null,'include':_0xf612d7[_0xe037('0x1b')]?_0xf612d7[_0xe037('0x1b')][_0xe037('0x20')]?_[_0xe037('0x21')](_0xf612d7['options']['include'],function(_0x2d0762){return{'model':db[_0x2d0762[_0xe037('0x22')]],'as':_0x2d0762['as'],'attributes':_0x2d0762[_0xe037('0x1e')],'include':_0x2d0762[_0xe037('0x20')]?_['map'](_0x2d0762[_0xe037('0x20')],function(_0x5414de){return{'model':db[_0x5414de[_0xe037('0x22')]],'as':_0x5414de['as'],'attributes':_0x5414de[_0xe037('0x1e')],'include':_0x5414de[_0xe037('0x20')]?_[_0xe037('0x21')](_0x5414de[_0xe037('0x20')],function(_0x192650){return{'model':db[_0x192650[_0xe037('0x22')]],'as':_0x192650['as'],'attributes':_0x192650[_0xe037('0x1e')]};}):[]};}):[]};}):[]:[]})[_0xe037('0x23')](function(_0x136a70){logger[_0xe037('0xe')]('GetWhatsappQueue',_0xf612d7);logger['debug']('GetWhatsappQueue',_0xf612d7,JSON['stringify'](_0x136a70));_0x7654a7(_0x136a70);})['catch'](function(_0x320fbd){logger[_0xe037('0x13')]('GetWhatsappQueue',_0x320fbd['message'],_0xf612d7);_0x33a34f(_0x322cba[_0xe037('0x13')](0x1f4,_0x320fbd['message']));});});};exports[_0xe037('0x24')]=function(_0x334db2){var _0xc8a9df=this;return new Promise(function(_0x24f093,_0x3cf5e1){return db[_0xe037('0x19')][_0xe037('0x25')]({'raw':_0x334db2['options']?_0x334db2[_0xe037('0x1b')][_0xe037('0x1c')]===undefined?!![]:![]:!![],'where':_0x334db2[_0xe037('0x1b')]?_0x334db2['options'][_0xe037('0x1d')]||null:null,'attributes':_0x334db2[_0xe037('0x1b')]?_0x334db2[_0xe037('0x1b')][_0xe037('0x1e')]||null:null,'include':_0x334db2['options']?_0x334db2[_0xe037('0x1b')]['include']?_[_0xe037('0x21')](_0x334db2[_0xe037('0x1b')][_0xe037('0x20')],function(_0x30cbf2){return{'model':db[_0x30cbf2[_0xe037('0x22')]],'as':_0x30cbf2['as'],'attributes':_0x30cbf2[_0xe037('0x1e')],'include':_0x30cbf2[_0xe037('0x20')]?_['map'](_0x30cbf2[_0xe037('0x20')],function(_0x214cf3){return{'model':db[_0x214cf3['model']],'as':_0x214cf3['as'],'attributes':_0x214cf3['attributes'],'include':_0x214cf3[_0xe037('0x20')]?_[_0xe037('0x21')](_0x214cf3[_0xe037('0x20')],function(_0x49c257){return{'model':db[_0x49c257[_0xe037('0x22')]],'as':_0x49c257['as'],'attributes':_0x49c257[_0xe037('0x1e')]};}):[]};}):[]};}):[]:[]})[_0xe037('0x23')](function(_0x557453){logger[_0xe037('0xe')](_0xe037('0x24'),_0x334db2);logger[_0xe037('0x11')](_0xe037('0x24'),_0x334db2,JSON[_0xe037('0x26')](_0x557453));_0x24f093(_0x557453);})['catch'](function(_0x72f9a4){logger[_0xe037('0x13')](_0xe037('0x24'),_0x72f9a4['message'],_0x334db2);_0x3cf5e1(_0xc8a9df['error'](0x1f4,_0x72f9a4[_0xe037('0x15')]));});});};