mirror of
https://github.com/netbirdio/netbird.git
synced 2026-10-20 20:39:08 +02:00
Merge branch 'chore/change-log-level' into test/affected-logic
This commit is contained in:
@@ -788,7 +788,11 @@ func (s *Server) Login(ctx context.Context, req *proto.EncryptedMessage) (*proto
|
|||||||
ExtraDNSLabels: loginReq.GetDnsLabels(),
|
ExtraDNSLabels: loginReq.GetDnsLabels(),
|
||||||
})
|
})
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.WithContext(ctx).Warnf("failed logging in peer %s: %s", peerKey, err)
|
if errors.Is(err, internalStatus.ErrNoAuthMethodProvided) {
|
||||||
|
log.WithContext(ctx).Tracef("failed logging in peer %s: %s", peerKey, err)
|
||||||
|
} else {
|
||||||
|
log.WithContext(ctx).Warnf("failed logging in peer %s: %s", peerKey, err)
|
||||||
|
}
|
||||||
return nil, mapError(ctx, err)
|
return nil, mapError(ctx, err)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -220,7 +220,7 @@ func (h *handler) getAllUsers(w http.ResponseWriter, r *http.Request) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
includeServiceUser, err := strconv.ParseBool(serviceUser)
|
includeServiceUser, err := strconv.ParseBool(serviceUser)
|
||||||
log.WithContext(r.Context()).Debugf("Should include service user: %v", includeServiceUser)
|
log.WithContext(r.Context()).Tracef("Should include service user: %v", includeServiceUser)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
util.WriteError(r.Context(), status.Errorf(status.InvalidArgument, "invalid service_user query parameter"), w)
|
util.WriteError(r.Context(), status.Errorf(status.InvalidArgument, "invalid service_user query parameter"), w)
|
||||||
return
|
return
|
||||||
|
|||||||
@@ -730,7 +730,7 @@ func (am *DefaultAccountManager) handleSetupKeyAddedPeer(ctx context.Context, en
|
|||||||
func (am *DefaultAccountManager) AddPeer(ctx context.Context, accountID, setupKey, userID string, peer *nbpeer.Peer, temporary bool) (*nbpeer.Peer, *types.Network, []*posture.Checks, bool, error) {
|
func (am *DefaultAccountManager) AddPeer(ctx context.Context, accountID, setupKey, userID string, peer *nbpeer.Peer, temporary bool) (*nbpeer.Peer, *types.Network, []*posture.Checks, bool, error) {
|
||||||
if setupKey == "" && userID == "" && !peer.ProxyMeta.Embedded {
|
if setupKey == "" && userID == "" && !peer.ProxyMeta.Embedded {
|
||||||
// no auth method provided => reject access
|
// no auth method provided => reject access
|
||||||
return nil, nil, nil, false, status.Errorf(status.Unauthenticated, "no peer auth method provided, please use a setup key or interactive SSO login")
|
return nil, nil, nil, false, status.ErrNoAuthMethodProvided
|
||||||
}
|
}
|
||||||
|
|
||||||
upperKey := strings.ToUpper(setupKey)
|
upperKey := strings.ToUpper(setupKey)
|
||||||
|
|||||||
@@ -1059,8 +1059,8 @@ func (am *DefaultAccountManager) BuildUserInfosForAccount(ctx context.Context, a
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
log.WithContext(ctx).Debugf("Got %d users from ExternalCache for account %s", len(usersFromIntegration), accountID)
|
log.WithContext(ctx).Tracef("Got %d users from ExternalCache for account %s", len(usersFromIntegration), accountID)
|
||||||
log.WithContext(ctx).Debugf("Got %d users from InternalCache for account %s", len(queriedUsers), accountID)
|
log.WithContext(ctx).Tracef("Got %d users from InternalCache for account %s", len(queriedUsers), accountID)
|
||||||
queriedUsers = append(queriedUsers, usersFromIntegration...)
|
queriedUsers = append(queriedUsers, usersFromIntegration...)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -48,6 +48,10 @@ type Type int32
|
|||||||
var (
|
var (
|
||||||
ErrExtraSettingsNotFound = errors.New("extra settings not found")
|
ErrExtraSettingsNotFound = errors.New("extra settings not found")
|
||||||
ErrPeerAlreadyLoggedIn = errors.New("peer with the same public key is already logged in")
|
ErrPeerAlreadyLoggedIn = errors.New("peer with the same public key is already logged in")
|
||||||
|
|
||||||
|
// ErrNoAuthMethodProvided is returned when a peer login attempt carries neither a
|
||||||
|
// setup key nor an SSO token. Match it with errors.Is.
|
||||||
|
ErrNoAuthMethodProvided = Errorf(Unauthenticated, "no peer auth method provided, please use a setup key or interactive SSO login")
|
||||||
)
|
)
|
||||||
|
|
||||||
// Error is an internal error
|
// Error is an internal error
|
||||||
@@ -66,6 +70,16 @@ func (e *Error) Error() string {
|
|||||||
return e.Message
|
return e.Message
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Is reports whether target is an *Error with the same type and message,
|
||||||
|
// enabling matching with errors.Is against sentinel errors.
|
||||||
|
func (e *Error) Is(target error) bool {
|
||||||
|
var t *Error
|
||||||
|
if !errors.As(target, &t) {
|
||||||
|
return false
|
||||||
|
}
|
||||||
|
return e.ErrorType == t.ErrorType && e.Message == t.Message
|
||||||
|
}
|
||||||
|
|
||||||
// Errorf returns Error(ErrorType, fmt.Sprintf(format, a...)).
|
// Errorf returns Error(ErrorType, fmt.Sprintf(format, a...)).
|
||||||
func Errorf(errorType Type, format string, a ...interface{}) error {
|
func Errorf(errorType Type, format string, a ...interface{}) error {
|
||||||
return &Error{
|
return &Error{
|
||||||
|
|||||||
Reference in New Issue
Block a user