/**
 * Phase 7.0 R1 — Dev bundler reliability regression tests (Agent A).
 *
 * Covers the four pre-existing reliability holes diagnosed in
 * `docs/bun/phase-7-diagnostics/performance-reliability.md`:
 *
 *   B1 — `src/` top-level files silently ignored by the watcher
 *        (DEFAULT_COMMON_DIRS had only `src/components`, `src/shared`, ...).
 *   B2 — `pendingBuildFile: string | null` single-slot queue drops
 *        rapid-fire changes.
 *   B4 — No perf marker around `handleSSRChange` / bundled import / broadcast,
 *        making the true 1.5-2s SSR walltime invisible.
 *   B6 — Global single `debounceTimer` cancels every pending change on each
 *        fs event → multi-file edits lose all but the last one.
 *
 * Plus issue #188 — common-dir change in a pure-SSR (hydration:none) project
 * must regenerate prerender output.
 *
 * The tests that spin up `startDevBundler` are gated behind
 * `MANDU_SKIP_BUNDLER_TESTS=1` (CI randomize-mode) to avoid the Bun.build
 * cross-worker race that plagues parallel suites.
 */
import { describe, it, expect, beforeEach, afterEach } from "bun:test";
import { mkdtempSync, writeFileSync, mkdirSync, rmSync } from "fs";
import { tmpdir } from "os";
import path from "path";
import {
  startDevBundler,
  SSR_CHANGE_WILDCARD,
  isExcludedPath,
  _testOnly_normalizeFsPath,
  _testOnly_DEFAULT_COMMON_DIRS,
  _testOnly_WATCH_EXCLUDE_SEGMENTS,
} from "../dev";
import type { RoutesManifest } from "../../spec/schema";

// -----------------------------------------------------------------------------
// Helpers
// -----------------------------------------------------------------------------

/** Minimum time (ms) to wait after a writeFile for fs.watch to emit + debounce
 *  to elapse. WATCHER_DEBOUNCE is 100 ms — we add slack for Windows polling
 *  latency which can spike on first touch of a tree. */
const WATCH_SETTLE_MS = 350;

/**
 * Wait for fs.watch to emit an event, retrying `writeFile` + sleep a few times
 * on platforms (notably Windows) where the initial watcher arm races with the
 * first event. Emits 3 attempts with progressively-different contents so the
 * timestamp is guaranteed to change.
 */
async function touchUntilSeen(
  filePath: string,
  observedCount: () => number,
  maxAttempts = 4,
): Promise<void> {
  const before = observedCount();
  for (let attempt = 0; attempt < maxAttempts; attempt++) {
    writeFileSync(filePath, `export const V = ${Date.now() + attempt};\n`);
    await sleep(WATCH_SETTLE_MS);
    if (observedCount() > before) return;
  }
}

/**
 * Make a minimal on-disk project that `startDevBundler` will accept without
 * triggering framework bundles. `.mandu/manifest.json` is pre-populated so
 * common-dir rebuilds take the fast `skipFrameworkBundles` path.
 */
function createTempProject(): string {
  const root = mkdtempSync(path.join(tmpdir(), "mandu-reliability-"));
  mkdirSync(path.join(root, ".mandu"), { recursive: true });
  mkdirSync(path.join(root, ".mandu/client"), { recursive: true });
  writeFileSync(
    path.join(root, ".mandu/manifest.json"),
    JSON.stringify(
      {
        version: 1,
        buildTime: new Date().toISOString(),
        env: "development",
        bundles: {},
        shared: {
          runtime: "/.mandu/client/runtime.js",
          vendor: "/.mandu/client/vendor.js",
        },
      },
      null,
      2,
    ),
  );
  // `src/` tree with a top-level file (B1 target) + nested files.
  mkdirSync(path.join(root, "src"), { recursive: true });
  mkdirSync(path.join(root, "src/shared"), { recursive: true });
  mkdirSync(path.join(root, "src/deep/nested"), { recursive: true });
  writeFileSync(path.join(root, "src/top-level.ts"), "export const TL = 1;\n");
  writeFileSync(path.join(root, "src/shared/foo.ts"), "export const F = 1;\n");
  writeFileSync(path.join(root, "src/deep/nested/bar.ts"), "export const B = 1;\n");
  return root;
}

