Function recoverDB

scripts/develop/dbrecovery.go:47–93

recoverDB checks for migration conflicts before the server starts. It connects to postgres on every run (embedded postgres starts fast enough that caching is unnecessary) and compares the tracking table against files on disk. Conflicts: - Tracked file missing from disk → needs --db-rollback or --db

(ctx context.Context, logger slog.Logger, cfg *devConfig)

//   - Tracked file content differs from disk → needs --db-continue or --db-reset.
//   - New files on disk not tracked → normal forward migration, server handles it.
func recoverDB(ctx context.Context, logger slog.Logger, cfg *devConfig) error {
	pgURL := os.Getenv("CODER_PG_CONNECTION_URL")
	isBuiltinPG := pgURL == ""

	if isBuiltinPG {
		pgDir := filepath.Join(cfg.configDir, "postgres")
		if _, err := os.Stat(filepath.Join(pgDir, "data")); err != nil {
			return nil // Fresh install.
		}
		if cfg.dbReset {
			logger.Warn(ctx, "wiping built-in database (--db-reset)")
			if err := os.RemoveAll(pgDir); err != nil {
				return xerrors.Errorf("remove postgres directory: %w", err)
			}
			return nil
		}
		stopPG, err := startTempPostgresSetURL(ctx, logger, cfg, &pgURL)
		if err != nil {
			return xerrors.Errorf(
				"cannot start temporary postgres: %w\n\ntry --db-reset instead", err)
		}
		defer stopPG()
	} else if cfg.dbReset {
		db, err := connectDB(ctx, pgURL)
		if err != nil {
			return xerrors.Errorf("connect for reset: %w", err)
		}
		defer db.Close()
		_, _ = fmt.Fprintf(os.Stderr,
			"\n  WARNING: this will DROP all schemas in the external database.\n"+
				"  Set CODER_DEV_DB_RESET=1 to confirm.\n\n")
		if os.Getenv("CODER_DEV_DB_RESET") != "1" {
			return xerrors.New("refusing to reset external database without CODER_DEV_DB_RESET=1")
		}
		logger.Warn(ctx, "resetting external database (--db-reset)")
		return resetSchema(ctx, db)
	}

	db, err := connectDB(ctx, pgURL)
	if err != nil {
		return xerrors.Errorf("connect: %w", err)
	}
	defer db.Close()

	migrDir := filepath.Join(cfg.projectRoot, "coderd", "database", "migrations")
	return checkAndRecover(ctx, logger, db, migrDir, cfg)
}

// checkAndRecover is the core logic:
//  1. Ensure tracking table exists.