Function Run

server-source-code/internal/migrate/migrate.go:24–61

Run applies all pending migrations using embedded SQL files. Logs to the provided logger and always prints migration status to stdout. Returns an error if migrations fail. ErrNoChange is treated as success (already up to date).

(databaseURL string, log *slog.Logger)

// Returns an error if migrations fail.
// ErrNoChange is treated as success (already up to date).
func Run(databaseURL string, log *slog.Logger) error {
	if databaseURL == "" {
		return fmt.Errorf("DATABASE_URL is required for migrations")
	}

	databaseURL = ensureSSLMode(databaseURL)

	_, _ = fmt.Fprintln(os.Stdout, "[migrate] running migrations from embedded binary")
	log.Info("running migrations", "path", "embedded")

	source, err := iofs.New(migrationsFS, "migrations")
	if err != nil {
		return fmt.Errorf("create embedded migrate source: %w", err)
	}

	m, err := migrate.NewWithSourceInstance("iofs", source, databaseURL)
	if err != nil {
		return fmt.Errorf("create migrate instance: %w", err)
	}
	defer func() { _, _ = m.Close() }()

	if err := m.Up(); err != nil && err != migrate.ErrNoChange {
		fmt.Fprintf(os.Stderr, "[migrate] failed: %v\n", err)
		return fmt.Errorf("migration up: %w", err)
	}

	if err == migrate.ErrNoChange {
		_, _ = fmt.Fprintln(os.Stdout, "[migrate] already up to date")
		log.Info("migrations: already up to date")
		return nil
	}

	version, _, _ := m.Version()
	msg := fmt.Sprintf("[migrate] applied successfully (version %d)", version)
	_, _ = fmt.Fprintln(os.Stdout, msg)
	log.Info("migrations applied successfully", "version", version)
	return nil
}

// Open returns a migrate instance using embedded migrations, for use by the CLI (up/down/force/version).
// Caller must call m.Close() when done.