sendnrw/netbird
2
0
Fork 0
mirror of https://github.com/netbirdio/netbird.git synced 2026-04-18 16:26:38 +00:00
Code Issues Packages Projects Releases Wiki Activity

remove proxy auth changes

Browse Source
This commit is contained in:
pascal
2026-04-09 13:00:05 +02:00
parent 7f98cf30cf
commit fd28178cc6
1 changed files with 12 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
management/internals/shared/grpc/proxy_auth.go
View File

@@ -71,14 +71,13 @@ func NewProxyAuthInterceptors(tokenStore proxyTokenStore) (grpc.UnaryServerInter
return handler(ctx, req) return handler(ctx, req)
} }
// token, err := interceptor.validateProxyToken(ctx) token, err := interceptor.validateProxyToken(ctx)
// if err != nil { if err != nil {
// // Log auth failures explicitly; gRPC doesn't log these by default. // Log auth failures explicitly; gRPC doesn't log these by default.
// log.WithContext(ctx).Warnf("proxy auth failed: %v", err) log.WithContext(ctx).Warnf("proxy auth failed: %v", err)
// return nil, err return nil, err
// } }
token := &types.ProxyAccessToken{}
ctx = context.WithValue(ctx, ProxyTokenContextKey, token) ctx = context.WithValue(ctx, ProxyTokenContextKey, token)
return handler(ctx, req) return handler(ctx, req)
} }
@@ -88,14 +87,13 @@ func NewProxyAuthInterceptors(tokenStore proxyTokenStore) (grpc.UnaryServerInter
return handler(srv, ss) return handler(srv, ss)
} }
// token, err := interceptor.validateProxyToken(ss.Context()) token, err := interceptor.validateProxyToken(ss.Context())
// if err != nil { if err != nil {
// // Log auth failures explicitly; gRPC doesn't log these by default. // Log auth failures explicitly; gRPC doesn't log these by default.
// log.WithContext(ss.Context()).Warnf("proxy auth failed: %v", err) log.WithContext(ss.Context()).Warnf("proxy auth failed: %v", err)
// return err return err
// } }
token := &types.ProxyAccessToken{}
ctx := context.WithValue(ss.Context(), ProxyTokenContextKey, token) ctx := context.WithValue(ss.Context(), ProxyTokenContextKey, token)
wrapped := &wrappedServerStream{ wrapped := &wrappedServerStream{
ServerStream: ss, ServerStream: ss,