forked from Mirrors/oauth2
54 lines
1.1 KiB
Go
54 lines
1.1 KiB
Go
package oauth2
|
|
|
|
import (
|
|
"net/http"
|
|
"net/http/httptest"
|
|
"testing"
|
|
"time"
|
|
)
|
|
|
|
type tokenSource struct{ token *Token }
|
|
|
|
func (t *tokenSource) Token() (*Token, error) {
|
|
return t.token, nil
|
|
}
|
|
|
|
func TestTransportTokenSource(t *testing.T) {
|
|
ts := &tokenSource{
|
|
token: &Token{
|
|
AccessToken: "abc",
|
|
},
|
|
}
|
|
tr := &Transport{
|
|
Source: ts,
|
|
}
|
|
server := newMockServer(func(w http.ResponseWriter, r *http.Request) {
|
|
if r.Header.Get("Authorization") != "Bearer abc" {
|
|
t.Errorf("Transport doesn't set the Authorization header from the fetched token")
|
|
}
|
|
})
|
|
defer server.Close()
|
|
client := http.Client{Transport: tr}
|
|
client.Get(server.URL)
|
|
}
|
|
|
|
func TestTokenValidNoAccessToken(t *testing.T) {
|
|
token := &Token{}
|
|
if token.Valid() {
|
|
t.Errorf("Token should not be valid with no access token")
|
|
}
|
|
}
|
|
|
|
func TestExpiredWithExpiry(t *testing.T) {
|
|
token := &Token{
|
|
Expiry: time.Now().Add(-5 * time.Hour),
|
|
}
|
|
if token.Valid() {
|
|
t.Errorf("Token should not be valid if it expired in the past")
|
|
}
|
|
}
|
|
|
|
func newMockServer(handler func(w http.ResponseWriter, r *http.Request)) *httptest.Server {
|
|
return httptest.NewServer(http.HandlerFunc(handler))
|
|
}
|