release compatible with Eventstore v20.10.x

test/common/base_test.js

@@ -12,6 +12,7 @@ protobufJS.configure();
 
 var settings = {
   log: new NoopLogger(),
+  useSslConnection: true,
 };
 if (process.env.TESTS_VERBOSE_LOGGING === '1') {
   settings.verboseLogging = true;
@@ -53,7 +54,7 @@ function setUpWithGossipSeeds(cb) {
 }
 
 function setUpWithDns(cb) {
-  var clusterDns = 'discover://eventstore.local:2113';
+  var clusterDns = 'discover://' + process.env.EVENTSTORE_HOST + ':2113';
   this.log = settings.log;
   this.testStreamName = 'test-' + uuid.v4();
   var connected = false;

test/connection_test.js

@@ -27,7 +27,7 @@ switch(evenstStoreType){
         done();
       });
       conn.on('error', done);
-  
+
       function done(err) {
         conn.close();
         if (err) return test.done(err);
@@ -41,7 +41,7 @@ switch(evenstStoreType){
         new GossipSeed({host: '1.2.3.4', port: 1113}),
         new GossipSeed({host: '2.3.4.5', port: 2113}),
         new GossipSeed({host: '3.4.5.6', port: 3113})
-      ];      
+      ];
       var conn = client.EventStoreConnection.create(testBase.settings({maxDiscoverAttempts: 1}), gossipSeeds);
       conn.connect()
         .catch(function (err) {
@@ -62,7 +62,7 @@ switch(evenstStoreType){
   case 'dns':
     module.exports['Connect to Cluster using dns discover'] = function (test) {
       test.expect(1);
-      var clusterDns = 'discover://eventstore.local:2113';
+      var clusterDns = 'discover://' + process.env.EVENTSTORE_HOST + ':2113';
       var conn = client.EventStoreConnection.create(testBase.settings(), clusterDns);
       conn.connect()
         .catch(function(err) {
@@ -73,7 +73,7 @@ switch(evenstStoreType){
         done();
       });
       conn.on('error', done);
-  
+
       function done(err) {
         conn.close();
         if (err) return test.done(err);
@@ -83,7 +83,7 @@ switch(evenstStoreType){
 
     module.exports['Connect To Cluster with bad dns discover'] = function (test) {
       test.expect(3);
-      var clusterDns = 'discover://eventstore-bad.local:2113';
+      var clusterDns = 'discover://abc.def.com:2113';
       var conn = client.EventStoreConnection.create(testBase.settings({maxDiscoverAttempts: 1}), clusterDns);
       conn.connect()
         .catch(function (err) {
@@ -91,6 +91,7 @@ switch(evenstStoreType){
         });
       conn.on('connected', function () {
         test.ok(false, 'Should not be able to connect.');
+        conn.close();
       });
       conn.on('error', function (err) {
         test.ok(err.message.indexOf('Failed to discover candidate in 1 attempts') === 0, 'Wrong expected reason.');
@@ -116,7 +117,7 @@ switch(evenstStoreType){
         done();
       });
       conn.on('error', done);
-  
+
       function done(err) {
         conn.close();
         if (err) return test.done(err);
@@ -144,7 +145,7 @@ switch(evenstStoreType){
         test.done();
       });
     };
-    
+
     module.exports['Create a connection with tcp://host:port string'] = function (test) {
       var conn = client.createConnection({}, `tcp://${process.env.EVENTSTORE_HOST || 'localhost'}:1113`);
       conn.close();

test/persistentSubscription_test.js

@@ -41,7 +41,7 @@ module.exports = {
       done();
     }
     var self = this;
-    this.conn.connectToPersistentSubscription(testStreamName, 'consumer-1', eventAppeared, subscriptionDropped)
+    this.conn.connectToPersistentSubscription(testStreamName, 'consumer-1', eventAppeared, subscriptionDropped, adminCredentials)
       .then(function(subscription) {
         test.ok(subscription, "Subscription is null.");
         return self.conn.appendToStream(testStreamName, client.expectedVersion.any, [createRandomEvent(), createRandomEvent()]);

test/projections_test.js

@@ -2,7 +2,7 @@ const client = require('../lib/dist');
 const userCredentials = new client.UserCredentials('admin', 'changeit');
 
 const log = new client.NoopLogger();
-const httpEndpoint = `http://${process.env.EVENTSTORE_HOST || "localhost"}:2113`;
+const httpEndpoint = `https://${process.env.EVENTSTORE_HOST || "localhost"}:2113`;
 const operationTimeout = 5000;
 
 const simpleProjection = "\
@@ -21,7 +21,7 @@ fromStream('$stats-127.0.0.1:2113')\
 
 module.exports = {
   setUp: function(cb) {
-    this.projectionsManager = new client.ProjectionsManager(log, httpEndpoint, operationTimeout);
+    this.projectionsManager = new client.ProjectionsManager(log, httpEndpoint, operationTimeout, false);
     cb();
   },
   'Create One Time Projection Happy Path': function(test) {