This commit is contained in:
parent
8d99527e45
commit
c17cd92268
|
@ -67,15 +67,11 @@ func (b *memoryBackend) checkAuthToken(header string, token *auth.TokenResponse)
|
||||||
|
|
||||||
tokenEndpoint := b.TokenEndpoint
|
tokenEndpoint := b.TokenEndpoint
|
||||||
|
|
||||||
req, err := http.NewRequest("GET", tokenEndpoint, nil)
|
req, err := buildValidateAuthTokenRequest(tokenEndpoint, header)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Println(err)
|
|
||||||
return false
|
return false
|
||||||
}
|
}
|
||||||
|
|
||||||
req.Header.Add("Authorization", header)
|
|
||||||
req.Header.Add("Accept", "application/json")
|
|
||||||
|
|
||||||
client := http.Client{}
|
client := http.Client{}
|
||||||
res, err := client.Do(req)
|
res, err := client.Do(req)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
@ -100,6 +96,13 @@ func (b *memoryBackend) checkAuthToken(header string, token *auth.TokenResponse)
|
||||||
return true
|
return true
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func buildValidateAuthTokenRequest(tokenEndpoint string, header string) (*http.Request, error) {
|
||||||
|
req, err := http.NewRequest("GET", tokenEndpoint, nil)
|
||||||
|
req.Header.Add("Authorization", header)
|
||||||
|
req.Header.Add("Accept", "application/json")
|
||||||
|
return req, err
|
||||||
|
}
|
||||||
|
|
||||||
// setCachedTokenResponseValue remembers the value of the auth token response in redis
|
// setCachedTokenResponseValue remembers the value of the auth token response in redis
|
||||||
func setCachedTokenResponseValue(conn redis.Conn, key string, r *auth.TokenResponse) error {
|
func setCachedTokenResponseValue(conn redis.Conn, key string, r *auth.TokenResponse) error {
|
||||||
_, err := conn.Do("HMSET", redis.Args{}.Add(key).AddFlat(r)...)
|
_, err := conn.Do("HMSET", redis.Args{}.Add(key).AddFlat(r)...)
|
||||||
|
|
Loading…
Reference in New Issue
Block a user