Move function down
This commit is contained in:
parent
8792285eb4
commit
8d99527e45
|
|
@ -62,26 +62,6 @@ func (b *memoryBackend) cachedCheckAuthToken(conn redis.Conn, header string, r *
|
||||||
return authorized
|
return authorized
|
||||||
}
|
}
|
||||||
|
|
||||||
// setCachedTokenResponseValue remembers the value of the auth token response in redis
|
|
||||||
func setCachedTokenResponseValue(conn redis.Conn, key string, r *auth.TokenResponse) error {
|
|
||||||
_, err := conn.Do("HMSET", redis.Args{}.Add(key).AddFlat(r)...)
|
|
||||||
if err != nil {
|
|
||||||
return fmt.Errorf("error while setting token: %v", err)
|
|
||||||
}
|
|
||||||
conn.Do("EXPIRE", key, uint64(10*time.Minute/time.Second))
|
|
||||||
}
|
|
||||||
|
|
||||||
// getCachedValue gets the cached value from Redis
|
|
||||||
func getCachedValue(conn redis.Conn, key string, r *auth.TokenResponse) (bool, error) {
|
|
||||||
values, err := redis.Values(conn.Do("HGETALL", key))
|
|
||||||
if err == nil && len(values) > 0 {
|
|
||||||
if err = redis.ScanStruct(values, r); err == nil {
|
|
||||||
return true, nil
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return false, fmt.Errorf("error while getting value from backend: %v", err)
|
|
||||||
}
|
|
||||||
|
|
||||||
func (b *memoryBackend) checkAuthToken(header string, token *auth.TokenResponse) bool {
|
func (b *memoryBackend) checkAuthToken(header string, token *auth.TokenResponse) bool {
|
||||||
log.Println("Checking auth token")
|
log.Println("Checking auth token")
|
||||||
|
|
||||||
|
|
@ -119,3 +99,23 @@ func (b *memoryBackend) checkAuthToken(header string, token *auth.TokenResponse)
|
||||||
log.Println("Auth Token: Success")
|
log.Println("Auth Token: Success")
|
||||||
return true
|
return true
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// setCachedTokenResponseValue remembers the value of the auth token response in redis
|
||||||
|
func setCachedTokenResponseValue(conn redis.Conn, key string, r *auth.TokenResponse) error {
|
||||||
|
_, err := conn.Do("HMSET", redis.Args{}.Add(key).AddFlat(r)...)
|
||||||
|
if err != nil {
|
||||||
|
return fmt.Errorf("error while setting token: %v", err)
|
||||||
|
}
|
||||||
|
conn.Do("EXPIRE", key, uint64(10*time.Minute/time.Second))
|
||||||
|
}
|
||||||
|
|
||||||
|
// getCachedValue gets the cached value from Redis
|
||||||
|
func getCachedValue(conn redis.Conn, key string, r *auth.TokenResponse) (bool, error) {
|
||||||
|
values, err := redis.Values(conn.Do("HGETALL", key))
|
||||||
|
if err == nil && len(values) > 0 {
|
||||||
|
if err = redis.ScanStruct(values, r); err == nil {
|
||||||
|
return true, nil
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return false, fmt.Errorf("error while getting value from backend: %v", err)
|
||||||
|
}
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue
Block a user