TheBrainFamily/chimpy

var log = require('./log'),
  URL = require('url'),
  DDPClient = require('xolvio-ddp'),
  booleanHelper = require('./boolean-helper'),
  wrapAsyncObject = require('xolvio-sync-webdriverio').wrapAsyncObject;

/**
 * DDP Constructor
 *
 * @api public
 */
function DDP(url) {
  log.debug('[chimp][ddp] creating DDP wrapper');
  process.env.ROOT_URL = process.env.ROOT_URL || process.env['chimp.ddp0'];

  if (!url) {
    this.url = this._getUrl(process.env['chimp.ddp0']);
  } else {
    this.url = this._getUrl(url);
  }
}

DDP.prototype.connect = function () {
  var options = this._getOptions();
  log.debug('[chimp][ddp] Connecting to DDP server', options);
  return wrapAsyncObject(
    new DDPClient(options),
    ['connect', 'call', 'apply', 'callWithRandomSeed', 'subscribe'],
    {syncByDefault: booleanHelper.isTruthy(process.env['chimp.sync'])}
  );
};

DDP.prototype._getUrl = function (ddpHost) {
  if (ddpHost.indexOf('http://') === -1 && ddpHost.indexOf('https://') === -1) {
    throw new Error('[chimp][ddp] DDP url must contain the protocol');
  }
  return URL.parse(ddpHost);
};


DDP.prototype._getOptions = function () {
  return {
    host: this.url.hostname,
    port: this.url.port,
    ssl: this.url.protocol === 'https:',
    path: this.url.pathname !== '/' ? this.url.pathname + '/websocket' : undefined,
    // TODO extract all options
    autoReconnect: true,
    autoReconnectTimer: 500,
    maintainCollections: true,
    ddpVersion: '1',
    useSockJs: this.url.pathname === '/'
  };
};

module.exports = DDP;