mirror of
https://github.com/moby/moby.git
synced 2026-01-11 18:51:37 +00:00
1a12717766
x/oauth2: populate RetrieveError from DeviceAuth Endpoints may return errors when attempting to request device authorization. Currently, these error codes are ignored and an otherwise empty RetrieveError returned. This change populates the RetrieveError similar to the oauth2 token exchange. full diff: https://github.com/golang/oauth2/compare/v0.30.0...v0.34.0 Signed-off-by: Sebastiaan van Stijn <github@gone.nl>
76 lines
1.9 KiB
Go
76 lines
1.9 KiB
Go
// Copyright 2014 The Go Authors. All rights reserved.
|
|
// Use of this source code is governed by a BSD-style
|
|
// license that can be found in the LICENSE file.
|
|
|
|
package oauth2
|
|
|
|
import (
|
|
"errors"
|
|
"log"
|
|
"net/http"
|
|
"sync"
|
|
)
|
|
|
|
// Transport is an [http.RoundTripper] that makes OAuth 2.0 HTTP requests,
|
|
// wrapping a base [http.RoundTripper] and adding an Authorization header
|
|
// with a token from the supplied [TokenSource].
|
|
//
|
|
// Transport is a low-level mechanism. Most code will use the
|
|
// higher-level [Config.Client] method instead.
|
|
type Transport struct {
|
|
// Source supplies the token to add to outgoing requests'
|
|
// Authorization headers.
|
|
Source TokenSource
|
|
|
|
// Base is the base RoundTripper used to make HTTP requests.
|
|
// If nil, http.DefaultTransport is used.
|
|
Base http.RoundTripper
|
|
}
|
|
|
|
// RoundTrip authorizes and authenticates the request with an
|
|
// access token from Transport's Source.
|
|
func (t *Transport) RoundTrip(req *http.Request) (*http.Response, error) {
|
|
reqBodyClosed := false
|
|
if req.Body != nil {
|
|
defer func() {
|
|
if !reqBodyClosed {
|
|
req.Body.Close()
|
|
}
|
|
}()
|
|
}
|
|
|
|
if t.Source == nil {
|
|
return nil, errors.New("oauth2: Transport's Source is nil")
|
|
}
|
|
token, err := t.Source.Token()
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
req2 := req.Clone(req.Context())
|
|
token.SetAuthHeader(req2)
|
|
|
|
// req.Body is assumed to be closed by the base RoundTripper.
|
|
reqBodyClosed = true
|
|
return t.base().RoundTrip(req2)
|
|
}
|
|
|
|
var cancelOnce sync.Once
|
|
|
|
// CancelRequest does nothing. It used to be a legacy cancellation mechanism
|
|
// but now only logs on first use to warn that it's deprecated.
|
|
//
|
|
// Deprecated: use contexts for cancellation instead.
|
|
func (t *Transport) CancelRequest(req *http.Request) {
|
|
cancelOnce.Do(func() {
|
|
log.Printf("deprecated: golang.org/x/oauth2: Transport.CancelRequest no longer does anything; use contexts")
|
|
})
|
|
}
|
|
|
|
func (t *Transport) base() http.RoundTripper {
|
|
if t.Base != nil {
|
|
return t.Base
|
|
}
|
|
return http.DefaultTransport
|
|
}
|