/* oxlint-disable executor/no-error-constructor, executor/no-try-catch-or-throw -- test fake models missing R2 objects */ import { writeFileSync, readFileSync } from "node:fs"; import { describe, expect, it } from "@effect/vitest";import { Effect } from "effect"; import {  googleOpenApiR2BlobMigration,  type R2ObjectStore,} from "../../scripts/code-migrations/google-openapi-r2-blobs";import type { CodeMigrationContext, CodeMigrationSql } from "../../scripts/code-migrations/runner"; interface GoogleRow {  readonly tenant: string;  readonly slug: string;  readonly plugin_id: string;  readonly spec_hash: string;} const sourceKey = (row: GoogleRow): string => `o:${row.tenant}/openapi/spec/${row.spec_hash}`;const targetKey = (row: GoogleRow): string => `o:${row.tenant}/google/spec/${row.spec_hash}`; const makeSql = (rows: readonly GoogleRow[]): CodeMigrationSql => ({  unsafe: () => Promise.resolve(rows as never),}); const makeStore = (  objects: Record<string, string>,): { readonly store: R2ObjectStore; readonly objects: Map<string, Buffer> } => {  const objectMap = new Map<string, Buffer>(    Object.entries(objects).map(([key, value]) => [key, Buffer.from(value, "utf8")] as const),  );  return {    objects: objectMap,    store: {      exists: (key) => objectMap.has(key),      get: (key, file) => {        const value = objectMap.get(key);        if (!value) throw new Error(`missing ${key}`);        writeFileSync(file, value);      },      put: (key, file) => {        objectMap.set(key, readFileSync(file));      },    },  };}; const runMigration = async (input: {  readonly dryRun: boolean;  readonly rows: readonly GoogleRow[];  readonly objects: Record<string, string>;}) => {  const { store, objects } = makeStore(input.objects);  const migration = googleOpenApiR2BlobMigration({ bucket: "executor-cloud-blobs", store });  const context: CodeMigrationContext = {    sql: makeSql(input.rows),    dryRun: input.dryRun,    log: () => {},  };  return { result: await migration.run(context), objects };}; describe("googleOpenApiR2BlobMigration", () => {  it.effect("dry run reports source and target R2 coverage without copying", () =>    Effect.promise(async () => {      const rows = [        { tenant: "org_1", slug: "google", plugin_id: "openapi", spec_hash: "hash-a" },        { tenant: "org_2", slug: "google", plugin_id: "openapi", spec_hash: "hash-b" },      ];      const { result, objects } = await runMigration({        dryRun: true,        rows,        objects: {          [sourceKey(rows[0]!)]: "spec-a",          [targetKey(rows[0]!)]: "spec-a",          [sourceKey(rows[1]!)]: "spec-b",        },      });       expect(result.summary).toContain("2/2 source R2 object(s) present");      expect(result.summary).toContain("1/2 target R2 object(s) already present");      expect(result.summary).toContain("would copy 1 object(s)");      expect(objects.has(targetKey(rows[1]!))).toBe(false);    }),  );   it.effect("apply copies missing target objects and leaves existing matches alone", () =>    Effect.promise(async () => {      const rows = [        { tenant: "org_1", slug: "google", plugin_id: "google", spec_hash: "hash-a" },        { tenant: "org_2", slug: "google", plugin_id: "google", spec_hash: "hash-b" },      ];      const { result, objects } = await runMigration({        dryRun: false,        rows,        objects: {          [sourceKey(rows[0]!)]: "spec-a",          [targetKey(rows[0]!)]: "spec-a",          [sourceKey(rows[1]!)]: "spec-b",        },      });       expect(result.summary).toContain("copied 1 R2 object(s)");      expect(objects.get(targetKey(rows[1]!))?.toString("utf8")).toBe("spec-b");    }),  );   it.effect("fails when a source object is missing", () =>    Effect.promise(async () => {      const rows = [{ tenant: "org_1", slug: "google", plugin_id: "openapi", spec_hash: "hash-a" }];       await expect(runMigration({ dryRun: true, rows, objects: {} })).rejects.toThrow(        "source object(s) missing",      );    }),  );});