docker-entrypoint.js

#!/usr/bin/env node
/* eslint-disable @typescript-eslint/no-require-imports */

const Database = require("better-sqlite3");
const fs = require("fs");
const path = require("path");
const { spawn } = require("child_process");

const dbPath = process.env.DATABASE_URL?.replace("file:", "") || "./data/sparqi.db";
const dbDir = path.dirname(dbPath);
const migrationsDir = "./drizzle";

// Ensure data directory exists
if (!fs.existsSync(dbDir)) {
  fs.mkdirSync(dbDir, { recursive: true });
  console.log(`Created data directory: ${dbDir}`);
}

// Run migrations
console.log("Running database migrations...");

const db = new Database(dbPath);

// Create migrations tracking table if it doesn't exist
db.exec(`
  CREATE TABLE IF NOT EXISTS __drizzle_migrations (
    id INTEGER PRIMARY KEY,
    hash TEXT NOT NULL,
    created_at INTEGER
  )
`);

// Get applied migrations
const applied = new Set(
  db.prepare("SELECT hash FROM __drizzle_migrations").all().map((r) => r.hash)
);

// Get migration files
const migrationFiles = fs
  .readdirSync(migrationsDir)
  .filter((f) => f.endsWith(".sql"))
  .sort();

// Apply pending migrations
for (const file of migrationFiles) {
  if (applied.has(file)) {
    console.log(`  Skipping ${file} (already applied)`);
    continue;
  }

  const sql = fs.readFileSync(path.join(migrationsDir, file), "utf-8");
  console.log(`  Applying ${file}...`);

  try {
    db.exec(sql);
    db.prepare("INSERT INTO __drizzle_migrations (hash, created_at) VALUES (?, ?)").run(
      file,
      Date.now()
    );
  } catch (err) {
    // Handle case where tables/columns already exist (e.g., migrating from local dev)
    if (err.message.includes("already exists") || err.message.includes("duplicate column")) {
      console.log(`  Schema already up to date, marking ${file} as applied`);
      db.prepare("INSERT INTO __drizzle_migrations (hash, created_at) VALUES (?, ?)").run(
        file,
        Date.now()
      );
    } else {
      console.error(`  Failed to apply ${file}:`, err.message);
      process.exit(1);
    }
  }
}

db.close();
console.log("Migrations complete.");

// Start the Next.js server
console.log("Starting Next.js server...");
const server = spawn("node", ["server.js"], {
  stdio: "inherit",
  env: process.env,
});

server.on("close", (code) => {
  process.exit(code);
});