Function processEventBatch

packages/core/src/app/createApp/eventLoop.ts:152–398

(
    batch: BackendEventBatch,
    releasedBatches: Set<BackendEventBatch>,
  )

  }

  function processEventBatch(
    batch: BackendEventBatch,
    releasedBatches: Set<BackendEventBatch>,
  ): void {
    const release = releaseOnce(batch, releasedBatches);

    const parseToken = perfMarkStart("event_parse");
    const parsed = parseEventBatchV1(batch.bytes, {
      maxTotalSize: options.config.maxEventBytes,
      timeUnwrap: options.timeUnwrap,
    });
    perfMarkEnd("event_parse", parseToken);
    if (!parsed.ok) {
      release();
      options.fatalNowOrEnqueue(
        "ZRUI_PROTOCOL_ERROR",
        `${parsed.error.code}: ${parsed.error.detail}`,
      );
      return;
    }

    const engineTruncated = (parsed.value.flags & 1) !== 0;
    const droppedBatches = batch.droppedBatches;

    try {
      if (engineTruncated || droppedBatches > 0) {
        if (!options.emit({ kind: "overrun", engineTruncated, droppedBatches })) return;
        if (options.getRuntimeState() !== "Running") return;
      }

      for (const ev of parsed.value.events) {
        const pairedShiftText =
          pendingShiftTextPair !== null &&
          ev.kind === "text" &&
          ev.timeMs === pendingShiftTextPair.timeMs &&
          ev.codepoint === pendingShiftTextPair.codepoint
            ? pendingShiftTextPair
            : null;
        pendingShiftTextPair = null;

        if (ev.kind === "key" || ev.kind === "text" || ev.kind === "paste" || ev.kind === "mouse") {
          options.setInteractiveBudget(2);
        }
        options.noteBreadcrumbEvent(ev.kind);
        if (!options.emit({ kind: "engine", event: ev })) return;
        if (options.getRuntimeState() !== "Running") return;

        if (ev.kind === "resize") {
          const prev = options.getViewport();
          if (prev === null || prev.cols !== ev.cols || prev.rows !== ev.rows) {
            options.setViewport(Object.freeze({ cols: ev.cols, rows: ev.rows }));
            if (options.widgetRenderer.hasViewportAwareComposites()) {
              options.widgetRenderer.invalidateCompositeWidgets();
              options.markDirty(DIRTY_LAYOUT | DIRTY_VIEW);
            } else {
              options.markDirty(DIRTY_LAYOUT);
            }
          }