sendnrw/netbird
2
0
Fork 0
mirror of https://github.com/netbirdio/netbird.git synced 2026-10-06 21:49:08 +02:00
Code Issues Packages Projects Releases Wiki Activity

update error message

Browse Source
This commit is contained in:
Pascal Fischer
2025-05-07 20:36:53 +02:00
parent 4a3c782a31
commit 6ea7c665dc
1 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
management/server/grpcserver.go
+2 -3
View File
@@ -2,7 +2,6 @@ package server
import ( import (
"context" "context"
"errors"
"fmt" "fmt"
"net" "net"
"net/netip" "net/netip"
@@ -133,7 +132,7 @@ var syncLimiter = rate.NewLimiter(rate.Every(time.Minute/300), 1)
// notifies the connected peer of any updates (e.g. new peers under the same account) // notifies the connected peer of any updates (e.g. new peers under the same account)
func (s *GRPCServer) Sync(req *proto.EncryptedMessage, srv proto.ManagementService_SyncServer) error { func (s *GRPCServer) Sync(req *proto.EncryptedMessage, srv proto.ManagementService_SyncServer) error {
if !syncLimiter.Allow() { if !syncLimiter.Allow() {
return errors.New("rate limit exceeded") return status.Errorf(codes.Internal, "temp rate limit reached")
} }
reqStart := time.Now() reqStart := time.Now()
@@ -427,7 +426,7 @@ var loginLimiter = rate.NewLimiter(rate.Every(time.Minute/300), 1)
// In case of the successful registration login is also successful // In case of the successful registration login is also successful
func (s *GRPCServer) Login(ctx context.Context, req *proto.EncryptedMessage) (*proto.EncryptedMessage, error) { func (s *GRPCServer) Login(ctx context.Context, req *proto.EncryptedMessage) (*proto.EncryptedMessage, error) {
if !loginLimiter.Allow() { if !loginLimiter.Allow() {
return nil, errors.New("rate limit exceeded") return nil, status.Errorf(codes.Internal, "temp rate limit reached")
} }
reqStart := time.Now() reqStart := time.Now()