Function loadMigrations

server/src/db/migrate.ts:45–91

* Load all migration files

()

 * Load all migration files
 */
async function loadMigrations(): Promise<Migration[]> {
  const migrationsDir = path.join(__dirname, "migrations");
  const files = await fs.readdir(migrationsDir);

  const migrations: Migration[] = [];
  const errors: string[] = [];

  for (const file of files) {
    if (file.endsWith(".sql")) {
      const parsed = parseMigrationFilename(file);

      if (!parsed) {
        errors.push(
          `Invalid migration filename: ${file}. Expected format: NNN_description.sql (e.g., 001_initial.sql)`
        );
        continue;
      }

      const filePath = path.join(migrationsDir, file);
      const sql = await fs.readFile(filePath, "utf-8");

      migrations.push({
        filename: file,
        version: parsed.version,
        sql,
      });
    }
  }

  // Detect duplicate version numbers (concurrent PRs picking the same number)
  const seen = new Map<number, string>();
  for (const m of migrations) {
    const existing = seen.get(m.version);
    if (existing) {
      errors.push(
        `Duplicate migration version ${m.version}: ${existing} and ${m.filename}`
      );
    }
    seen.set(m.version, m.filename);
  }

  if (errors.length > 0) {
    throw new Error(`Migration filename validation failed:\n${errors.join("\n")}`);
  }

  return migrations.sort((a, b) => a.version - b.version);
}

/**
 * Create migrations tracking table