pretecno/crowdsec-bouncer-traefik-plugin
3
0
Fork 0
mirror of https://github.com/maxlerebourg/crowdsec-bouncer-traefik-plugin.git synced 2026-09-03 04:28:52 +02:00
Code Issues Packages Releases Activity

🍱 fix logic

Browse Source
This commit is contained in:
maxlerebourg
2026-07-25 15:35:08 +02:00
parent ad7596ff85
commit 6958432a7c
1 changed files with 8 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/cache/cache.go
Vendored
+2 -9
View File
@@ -65,14 +65,14 @@ func (rc *redisCache) nextReader() *simpleredis.SimpleRedis {
return &rc.readers[idx] return &rc.readers[idx]
} }
func redisResultToString(value []byte, err error) (string, error) { func (rc *redisCache) get(key string) (string, error) {
value, err := rc.nextReader().Get(key)
if err == nil { if err == nil {
valueString := string(value) valueString := string(value)
if len(valueString) > 0 { if len(valueString) > 0 {
return valueString, nil return valueString, nil
} }
} }
if err != nil {
switch err.Error() { switch err.Error() {
case simpleredis.RedisMiss: case simpleredis.RedisMiss:
return "", errors.New(CacheMiss) return "", errors.New(CacheMiss)
@@ -81,13 +81,6 @@ func redisResultToString(value []byte, err error) (string, error) {
} }
return "", err return "", err
} }
return "", errors.New(CacheMiss)
}
func (rc *redisCache) get(key string) (string, error) {
value, err := rc.nextReader().Get(key)
return redisResultToString(value, err)
}
func (rc *redisCache) set(key, value string, duration int64) { func (rc *redisCache) set(key, value string, duration int64) {
if err := rc.writer.Set(key, []byte(value), duration); err != nil { if err := rc.writer.Set(key, []byte(value), duration); err != nil {