Extending DDP.connect

suhaila · May 11, 2016, 1:41pm

I am using DDP.connect to communicate between two meteor servers. DDP.connect returns an object with a method called status. When status is called it returns an object which is reactive but since there is no autorun/tracker on the server it is impossible to know when the connection actually happened unless you do all that by yourself.

There is a Meteor.onConnection available but in documentation i do not see anything like this when using DDP.connect.

Shouldn’t DDP.connect also provide some kind of callback like onConnection?

reoh · May 11, 2016, 4:21pm

Seems like DDP.connect does actually take options, it’s just undocumented:

github.com

meteor/meteor/blob/master/packages/ddp-client/livedata_connection.js#L1689


    Meteor._debug("For: ", msg.offendingMessage);
},


_callOnReconnectAndSendAppropriateOutstandingMethods: function() {
  var self = this;
  var oldOutstandingMethodBlocks = self._outstandingMethodBlocks;
  self._outstandingMethodBlocks = [];


  self.onReconnect && self.onReconnect();
  DDP._reconnectHook.each(function (callback) {
    callback(self);
    return true;
  });


  if (_.isEmpty(oldOutstandingMethodBlocks))
    return;


  // We have at least one block worth of old outstanding methods to try
  // again. First: did onReconnect actually send anything? If not, we just
  // restore all outstanding methods and run the first block.
  if (_.isEmpty(self._outstandingMethodBlocks)) {

github.com

meteor/meteor/blob/master/packages/ddp-client/livedata_connection.js#L234


    }
  });
}


var onMessage = function (raw_msg) {
  try {
    var msg = DDPCommon.parseDDP(raw_msg);
  } catch (e) {
    Meteor._debug("Exception while parsing DDP", e);
    return;
  }


  // Any message counts as receiving a pong, as it demonstrates that
  // the server is still alive.
  if (self._heartbeat) {
    self._heartbeat.messageReceived();
  }


  if (msg === null || !msg.msg) {
    // XXX COMPAT WITH 0.6.6. ignore the old welcome message for back
    // compat.  Remove this 'if' once the server stops sending welcome