Function patchTableRows

src/patch-streaming-html.ts:705–797

(
  container: HTMLElement,
  displayHtml: string,
  track: string,
  prefix: string,
)

}

function patchTableRows(
  container: HTMLElement,
  displayHtml: string,
  track: string,
  prefix: string,
): boolean {
  const table = findActiveTable(container);
  if (!table) {
    return false;
  }

  if (!table.dataset.shLayoutFixed) {
    table.style.tableLayout = "fixed";
    table.dataset.shLayoutFixed = "1";
  }

  seedRowCountsFromDom(table);

  const tableSection = track.slice(prefix.length);
  const parts = splitTableStream(tableSection);

  // Multiple <tr> opens with no </tr> in track — incremental append duplicates rows.
  const rowOpens = (tableSection.match(/<tr\b/gi) ?? []).length;
  if (
    !/<\/tr>/i.test(tableSection) &&
    rowOpens >= 2 &&
    parts.tbodyComplete.length === 0 &&
    parts.theadComplete.length === 0 &&
    (parts.tbodyPartial || parts.theadPartial)
  ) {
    return false;
  }

  let thead = table.querySelector("thead");
  if (!thead) {
    thead = document.createElement("thead");
    table.insertBefore(thead, table.firstChild);
  }

  let tbody = table.querySelector("tbody");
  if (!tbody) {
    tbody = document.createElement("tbody");
    table.appendChild(tbody);
  }

  // Drop header rows mistakenly patched into tbody during early stream frames
  if (parts.theadComplete.length > 0) {
    let removed = false;
    tbody.querySelectorAll("tr").forEach((tr) => {
      if (tr.querySelector("th")) {
        tr.remove();
        removed = true;
      }
    });
    if (removed) {
      table.dataset.shRowCount = String(countBodyRows(tbody));
    }
  }