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

Update daemon server adminURL and managementURL fields (#314)

Browse Source 
Removed the UP call in the login function

Attempt login on change to get status
This commit is contained in:
Maycon Santos 2022-05-18 00:22:47 +02:00 committed by GitHub
parent 77e58295e7
commit 001cf98dce
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 38 additions and 25 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

52
client/server/server.go
View File

@ -90,6 +90,23 @@ func (s *Server) Start() error {
return nil return nil
} }
// loginAttempt attempts to login using the provided information. it returns a status in case something fails
func (s *Server) loginAttempt(ctx context.Context, setupKey, jwtToken string) (internal.StatusType, error) {
var status internal.StatusType
err := internal.Login(ctx, s.config, setupKey, jwtToken)
if err != nil {
if s, ok := gstatus.FromError(err); ok && (s.Code() == codes.InvalidArgument || s.Code() == codes.PermissionDenied) {
log.Warnf("failed login: %v", err)
status = internal.StatusNeedsLogin
} else {
log.Errorf("failed login: %v", err)
status = internal.StatusLoginFailed
}
return status, err
}
return "", nil
}
// Login uses setup key to prepare configuration for the daemon. // Login uses setup key to prepare configuration for the daemon.
func (s *Server) Login(_ context.Context, msg *proto.LoginRequest) (*proto.LoginResponse, error) { func (s *Server) Login(_ context.Context, msg *proto.LoginRequest) (*proto.LoginResponse, error) {
s.mutex.Lock() s.mutex.Lock()
@ -102,23 +119,23 @@ func (s *Server) Login(_ context.Context, msg *proto.LoginRequest) (*proto.Login
state := internal.CtxGetState(ctx) state := internal.CtxGetState(ctx)
defer func() { defer func() {
s, err := state.Status() status, err := state.Status()
if err != nil || (s != internal.StatusNeedsLogin && s != internal.StatusLoginFailed) { if err != nil || (status != internal.StatusNeedsLogin && status != internal.StatusLoginFailed) {
state.Set(internal.StatusIdle) state.Set(internal.StatusIdle)
} }
}() }()
state.Set(internal.StatusConnecting)
s.mutex.Lock() s.mutex.Lock()
managementURL := s.managementURL managementURL := s.managementURL
if msg.ManagementUrl != "" { if msg.ManagementUrl != "" {
managementURL = msg.ManagementUrl managementURL = msg.ManagementUrl
s.managementURL = msg.ManagementUrl
} }
adminURL := s.adminURL adminURL := s.adminURL
if msg.AdminURL != "" { if msg.AdminURL != "" {
adminURL = msg.AdminURL adminURL = msg.AdminURL
s.adminURL = msg.AdminURL
} }
s.mutex.Unlock() s.mutex.Unlock()
@ -131,6 +148,13 @@ func (s *Server) Login(_ context.Context, msg *proto.LoginRequest) (*proto.Login
s.config = config s.config = config
s.mutex.Unlock() s.mutex.Unlock()
if _, err := s.loginAttempt(ctx, "", ""); err == nil {
state.Set(internal.StatusIdle)
return &proto.LoginResponse{}, nil
}
state.Set(internal.StatusConnecting)
if msg.SetupKey == "" { if msg.SetupKey == "" {
providerConfig, err := internal.GetDeviceAuthorizationFlowInfo(ctx, config) providerConfig, err := internal.GetDeviceAuthorizationFlowInfo(ctx, config)
if err != nil { if err != nil {
@ -176,14 +200,8 @@ func (s *Server) Login(_ context.Context, msg *proto.LoginRequest) (*proto.Login
}, nil }, nil
} }
if err := internal.Login(ctx, s.config, msg.SetupKey, ""); err != nil { if loginStatus, err := s.loginAttempt(ctx, msg.SetupKey, ""); err != nil {
if s, ok := gstatus.FromError(err); ok && (s.Code() == codes.InvalidArgument || s.Code() == codes.PermissionDenied) { state.Set(loginStatus)
log.Warnf("failed login with known status: %v", err)
state.Set(internal.StatusNeedsLogin)
} else {
log.Errorf("failed login: %v", err)
state.Set(internal.StatusLoginFailed)
}
return nil, err return nil, err
} }
@ -235,14 +253,8 @@ func (s *Server) WaitSSOLogin(_ context.Context, msg *proto.WaitSSOLoginRequest)
return nil, err return nil, err
} }
if err := internal.Login(ctx, s.config, "", tokenInfo.AccessToken); err != nil { if loginStatus, err := s.loginAttempt(ctx, "", tokenInfo.AccessToken); err != nil {
if s, ok := gstatus.FromError(err); ok && (s.Code() == codes.InvalidArgument || s.Code() == codes.PermissionDenied) { state.Set(loginStatus)
log.Warnf("failed login: %v", err)
state.Set(internal.StatusNeedsLogin)
} else {
log.Errorf("failed login: %v", err)
state.Set(internal.StatusLoginFailed)
}
return nil, err return nil, err
} }

11
client/ui/client_ui.go
View File

@ -247,11 +247,6 @@ func (s *serviceClient) login() error {
} }
} }
if _, err := s.conn.Up(s.ctx, &proto.UpRequest{}); err != nil {
log.Errorf("up service: %v", err)
return err
}
return nil return nil
} }
@ -276,6 +271,12 @@ func (s *serviceClient) menuUpClick() error {
} }
} }
status, err = conn.Status(s.ctx, &proto.StatusRequest{})
if err != nil {
log.Errorf("get service status: %v", err)
return err
}
if status.Status != string(internal.StatusIdle) { if status.Status != string(internal.StatusIdle) {
log.Warnf("already connected") log.Warnf("already connected")
return nil return nil