Function getMissingMigrations

migrate-db.ts:29–64

()

}

async function getMissingMigrations(): Promise<string[]> {
  const existingMigrations: Set<string> = new Set();

  for await (const migrationFile of migrationsDirectory) {
    // Skip non-files
    if (!migrationFile.isFile) {
      continue;
    }

    // Skip files not in the "001-blah.pgsql" format
    if (!migrationFile.name.match(/^\d+-.*(\.pgsql)$/)) {
      continue;
    }

    existingMigrations.add(migrationFile.name);
  }

  // Sort migrations
  const sortedExistingMigrations = [...existingMigrations].sort();

  // Add everything to run, by default
  const migrationsToExecute = new Set([...sortedExistingMigrations]);

  try {
    const executedMigrations = await getExecutedMigrations();

    // Remove any existing migrations that were executed, from the list of migrations to execute
    for (const executedMigration of executedMigrations) {
      migrationsToExecute.delete(executedMigration);
    }
  } catch (_error) {
    // The table likely doesn't exist, so run everything.
  }

  return Array.from(migrationsToExecute).sort();
}

async function runMigrations(missingMigrations: string[]): Promise<void> {
  for (const missingMigration of missingMigrations) {