import pg from "pg";
import { runMigrations } from "./migrationLib.mjs";

const databaseUrl = process.env.DATABASE_URL;
if (!databaseUrl) {
  console.error("DATABASE_URL is required");
  process.exit(1);
}

const pool = new pg.Pool({ connectionString: databaseUrl });
const migrationsDir = process.env.MIKE_MIGRATIONS_DIR;
const allowMockAuthBootstrap =
  process.env.MIKE_ALLOW_MOCK_AUTH_BOOTSTRAP === "1";

try {
  const result = await runMigrations(
    pool,
    {
      ...(migrationsDir ? { migrationsDir } : {}),
      allowMockAuthBootstrap,
    },
  );
  if (result.applied.length === 0) {
    console.log("No pending migrations");
  } else {
    console.log(`Applied migrations: ${result.applied.join(", ")}`);
  }
} catch (error) {
  console.error(error instanceof Error ? error.message : error);
  process.exitCode = 1;
} finally {
  await pool.end();
}

if (process.exitCode) {
  process.exit(process.exitCode);
}