Compare commits

...

2 Commits

2 changed files with 23 additions and 9 deletions
+19 -7
View File
@@ -5,6 +5,7 @@ import (
"net/http" "net/http"
"os" "os"
"strings" "strings"
"sync"
"time" "time"
) )
@@ -220,18 +221,29 @@ func isSuspiciousUserAgent(userAgent string) bool {
return false return false
} }
var requestCounts = make(map[string]int) type rapidRequestTracker struct {
var lastReset = time.Now() mu sync.Mutex
counts map[string]int
lastReset time.Time
}
var rapidRequests = rapidRequestTracker{
counts: make(map[string]int),
lastReset: time.Now(),
}
func isRapidRequest(ip string) bool { func isRapidRequest(ip string) bool {
rapidRequests.mu.Lock()
defer rapidRequests.mu.Unlock()
now := time.Now() now := time.Now()
if now.Sub(lastReset) > time.Minute { if now.Sub(rapidRequests.lastReset) > time.Minute {
requestCounts = make(map[string]int) rapidRequests.counts = make(map[string]int)
lastReset = now rapidRequests.lastReset = now
} }
requestCounts[ip]++ rapidRequests.counts[ip]++
return requestCounts[ip] > 100 return rapidRequests.counts[ip] > 100
} }
+4 -2
View File
@@ -453,8 +453,10 @@ func TestIsSuspiciousUserAgent(t *testing.T) {
func TestIsRapidRequest(t *testing.T) { func TestIsRapidRequest(t *testing.T) {
requestCounts = make(map[string]int) rapidRequests.mu.Lock()
lastReset = time.Now() rapidRequests.counts = make(map[string]int)
rapidRequests.lastReset = time.Now()
rapidRequests.mu.Unlock()
ip := "192.168.1.1" ip := "192.168.1.1"