watch-finished-turbo/scripts/migrate.ts

#!/usr/bin/env tsx

import Database from "better-sqlite3";
import fs from "fs";
import path from "path";
import { MigrationRunner } from "../apps/service/src/migration-runner";

const args = process.argv.slice(2);
const command = args[0];

if (!command) {
  console.log("Usage: migrate <command>");
  console.log("Commands:");
  console.log("  up          - Apply all pending migrations");
  console.log("  create <name> - Create a new migration file");
  console.log("  status      - Show migration status");
  process.exit(1);
}

// Find project root
let projectRoot = process.cwd();
while (projectRoot !== path.dirname(projectRoot)) {
  if (fs.existsSync(path.join(projectRoot, "package.json"))) {
    try {
      const pkg = JSON.parse(
        fs.readFileSync(path.join(projectRoot, "package.json"), "utf-8")
      );
      if (pkg.name === "watch-finished-turbo") {
        break;
      }
    } catch (e) {
      // ignore
    }
  }
  projectRoot = path.dirname(projectRoot);
}

const dbPath = path.resolve(projectRoot, "data/database.db");
const migrationsDir = path.resolve(projectRoot, "data/migrations");

// Ensure directories exist
if (!fs.existsSync(path.dirname(dbPath))) {
  fs.mkdirSync(path.dirname(dbPath), { recursive: true });
}
if (!fs.existsSync(migrationsDir)) {
  fs.mkdirSync(migrationsDir, { recursive: true });
}

const db = new Database(dbPath);
const runner = new MigrationRunner(db, migrationsDir);

try {
  switch (command) {
    case "up":
      runner.applyPendingMigrations();
      break;

    case "create":
      const name = args[1];
      if (!name) {
        console.error("Migration name is required");
        process.exit(1);
      }
      runner.createMigration(name);
      break;

    case "status":
      runner.init();
      const applied = runner.getAppliedMigrations();
      const available = runner.getAvailableMigrations();
      const pending = available.filter((m) => !applied.includes(m));

      console.log("Migration Status:");
      console.log(`Applied: ${applied.length}`);
      console.log(`Available: ${available.length}`);
      console.log(`Pending: ${pending.length}`);

      if (pending.length > 0) {
        console.log("\nPending migrations:");
        pending.forEach((m) => console.log(`  - ${m}`));
      }
      break;

    default:
      console.error(`Unknown command: ${command}`);
      process.exit(1);
  }
} finally {
  db.close();
}