Method handleWorkerMessage

server/utils/import-queue.ts:261–279

(workerId: number, message: any)

  }

  private handleWorkerMessage(workerId: number, message: any): void {
    switch (message.type) {
      case "requestWork":
        this.assignWorkToThread(workerId);
        break;
      case "workComplete":
        this.handleWorkCompletion(workerId, message.data);
        break;
      case "progress":
        this.handleProgressUpdate(message.data);
        break;
      case "log":
        handleLog(`Worker ${workerId}: ${message.message}`);
        break;
      case "error":
        handleLog(`Worker ${workerId} error: ${message.error}`);
        break;
    }
  }

  private async assignWorkToThread(workerId: number): Promise<void> {
    const workItem = await this.getNextWorkItem(workerId);