Compare commits
2 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 0baf7053fc | |||
| 5d145613d2 |
@@ -5,6 +5,7 @@ import (
|
||||
"net/http"
|
||||
"os"
|
||||
"strings"
|
||||
"sync"
|
||||
"time"
|
||||
)
|
||||
|
||||
@@ -220,18 +221,29 @@ func isSuspiciousUserAgent(userAgent string) bool {
|
||||
return false
|
||||
}
|
||||
|
||||
var requestCounts = make(map[string]int)
|
||||
var lastReset = time.Now()
|
||||
type rapidRequestTracker struct {
|
||||
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 {
|
||||
rapidRequests.mu.Lock()
|
||||
defer rapidRequests.mu.Unlock()
|
||||
|
||||
now := time.Now()
|
||||
|
||||
if now.Sub(lastReset) > time.Minute {
|
||||
requestCounts = make(map[string]int)
|
||||
lastReset = now
|
||||
if now.Sub(rapidRequests.lastReset) > time.Minute {
|
||||
rapidRequests.counts = make(map[string]int)
|
||||
rapidRequests.lastReset = now
|
||||
}
|
||||
|
||||
requestCounts[ip]++
|
||||
rapidRequests.counts[ip]++
|
||||
|
||||
return requestCounts[ip] > 100
|
||||
return rapidRequests.counts[ip] > 100
|
||||
}
|
||||
|
||||
@@ -453,8 +453,10 @@ func TestIsSuspiciousUserAgent(t *testing.T) {
|
||||
|
||||
func TestIsRapidRequest(t *testing.T) {
|
||||
|
||||
requestCounts = make(map[string]int)
|
||||
lastReset = time.Now()
|
||||
rapidRequests.mu.Lock()
|
||||
rapidRequests.counts = make(map[string]int)
|
||||
rapidRequests.lastReset = time.Now()
|
||||
rapidRequests.mu.Unlock()
|
||||
|
||||
ip := "192.168.1.1"
|
||||
|
||||
|
||||
Reference in New Issue
Block a user