server/api/chatMessage/chatMessage.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 _0xdae3=['info','debug','ChatMessage,\x20%s,\x20%s,\x20%s','request\x20sent','ChatMessage,\x20%s,\x20%s','error','message','result','catch','ChatMessage','body','options','CreateChatMessage','stringify','lodash','util','moment','bluebird','randomstring','ioredis','../../config/logger','rpc','../../config/environment','client','redis','defaults','localhost','socket.io-emitter','./chatMessage.socket','register','request','then'];(function(_0x2b68fd,_0x594330){var _0x367bad=function(_0x5826bc){while(--_0x5826bc){_0x2b68fd['push'](_0x2b68fd['shift']());}};_0x367bad(++_0x594330);}(_0xdae3,0x10e));var _0x3dae=function(_0x19c1d9,_0x530af1){_0x19c1d9=_0x19c1d9-0x0;var _0x298bd2=_0xdae3[_0x19c1d9];return _0x298bd2;};'use strict';var _=require(_0x3dae('0x0'));var util=require(_0x3dae('0x1'));var moment=require(_0x3dae('0x2'));var BPromise=require(_0x3dae('0x3'));var rs=require(_0x3dae('0x4'));var fs=require('fs');var Redis=require(_0x3dae('0x5'));var db=require('../../mysqldb')['db'];var utils=require('../../config/utils');var logger=require(_0x3dae('0x6'))(_0x3dae('0x7'));var config=require(_0x3dae('0x8'));var jayson=require('jayson/promise');var client=jayson[_0x3dae('0x9')]['http']({'port':0x232a});config[_0x3dae('0xa')]=_[_0x3dae('0xb')](config[_0x3dae('0xa')],{'host':_0x3dae('0xc'),'port':0x18eb});var socket=require(_0x3dae('0xd'))(new Redis(config['redis']));require(_0x3dae('0xe'))[_0x3dae('0xf')](socket);function respondWithRpcPromise(_0x4f5f9e,_0x535685,_0x554ed4){return new BPromise(function(_0x4e3295,_0x4f0808){return client[_0x3dae('0x10')](_0x4f5f9e,_0x554ed4)[_0x3dae('0x11')](function(_0x512fed){logger[_0x3dae('0x12')]('ChatMessage,\x20%s,\x20%s',_0x535685,'request\x20sent');logger[_0x3dae('0x13')](_0x3dae('0x14'),_0x535685,_0x3dae('0x15'),JSON['stringify'](_0x512fed));if(_0x512fed['error']){if(_0x512fed['error']['code']===0x1f4){logger['error'](_0x3dae('0x16'),_0x535685,_0x512fed[_0x3dae('0x17')][_0x3dae('0x18')]);return _0x4f0808(_0x512fed[_0x3dae('0x17')]['message']);}logger[_0x3dae('0x17')](_0x3dae('0x16'),_0x535685,_0x512fed[_0x3dae('0x17')]['message']);return _0x4e3295(_0x512fed[_0x3dae('0x17')][_0x3dae('0x18')]);}else{logger[_0x3dae('0x12')](_0x3dae('0x16'),_0x535685,_0x3dae('0x15'));_0x4e3295(_0x512fed[_0x3dae('0x19')][_0x3dae('0x18')]);}})[_0x3dae('0x1a')](function(_0x7b1c17){logger['error']('ChatMessage,\x20%s,\x20%s',_0x535685,_0x7b1c17);_0x4f0808(_0x7b1c17);});});}exports['CreateChatMessage']=function(_0x137434){var _0x4e8c31=this;return new Promise(function(_0x155c4b,_0x238190){return db[_0x3dae('0x1b')]['create'](_0x137434[_0x3dae('0x1c')],{'raw':_0x137434[_0x3dae('0x1d')]?_0x137434[_0x3dae('0x1d')]['raw']===undefined?!![]:![]:!![]})['then'](function(_0x6b35b){logger['info'](_0x3dae('0x1e'),_0x137434);logger[_0x3dae('0x13')]('CreateChatMessage',_0x137434,JSON[_0x3dae('0x1f')](_0x6b35b));_0x155c4b(_0x6b35b);})[_0x3dae('0x1a')](function(_0x316b61){logger[_0x3dae('0x17')](_0x3dae('0x1e'),_0x316b61['message'],_0x137434);_0x238190(_0x4e8c31[_0x3dae('0x17')](0x1f4,_0x316b61[_0x3dae('0x18')]));});});};