summaryrefslogtreecommitdiff
path: root/app/middleware/user_parser.go
diff options
context:
space:
mode:
Diffstat (limited to 'app/middleware/user_parser.go')
-rw-r--r--app/middleware/user_parser.go28
1 files changed, 4 insertions, 24 deletions
diff --git a/app/middleware/user_parser.go b/app/middleware/user_parser.go
index cd6f36f..dfa0cce 100644
--- a/app/middleware/user_parser.go
+++ b/app/middleware/user_parser.go
@@ -3,34 +3,14 @@ package middleware
import (
"net/http"
- "github.com/coreos/go-oidc/v3/oidc"
+ "github.com/xlgmokha/x/pkg/log"
"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] {
+func UserParser() 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
+ log.WithFields(r.Context(), log.Fields{"header": r.Header})
+ return mapper.MapFrom[http.Header, *domain.User](r.Header)
}
}