fix wrong unsubscribe code handling

centrifugal · Jan 5, 2023 · abff7c6 · abff7c6
1 parent a013082
commit abff7c6
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/subscription.go b/subscription.go
@@ -617,10 +617,10 @@ func (s *Subscription) handleLeave(info *protocol.ClientInfo) {
 
 func (s *Subscription) handleUnsubscribe(unsubscribe *protocol.Unsubscribe) {
 	if unsubscribe.Code < 2500 {
-		s.moveToSubscribing(unsubscribe.Code, "server")
-		s.resubscribe()
+		s.moveToUnsubscribed(unsubscribe.Code, unsubscribe.Reason)
 	} else {
-		s.moveToUnsubscribed(unsubscribe.Code, "server")
+		s.moveToSubscribing(unsubscribe.Code, unsubscribe.Reason)
+		s.resubscribe()
 	}
 }