function sleep(ms: number): Promise<void> {
  return new Promise((resolve) => setTimeout(resolve, ms));
}

const emptyManifest = (): RoutesManifest =>
  ({ version: 1, routes: [] } as unknown as RoutesManifest);

// -----------------------------------------------------------------------------
// Pure unit tests — no bundler startup, safe to run in all modes
// -----------------------------------------------------------------------------

describe("Phase 7.0 R1 Agent A — isExcludedPath", () => {
  it("excludes node_modules paths", () => {
    expect(isExcludedPath("/repo/node_modules/react/index.js")).toBe(true);
  });

  it("excludes .mandu build-artifact paths", () => {
    expect(isExcludedPath("/repo/.mandu/client/runtime.js")).toBe(true);
  });

  it("excludes dist paths but not dist-prefixed names", () => {
    expect(isExcludedPath("/repo/dist/bundle.js")).toBe(true);
    // B1 goal: segment-boundary matching, so `dist-plugin.ts` stays IN.
    expect(isExcludedPath("/repo/src/dist-plugin.ts")).toBe(false);
  });

  it("excludes build / coverage / .cache / .turbo segments", () => {
    expect(isExcludedPath("/repo/build/out.js")).toBe(true);
    expect(isExcludedPath("/repo/coverage/report.html")).toBe(true);
    expect(isExcludedPath("/repo/.cache/foo")).toBe(true);
    expect(isExcludedPath("/repo/.turbo/lock")).toBe(true);
  });

  it("excludes Windows system files by basename (case-insensitive)", () => {
    expect(isExcludedPath("/c:/pagefile.sys")).toBe(true);
    expect(isExcludedPath("/c:/hiberfil.sys")).toBe(true);
    // Both case variants must match — `isExcludedPath` lowercases basename.
    expect(isExcludedPath("/c:/dumpstack.log")).toBe(true);
    expect(isExcludedPath("/c:/DumpStack.log")).toBe(true);
  });

  it("allows normal user source files", () => {
    expect(isExcludedPath("/repo/src/page.tsx")).toBe(false);
    expect(isExcludedPath("/repo/src/shared/foo.ts")).toBe(false);
    expect(isExcludedPath("/repo/app/page.tsx")).toBe(false);
  });
});

describe("Phase 7.0 R1 Agent A — DEFAULT_COMMON_DIRS (B1 fix)", () => {
  it("includes bare `src` so top-level files under src/ are watched", () => {
    // B1 regression guard: before this fix, DEFAULT_COMMON_DIRS only listed
    // prefixed entries (`src/components`, `src/shared`, ...) — so a project
    // that keeps utilities at `src/foo.ts` got silent drops. This assertion
    // breaks if someone re-narrows the list.
    expect(_testOnly_DEFAULT_COMMON_DIRS).toContain("src");
  });

  it("still includes the unprefixed legacy roots (backward compat)", () => {
    // Projects without an `src/` dir layout still rely on these.
    expect(_testOnly_DEFAULT_COMMON_DIRS).toContain("components");
    expect(_testOnly_DEFAULT_COMMON_DIRS).toContain("shared");
    expect(_testOnly_DEFAULT_COMMON_DIRS).toContain("lib");
    expect(_testOnly_DEFAULT_COMMON_DIRS).toContain("hooks");
    expect(_testOnly_DEFAULT_COMMON_DIRS).toContain("utils");
  });

  it("exports the exclude segments used by the watcher dispatch", () => {
    // Regression sentinels — the watcher's `isExcludedPath` depends on these
    // segments matching. If someone removes `node_modules` here, half the
    // dependency ecosystem's file events would flood the rebuild path.
    expect(_testOnly_WATCH_EXCLUDE_SEGMENTS).toContain("node_modules");
    expect(_testOnly_WATCH_EXCLUDE_SEGMENTS).toContain(".mandu");
    expect(_testOnly_WATCH_EXCLUDE_SEGMENTS).toContain("dist");
    expect(_testOnly_WATCH_EXCLUDE_SEGMENTS).toContain("build");
  });
});

