Function maybeAutoUpgradeRepository

cli/auto_upgrade.go:12–36

(ctx context.Context, r repo.Repository)

)

func maybeAutoUpgradeRepository(ctx context.Context, r repo.Repository) error {
	// only upgrade repository when it's directly connected, not via API.
	dr, _ := r.(repo.DirectRepository)
	if dr == nil {
		return nil
	}

	has, err := maintenance.HasParams(ctx, r)
	if err != nil {
		return errors.Wrap(err, "error looking for maintenance parameters")
	}

	if has {
		return nil
	}

	log(ctx).Debug("Setting default maintenance parameters...")

	//nolint:wrapcheck
	return repo.DirectWriteSession(ctx, dr, repo.WriteSessionOptions{
		Purpose: "setDefaultMaintenanceParameters",
	}, func(ctx context.Context, w repo.DirectRepositoryWriter) error {
		return setDefaultMaintenanceParameters(ctx, w)
	})
}

func setDefaultMaintenanceParameters(ctx context.Context, rep repo.RepositoryWriter) error {
	p := maintenance.DefaultParams()