fix: communication with worker thread not working

antares-sql · Dec 6, 2023 · 6a72f6b · 6a72f6b
1 parent 861b704
commit 6a72f6b
Showing 1 changed file with 4 additions and 22 deletions.
diff --git 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':