server/api/whatsappInteraction/whatsappInteraction.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 _0x213e=['request\x20sent','stringify','error','message','info','result','UpdateWhatsappInteraction','update','body','options','where','attributes','limit','catch','WhatsappInteraction','find','ids','omit','spread','debug','AddTags','lodash','util','moment','bluebird','ioredis','../../config/logger','rpc','../../config/environment','client','defaults','redis','localhost','./whatsappInteraction.socket','register','request','then','WhatsappInteraction,\x20%s,\x20%s','WhatsappInteraction,\x20%s,\x20%s,\x20%s'];(function(_0x2fd719,_0xa1c429){var _0x3fcc83=function(_0x8e31fa){while(--_0x8e31fa){_0x2fd719['push'](_0x2fd719['shift']());}};_0x3fcc83(++_0xa1c429);}(_0x213e,0xb1));var _0xe213=function(_0x12206c,_0x31d17a){_0x12206c=_0x12206c-0x0;var _0x435890=_0x213e[_0x12206c];return _0x435890;};'use strict';var _=require(_0xe213('0x0'));var util=require(_0xe213('0x1'));var moment=require(_0xe213('0x2'));var BPromise=require(_0xe213('0x3'));var rs=require('randomstring');var fs=require('fs');var Redis=require(_0xe213('0x4'));var db=require('../../mysqldb')['db'];var utils=require('../../config/utils');var logger=require(_0xe213('0x5'))(_0xe213('0x6'));var config=require(_0xe213('0x7'));var jayson=require('jayson/promise');var client=jayson[_0xe213('0x8')]['http']({'port':0x232a});config['redis']=_[_0xe213('0x9')](config[_0xe213('0xa')],{'host':_0xe213('0xb'),'port':0x18eb});var socket=require('socket.io-emitter')(new Redis(config[_0xe213('0xa')]));require(_0xe213('0xc'))[_0xe213('0xd')](socket);function respondWithRpcPromise(_0x3ec721,_0x1f44d5,_0x47a29a){return new BPromise(function(_0x79d3f9,_0x297d51){return client[_0xe213('0xe')](_0x3ec721,_0x47a29a)[_0xe213('0xf')](function(_0x4884ad){logger['info'](_0xe213('0x10'),_0x1f44d5,'request\x20sent');logger['debug'](_0xe213('0x11'),_0x1f44d5,_0xe213('0x12'),JSON[_0xe213('0x13')](_0x4884ad));if(_0x4884ad[_0xe213('0x14')]){if(_0x4884ad[_0xe213('0x14')]['code']===0x1f4){logger[_0xe213('0x14')]('WhatsappInteraction,\x20%s,\x20%s',_0x1f44d5,_0x4884ad[_0xe213('0x14')]['message']);return _0x297d51(_0x4884ad['error'][_0xe213('0x15')]);}logger[_0xe213('0x14')](_0xe213('0x10'),_0x1f44d5,_0x4884ad[_0xe213('0x14')][_0xe213('0x15')]);return _0x79d3f9(_0x4884ad['error']['message']);}else{logger[_0xe213('0x16')]('WhatsappInteraction,\x20%s,\x20%s',_0x1f44d5,_0xe213('0x12'));_0x79d3f9(_0x4884ad[_0xe213('0x17')][_0xe213('0x15')]);}})['catch'](function(_0xd99319){logger[_0xe213('0x14')](_0xe213('0x10'),_0x1f44d5,_0xd99319);_0x297d51(_0xd99319);});});}exports[_0xe213('0x18')]=function(_0x156319){var _0x458c5a=this;return new Promise(function(_0xe55f7a,_0x1a3d97){return db['WhatsappInteraction'][_0xe213('0x19')](_0x156319[_0xe213('0x1a')],{'raw':_0x156319[_0xe213('0x1b')]?_0x156319[_0xe213('0x1b')]['raw']===undefined?!![]:![]:!![],'individualHooks':!![],'where':_0x156319['options']?_0x156319[_0xe213('0x1b')][_0xe213('0x1c')]||null:null,'attributes':_0x156319[_0xe213('0x1b')]?_0x156319['options'][_0xe213('0x1d')]||null:null,'limit':_0x156319[_0xe213('0x1b')]?_0x156319[_0xe213('0x1b')][_0xe213('0x1e')]||null:null})[_0xe213('0xf')](function(_0x4c6b2b){logger[_0xe213('0x16')]('UpdateWhatsappInteraction',_0x156319);logger['debug'](_0xe213('0x18'),_0x156319,JSON[_0xe213('0x13')](_0x4c6b2b));_0xe55f7a(_0x4c6b2b);})[_0xe213('0x1f')](function(_0x58944d){logger['error']('UpdateWhatsappInteraction',_0x58944d[_0xe213('0x15')],_0x156319);_0x1a3d97(_0x458c5a['error'](0x1f4,_0x58944d[_0xe213('0x15')]));});});};exports['AddTagsToWhatsappInteraction']=function(_0x11d272){return new Promise(function(_0x28ebd5,_0x431e88){return db[_0xe213('0x20')][_0xe213('0x21')]({'where':_0x11d272[_0xe213('0x1b')]?_0x11d272[_0xe213('0x1b')]['where']||null:null})['then'](function(_0x515a4e){if(_0x515a4e){return _0x515a4e['addTags'](_0x11d272[_0xe213('0x1a')][_0xe213('0x22')],_[_0xe213('0x23')](_0x11d272[_0xe213('0x1a')],[_0xe213('0x22'),'id'])||{});}})[_0xe213('0x24')](function(_0x58ec8d){logger[_0xe213('0x16')]('AddTags',_0x11d272);logger[_0xe213('0x25')]('AddTags',_0x11d272,JSON[_0xe213('0x13')](_0x58ec8d));_0x28ebd5(_0x58ec8d);})[_0xe213('0x1f')](function(_0x4e4b33){logger['error'](_0xe213('0x26'),_0x4e4b33['message'],_0x11d272);_0x431e88(_this[_0xe213('0x14')](0x1f4,_0x4e4b33['message']));});});};