From 6a72f6b4ae3f4c1d6c42ca7a817d2f2c135696a7 Mon Sep 17 00:00:00 2001 From: Fabio Di Stasio Date: Wed, 6 Dec 2023 08:51:48 +0100 Subject: [PATCH] fix: communication with worker thread not working --- src/main/ipc-handlers/schema.ts | 26 ++++---------------------- 1 file changed, 4 insertions(+), 22 deletions(-) diff --git a/src/main/ipc-handlers/schema.ts b/src/main/ipc-handlers/schema.ts index 7871c86d..0f4f84ee 100644 --- a/src/main/ipc-handlers/schema.ts +++ b/src/main/ipc-handlers/schema.ts @@ -240,17 +240,8 @@ export default (connections: {[key: string]: antares.Client}) => { }); // Exporter message listener - exporter.stdout.on('data', (buff: Buffer) => { - let message; - try { // Ignore non-JSON data (console.log output) - message = JSON.parse(buff.toString()); - } - catch (_) { - if (process.env.NODE_ENV === 'development') console.log('EXPORTER:', buff.toString()); - return; - } - - const { type, payload } = message as workers.WorkerIpcMessage; + exporter.on('message', (message: workers.WorkerIpcMessage) => { + const { type, payload } = message; switch (type) { case 'export-progress': @@ -331,17 +322,8 @@ export default (connections: {[key: string]: antares.Client}) => { }); // Importer message listener - importer.stdout.on('data', (buff: Buffer) => { - let message; - try { // Ignore non-JSON data (console.log output) - message = JSON.parse(buff.toString()); - } - catch (_) { - if (process.env.NODE_ENV === 'development') console.log('IMPORTER:', buff.toString()); - return; - } - - const { type, payload } = message as workers.WorkerIpcMessage; + importer.on('message', (message: workers.WorkerIpcMessage) => { + const { type, payload } = message; switch (type) { case 'import-progress':