diff --git a/src/handlers.rs b/src/handlers.rs
index f856c3e..9785077 100644
--- a/src/handlers.rs
+++ b/src/handlers.rs
@@ -92,10 +92,16 @@ pub async fn handle_socket(mut socket: WebSocket, _addr: SocketAddr, state: AppS
                     Some(Ok(Message::Text(text))) => {
                          if let Ok(control) = serde_json::from_str::<ControlMsg>(&text) {
                              match control {
-                                 ControlMsg::UpdateStream { .. } => {
-                                     // Broadcast to room
+                                 ControlMsg::UpdateStream { stream_id, active, media_type, .. } => {
+                                     // Broadcast to room with sender's user_id
+                                     let update = ControlMsg::UpdateStream {
+                                         user_id: uid,
+                                         stream_id,
+                                         active,
+                                         media_type,
+                                     };
                                      if let Some(room) = state.rooms.get(&rid) {
-                                         let _ = room.tx.send(control);
+                                         let _ = room.tx.send(update);
                                      }
                                  }
                                  ControlMsg::ChatMessage { message, display_name, .. } => {