peter/ekster
1
0
Fork 0
Code Issues 3 Pull Requests Projects 3 Releases 1 Wiki Activity

Get the cached value from Redis

Browse Source
This commit is contained in:
Peter Stuifzand 2018-09-15 16:04:50 +02:00
parent 3c9f7eae47
commit 7361b524e8
Signed by: peter
GPG Key ID: 374322D56E5209E8
1 changed files with 13 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
cmd/eksterd/auth.go
View File

@ -43,14 +43,10 @@ func (b *memoryBackend) cachedCheckAuthToken(conn redis.Conn, header string, r *
var err error var err error
values, err := redis.Values(conn.Do("HGETALL", key)) areweauth, err := getCachedValue(err, conn, key, r)
if err == nil && len(values) > 0 { if areweauth {
if err = redis.ScanStruct(values, r); err == nil {
return true return true
} }
} else {
log.Printf("Error while HGETALL %v\n", err)
}
authorized := b.checkAuthToken(header, r) authorized := b.checkAuthToken(header, r)
if authorized { if authorized {
@ -75,6 +71,16 @@ func (b *memoryBackend) cachedCheckAuthToken(conn redis.Conn, header string, r *
return authorized return authorized
} }
func getCachedValue(err error, 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")