From e1b992526e4218f0795aaf886c2fa15ce192313b Mon Sep 17 00:00:00 2001 From: exterr2f Date: Fri, 14 Feb 2025 20:20:42 +0100 Subject: [PATCH] Improve rate limiting to combination of IP and username --- internal/auth/auth.go | 42 ++++++++++++------------------------------ 1 file changed, 12 insertions(+), 30 deletions(-) diff --git a/internal/auth/auth.go b/internal/auth/auth.go index 1892b0e..6241585 100644 --- a/internal/auth/auth.go +++ b/internal/auth/auth.go @@ -35,25 +35,15 @@ var ( authInstance *Authentication ) -var ( - ipLimiters sync.Map - usernameLimiters sync.Map -) +var ipUserLimiters sync.Map -func getIPLimiter(ip string) *rate.Limiter { - limiter, ok := ipLimiters.Load(ip) +func getIPUserLimiter(ip, username string) *rate.Limiter { + key := ip + ":" + username + limiter, ok := ipUserLimiters.Load(key) if !ok { - limiter = rate.NewLimiter(rate.Every(time.Minute/5), 5) - ipLimiters.Store(ip, limiter) - } - return limiter.(*rate.Limiter) -} - -func getUserLimiter(username string) *rate.Limiter { - limiter, ok := usernameLimiters.Load(username) - if !ok { - limiter = rate.NewLimiter(rate.Every(time.Hour/10), 10) - usernameLimiters.Store(username, limiter) + newLimiter := rate.NewLimiter(rate.Every(time.Hour/10), 10) + ipUserLimiters.Store(key, newLimiter) + return newLimiter } return limiter.(*rate.Limiter) } @@ -241,19 +231,11 @@ func (auth *Authentication) Login( username := r.FormValue("username") - ipLimiter := getIPLimiter(ip) - userLimiter := getUserLimiter(username) - - if !ipLimiter.Allow() { - log.Warnf("AUTH/RATE > Too many login attempts from IP %s", ip) - onfailure(rw, r, errors.New("too many login attempts, please try again later")) - return - } - - if !userLimiter.Allow() { - log.Warnf("AUTH/RATE > Too many failed login attempts for user %s", username) - onfailure(rw, r, errors.New("too many login attempts for this user, please try again later")) - return + limiter := getIPUserLimiter(ip, username) + if !limiter.Allow() { + log.Warnf("AUTH/RATE > Too many login attempts for combination IP: %s, Username: %s", ip, username) + onfailure(rw, r, errors.New("Too many login attempts, try again in 1 hour")) + return } var dbUser *schema.User