rename ChunkComplete to BeginChunkProcessing

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, WorkerMessage } from './thread-types';
+import type { BeginChunkProcessingData, InitData, ParentMessage, RecordType, WorkerMessage } from './thread-types';
 
 type ExpandDataType =
   | {
@@ -52,7 +52,7 @@ function handleInit(data: InitData) {
   parentPort?.postMessage({ success: true });
 }
 
-function handleChunkComplete(_data: ChunkCompleteData) {
+function handleChunkComplete(_data: BeginChunkProcessingData) {
   if (!initData) {
     throw new Error('Expected init data to be defined');
   }
@@ -125,7 +125,7 @@ function handleChunkComplete(_data: ChunkCompleteData) {
 
 parentPort!.on('message', (message: ParentMessage) => {
   switch (message.type) {
-    case 'CHUNK_COMPLETE':
+    case 'BEGIN_CHUNK_PROCESSING':
       return handleChunkComplete(message.data);
     case 'INIT':
       return handleInit(message.data);

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

@@ -32,7 +32,7 @@ import { SubjectsService } from '@/subjects/subjects.service';
 import { InstrumentMeasuresService } from './instrument-measures.service';
 
 import type {
-  ChunkCompleteMessage,
+  BeginChunkProcessingMessage,
   InitData,
   InitialMessage,
   InitMessage,
@@ -169,7 +169,7 @@ export class InstrumentRecordsService {
 
         worker.on('message', (message: InitialMessage) => {
           if (message.success) {
-            worker.postMessage({ data: chunk, type: 'CHUNK_COMPLETE' } satisfies ChunkCompleteMessage);
+            worker.postMessage({ data: chunk, type: 'BEGIN_CHUNK_PROCESSING' } satisfies BeginChunkProcessingMessage);
             worker.on('message', (message: WorkerMessage) => {
               if (message.success) {
                 resolve(message.data);

apps/api/src/instrument-records/thread-types.ts

@@ -33,14 +33,14 @@ export type InitMessage = {
   type: 'INIT';
 };
 
-export type ChunkCompleteData = RecordType[];
+export type BeginChunkProcessingData = RecordType[];
 
-export type ChunkCompleteMessage = {
-  data: ChunkCompleteData;
-  type: 'CHUNK_COMPLETE';
+export type BeginChunkProcessingMessage = {
+  data: BeginChunkProcessingData;
+  type: 'BEGIN_CHUNK_PROCESSING';
 };
 
-export type ParentMessage = ChunkCompleteMessage | InitMessage;
+export type ParentMessage = BeginChunkProcessingMessage | InitMessage;
 
 export type WorkerMessage = { data: InstrumentRecordsExport; success: true } | { error: string; success: false };