socket.js

socket.on('close', Meteor.bindEnvironment(hasError => {
      let retries = this.collection.findOne({ name: this.name }).connection.retryCount;
      if (retries < this.config.maxRetries) {
        Meteor.setTimeout(() => {
          this.collection.update({ name: this.name }, {
            $set: {
              'connection.status': 'connecting',
              'connection.retryTime': new Date
            },
            $inc: { 'connection.retryCount': 1 }
          });
          super.connect(...args);
        }, this.config.retryInterval);
      } else {
        this.removeAllListeners();
        this.collection.update({ name: this.name }, {
          $set: {
            'connection.status': 'failed',
            'connection.reason': 'Max retries exceeded'
          }
        });
        this.end();
      }
    }))