migrator.ts

import * as path from "path";
import {promises as fs} from "fs";
import {Database} from "./app/database";
import {Kysely, Migrator, FileMigrationProvider, PostgresDialect} from "kysely";
import dotenv from "dotenv";
import {fileURLToPath} from "url";
import {dirname} from "path";
import pg from "pg";

const {Pool} = pg;

const __filename = fileURLToPath(import.meta.url);
const __dirname = dirname(__filename);

dotenv.config();

export const migrator = async () => {
	const db = new Kysely<Database>({
		dialect: new PostgresDialect({
			pool: new Pool({
				database: process.env.DATABASE_NAME,
				host: process.env.DATABASE_HOST,
				user: process.env.DATABASE_USER,
				port: Number(process.env.DATABASE_PORT),
				max: 10,
				password: process.env.DATABASE_PWD,
			}),
		}),
	});

	const migrator = new Migrator({
		db,
		provider: new FileMigrationProvider({
			fs,
			path,
			migrationFolder: path.join(__dirname, "./migrations"),
		}),
	});

	const {error, results} = await migrator.migrateToLatest();

	results?.forEach((it) => {
		if (it.status === "Success") {
			console.log(`migration "${it.migrationName}" was executed successfully`);
		} else if (it.status === "Error") {
			console.error(`failed to execute migration "${it.migrationName}"`);
		}
	});

	if (error) {
		console.error("failed to migrate");
		console.error(JSON.stringify(error, null, 4));
		process.exit(1);
	}

	await db.destroy();
};

migrator();