import { readdir, readFile } from "fs/promises";
import { join } from "path";
import { neon } from "@neondatabase/serverless";
import postgres from "postgres";
import { config } from "../lib/config";
import { isNeonUrl } from "./index";
type Exec = (query: string, params?: unknown[]) => Promise<unknown>;
function splitMigrationStatements(content: string): string[] {
if (/-->\s*statement-breakpoint/.test(content)) {
return content
.split(/-->\s*statement-breakpoint/)
.map((s) =>
s
.split("\n")
.filter((line) => !line.trim().startsWith("--"))
.join("\n")
.trim()
)
.filter((s) => s.length > 0);
}
const stripped = content
.split("\n")
.filter((line) => !line.trim().startsWith("--"))
.join("\n");
return stripped
.split(/;\s*\n/)
.map((s) => s.trim().replace(/;\s*$/, "").trim())
.filter((s) => s.length > 0);
}
async function runMigrations() {
if (!config.databaseUrl) {
throw new Error("DATABASE_URL is not set");
}
let exec: Exec;
let cleanup: (() => Promise<void>) | null = null;
if (isNeonUrl(config.databaseUrl)) {
const neonSql = neon(config.databaseUrl);
exec = (q, p = []) => neonSql.query(q, p);
} else {
const client = postgres(config.databaseUrl, { max: 1, prepare: false });
exec = (q, p) =>
p && p.length > 0 ? client.unsafe(q, p as never[]) : client.unsafe(q);
cleanup = async () => {
await client.end({ timeout: 5 });
};
}
try {
await exec(`
CREATE TABLE IF NOT EXISTS "_migrations" (
"name" text PRIMARY KEY,
"applied_at" timestamp DEFAULT now() NOT NULL
)
`);
const appliedRows = (await exec(`SELECT name FROM _migrations`)) as Array<{
name: string;
}>;
const appliedSet = new Set(appliedRows.map((r) => r.name));
const migrationsDir = join(process.cwd(), "drizzle");
const files = (await readdir(migrationsDir))
.filter((f) => f.endsWith(".sql"))
.sort();
if (files.length === 0) {
console.log("No migration files found.");
return;
}
for (const file of files) {
if (appliedSet.has(file)) {
console.log(`[migrate] ${file} — already applied, skipping`);
continue;
}
console.log(`[migrate] applying ${file}...`);
const content = await readFile(join(migrationsDir, file), "utf8");
const statements = splitMigrationStatements(content);
for (const stripped of statements) {
try {
await exec(stripped);
} catch (err) {
const msg = err instanceof Error ? err.message : String(err);
if (
msg.includes("already exists") ||
msg.includes("duplicate_column") ||
msg.includes("duplicate_object")
) {
console.warn(
`[migrate] ${file}: ${msg.slice(0, 120)} (treated as applied)`
);
continue;
}
console.error(
`[migrate] ${file} failed on statement:\n${stripped.slice(0, 500)}\n\n${msg}`
);
throw err;
}
}
await exec(`INSERT INTO _migrations (name) VALUES ($1)`, [file]);
console.log(`[migrate] ${file} applied`);
}
console.log("[migrate] all migrations complete");
} finally {
if (cleanup) await cleanup();
}
}
runMigrations().catch((err) => {
console.error("Migration failed:", err);
process.exit(1);
});
|