This commit is contained in:
Max Lerebourg
2022-09-29 11:18:35 +02:00
parent 6b46c63287
commit 773f001239
+2 -5
View File
@@ -46,8 +46,8 @@ func CreateConfig() *Config {
CrowdsecLapiScheme: "http",
CrowdsecLapiHost: "crowdsec:8080",
CrowdsecLapiKey: "",
UpdateIntervalSeconds: 10,
DefaultDecisionSeconds: 10,
UpdateIntervalSeconds: 60,
DefaultDecisionSeconds: 60,
}
}
@@ -161,7 +161,6 @@ func (a *Bouncer) ServeHTTP(rw http.ResponseWriter, req *http.Request) {
if a.crowdsecMode == "stream" || a.crowdsecMode == "live" {
isBanned, err := getDecision(remoteHost)
log.Printf("ip: %v, %v, %s", remoteHost, isBanned, err)
if err == nil {
if isBanned {
rw.WriteHeader(http.StatusForbidden)
@@ -219,7 +218,6 @@ func contains(source []string, target string) bool {
func getDecision(clientIP string) (bool, error) {
banned, isCached := cache.Get(clientIP)
bannedString, isValid := banned.(string)
log.Printf("ip: %v, %v, %v", bannedString == cacheBannedValue, isCached, isValid)
if isCached && isValid && len(bannedString) > 0 {
return bannedString == cacheBannedValue, nil
}
@@ -301,7 +299,6 @@ func handleStreamCache(a *Bouncer, initialized bool) {
}
}
for _, decision := range stream.Deleted {
log.Printf("ip deleted: %v", decision.Value)
cache.Del(decision.Value)
}
a.crowdsecStreamHealthy = true