From f76542bc846bc77e825055a1a6ea7cd0cb178844 Mon Sep 17 00:00:00 2001 From: mo khan Date: Wed, 28 May 2025 10:38:24 -0600 Subject: refactor: extract type to parse user from http.Request --- app/middleware/user_parser.go | 36 ++++++++++++++++++++++++++++++++++++ 1 file changed, 36 insertions(+) create mode 100644 app/middleware/user_parser.go (limited to 'app/middleware/user_parser.go') diff --git a/app/middleware/user_parser.go b/app/middleware/user_parser.go new file mode 100644 index 0000000..cd6f36f --- /dev/null +++ b/app/middleware/user_parser.go @@ -0,0 +1,36 @@ +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 + } +} -- cgit v1.2.3