import { describe, expect, it } from "@effect/vitest";import { Effect } from "effect"; import {  runCodeMigrations,  type CodeMigration,  type CodeMigrationSql,} from "../../scripts/code-migrations/runner"; const makeFakeSql = (options: { readonly ledgerExists?: boolean; readonly stamped?: string[] }) => {  const log: { readonly query: string; readonly params?: readonly unknown[] }[] = [];  const stamped = [...(options.stamped ?? [])];  const sql: CodeMigrationSql = {    unsafe: (query, params) => {      log.push({ query, params });      if (query.includes("to_regclass")) {        const rows = [          { ledger_table: options.ledgerExists === false ? null : "cloud_code_migration" },        ];        return Promise.resolve(rows as never);      }      if (query.includes('SELECT "name" FROM "cloud_code_migration"')) {        return Promise.resolve(stamped.map((name) => ({ name })) as never);      }      if (query.includes('INSERT INTO "cloud_code_migration"')) {        stamped.push(String(params?.[0]));      }      return Promise.resolve([] as never);    },  };  return { sql, log, stamped };}; const migrationSpy = (name: string): { migration: CodeMigration; calls: boolean[] } => {  const calls: boolean[] = [];  return {    calls,    migration: {      name,      run: async ({ dryRun }) => {        calls.push(dryRun);        return { summary: `${name} done` };      },    },  };}; describe("runCodeMigrations", () => {  it.effect("runs pending migrations and stamps them", () =>    Effect.promise(async () => {      const { sql, stamped } = makeFakeSql({});      const a = migrationSpy("2026-06-20-a");      const b = migrationSpy("2026-06-21-b");       const applied = await runCodeMigrations(sql, [a.migration, b.migration], { log: () => {} });       expect(applied).toEqual(["2026-06-20-a", "2026-06-21-b"]);      expect(a.calls).toEqual([false]);      expect(b.calls).toEqual([false]);      expect(stamped).toEqual(["2026-06-20-a", "2026-06-21-b"]);    }),  );   it.effect("dry run plans pending migrations without creating or stamping the ledger", () =>    Effect.promise(async () => {      const { sql, log, stamped } = makeFakeSql({ ledgerExists: false });      const migration = migrationSpy("2026-06-20-a");       const applied = await runCodeMigrations(sql, [migration.migration], {        dryRun: true,        log: () => {},      });       expect(applied).toEqual(["2026-06-20-a"]);      expect(migration.calls).toEqual([true]);      expect(stamped).toEqual([]);      expect(log.some((entry) => entry.query.includes("CREATE TABLE"))).toBe(false);      expect(log.some((entry) => entry.query.includes("INSERT INTO"))).toBe(false);    }),  );   it.effect("skips stamped migrations", () =>    Effect.promise(async () => {      const { sql } = makeFakeSql({ stamped: ["2026-06-20-a"] });      const a = migrationSpy("2026-06-20-a");      const b = migrationSpy("2026-06-21-b");       const applied = await runCodeMigrations(sql, [a.migration, b.migration], { log: () => {} });       expect(applied).toEqual(["2026-06-21-b"]);      expect(a.calls).toEqual([]);      expect(b.calls).toEqual([false]);    }),  );   it.effect("rejects duplicate names before touching the database", () =>    Effect.promise(async () => {      const { sql, log } = makeFakeSql({});      const a = migrationSpy("2026-06-20-a");       await expect(runCodeMigrations(sql, [a.migration, a.migration])).rejects.toThrow(        "Duplicate code migration name",      );      expect(log).toEqual([]);    }),  );});