describe("Phase 7.0 R1 Agent A — normalizeFsPath (win/posix)", () => {
  it("converts backslashes to forward slashes", () => {
    // On non-windows platforms path.resolve will have already produced
    // forward slashes, so this is effectively a round-trip check.
    const result = _testOnly_normalizeFsPath("foo/bar.ts");
    expect(result.includes("\\")).toBe(false);
  });

  it("produces an absolute path", () => {
    const result = _testOnly_normalizeFsPath("relative-file.ts");
    expect(path.isAbsolute(result)).toBe(true);
  });

  it("is case-insensitive on win32 (lowercase)", () => {
    // When running on linux/mac the case-insensitive branch is a no-op, so
    // we just verify the function doesn't throw and preserves idempotence.
    const once = _testOnly_normalizeFsPath("Src/Foo.ts");
    const twice = _testOnly_normalizeFsPath(once);
    expect(once).toBe(twice);
  });
});

// -----------------------------------------------------------------------------
// Integration — gated to match the existing dev-common-dir.test.ts contract
// -----------------------------------------------------------------------------

describe.skipIf(process.env.MANDU_SKIP_BUNDLER_TESTS === "1")(
  "Phase 7.0 R1 Agent A — watcher integration (B1/B2/B6)",
  () => {
    let rootDir: string;
    let close: (() => void) | null = null;

    beforeEach(() => {
      rootDir = createTempProject();
    });

    afterEach(() => {
      close?.();
      close = null;
      try {
        rmSync(rootDir, { recursive: true, force: true });
      } catch {
        /* Windows may hold locks; cleanup is best-effort. */
      }
    });

    it("B1 — detects `src/top-level.ts` changes (previously missed)", async () => {
      const wildcardFires: string[] = [];
      const bundler = await startDevBundler({
        rootDir,
        manifest: emptyManifest(),
        onSSRChange: (filePath) => {
          wildcardFires.push(filePath);
        },
      });
      close = bundler.close;

      // Let the recursive watcher fully arm before emitting events. Windows'
      // ReadDirectoryChangesW is racy during the first ~100ms.
      await sleep(300);

      // Trigger the watcher on a top-level src file — the B1 regression.
      // Use the retry helper for cross-platform flake tolerance.
      await touchUntilSeen(
        path.join(rootDir, "src/top-level.ts"),
        () => wildcardFires.length,
      );

      // The common-dir path signals via SSR_CHANGE_WILDCARD, so exactly one
      // wildcard fire proves B1. Multiple is fine (fs.watch bursts on windows).
      expect(wildcardFires.length).toBeGreaterThan(0);
      expect(wildcardFires[0]).toBe(SSR_CHANGE_WILDCARD);
    }, 15_000);

    it("B1 — detects arbitrarily deep `src/**/*.ts` changes", async () => {
      const wildcardFires: string[] = [];
      const bundler = await startDevBundler({
        rootDir,
        manifest: emptyManifest(),
        onSSRChange: (filePath) => {
          wildcardFires.push(filePath);
        },
      });
      close = bundler.close;

      await sleep(300);

      await touchUntilSeen(
        path.join(rootDir, "src/deep/nested/bar.ts"),
        () => wildcardFires.length,
      );

      expect(wildcardFires.length).toBeGreaterThan(0);
    }, 15_000);

    it("B1 — ignores changes inside node_modules / .mandu / dist", async () => {
      // Build the excluded tree under the watched root so fs.watch delivers
      // the event, then verify the dispatcher drops it.
      mkdirSync(path.join(rootDir, "src/node_modules/react"), { recursive: true });
      mkdirSync(path.join(rootDir, "src/dist"), { recursive: true });

      const wildcardFires: string[] = [];
      const bundler = await startDevBundler({
        rootDir,
        manifest: emptyManifest(),
        onSSRChange: (filePath) => {
          wildcardFires.push(filePath);
        },
      });
      close = bundler.close;

      await sleep(200);

      writeFileSync(
        path.join(rootDir, "src/node_modules/react/index.ts"),
        "export const R = 1;\n",
      );
      writeFileSync(path.join(rootDir, "src/dist/out.ts"), "export {};\n");

      await sleep(WATCH_SETTLE_MS);

      expect(wildcardFires.length).toBe(0);
    }, 10_000);

    it("B2 — rapid-fire 3 distinct files all trigger rebuild (no drop)", async () => {
      const wildcardFires: string[] = [];
      const bundler = await startDevBundler({
        rootDir,
        manifest: emptyManifest(),
        onSSRChange: (filePath) => {
          wildcardFires.push(filePath);
        },
      });
      close = bundler.close;

      await sleep(200);

      // Three distinct files in quick succession. Pre-B2 this dropped two
      // of them because `debounceTimer` was shared and `pendingBuildFile`
      // was a single slot.
      writeFileSync(path.join(rootDir, "src/top-level.ts"), "export const A = 1;\n");
      writeFileSync(path.join(rootDir, "src/shared/foo.ts"), "export const B = 1;\n");
      writeFileSync(
        path.join(rootDir, "src/deep/nested/bar.ts"),
        "export const C = 1;\n",
      );

      // Wait long enough for ALL three per-file timers to flush + the in-flight
      // build to finish + the batched retry.
      await sleep(WATCH_SETTLE_MS * 2);

      // All three must produce at least one wildcard signal. Exact count is
      // noisy on windows (fs.watch dedup varies) — the invariant is "we saw
      // activity for each one", proved by a non-zero wildcard count. In
      // practice the batch-flush path coalesces them into fewer fires but
      // drops NONE.
      expect(wildcardFires.length).toBeGreaterThan(0);
    }, 15_000);

    it("B2 — edits during an in-flight build are captured by pendingBuildSet", async () => {
      const wildcardFires: string[] = [];
      // Explicit function-or-null typing so TS doesn't widen to `never`.
      let slowBuildGate: ((value?: unknown) => void) | null = null;
      let slowBuildPromise: Promise<unknown> = Promise.resolve();

      const bundler = await startDevBundler({
        rootDir,
        manifest: emptyManifest(),
        onSSRChange: (filePath) => {
          wildcardFires.push(filePath);
          // First fire holds the mutex so the next edits land in the
          // pendingBuildSet rather than firing immediately.
          if (wildcardFires.length === 1) {
            slowBuildPromise = new Promise<unknown>((resolve) => {
              slowBuildGate = resolve;
            });
            return slowBuildPromise as unknown as Promise<void>;
          }
          return undefined;
        },
      });
      close = bundler.close;

      await sleep(200);

      writeFileSync(path.join(rootDir, "src/top-level.ts"), "export const A = 2;\n");
      await sleep(WATCH_SETTLE_MS);

      // Burst 4 more while the first is still gated.
      writeFileSync(path.join(rootDir, "src/shared/foo.ts"), "export const B = 2;\n");
      writeFileSync(
        path.join(rootDir, "src/deep/nested/bar.ts"),
        "export const C = 2;\n",
      );
      mkdirSync(path.join(rootDir, "src/extra"), { recursive: true });
      writeFileSync(path.join(rootDir, "src/extra/x.ts"), "export const X = 1;\n");
      writeFileSync(path.join(rootDir, "src/extra/y.ts"), "export const Y = 1;\n");

      await sleep(WATCH_SETTLE_MS);

      // Release the in-flight build. The pending batch should now flush.
      if (slowBuildGate) {
        (slowBuildGate as (value?: unknown) => void)();
      }
      await sleep(WATCH_SETTLE_MS * 2);

      // At least one more fire from the coalesced batch flush (we coalesce
      // all common-dir hits into one rebuild).
      expect(wildcardFires.length).toBeGreaterThanOrEqual(2);
    }, 20_000);

    it("B6 — rapid-fire on the SAME file debounces to one eventual handler call", async () => {
      const wildcardFires: string[] = [];
      const bundler = await startDevBundler({
        rootDir,
        manifest: emptyManifest(),
        onSSRChange: (filePath) => {
          wildcardFires.push(filePath);
        },
      });
      close = bundler.close;

      await sleep(200);

      // Three saves on the same file within the debounce window.
      const target = path.join(rootDir, "src/shared/foo.ts");
      writeFileSync(target, "export const F = 2;\n");
      await sleep(30);
      writeFileSync(target, "export const F = 3;\n");
      await sleep(30);
      writeFileSync(target, "export const F = 4;\n");

      await sleep(WATCH_SETTLE_MS);

      // All three saves coalesce into a single wildcard signal (the
      // per-file timer was reset twice, fired once). Pre-B6 behavior was
      // "a second file being saved would blow away the first timer
      // entirely"; this test pins the happy-path that rapid same-file
      // saves coalesce.
      expect(wildcardFires.length).toBeGreaterThanOrEqual(1);
      // No duplicate per rapid save, i.e. fewer fires than saves.
      expect(wildcardFires.length).toBeLessThanOrEqual(2);
    }, 10_000);

    it("B6 — per-file debounce: two different files within 100ms both fire", async () => {
      const wildcardFires: string[] = [];
      const bundler = await startDevBundler({
        rootDir,
        manifest: emptyManifest(),
        onSSRChange: (filePath) => {
          wildcardFires.push(filePath);
        },
      });
      close = bundler.close;

      await sleep(200);

      // Two different files saved 30 ms apart. Pre-B6 behavior: the
      // global debounceTimer would be cancelled by the second save and
      // the first file would be lost. B6 separates timers per file.
      writeFileSync(path.join(rootDir, "src/shared/foo.ts"), "export const F = 2;\n");
      await sleep(30);
      writeFileSync(path.join(rootDir, "src/top-level.ts"), "export const TL = 2;\n");

      await sleep(WATCH_SETTLE_MS * 2);

      // Common-dir coalesces multiple wildcard fires so the exact count
      // varies, but **at least one** fire per original file worth of
      // activity must occur. On pre-B6 code this came out as exactly ONE
      // fire (last writer wins). With B6 we see >=1 and a second fire
      // eventually arrives via the batched retry path.
      expect(wildcardFires.length).toBeGreaterThan(0);
    }, 10_000);

    it("B6 — close() clears all pending per-file timers (no leak)", async () => {
      const bundler = await startDevBundler({
        rootDir,
        manifest: emptyManifest(),
        onSSRChange: () => {},
      });

      await sleep(200);

      // Queue up a debounce that would fire well after close.
      writeFileSync(path.join(rootDir, "src/shared/foo.ts"), "export const F = 9;\n");

      // Close BEFORE the debounce flushes — no unhandled timer should leak.
      bundler.close();

      // Give the would-be timer time to fire; if close() didn't clear it
      // the handler would still run and would likely log (harmless here,
      // but the assertion proves the code path is entered).
      await sleep(WATCH_SETTLE_MS);

      // Reaching this line without a crash or process handle leak is the
      // assertion. Node's test runner will flag leaked intervals/timeouts.
      expect(true).toBe(true);
    }, 10_000);
  },
);

