feat: add parent port message to initial thread function

Author: david-roper

apps/api/src/instrument-records/export-worker.ts

@@ -142,7 +142,8 @@ let initData: Map<
 
 function handleInit(data: InitData) {
   initData = new Map(data.map((instrument) => [instrument.id, instrument]));
-  return { success: true };
+
+  parentPort?.postMessage({ success: true });
 }
 
 function handleChunkComplete(_data: ChunkCompleteData) {

apps/api/src/instrument-records/instrument-records.service.ts

@@ -264,16 +264,26 @@ export class InstrumentRecordsService {
         };
       });
 
-    const initWorker = new Worker(join(__dirname, 'export-worker.ts'));
+    const initWorkerPromise = new Promise<InitialMessage>((resolve, reject) => {
+      const initWorker = new Worker(join(__dirname, 'export-worker.ts'));
 
-    initWorker.postMessage({ data: availableInstrumentArray, type: 'INIT' });
+      initWorker.postMessage({ data: availableInstrumentArray, type: 'INIT' });
 
-    initWorker.on('message', (message: InitialMessage) => {
-      if (!message.success) {
-        throw Error('Initial thread failed');
-      }
+      initWorker.on('message', (message: InitialMessage) => {
+        if (!message.success) {
+          reject(new Error('Error in initial thread'));
+        }
+        resolve(message);
+        void initWorker.terminate();
+      });
     });
 
+    try {
+      await initWorkerPromise;
+    } catch (error) {
+      console.error('Worker failed:', error);
+    }
+
     const workerPromises = chunks.map((chunk) => {
       return new Promise<InstrumentRecordsExport>((resolve, reject) => {
         const worker = new Worker(join(__dirname, 'export-worker.ts'));