Notify connected user of others state

streamer45 · Apr 9, 2021 · b767f30 · b767f30
1 parent 25de7e8
commit b767f30
Showing 1 changed file with 17 additions and 0 deletions.
diff --git a/server/signal.go b/server/signal.go
@@ -81,6 +81,23 @@ func (p *Plugin) handleWebSocket(w http.ResponseWriter, r *http.Request, channel
 		"userID": userID,
 	}, &model.WebsocketBroadcast{ChannelId: channelID})
 
+	// notify connected user about other users state.
+	p.mut.RLock()
+	for id, session := range p.sessions {
+		var evType string
+		if session.isMuted {
+			evType = wsEventUserMuted
+		} else {
+			evType = wsEventUserUnmuted
+		}
+		if id != userID {
+			p.API.PublishWebSocketEvent(evType, map[string]interface{}{
+				"userID": id,
+			}, &model.WebsocketBroadcast{ChannelId: channelID, UserId: userID})
+		}
+	}
+	p.mut.RUnlock()
+
 	go func() {
 		defer wg.Done()
 		for {