fix: logstash-http flushes message one by one by default

Author: Zacaria

package.json

@@ -113,4 +113,4 @@
     ]
   },
   "packageManager": "yarn@3.2.1"
-}
+}

packages/connect/package.json

@@ -47,4 +47,4 @@
   "peerDependencies": {
     "@tsed/logger": "6.6.1"
   }
-}
+}

packages/file/package.json

@@ -48,4 +48,4 @@
   "peerDependencies": {
     "@tsed/logger": "6.6.1"
   }
-}
+}

packages/insight/package.json

@@ -48,4 +48,4 @@
   "peerDependencies": {
     "@tsed/logger": "6.6.1"
   }
-}
+}

packages/logentries/package.json

@@ -48,4 +48,4 @@
   "peerDependencies": {
     "@tsed/logger": "6.6.1"
   }
-}
+}

packages/logger/package.json

@@ -45,6 +45,5 @@
   },
   "devDependencies": {
     "typescript": "5.0.4"
-  },
-  "peerDependencies": {}
-}
+  }
+}

packages/loggly/package.json

@@ -49,4 +49,4 @@
   "peerDependencies": {
     "@tsed/logger": "6.6.1"
   }
-}
+}

packages/logstash-http/package.json

@@ -52,4 +52,4 @@
   "peerDependencies": {
     "@tsed/logger": "6.6.1"
   }
-}
+}

packages/logstash-http/src/LogStashHttpAppender.ts

@@ -90,15 +90,14 @@ export class LogStashHttpAppender extends BaseAppender<LogStashHttpOptions> {
     const {bufferMax = 0, delayToFlush = 0} = this.config.options;
     this.#buffer.push(bulk);
 
+    if (!bufferMax || bufferMax <= this.#buffer.length) {
+      return this.flush();
+    }
+
     if (delayToFlush) {
       this.#timer && clearTimeout(this.#timer);
       this.#timer = setTimeout(() => this.flush(), delayToFlush);
     }
-
-    if (bufferMax <= this.#buffer.length) {
-      this.#buffer.push(bulk);
-      return this.flush();
-    }
   }
 
   async flush() {

packages/logstash-udp/package.json

@@ -48,4 +48,4 @@
   "peerDependencies": {
     "@tsed/logger": "6.6.1"
   }
-}
+}