feat: return oidc.Error in case of call token failure

This commit is contained in:
Celian GARCIA 2024-03-14 18:07:07 +01:00
parent 4d63d68c9e
commit e7f5de82c0
2 changed files with 11 additions and 19 deletions

View file

@ -2,7 +2,6 @@ package client
import ( import (
"context" "context"
"encoding/json"
"errors" "errors"
"fmt" "fmt"
"io" "io"
@ -251,25 +250,11 @@ func CallDeviceAccessTokenEndpoint(ctx context.Context, request *DeviceAccessTok
req.SetBasicAuth(request.ClientID, request.ClientSecret) req.SetBasicAuth(request.ClientID, request.ClientSecret)
} }
httpResp, err := caller.HttpClient().Do(req) resp := new(oidc.AccessTokenResponse)
if err != nil { if err := httphelper.HttpRequest(caller.HttpClient(), req, &resp); err != nil {
return nil, err return nil, err
} }
defer httpResp.Body.Close() return resp, nil
resp := new(struct {
*oidc.AccessTokenResponse
*oidc.Error
})
if err = json.NewDecoder(httpResp.Body).Decode(resp); err != nil {
return nil, err
}
if httpResp.StatusCode == http.StatusOK {
return resp.AccessTokenResponse, nil
}
return nil, resp.Error
} }
func PollDeviceAccessTokenEndpoint(ctx context.Context, interval time.Duration, request *DeviceAccessTokenRequest, caller TokenEndpointCaller) (*oidc.AccessTokenResponse, error) { func PollDeviceAccessTokenEndpoint(ctx context.Context, interval time.Duration, request *DeviceAccessTokenRequest, caller TokenEndpointCaller) (*oidc.AccessTokenResponse, error) {

View file

@ -10,6 +10,8 @@ import (
"net/url" "net/url"
"strings" "strings"
"time" "time"
"github.com/zitadel/oidc/v3/pkg/oidc"
) )
var DefaultHTTPClient = &http.Client{ var DefaultHTTPClient = &http.Client{
@ -66,7 +68,12 @@ func HttpRequest(client *http.Client, req *http.Request, response any) error {
} }
if resp.StatusCode != http.StatusOK { if resp.StatusCode != http.StatusOK {
return fmt.Errorf("http status not ok: %s %s", resp.Status, body) var oidcErr oidc.Error
err = json.Unmarshal(body, &oidcErr)
if err != nil || oidcErr.ErrorType == "" {
return fmt.Errorf("http status not ok: %s %s", resp.Status, body)
}
return &oidcErr
} }
err = json.Unmarshal(body, response) err = json.Unmarshal(body, response)