fix: use different approach

api/app.ts

@@ -45,7 +45,6 @@ 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)
 
@@ -441,14 +440,9 @@ async function destroyPlugins() {
 
 function setupInterceptor() {
 	// intercept logs and redirect them to socket
-	loggers.logStream.pipe(
-		new Writable({
-			write(chunk, encoding, callback) {
-				socketManager.io.emit(socketEvents.debug, chunk.toString())
-				callback()
-			},
-		}),
-	)
+	loggers.logStream.on('data', (chunk) => {
+		socketManager.io.emit(socketEvents.debug, chunk.toString())
+	})
 }
 
 async function parseDir(dir: string): Promise<StoreFileEntry[]> {

api/lib/ZwaveClient.ts

@@ -124,7 +124,6 @@ import { ConfigManager, DeviceConfig } from '@zwave-js/config'
 import { readFile } from 'fs/promises'
 import backupManager, { NVM_BACKUP_PREFIX } from './BackupManager'
 import { socketEvents } from './SocketEvents'
-import { PassThrough } from 'stream'
 
 export const deviceConfigPriorityDir = storeDir + '/config'
 
@@ -2268,7 +2267,7 @@ class ZwaveClient extends TypedEventEmitter<ZwaveClientEventCallbacks> {
 		zwaveOptions.logConfig.transports = [logTransport]
 
 		logTransport.stream.on('data', (data) => {
-			LogManager.logStream.push(Buffer.from(data.message))
+			this.socket.emit(socketEvents.debug, data.message.toString())
 		})
 
 		try {