Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
server: take in context as parameter to error handlers
Contexts are frequently used to store request-specific metadata, such as
logging, metrics and tracing information. Error handlers configured by
the user are much more useful if they have this information available.
  • Loading branch information
torkelrogstad committed Oct 24, 2025
commit ef3f510dbfa28b5460c3595fef8711a7294f19e1
4 changes: 2 additions & 2 deletions example/server/server.go
Original file line number Diff line number Diff line change
Expand Up @@ -75,12 +75,12 @@ func main() {

srv.SetUserAuthorizationHandler(userAuthorizeHandler)

srv.SetInternalErrorHandler(func(err error) (re *errors.Response) {
srv.SetInternalErrorHandler(func(ctx context.Context, err error) (re *errors.Response) {
log.Println("Internal Error:", err.Error())
return
})

srv.SetResponseErrorHandler(func(re *errors.Response) {
srv.SetResponseErrorHandler(func(ctx context.Context, re *errors.Response) {
log.Println("Response Error:", re.Error.Error())
})

Expand Down
6 changes: 3 additions & 3 deletions server/handler.go
Original file line number Diff line number Diff line change
Expand Up @@ -33,13 +33,13 @@ type (
RefreshingValidationHandler func(ti oauth2.TokenInfo) (allowed bool, err error)

// ResponseErrorHandler response error handing
ResponseErrorHandler func(re *errors.Response)
ResponseErrorHandler func(ctx context.Context, re *errors.Response)

// InternalErrorHandler internal error handing
InternalErrorHandler func(err error) (re *errors.Response)
InternalErrorHandler func(ctx context.Context, err error) (re *errors.Response)

// PreRedirectErrorHandler is used to override "redirect-on-error" behavior
PreRedirectErrorHandler func(w http.ResponseWriter, req *AuthorizeRequest, err error) error
PreRedirectErrorHandler func(ctx context.Context, w http.ResponseWriter, req *AuthorizeRequest, err error) error

// AuthorizeScopeHandler set the authorized scope
AuthorizeScopeHandler func(w http.ResponseWriter, r *http.Request) (scope string, err error)
Expand Down
18 changes: 9 additions & 9 deletions server/server.go
Original file line number Diff line number Diff line change
Expand Up @@ -63,7 +63,7 @@ type Server struct {

func (s *Server) handleError(w http.ResponseWriter, req *AuthorizeRequest, err error) error {
if fn := s.PreRedirectErrorHandler; fn != nil {
return fn(w, req, err)
return fn(req.Request.Context(), w, req, err)
}

return s.redirectError(w, req, err)
Expand All @@ -74,7 +74,7 @@ func (s *Server) redirectError(w http.ResponseWriter, req *AuthorizeRequest, err
return err
}

data, _, _ := s.GetErrorData(err)
data, _, _ := s.GetErrorData(req.Request.Context(), err)
return s.redirect(w, req, data)
}

Expand All @@ -89,8 +89,8 @@ func (s *Server) redirect(w http.ResponseWriter, req *AuthorizeRequest, data map
return nil
}

func (s *Server) tokenError(w http.ResponseWriter, err error) error {
data, statusCode, header := s.GetErrorData(err)
func (s *Server) tokenError(ctx context.Context, w http.ResponseWriter, err error) error {
data, statusCode, header := s.GetErrorData(ctx, err)
return s.token(w, data, header, statusCode)
}

Expand Down Expand Up @@ -511,27 +511,27 @@ func (s *Server) HandleTokenRequest(w http.ResponseWriter, r *http.Request) erro

gt, tgr, err := s.ValidationTokenRequest(r)
if err != nil {
return s.tokenError(w, err)
return s.tokenError(ctx, w, err)
}

ti, err := s.GetAccessToken(ctx, gt, tgr)
if err != nil {
return s.tokenError(w, err)
return s.tokenError(ctx, w, err)
}

return s.token(w, s.GetTokenData(ti), nil)
}

// GetErrorData get error response data
func (s *Server) GetErrorData(err error) (map[string]interface{}, int, http.Header) {
func (s *Server) GetErrorData(ctx context.Context, err error) (map[string]interface{}, int, http.Header) {
var re errors.Response
if v, ok := errors.Descriptions[err]; ok {
re.Error = err
re.Description = v
re.StatusCode = errors.StatusCodes[err]
} else {
if fn := s.InternalErrorHandler; fn != nil {
if v := fn(err); v != nil {
if v := fn(ctx, err); v != nil {
re = *v
}
}
Expand All @@ -544,7 +544,7 @@ func (s *Server) GetErrorData(err error) (map[string]interface{}, int, http.Head
}

if fn := s.ResponseErrorHandler; fn != nil {
fn(&re)
fn(ctx, &re)
}

data := make(map[string]interface{})
Expand Down
4 changes: 2 additions & 2 deletions server/server_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -296,12 +296,12 @@ func TestClientCredentials(t *testing.T) {
srv = server.NewDefaultServer(manager)
srv.SetClientInfoHandler(server.ClientFormHandler)

srv.SetInternalErrorHandler(func(err error) (re *errors.Response) {
srv.SetInternalErrorHandler(func(ctx context.Context, err error) (re *errors.Response) {
t.Log("OAuth 2.0 Error:", err.Error())
return
})

srv.SetResponseErrorHandler(func(re *errors.Response) {
srv.SetResponseErrorHandler(func(ctx context.Context, re *errors.Response) {
t.Log("Response Error:", re.Error)
})

Expand Down