node-eventstore-client/test/connection_test.js

var client = require('../lib/dist');
var GossipSeed = require('../src/gossipSeed');

var testBase = require('./common/base_test');

var withSsl = !!process.env.NODE_ESC_WITH_SSL;

module.exports = {
  'Connect To Endpoint Happy Path': function (test) {
    test.expect(1);
    var tcpEndpoint = {host: 'localhost', port: 1113};
    var conn = client.EventStoreConnection.create(testBase.settings(), tcpEndpoint);
    conn.connect()
      .catch(function (err) {
        test.done(err);
      });
    conn.on('connected', function (endPoint) {
      test.areEqual("connected endPoint", endPoint, tcpEndpoint);
      done();
    });
    conn.on('error', done);

    function done(err) {
      conn.close();
      if (err) return test.done(err);
      test.done();
    }
  },
  'Connect To Endpoint That Doesn\'t Exist': function (test) {
    test.expect(1);
    var tcpEndpoint = {host: 'localhost', port: 11112};
    var conn = client.EventStoreConnection.create(testBase.settings({maxReconnections: 1}), tcpEndpoint);
    conn.connect()
      .catch(function (err) {
        test.done(err);
      });
    conn.on('connected', function () {
      test.ok(false, "Should not be able to connect.");
      test.done();
    });
    conn.on('error', function (err) {
      test.done(err);
    });
    conn.on('closed', function (reason) {
      test.ok(reason.indexOf("Reconnection limit reached") === 0, "Wrong expected reason.");
      test.done();
    });
  },
  'Create a connection with tcp://host:port string': function (test) {
    var conn = client.createConnection({}, 'tcp://localhost:1113');
    conn.close();
    test.done();
  }/*,
  'Connect to Cluster using gossip seeds': function (test) {
    test.expect(1);
    var gossipSeeds = [
      new GossipSeed({host: 'localhost', port: 1113}),
      new GossipSeed({host: 'localhost', port: 2113}),
      new GossipSeed({host: 'localhost', port: 3113})
    ];
    var conn = client.EventStoreConnection.create(testBase.settings(), gossipSeeds);
    conn.connect()
      .catch(function(err) {
        test.done(err);
      });
    conn.on('connected', function(endPoint){
      test.ok(endPoint, "no endpoint");
      done();
    });
    conn.on('error', done);

    function done(err) {
      conn.close();
      if (err) return test.done(err);
      test.done();
    }
  }*/
};

if (withSsl) {
  module.exports['Connect to secure tcp endpoint'] = function(test) {
    var conn = client.createConnection({
      useSslConnection: true,
      targetHost: 'localhost',
      validateServer: false
    }, 'tcp://localhost:1115');
    conn.on('error', function (err) {
      test.done(err);
    });
    conn.connect()
      .catch(function (err) {
        test.done(err);
      });
    conn.on('connected', function () {
      test.done();
    });
  }
}

testBase.init(module.exports, false);