controllers/user/chain/chain.go

package chain

import (
	"context"
	"fmt"

	ctrl "sigs.k8s.io/controller-runtime"

	sonarApi "github.com/epam/edp-sonar-operator/api/v1alpha1"
)

type SonarUserHandler interface {
	ServeRequest(context.Context, *sonarApi.SonarUser) error
}

type chain struct {
	handlers []SonarUserHandler
}

func (ch *chain) Use(handlers ...SonarUserHandler) {
	ch.handlers = append(ch.handlers, handlers...)
}

func (ch *chain) ServeRequest(ctx context.Context, s *sonarApi.SonarUser) error {
	log := ctrl.LoggerFrom(ctx)
	log.Info("Starting SonarUser chain")

	for i := 0; i < len(ch.handlers); i++ {
		h := ch.handlers[i]

		err := h.ServeRequest(ctx, s)
		if err != nil {
			return fmt.Errorf("failed to serve handler: %w", err)
		}
	}

	log.Info("Handling of SonarUser has been finished")

	return nil
}