Feat/mute participant

src/components/landing-page/join-production.tsx

@@ -181,6 +181,8 @@ export const JoinProduction = ({
           connectionState: null,
           audioElements: null,
           sessionId: null,
+          dataChannel: null,
+          isRemotelyMuted: false,
           hotkeys: {
             muteHotkey: "m",
             speakerHotkey: "n",

src/components/modal/modal-confirmation-text.ts

@@ -2,4 +2,8 @@ import styled from "@emotion/styled";
 
 export const ModalConfirmationText = styled.p`
   padding-bottom: 1rem;
+
+  &.bold {
+    font-weight: bold;
+  }
 `;

src/components/production-line/production-line.tsx

@@ -163,6 +163,10 @@ export const ProductionLine = ({
   const [refresh, setRefresh] = useState<number>(0);
   const [confirmExitModalOpen, setConfirmExitModalOpen] = useState(false);
   const [value, setValue] = useState(0.75);
+  const [confirmModalOpen, setConfirmModalOpen] = useState(false);
+  const [muteError, setMuteError] = useState(false);
+  const [userId, setUserId] = useState("");
+  const [userName, setUserName] = useState("");
   const {
     joinProductionOptions,
     dominantSpeaker,
@@ -171,6 +175,8 @@ export const ProductionLine = ({
     audioElements,
     sessionId,
     hotkeys: savedHotkeys,
+    dataChannel,
+    isRemotelyMuted,
   } = callState;
 
   const {
@@ -254,10 +260,33 @@ export const ProductionLine = ({
         });
         setIsInputMuted(mute);
       }
+      if (mute) {
+        dispatch({
+          type: "UPDATE_CALL",
+          payload: {
+            id,
+            updates: {
+              isRemotelyMuted: false,
+            },
+          },
+        });
+      }
     },
-    [inputAudioStream]
+    [dispatch, id, inputAudioStream]
   );
 
+  useEffect(() => {
+    if (!confirmModalOpen) {
+      setMuteError(false);
+    }
+  }, [confirmModalOpen]);
+
+  useEffect(() => {
+    if (isRemotelyMuted) {
+      muteInput(true);
+    }
+  }, [isRemotelyMuted, muteInput]);
+
   const { playEnterSound, playExitSound } = useAudioCue();
 
   const exit = useCallback(() => {
@@ -296,7 +325,18 @@ export const ProductionLine = ({
       });
       setIsInputMuted(masterInputMute);
     }
-  }, [inputAudioStream, masterInputMute]);
+    if (masterInputMute) {
+      dispatch({
+        type: "UPDATE_CALL",
+        payload: {
+          id,
+          updates: {
+            isRemotelyMuted: false,
+          },
+        },
+      });
+    }
+  }, [dispatch, id, inputAudioStream, masterInputMute]);
 
   useEffect(() => {
     if (connectionState === "connected") {
@@ -408,6 +448,25 @@ export const ProductionLine = ({
     }
   };
 
+  const muteParticipant = () => {
+    const msg = JSON.stringify({
+      type: "EndpointMessage",
+      to: userId,
+      payload: {
+        muteParticipant: "mute",
+      },
+    });
+
+    if (dataChannel && dataChannel.readyState === "open") {
+      dataChannel.send(msg);
+      setMuteError(false);
+      setConfirmModalOpen(false);
+    } else {
+      setMuteError(true);
+      console.error("Data channel is not open.");
+    }
+  };
+
   // TODO detect if browser back button is pressed and run exit();
 
   return (
@@ -629,8 +688,30 @@ export const ProductionLine = ({
                 participants={line.participants}
                 dominantSpeaker={dominantSpeaker}
                 audioLevelAboveThreshold={audioLevelAboveThreshold}
+                setConfirmModalOpen={setConfirmModalOpen}
+                setUserId={setUserId}
+                setUserName={setUserName}
               />
             )}
+            {confirmModalOpen && (
+              <Modal onClose={() => setConfirmModalOpen(false)}>
+                <DisplayContainerHeader>Confirm</DisplayContainerHeader>
+                <ModalConfirmationText>
+                  {muteError
+                    ? "Something went wrong, Please try again"
+                    : `Are you sure you want to mute ${userName}?`}
+                </ModalConfirmationText>
+                <ModalConfirmationText className="bold">
+                  {muteError
+                    ? ""
+                    : `This will mute ${userName} for everyone in the call.`}
+                </ModalConfirmationText>
+                <VerifyDecision
+                  confirm={muteParticipant}
+                  abort={() => setConfirmModalOpen(false)}
+                />
+              </Modal>
+            )}
           </ListWrapper>
         </FlexContainer>
       )}

src/components/production-line/use-rtc-connection.ts

@@ -127,6 +127,16 @@ const establishConnection = ({
     }
   );
 
+  dispatch({
+    type: "UPDATE_CALL",
+    payload: {
+      id: callId,
+      updates: {
+        dataChannel,
+      },
+    },
+  });
+
   const onDataChannelMessage = ({ data }: MessageEvent) => {
     let message: unknown;
 
@@ -153,6 +163,30 @@ const establishConnection = ({
           },
         },
       });
+    } else if (
+      message &&
+      typeof message === "object" &&
+      "type" in message &&
+      message.type === "EndpointMessage" &&
+      "payload" in message &&
+      "to" in message &&
+      "from" in message &&
+      message.payload &&
+      typeof message.payload === "object" &&
+      "muteParticipant" in message.payload &&
+      typeof message.payload.muteParticipant === "string"
+    ) {
+      dispatch({
+        type: "UPDATE_CALL",
+        payload: {
+          id: callId,
+          updates: {
+            isRemotelyMuted:
+              message.payload.muteParticipant === "mute" &&
+              message.to !== message.from,
+          },
+        },
+      });
     } else {
       console.error("Unexpected data channel message structure");
     }

src/components/production-line/user-list.tsx

@@ -1,7 +1,7 @@
 import styled from "@emotion/styled";
 import { DisplayContainerHeader } from "../landing-page/display-container-header.tsx";
 import { TParticipant } from "./types.ts";
-import { UserIcon } from "../../assets/icons/icon.tsx";
+import { MicMuted, UserIcon } from "../../assets/icons/icon.tsx";
 
 const Container = styled.div`
   width: 100%;
@@ -26,11 +26,12 @@ type TIndicatorProps = {
   isActive: boolean;
 };
 
-const User = styled.div<TUserProps>`
+const UserWrapper = styled.div<TUserProps>`
   display: flex;
   align-items: center;
-  background: #1a1a1a;
+  justify-content: space-between;
   padding: 1rem;
+  background: #1a1a1a;
   color: #ddd;
   border: transparent;
   border-bottom: 0.1rem solid #464646;
@@ -47,6 +48,11 @@ const User = styled.div<TUserProps>`
   ${({ isYou }) => (isYou ? `background: #353434;` : "")}
 `;
 
+const User = styled.div`
+  display: flex;
+  align-items: center;
+`;
+
 const IsTalkingIndicator = styled.div<TIsTalkingIndicator>`
   width: 4rem;
   height: 4rem;
@@ -79,41 +85,73 @@ const IconWrapper = styled.div`
   width: 2rem;
 `;
 
+const MuteParticipantButton = styled.button`
+  width: 3rem;
+  padding: 0.3rem;
+  margin: 0;
+  background: #302b2b;
+  border: 0.1rem solid #707070;
+  border-radius: 0.4rem;
+  cursor: pointer;
+`;
+
 type TUserListOptions = {
   participants: TParticipant[];
   sessionId: string | null;
   dominantSpeaker: string | null;
   audioLevelAboveThreshold: boolean;
+  setConfirmModalOpen: (value: boolean) => void;
+  setUserId: (value: string) => void;
+  setUserName: (value: string) => void;
 };
 
 export const UserList = ({
   participants,
   sessionId,
   dominantSpeaker,
   audioLevelAboveThreshold,
+  setConfirmModalOpen,
+  setUserId,
+  setUserName,
 }: TUserListOptions) => {
   if (!participants) return null;
 
   return (
     <Container>
       <DisplayContainerHeader>Participants</DisplayContainerHeader>
       <ListWrapper>
-        {participants.map((p) => (
-          <User key={p.sessionId} isYou={p.sessionId === sessionId}>
-            <IsTalkingIndicator
-              isTalking={
-                audioLevelAboveThreshold && p.endpointId === dominantSpeaker
-              }
-            >
-              <OnlineIndicator isActive={p.isActive}>
-                <IconWrapper>
-                  <UserIcon />
-                </IconWrapper>
-              </OnlineIndicator>
-            </IsTalkingIndicator>
-            {p.name} {p.isActive ? "" : "(inactive)"}
-          </User>
-        ))}
+        {participants.map((p) => {
+          const isYou = p.sessionId === sessionId;
+          return (
+            <UserWrapper key={p.sessionId} isYou={isYou}>
+              <User>
+                <IsTalkingIndicator
+                  isTalking={
+                    audioLevelAboveThreshold && p.endpointId === dominantSpeaker
+                  }
+                >
+                  <OnlineIndicator isActive={p.isActive}>
+                    <IconWrapper>
+                      <UserIcon />
+                    </IconWrapper>
+                  </OnlineIndicator>
+                </IsTalkingIndicator>
+                {p.name} {p.isActive ? "" : "(inactive)"}
+              </User>
+              {!isYou && p.isActive && (
+                <MuteParticipantButton
+                  onClick={() => {
+                    setUserId(p.endpointId);
+                    setUserName(p.name);
+                    setConfirmModalOpen(true);
+                  }}
+                >
+                  <MicMuted />
+                </MuteParticipantButton>
+              )}
+            </UserWrapper>
+          );
+        })}
       </ListWrapper>
     </Container>
   );

src/components/production-list/production-list-item.tsx

@@ -164,6 +164,8 @@ export const ProductionsListItem = ({
             connectionState: null,
             audioElements: null,
             sessionId: null,
+            dataChannel: null,
+            isRemotelyMuted: false,
             hotkeys: {
               muteHotkey: "m",
               speakerHotkey: "n",

src/global-state/types.ts

@@ -20,6 +20,8 @@ export interface CallState {
   audioElements: HTMLAudioElement[] | null;
   sessionId: string | null;
   hotkeys: Hotkeys;
+  dataChannel: RTCDataChannel | null;
+  isRemotelyMuted: boolean;
 }
 
 export type TGlobalState = {