add some type safety

Author: joshunrau

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

@@ -5,7 +5,7 @@ import { DEFAULT_GROUP_NAME } from '@opendatacapture/schemas/core';
 import type { InstrumentRecordsExport } from '@opendatacapture/schemas/instrument-records';
 import { removeSubjectIdScope } from '@opendatacapture/subject-utils';
 
-import type { ChunkCompleteData, InitData, ParentMessage, RecordType } from './thread-types';
+import type { ChunkCompleteData, InitData, ParentMessage, RecordType, WorkerMessage } from './thread-types';
 
 type ExpandDataType =
   | {
@@ -117,9 +117,9 @@ function handleChunkComplete(_data: ChunkCompleteData) {
 
   try {
     const results = _data.map(processRecord);
-    parentPort?.postMessage({ data: results.flat(), success: true });
+    parentPort?.postMessage({ data: results.flat(), success: true } satisfies WorkerMessage);
   } catch (error) {
-    parentPort?.postMessage({ error: (error as Error).message, success: false });
+    parentPort?.postMessage({ error: (error as Error).message, success: false } satisfies WorkerMessage);
   }
 }
 

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

@@ -31,7 +31,14 @@ import { SubjectsService } from '@/subjects/subjects.service';
 
 import { InstrumentMeasuresService } from './instrument-measures.service';
 
-import type { InitData, InitialMessage, RecordType, WorkerMessage } from './thread-types';
+import type {
+  ChunkCompleteMessage,
+  InitData,
+  InitialMessage,
+  InitMessage,
+  RecordType,
+  WorkerMessage
+} from './thread-types';
 
 @Injectable()
 export class InstrumentRecordsService {
@@ -158,11 +165,11 @@ export class InstrumentRecordsService {
     const workerPromises = chunks.map((chunk) => {
       return new Promise<InstrumentRecordsExport>((resolve, reject) => {
         const worker = new Worker(join(import.meta.dirname, 'export-worker.ts'));
-        worker.postMessage({ data: availableInstrumentArray, type: 'INIT' });
+        worker.postMessage({ data: availableInstrumentArray, type: 'INIT' } satisfies InitMessage);
 
         worker.on('message', (message: InitialMessage) => {
           if (message.success) {
-            worker.postMessage({ data: chunk, type: 'CHUNK_COMPLETE' });
+            worker.postMessage({ data: chunk, type: 'CHUNK_COMPLETE' } satisfies ChunkCompleteMessage);
             worker.on('message', (message: WorkerMessage) => {
               if (message.success) {
                 resolve(message.data);