Merge branch 'main' of github.com:l3montree-dev/traefik-crowdsec-bouncer

bouncer.go

@@ -14,7 +14,7 @@ import (
 func getLogLevel() slog.Level {
 	envVar := os.Getenv("LOG_LEVEL")
 	if envVar == "" {
-		return slog.LevelDebug
+		return slog.LevelInfo
 	}
 	switch envVar {
 	case "DEBUG":
@@ -26,7 +26,7 @@ func getLogLevel() slog.Level {
 	case "ERROR":
 		return slog.LevelError
 	default:
-		return slog.LevelDebug
+		return slog.LevelInfo
 	}
 }
 func initLogger() {

controller/controller.go

@@ -62,7 +62,10 @@ type blocklist struct {
 	rwMutex sync.RWMutex
 }
 
-var globalBlocklist blocklist = blocklist{}
+var globalBlocklist blocklist = blocklist{
+	list:    make(map[string]struct{}),
+	rwMutex: sync.RWMutex{},
+}
 
 // will be nil if unparsable
 func getIpFromDecision(d model.Decision) net.IP {
@@ -136,7 +139,7 @@ func StartStreaming() {
 				slog.Error("could not start streaming", "err", err)
 				panic("")
 			}
-
+			req.Header.Add(crowdsecAuthHeader, crowdsecBouncerApiKey)
 			resp, err := client.Do(req)
 			if err != nil {
 				slog.Error("could not fetch initial streaming state", "err", err)