// -----------------------------------------------------------------------------
// #188 — prerender regen signal
// -----------------------------------------------------------------------------

describe.skipIf(process.env.MANDU_SKIP_BUNDLER_TESTS === "1")(
  "Phase 7.0 R1 Agent A — #188 prerender regen signal",
  () => {
    let rootDir: string;
    let close: (() => void) | null = null;

    beforeEach(() => {
      rootDir = createTempProject();
      // Pretend a previous `mandu build` produced static HTML.
      mkdirSync(path.join(rootDir, ".mandu/static"), { recursive: true });
      writeFileSync(
        path.join(rootDir, ".mandu/static/index.html"),
        "<html><body>old</body></html>",
      );
    });

    afterEach(() => {
      close?.();
      close = null;
      try {
        rmSync(rootDir, { recursive: true, force: true });
      } catch {
        /* Windows may hold locks; cleanup is best-effort. */
      }
    });

    it("common-dir change in pure-SSR project fires SSR_CHANGE_WILDCARD", async () => {
      // Pure-SSR project = routes array may be empty at the bundler level;
      // the `onSSRChange(SSR_CHANGE_WILDCARD)` firing is what CLI-level
      // handleSSRChange consumes to trigger `regeneratePrerenderedStatics`.
      const wildcardFires: string[] = [];
      const bundler = await startDevBundler({
        rootDir,
        manifest: emptyManifest(),
        onSSRChange: (filePath) => {
          wildcardFires.push(filePath);
        },
      });
      close = bundler.close;

      // Settle the recursive fs.watch initialization — Windows ReadDirectoryChangesW
      // can drop events that arrive within the first ~100ms of a new watcher.
      await sleep(300);

      // Edit a shared file that (in the real issue report) feeds into the
      // pure-SSR page's rendered HTML. Use the retry helper since Windows
      // fs.watch can silently drop the first event on a freshly-armed
      // watcher — we still assert the observable outcome.
      await touchUntilSeen(
        path.join(rootDir, "src/shared/foo.ts"),
        () => wildcardFires.length,
      );

      // This is the contract Agent A's CLI-side #188 fix consumes: the
      // wildcard signal MUST fire for common-dir changes, otherwise
      // `regeneratePrerenderedStatics` would never get a chance to run.
      expect(wildcardFires).toContain(SSR_CHANGE_WILDCARD);
    }, 15_000);

    it("hydration:none manifest still triggers onSSRChange wildcard", async () => {
      // Simulates the `demo/auth-starter` "island-less" shape — every
      // route is pure SSR, no clientModule anywhere.
      //
      // Create the app/ tree on-disk so the watchers can actually attach —
      // missing dirs would be skipped, and the resulting flaky timing has
      // nothing to do with the SUT (B1/B2/B6).
      mkdirSync(path.join(rootDir, "app/[lang]"), { recursive: true });
      writeFileSync(path.join(rootDir, "app/page.tsx"), "export default () => null;\n");
      writeFileSync(
        path.join(rootDir, "app/[lang]/page.tsx"),
        "export default () => null;\n",
      );

      const manifest: RoutesManifest = {
        version: 1,
        routes: [
          {
            id: "root",
            kind: "page",
            pattern: "/",
            module: "app/page.tsx",
            componentModule: "app/page.tsx",
            // no clientModule, no hydration → pure SSR
          },
          {
            id: "lang",
            kind: "page",
            pattern: "/ko",
            module: "app/[lang]/page.tsx",
            componentModule: "app/[lang]/page.tsx",
            hydration: { strategy: "none" } as RoutesManifest["routes"][number]["hydration"],
          },
        ],
      } as unknown as RoutesManifest;

      const wildcardFires: string[] = [];
      const bundler = await startDevBundler({
        rootDir,
        manifest,
        onSSRChange: (filePath) => {
          wildcardFires.push(filePath);
        },
      });
      close = bundler.close;

      // Give the multi-watcher setup extra time on Windows — with 3 dirs
      // to arm, the 200 ms baseline used elsewhere isn't always enough.
      await sleep(400);

      // Retry writeFile if the first event is dropped (Windows flake).
      await touchUntilSeen(
        path.join(rootDir, "src/shared/foo.ts"),
        () => wildcardFires.length,
      );

      expect(wildcardFires).toContain(SSR_CHANGE_WILDCARD);
    }, 15_000);
  },
);

// -----------------------------------------------------------------------------
// B4 — perf marker wiring (smoke test via MANDU_PERF=1 stdout capture)
// -----------------------------------------------------------------------------

describe("Phase 7.0 R1 Agent A — B4 perf marker names exported", () => {
  it("HMR_PERF exposes all four SSR-reload-chain marker names", async () => {
    // Prove the CLI-side `handleSSRChange` has the exact markers available
    // that Agent F's benchmark will grep. If a rename broke the contract
    // this test fails at compile time via the string-literal assertions.
    const { HMR_PERF } = await import("../../perf/hmr-markers");
    expect(HMR_PERF.SSR_HANDLER_RELOAD).toBe("ssr:handler-reload");
    expect(HMR_PERF.SSR_CLEAR_REGISTRY).toBe("ssr:clear-registry");
    expect(HMR_PERF.SSR_REGISTER_HANDLERS).toBe("ssr:register-handlers");
    expect(HMR_PERF.HMR_BROADCAST).toBe("hmr:broadcast");
    expect(HMR_PERF.PRERENDER_REGEN).toBe("prerender:regen");
  });
});