pomelo/lib/common/remote/backend/msgRemote.js at c1ebaf31345c29a08962c8a8f4a57b44e435d13b · NetEase/pomelo · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
var utils = require('../../../util/utils');
var logger = require('pomelo-logger').getLogger('forward-log', __filename);
/**
 * Remote service for backend servers.
 * Receive and handle request message forwarded from frontend server.
 */
module.exports = function(app) {
  return new Remote(app);
};

var Remote = function(app) {
  this.app = app;
};

/**
 * Forward message from frontend server to other server's handlers
 *
 * @param msg {Object} request message
 * @param session {Object} session object for current request
 * @param cb {Function} callback function
 */
Remote.prototype.forwardMessage = function(msg, session, cb) {
  var server = this.app.components.__server__;
  var sessionService = this.app.components.__backendSession__;

  if(!server) {
    logger.error('server component not enable on %s', this.app.serverId);
    utils.invokeCallback(cb, new Error('server component not enable'));
    return;
  }

  if(!sessionService) {
    logger.error('backend session component not enable on %s', this.app.serverId);
    utils.invokeCallback(cb, new Error('backend sesssion component not enable'));
    return;
  }

  // generate backend session for current request
  var backendSession = sessionService.create(session);

  // handle the request

  logger.debug('backend server [%s] handle message: %j', this.app.serverId, msg);

  server.handle(msg, backendSession, function(err, resp, opts) {
    // cb && cb(err, resp, opts);
    utils.invokeCallback(cb, err, resp, opts);
  });
};

Remote.prototype.forwardMessage2 = function(route, body, aesPassword, compressGzip, session, cb) {
  var server = this.app.components.__server__;
  var sessionService = this.app.components.__backendSession__;

  if(!server) {
    logger.error('server component not enable on %s', this.app.serverId);
    utils.invokeCallback(cb, new Error('server component not enable'));
    return;
  }

  if(!sessionService) {
    logger.error('backend session component not enable on %s', this.app.serverId);
    utils.invokeCallback(cb, new Error('backend sesssion component not enable'));
    return;
  }

  // generate backend session for current request
  var backendSession = sessionService.create(session);

  // handle the request

  // logger.debug('backend server [%s] handle message: %j', this.app.serverId, msg);

  var dmsg = {
    route: route,
    body: body,
    compressGzip: compressGzip
  }

  var socket = {
    aesPassword: aesPassword
  }

  var connector = this.app.components.__connector__.connector;
  connector.runDecode(dmsg, socket, function(err, msg) {
    if(err) {
      return cb(err);
    }

    server.handle(msg, backendSession, function(err, resp, opts) {
      utils.invokeCallback(cb, err, resp, opts);
    });
  });
};