Add automatic integration tests

.github/workflows/integration-test.yaml

@@ -0,0 +1,52 @@
+name: Integration tests with Logstash instanse
+
+on:
+  push:
+    branches: [ main ]
+  pull_request:
+    branches: [ main ]
+
+jobs:
+  build:
+    timeout-minutes: 2
+    runs-on: ubuntu-latest
+
+    strategy:
+      matrix:
+        node-version: [16.x, 18.x, 19.x]
+        winston-version: [2x, 3x]
+
+    steps:
+      - uses: actions/checkout@v3
+      - name: Start containers for Winston ${{ matrix.winston-version }}
+        working-directory: ./test-bench/logstash/
+        run: docker-compose -f "docker-compose.yml" up -d
+      - name: Use Node.js ${{ matrix.node-version }}
+        uses: actions/setup-node@v3
+        with:
+          node-version: ${{ matrix.node-version }}
+      - name: Install base project deps
+        run: npm install
+      - name: Build base project
+        run: npm run build
+      - name: Install dependencies for test case
+        working-directory: ./test-bench/winston-${{ matrix.winston-version }}
+        run: npm install
+      - name: Wait for Logstash
+        working-directory: ./test-bench/logstash/
+        run: |
+          npx --yes wait-on --timeout 3000 --verbose tcp:localhost:9777 &&
+          npx --yes wait-on --timeout 3000 --verbose tcp:localhost:9888 &&
+          npx --yes wait-on --timeout 3000 --verbose tcp:localhost:9999 &&
+          npx --yes wait-on --timeout 3000 --verbose tcp:localhost:9777 &&
+          npx --yes wait-on --timeout 3000 --verbose tcp:localhost:9888 &&
+          npx --yes wait-on --timeout 3000 --verbose tcp:localhost:9999 &&
+          docker-compose logs --no-color logstash
+      - run: npm test
+        working-directory: ./test-bench/winston-${{ matrix.winston-version }}
+      - name: Stop containers
+        working-directory: ./test-bench/logstash/
+        if: always()
+        run: |
+         docker-compose logs --no-color logstash &&
+         docker-compose -f "docker-compose.yml" down

.gitignore

@@ -29,4 +29,5 @@ test/runner.js
 
 test/support/logstash/*
 
-test-bench/logstash/logstash/output/*
+!test-bench/logstash/logstash/output/.gitkeep
+test-bench/logstash/logstash/output/sample.log

lib/manager.js

@@ -19,20 +19,21 @@ class Manager extends _events.EventEmitter {
     _defineProperty(this, "retries", -1);
     _defineProperty(this, "max_connect_retries", void 0);
     _defineProperty(this, "timeout_connect_retries", void 0);
+    _defineProperty(this, "retry_timeout", undefined);
     this.options = options;
     this.ssl_enable = (options === null || options === void 0 ? void 0 : options.ssl_enable) === true;
     this.logQueue = new Array();
 
     // Connection retry attributes
-    this.retries = -1;
+    this.retries = 0;
     this.max_connect_retries = (_options$max_connect_ = options === null || options === void 0 ? void 0 : options.max_connect_retries) !== null && _options$max_connect_ !== void 0 ? _options$max_connect_ : 4;
     this.timeout_connect_retries = (_options$timeout_conn = options === null || options === void 0 ? void 0 : options.timeout_connect_retries) !== null && _options$timeout_conn !== void 0 ? _options$timeout_conn : 100;
   }
   addEventListeners() {
-    this.on('connection:connected', this.onConnected.bind(this));
-    this.on('connection:closed', this.onConnectionClosed.bind(this));
-    this.on('connection:error', this.onConnectionError.bind(this));
-    this.on('connection:timeout', this.onConnectionError.bind(this));
+    this.once('connection:connected', this.onConnected.bind(this));
+    this.once('connection:closed', this.onConnectionClosed.bind(this));
+    this.once('connection:error', this.onConnectionError.bind(this));
+    this.once('connection:timeout', this.onConnectionError.bind(this));
   }
   removeEventListeners() {
     this.off('connection:connected', this.onConnected.bind(this));
@@ -59,7 +60,7 @@ class Manager extends _events.EventEmitter {
   isRetryableError(error) {
     // TODO: Due bug in the orginal implementation
     //       all the errors will get retried
-    return true; // !ECONNREFUSED_REGEXP.test(error.code);
+    return true; // !ECONNREFUSED_REGEXP.test(error.message);
   }
 
   shouldTryToReconnect(error) {
@@ -75,22 +76,26 @@ class Manager extends _events.EventEmitter {
   }
   onConnectionError(error) {
     if (this.shouldTryToReconnect(error)) {
+      this.retry();
+    } else {
       var _this$connection;
       this.removeEventListeners();
       (_this$connection = this.connection) === null || _this$connection === void 0 ? void 0 : _this$connection.close();
       this.emit('error', new Error('Max retries reached, transport in silent mode, OFFLINE'));
-    } else {
-      this.retry();
     }
   }
   retry() {
     var _this$connection2;
+    if (this.retry_timeout) {
+      clearTimeout(this.retry_timeout);
+    }
     this.emit('retrying');
     this.removeEventListeners();
     const self = this;
     this.once('connection:closed', () => {
       self.removeEventListeners();
-      setInterval(() => {
+      self.retry_timeout = setTimeout(() => {
+        self.connection = undefined;
         self.start();
       }, self.timeout_connect_retries);
     });