import postgres from "postgres";
import { createDatabaseClient, migrate } from "../src/client.ts";

const databaseUrl = process.env.DATABASE_URL;

if (!databaseUrl) {
  throw new Error("DATABASE_URL is required to run database migrations");
}

const sql = postgres(databaseUrl, { max: 1 });

try {
  await migrate(
    createDatabaseClient(async (statement) => {
      await sql.unsafe(statement);
    })
  );
  console.log("LinkedAt database migrations applied.");
} finally {
  await sql.end();
}