// Regression: the media file route used `Readable.toWeb(createReadStream(...))`
// which can call enqueue on the WHATWG controller AFTER the consumer aborts,
// surfacing `Invalid state: Controller is already closed` as an
// uncaughtException. Browsers issue range requests with rapid aborts while
// scrubbing <audio>/<video>, so opening the single-video view alone could
// trip this.

import { test, expect } from "@playwright/test";
import { resetData } from "./helpers";
import { baseUrl } from "./baseUrl";

async function readUncaughtCount(): Promise<{
  uncaught: number;
  unhandled: number;
  messages: string[];
}> {
  const res = await fetch(`${baseUrl}/api/test/uncaught-count`);
  return res.json() as Promise<{
    uncaught: number;
    unhandled: number;
    messages: string[];
  }>;
}

async function clearUncaughtCount(): Promise<void> {
  await fetch(`${baseUrl}/api/test/uncaught-count`, { method: "DELETE" });
}

test("aborting media file requests does not crash with 'Controller is already closed'", async () => {
  test.setTimeout(30_000);
  await resetData("one-transcribe-channel-with-audio");
  await clearUncaughtCount();

  const url = `${baseUrl}/api/channels/test-transcribe/videos/vidA/files/audio.m4a`;

  // Fire a burst of overlapping range requests, each aborted shortly after
  // they start. This is what a browser does when the user scrubs through an
  // <audio> element — every seek cancels the prior range request.
  const aborts: Promise<unknown>[] = [];
  for (let i = 0; i < 25; i++) {
    const ac = new AbortController();
    const start = i * 64;
    const end = start + 4096;
    aborts.push(
      fetch(url, {
        headers: { Range: `bytes=${start}-${end}` },
        signal: ac.signal,
      })
        .then((res) => res.body?.getReader().read())
        .catch(() => {}),
    );
    // Abort almost immediately so the consumer disappears while data may
    // still be in flight on the server side.
    setTimeout(() => ac.abort(), 5);
  }
  await Promise.all(aborts);

  // Let any post-cancel async cleanup fire its error path before we check.
  await new Promise<void>((resolve) => setTimeout(resolve, 750));

  const counts = await readUncaughtCount();
  expect(
    counts.messages.filter((m) => m.includes("Controller is already closed")),
  ).toEqual([]);
  expect(counts.uncaught).toBe(0);
});