fabio286
/
antares
mirror of https://github.com/Fabio286/antares.git
1
1
Fork 0
Code Issues Releases Wiki Activity

fix: communication with worker thread not working

This commit is contained in:
Fabio Di Stasio 2023-12-06 08:51:48 +01:00
parent 861b704344
commit 6a72f6b4ae
1 changed files with 4 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
src/main/ipc-handlers/schema.ts
View File

@ -240,17 +240,8 @@ export default (connections: {[key: string]: antares.Client}) => {
}); });
// Exporter message listener // Exporter message listener
exporter.stdout.on('data', (buff: Buffer) => { exporter.on('message', (message: workers.WorkerIpcMessage) => {
let message; const { type, payload } = 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;
switch (type) { switch (type) {
case 'export-progress': case 'export-progress':
@ -331,17 +322,8 @@ export default (connections: {[key: string]: antares.Client}) => {
}); });
// Importer message listener // Importer message listener
importer.stdout.on('data', (buff: Buffer) => { importer.on('message', (message: workers.WorkerIpcMessage) => {
let message; const { type, payload } = 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;
switch (type) { switch (type) {
case 'import-progress': case 'import-progress':