Fix/http transport memory leak

lib/winston/transports/console.js

@@ -49,8 +49,9 @@
    * @param {Function} callback - TODO: add param description.
    * @returns {undefined}
    */
   log(info, callback) {
-    setImmediate(() => this.emit('logged', info));
+    // Emit logged event directly - no need for setImmediate since writes are async
+    this.emit('logged', info);
 
     // Remark: what if there is no raw...?
     if (this.stderrLevels[info[LEVEL]]) {

lib/winston/transports/http.js

@@ -58,6 +58,11 @@ module.exports = class Http extends TransportStream {
    * @returns {undefined}
    */
   log(info, callback) {
+    // Handle callback immediately since HTTP requests are already async
+    if (callback) {
+      return callback();
+    }
+
     this._request(info, null, null, (err, res) => {
       if (res && res.statusCode !== 200) {
         err = new Error(`Invalid HTTP Status Code: ${res.statusCode}`);
@@ -69,12 +74,6 @@ module.exports = class Http extends TransportStream {
         this.emit('logged', info);
       }
     });
-
-    // Remark: (jcrugzz) Fire and forget here so requests dont cause buffering
-    // and block more requests from happening?
-    if (callback) {
-      setImmediate(callback);
-    }
   }
 
   /**
@@ -192,20 +191,24 @@ module.exports = class Http extends TransportStream {
    * @param {string} path - request path
    */
   _doBatch(options, callback, auth, path) {
+    // Handle callback immediately since batching is async
+    if (callback) {
+      return callback();
+    }
+
     this.batchOptions.push(options);
     if (this.batchOptions.length === 1) {
-      // First message stored, it's time to start the timeout!
-      const me = this;
-      this.batchCallback = callback;
-      this.batchTimeoutID = setTimeout(function () {
-        // timeout is reached, send all messages to endpoint
-        me.batchTimeoutID = -1;
-        me._doBatchRequest(me.batchCallback, auth, path);
+      // First message stored, start the timeout
+      this.batchTimeoutID = setTimeout(() => {
+        this.batchTimeoutID = -1;
+        this._doBatchRequest(null, auth, path);
       }, this.batchInterval);
     }
     if (this.batchOptions.length === this.batchCount) {
-      // max batch count is reached, send all messages to endpoint
-      this._doBatchRequest(this.batchCallback, auth, path);
+      // max batch count reached, send immediately
+      clearTimeout(this.batchTimeoutID);
+      this.batchTimeoutID = -1;
+      this._doBatchRequest(null, auth, path);
     }
   }