extern/netbird
1
0
Fork 0
mirror of https://github.com/netbirdio/netbird.git synced 2025-06-20 09:47:49 +02:00
Code Issues Packages Projects Releases Wiki Activity

minor fix of logging

Browse Source
This commit is contained in:
crn4 2025-06-19 17:01:03 +02:00
parent 2f73b7a35f
commit 00ccca0206
1 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
management/server/grpcserver.go
View File

@ -36,6 +36,10 @@ import (
"github.com/netbirdio/netbird/management/server/types" "github.com/netbirdio/netbird/management/server/types"
) )
const (
envLogBlockedPeers = "NB_LOG_BLOCKED_PEERS"
)
// GRPCServer an instance of a Management gRPC API server // GRPCServer an instance of a Management gRPC API server
type GRPCServer struct { type GRPCServer struct {
accountManager account.Manager accountManager account.Manager
@ -80,7 +84,7 @@ func NewServer(
} }
} }
logBlockedPeers := os.Getenv("NB_LOG_BLOCKED_PEERS") == "true" logBlockedPeers := os.Getenv(envLogBlockedPeers) == "true"
return &GRPCServer{ return &GRPCServer{
wgKey: key, wgKey: key,
@ -466,6 +470,9 @@ func (s *GRPCServer) Login(ctx context.Context, req *proto.EncryptedMessage) (*p
peerMeta := extractPeerMeta(ctx, loginReq.GetMeta()) peerMeta := extractPeerMeta(ctx, loginReq.GetMeta())
metahashed := metaHash(peerMeta, sRealIP) metahashed := metaHash(peerMeta, sRealIP)
if !s.accountManager.AllowSync(peerKey.String(), metahashed) { if !s.accountManager.AllowSync(peerKey.String(), metahashed) {
if s.logBlockedPeers {
log.WithContext(ctx).Warnf("peer %s with meta hash %d is blocked from login", peerKey.String(), metahashed)
}
if s.appMetrics != nil { if s.appMetrics != nil {
s.appMetrics.GRPCMetrics().CountLoginRequestBlocked() s.appMetrics.GRPCMetrics().CountLoginRequestBlocked()
} }