Correct auth check

10 months ago · 421521b314
parent 173120194e
commit 421521b314
1 changed files with 1 additions and 1 deletions
--- a/cluster/service.go
+++ b/cluster/service.go
@ -439,7 +439,7 @@ func (s *Service) handleConn(conn net.Conn) {
 			nr := c.GetNotifyRequest()
 			if nr == nil {
 				resp.Error = "NotifyRequest is nil"
-			} else if !s.checkCommandPermAll(c, auth.PermJoin) {
+			} else if !s.checkCommandPerm(c, auth.PermJoin) {
 				resp.Error = "unauthorized"
 			} else {
 				if err := s.mgr.Notify(nr); err != nil {