🐛 Fix logic for update max failure

maxlerebourg · Apr 29, 2024 · 2fc152e · 2fc152e
1 parent fc41962
commit 2fc152e
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 2 deletions.
diff --git a/bouncer.go b/bouncer.go
@@ -360,11 +360,13 @@ func handleNextServeHTTP(bouncer *Bouncer, remoteIP string, rw http.ResponseWrit
 }
 
 func handleStreamTicker(bouncer *Bouncer) {
+	bouncer.log.Debug(fmt.Sprintf("handleStreamTicker:start isCrowdsecStreamHealthy:%t", isCrowdsecStreamHealthy))
 	if err := handleStreamCache(bouncer); err != nil {
-		updateFailure++
-		if updateFailure >= bouncer.updateMaxFailure || bouncer.updateMaxFailure == -1 {
+		bouncer.log.Debug(fmt.Sprintf("handleStreamTicker:%d failure to reach crowdsec", updateFailure))
+		if updateFailure >= bouncer.updateMaxFailure && bouncer.updateMaxFailure != -1 {
 			isCrowdsecStreamHealthy = false
 		}
+		updateFailure++
 		bouncer.log.Error(err.Error())
 	} else {
 		isCrowdsecStreamHealthy = true

diff --git a/docker-compose.local.yml b/docker-compose.local.yml
@@ -49,6 +49,9 @@ services:
       - "traefik.http.middlewares.crowdsec.plugin.bouncer.enabled=true"
       - "traefik.http.middlewares.crowdsec.plugin.bouncer.loglevel=DEBUG"
       - "traefik.http.middlewares.crowdsec.plugin.bouncer.crowdsecappsecenabled=true"
+      - "traefik.http.middlewares.crowdsec.plugin.bouncer.crowdsecmode=stream"
+      - "traefik.http.middlewares.crowdsec.plugin.bouncer.UpdateIntervalSeconds=10"
+      - "traefik.http.middlewares.crowdsec.plugin.bouncer.UpdateMaxFailure=-1"
       - "traefik.http.middlewares.crowdsec.plugin.bouncer.crowdseclapikey=40796d93c2958f9e58345514e67740e5="
 
   crowdsec: