Function processRecords

packages/core/src/debug/debugController.ts:651–712

(headers: Uint8Array, payloads: Map<bigint, Uint8Array>)

  }

  function processRecords(headers: Uint8Array, payloads: Map<bigint, Uint8Array>): void {
    const count = Math.floor(headers.byteLength / DEBUG_RECORD_HEADER_SIZE);

    for (let i = 0; i < count; i++) {
      const offset = i * DEBUG_RECORD_HEADER_SIZE;
      const headerResult = parseRecordHeader(headers, offset);

      if (!headerResult.ok) {
        continue;
      }

      const header = headerResult.value;
      let payload: DebugPayload | null = null;

      const payloadBytes = payloads.get(header.recordId);
      if (payloadBytes) {
        const payloadResult = parsePayload(header.category, payloadBytes);
        if (payloadResult.ok) {
          payload = payloadResult.value;
        }
      }

      const record: DebugRecord = { header, payload };

      // Route to appropriate component based on category
      switch (header.category) {
        case "frame":
          if (payload && payloadBytes) {
            const frameResult = parseFrameRecord(payloadBytes);
            if (frameResult.ok) {
              frameInspector.addFrame(frameResult.value, header.timestampUs);
            }
          }
          break;

        case "event":
          if (payload && payloadBytes) {
            const eventResult = parseEventRecord(payloadBytes);
            if (eventResult.ok) {
              eventTrace.addEvent(eventResult.value, header.recordId, header.timestampUs);
            }
          }
          break;

        case "error":
          if (payload && payloadBytes) {
            const errorResult = parseErrorRecord(payloadBytes);
            if (errorResult.ok) {
              errorAggregator.addError(
                errorResult.value,
                header.category,
                header.severity,
                header.timestampUs,
              );
            }
          }
          break;
      }