Function killMigrationAtPause

apps/local/src/db/v1-v2-migration.test.ts:776–832

(input: {
  readonly dbPath: string;
  readonly tenantId: string;
  readonly pauseAt: MigrationPausePoint;
})

};

const killMigrationAtPause = async (input: {
  readonly dbPath: string;
  readonly tenantId: string;
  readonly pauseAt: MigrationPausePoint;
}): Promise<void> => {
  const marker = join(workDir, `pause-${input.pauseAt}`);
  const code = `
    import { collectTables } from "@executor-js/api/server";
    import { migrateLocalV1ToV2IfNeeded } from "./src/db/v1-v2-migration.ts";
    await migrateLocalV1ToV2IfNeeded({
      sqlitePath: ${JSON.stringify(input.dbPath)},
      tables: collectTables(),
      namespace: "executor_local",
      tenantId: ${JSON.stringify(input.tenantId)},
    });
  `;
  const child = spawn(process.execPath, ["-e", code], {
    cwd: join(import.meta.dirname, "../.."),
    env: {
      ...process.env,
      NODE_ENV: "test",
      EXECUTOR_V1_V2_MIGRATION_PAUSE_AT: input.pauseAt,
      EXECUTOR_V1_V2_MIGRATION_PAUSE_FILE: marker,
    },
    stdio: "pipe",
  });
  child.unref();
  const output: ChildOutput = { stdout: "", stderr: "" };
  child.stdout.setEncoding("utf-8");
  child.stderr.setEncoding("utf-8");
  child.stdout.on("data", (chunk) => {
    output.stdout += chunk;
  });
  child.stderr.on("data", (chunk) => {
    output.stderr += chunk;
  });
  // oxlint-disable-next-line executor/no-try-catch-or-throw -- boundary: subprocess kill harness must clean up marker/child even when assertions fail
  try {
    const paused = await waitForPauseMarker(marker, child, output);
    if (!paused.markerFound) {
      child.kill("SIGKILL");
      await waitForChildExit(child);
    }
    expect(paused).toMatchObject({ markerFound: true, exitCode: null, signalCode: null });
    child.kill("SIGKILL");
    await waitForChildExit(child);
    expect(child.signalCode).toBe("SIGKILL");
  } finally {
    if (child.exitCode === null && child.signalCode === null) {
      child.kill("SIGKILL");
      await waitForChildExit(child);
    }
    child.stdout.destroy();
    child.stderr.destroy();
    rmSync(marker, { force: true });
  }
};