fix: use stream passthrough

api/app.ts

@@ -45,6 +45,7 @@ import { readFile, realpath } from 'fs/promises'
 import { generate } from 'selfsigned'
 import ZnifferManager, { ZnifferConfig } from './lib/ZnifferManager'
 import { getAllNamedScaleGroups, getAllSensors } from '@zwave-js/core'
+import { Writable } from 'stream'
 
 const createCertificate = promisify(generate)
 
@@ -440,10 +441,14 @@ async function destroyPlugins() {
 
 function setupInterceptor() {
 	// intercept logs and redirect them to socket
-	loggers.logStream._write = function (data, _, next) {
-		socketManager.io.emit(socketEvents.debug, data.toString())
-		next()
-	}
+	loggers.logStream.pipe(
+		new Writable({
+			write(chunk, encoding, callback) {
+				socketManager.io.emit(socketEvents.debug, chunk.toString())
+				callback()
+			},
+		}),
+	)
 }
 
 async function parseDir(dir: string): Promise<StoreFileEntry[]> {

api/lib/logger.ts

@@ -10,7 +10,7 @@ import * as path from 'path'
 import { readdir, stat, unlink } from 'fs/promises'
 import { Stats } from 'fs'
 import escapeStringRegexp from '@esm2cjs/escape-string-regexp'
-import { Writable } from 'stream'
+import { PassThrough } from 'stream'
 
 const { format, transports, addColors } = winston
 const { combine, timestamp, label, printf, colorize, splat } = format
@@ -103,11 +103,8 @@ export function customFormat(
 	return combine(...formats)
 }
 
-export const logStream = new Writable()
-logStream._write = function (chunk, encoding, done) {
-	// noop
-	done()
-}
+export const logStream = new PassThrough()
+
 /**
  * Create the base transports based on settings provided
  */