tealfmbot / packages / database / migrate.ts

import { env } from "@tealfmbot/common/constants";
import { Kysely, Migrator, PostgresDialect, FileMigrationProvider } from "kysely";
import { run } from "kysely-migration-cli";
import fs from "node:fs/promises";
import path from "node:path";
import { Pool } from "pg";

import type { DB } from "./database.js";

async function migrateToLatest() {
  const migrationFolder = new URL("../migrations", import.meta.url).pathname;

  const db = new Kysely<DB>({
    dialect: new PostgresDialect({
      pool: new Pool({
        connectionString: env.DATABASE_URL,
      }),
    }),
  });

  const migrator = new Migrator({
    db,
    provider: new FileMigrationProvider({
      fs,
      path,
      migrationFolder,
    }),
  });

  // @ts-ignore fix later
  run(db, migrator, migrationFolder);
  await db.destroy();
}

migrateToLatest().catch((err) => console.error(err));