runner.go

package validations

import (
	"errors"
	"fmt"

	eksae "github.com/aws/eks-anywhere/pkg/errors"
)

var errRunnerValidation = errors.New("validations failed")

type Validation func() *ValidationResult

type Runner struct {
	validations []Validation
}

func NewRunner() *Runner {
	return &Runner{validations: make([]Validation, 0)}
}

func (r *Runner) Register(validations ...Validation) {
	r.validations = append(r.validations, validations...)
}

func (r *Runner) Run() error {
	var errs []error
	for _, v := range r.validations {
		result := v()
		result.Report()
		if result.Err != nil {
			errs = append(errs, result.Err)
		}
	}

	if len(errs) > 0 {
		return fmt.Errorf("validations failed: %w", eksae.NewAggregate(errs))
	}

	return nil
}