Reactive-Resume/tests/e2e/fixtures/db.ts

import type { E2EAccount } from "./data";
import { Pool } from "pg";

export async function deleteE2EUser(account: E2EAccount) {
	const databaseUrl = process.env.DATABASE_URL;
	if (!databaseUrl) throw new Error("DATABASE_URL is required for E2E cleanup.");

	const pool = new Pool({ connectionString: databaseUrl });

	try {
		await pool.query('delete from "user" where email = $1 or username = $2', [account.email, account.username]);
	} finally {
		await pool.end();
	}
}