add websocket destroy reason.

internal/session/manager.go

@@ -122,7 +122,7 @@ func (manager *SessionManagerCtx) Delete(id string) error {
 	manager.sessionsMu.Unlock()
 
 	if session.State().IsConnected {
-		session.GetWebSocketPeer().Destroy()
+		session.GetWebSocketPeer().Destroy("session deleted")
 	}
 
 	if session.State().IsWatching {

internal/session/session.go

@@ -35,7 +35,7 @@ func (session *SessionCtx) profileChanged() {
 	}
 
 	if (!session.profile.CanConnect || !session.profile.CanLogin) && session.state.IsConnected {
-		session.websocketPeer.Destroy()
+		session.websocketPeer.Destroy("profile changed")
 	}
 }
 
@@ -53,7 +53,7 @@ func (session *SessionCtx) IsHost() bool {
 
 func (session *SessionCtx) SetWebSocketPeer(websocketPeer types.WebSocketPeer) {
 	if session.websocketPeer != nil {
-		session.websocketPeer.Destroy()
+		session.websocketPeer.Destroy("connection replaced")
 	}
 
 	session.websocketPeer = websocketPeer

internal/types/websocket.go

@@ -16,7 +16,7 @@ type CheckOrigin func(r *http.Request) bool
 
 type WebSocketPeer interface {
 	Send(event string, payload interface{})
-	Destroy()
+	Destroy(reason string)
 }
 
 type WebSocketManager interface {

internal/websocket/manager.go

@@ -162,14 +162,7 @@ func (manager *WebSocketManagerCtx) Upgrade(w http.ResponseWriter, r *http.Reque
 	session, err := manager.sessions.Authenticate(r)
 	if err != nil {
 		manager.logger.Warn().Err(err).Msg("authentication failed")
-
+		peer.Destroy(err.Error())
-		peer.Send(
-			event.SYSTEM_DISCONNECT,
-			message.SystemDisconnect{
-				Message: err.Error(),
-			})
-
-		peer.Destroy()
 		return
 	}
 
@@ -179,14 +172,7 @@ func (manager *WebSocketManagerCtx) Upgrade(w http.ResponseWriter, r *http.Reque
 
 	if !session.Profile().CanConnect {
 		logger.Warn().Msg("connection disabled")
-
+		peer.Destroy("connection disabled")
-		peer.Send(
-			event.SYSTEM_DISCONNECT,
-			message.SystemDisconnect{
-				Message: "connection disabled",
-			})
-
-		peer.Destroy()
 		return
 	}
 
@@ -194,13 +180,7 @@ func (manager *WebSocketManagerCtx) Upgrade(w http.ResponseWriter, r *http.Reque
 		logger.Warn().Msg("already connected")
 
 		if !manager.sessions.MercifulReconnect() {
-			peer.Send(
+			peer.Destroy("already connected")
-				event.SYSTEM_DISCONNECT,
-				message.SystemDisconnect{
-					Message: "already connected",
-				})
-
-			peer.Destroy()
 			return
 		}
 

internal/websocket/peer.go

@@ -66,7 +66,7 @@ func (peer *WebSocketPeerCtx) Send(event string, payload interface{}) {
 		Msg("sending message to client")
 }
 
-func (peer *WebSocketPeerCtx) Destroy() {
+func (peer *WebSocketPeerCtx) Destroy(reason string) {
 	peer.mu.Lock()
 	defer peer.mu.Unlock()
 
@@ -77,7 +77,7 @@ func (peer *WebSocketPeerCtx) Destroy() {
 	peer.Send(
 		event.SYSTEM_DISCONNECT,
 		message.SystemDisconnect{
-			Message: "connection destroyed",
+			Message: reason,
 		})
 
 	if err := peer.connection.Close(); err != nil {