import assert from "node:assert/strict";
import { spawnSync } from "node:child_process";
import { mkdtempSync, readFileSync, rmSync, writeFileSync } from "node:fs";
import { createRequire } from "node:module";
import { tmpdir } from "node:os";
import { dirname, join } from "node:path";
import { fileURLToPath } from "node:url";
import test from "node:test";

const require = createRequire(import.meta.url);
test("offline race fixture slices satisfy the merged core public contract", () => {
  const source = readFileSync(new URL("../../forkhorse-core/src/workflow-types.ts", import.meta.url), "utf8");
  // StateSnapshot imports Worker internals for project/activity. Check the public
  // records before it in isolation, using the installed compiler and actual source.
  const boundary = source.indexOf("export interface StateSnapshot");
  assert.ok(boundary > 0, "Core public record declarations must precede StateSnapshot");
  const fixturePath = fileURLToPath(new URL("race-fixtures.ts", import.meta.url));
  const scratch = mkdtempSync(join(tmpdir(), "fh-race-contract-"));
  try {
    const contractPath = join(scratch, "contract.ts");
    writeFileSync(contractPath, `${source.slice(0, boundary)}
      import type { RaceFixture } from ${JSON.stringify(fixturePath)};
      declare const fixture: RaceFixture;
      const races: RaceState[] = fixture.races;
      const ledger: LedgerEntry[] = fixture.ledger;
      const reviews: (Review & { receipt: ReceiptSummary | null })[] = fixture.reviews;
    `);
    const compiler = join(dirname(require.resolve("typescript/package.json")), "bin/tsc");
    const typeRoots = fileURLToPath(new URL("../../../node_modules/@types", import.meta.url));
    const result = spawnSync(process.execPath, [compiler, "--ignoreConfig", "--noEmit",
      "--strict", "--skipLibCheck", "--allowImportingTsExtensions", "--module", "ESNext",
      "--moduleResolution", "bundler", "--target", "ESNext", "--types", "node",
      "--typeRoots", typeRoots, contractPath], { encoding: "utf8", timeout: 30000 });
    assert.equal(result.status, 0, result.error?.message ?? result.stdout + result.stderr);
  } finally {
    rmSync(scratch, { recursive: true, force: true });
  }
});