Function handleWorkerMessage

packages/node/src/backend/nodeBackend.ts:278–589

(m: unknown)

  }

  function handleWorkerMessage(m: unknown): void {
    if (fatal !== null) return;
    if (typeof m !== "object" || m === null) return;
    const type = (m as { type?: unknown }).type;
    if (typeof type !== "string") return;

    const msg = m as WorkerToMainMessage;
    switch (msg.type) {
      case "ready": {
        started = true;
        stopRequested = false;
        if (startDef !== null && !startSettled) {
          startSettled = true;
          startDef.resolve();
        }
        return;
      }

      case "frameStatus": {
        if (frameAudit.enabled) {
          frameAudit.emit("worker.frameStatus", {
            acceptedSeq: msg.acceptedSeq,
            completedSeq: msg.completedSeq ?? null,
            completedResult: msg.completedResult ?? null,
          });
        }
        if (!Number.isInteger(msg.acceptedSeq) || msg.acceptedSeq <= 0) {
          fatal = new ZrUiError(
            "ZRUI_BACKEND_ERROR",
            `invalid frameStatus.acceptedSeq: ${String(msg.acceptedSeq)}`,
          );
          failAll(fatal);
          return;
        }
        resolveAcceptedFramesUpTo(frameTracking, frameAudit, msg.acceptedSeq);
        resolveCoalescedCompletionFramesUpTo(frameTracking, frameAudit, msg.acceptedSeq);

        if (msg.completedSeq !== undefined) {
          if (!Number.isInteger(msg.completedSeq) || msg.completedSeq <= 0) {
            fatal = new ZrUiError(
              "ZRUI_BACKEND_ERROR",
              `invalid frameStatus.completedSeq: ${String(msg.completedSeq)}`,
            );
            failAll(fatal);
            return;
          }
          const completedResult = msg.completedResult ?? 0;
          if (!Number.isInteger(completedResult)) {
            fatal = new ZrUiError(
              "ZRUI_BACKEND_ERROR",
              `invalid frameStatus.completedResult: ${String(msg.completedResult)}`,
            );
            failAll(fatal);
            return;
          }
          settleCompletedFrame(frameTracking, frameAudit, msg.completedSeq, completedResult);
          if (completedResult < 0) {
            fatal = new ZrUiError(