package middleware

import (
	"net/http"

	"github.com/coreos/go-oidc/v3/oidc"
	"github.com/xlgmokha/x/pkg/mapper"
	"github.com/xlgmokha/x/pkg/x"
	"gitlab.com/gitlab-org/software-supply-chain-security/authorization/sparkled/app/cfg"
	"gitlab.com/gitlab-org/software-supply-chain-security/authorization/sparkled/app/domain"
	"gitlab.com/gitlab-org/software-supply-chain-security/authorization/sparkled/pkg/pls"
)

func UserParser(db domain.Repository[*domain.User]) RequestParser[*domain.User] {
	return func(r *http.Request) *domain.User {
		subject := r.Header.Get("x-jwt-claim-sub")
		user := db.Find(r.Context(), domain.ID(subject))

		if !x.IsPresent(user) {
			idToken := cfg.IDToken.From(r.Context())

			if x.IsZero(idToken) {
				return nil
			}

			user = db.Find(r.Context(), domain.ID(idToken.Subject))
			if !x.IsPresent(user) {
				user = mapper.MapFrom[*oidc.IDToken, *domain.User](idToken)
				if err := db.Save(r.Context(), user); err != nil {
					pls.LogError(r.Context(), err)
				}
			}
		}
		return user
	}
}