Add unmute media event (#344)

## Description

# Closes FCE-1444

## Motivation and Context

Why is this change required? What problem does it solve? If it fixes an
open
issue, please link to the issue here.

## Types of changes

- [ ] Bug fix (non-breaking change which fixes an issue)
- [ ] New feature (non-breaking change which adds functionality)
- [ ] Breaking change (fix or feature that would cause existing
functionality to
      not work as expected)

Author: Karolk99

e2e-tests/react-client/docker-compose-test.yaml

@@ -2,13 +2,13 @@ version: "3"
 
 services:
   fishjam:
-    image: "ghcr.io/fishjam-cloud/fishjam:0.10.0-dev"
+    image: "ghcr.io/fishjam-cloud/fishjam:edge"
     container_name: fishjam
     restart: on-failure
     platform: linux/amd64
     healthcheck:
       test: >
-        curl --fail -H "authorization: Bearer development" http://localhost:5002/room || exit 1
+        curl --fail -H "authorization: Bearer admin" http://localhost:5002/room || exit 1
       interval: 3s
       retries: 2
       timeout: 2s
@@ -20,7 +20,8 @@ services:
       FJ_WEBRTC_TURN_LISTEN_IP: "0.0.0.0"
       FJ_WEBRTC_TURN_PORT_RANGE: "50000-50050"
       FJ_WEBRTC_TURN_TCP_PORT: "49999"
-      FJ_SERVER_API_TOKEN: "development"
+      FJ_ADMIN_TOKEN: "admin"
+      FJ_TEST_USER_TOKEN: "development"
       FJ_CHECK_ORIGIN: "false"
     ports:
       - "5002:5002"

e2e-tests/webrtc-client/docker-compose-test.yaml

@@ -2,13 +2,13 @@ version: "3"
 
 services:
   fishjam:
-    image: "ghcr.io/fishjam-cloud/fishjam:0.10.0-dev"
+    image: "ghcr.io/fishjam-cloud/fishjam:edge"
     container_name: fishjam
     restart: on-failure
     platform: linux/amd64
     healthcheck:
       test: >
-        curl --fail -H "authorization: Bearer development"
+        curl --fail -H "authorization: Bearer admin"
         http://localhost:5002/room || exit 1
       interval: 3s
       retries: 2
@@ -21,7 +21,8 @@ services:
       FJ_WEBRTC_TURN_LISTEN_IP: "0.0.0.0"
       FJ_WEBRTC_TURN_PORT_RANGE: "50000-50050"
       FJ_WEBRTC_TURN_TCP_PORT: "49999"
-      FJ_SERVER_API_TOKEN: "development"
+      FJ_ADMIN_TOKEN: "admin"
+      FJ_TEST_USER_TOKEN: "development"
       FJ_CHECK_ORIGIN: "false"
     ports:
       - "5002:5002"

packages/protobufs/fishjam/media_events/peer/peer.ts

@@ -137,10 +137,11 @@ export class LocalTrack implements TrackCommon {
       stream?.addTrack(newTrack);
     }
 
+    const action = getActionType(this.trackContext.track, newTrack);
+
     this.trackContext.track = newTrack;
     this.mediaStreamTrackId = newTrack?.id ?? null;
 
-    const action = getActionType(this.trackContext.track, newTrack);
     if (action === 'mute' || action === 'unmute') {
       emitMutableEvents(action, webrtc, trackId);
     }

packages/protobufs/fishjam/media_events/server/server.ts

@@ -1,11 +1,17 @@
+import { MediaEvent_UnmuteTrack } from '@fishjam-cloud/protobufs/peer';
+
+import { serializePeerMediaEvent } from '../mediaEvent';
 import type { WebRTCEndpoint } from '../webRTCEndpoint';
 
 export function emitMutableEvents(action: 'mute' | 'unmute', webrtc: WebRTCEndpoint, trackId: string) {
   const localEventType = action === 'mute' ? 'localTrackMuted' : 'localTrackUnmuted';
 
-  // TODO add the mute/unmute event back if they're needed
-  // const mediaEvent = generateMediaEvent(mediaEventType, { trackId: trackId });
-  // webrtc.sendMediaEvent(mediaEvent);
+  // Sending the media event `unmuteTrack` speeds up the unmuting of this track for other users
+  // Without this media event, the track may take up to 5-10 seconds to unmute
+  if (action == 'unmute') {
+    const unmuteTrack = MediaEvent_UnmuteTrack.create({ trackId });
+    webrtc.emit('sendMediaEvent', serializePeerMediaEvent({ unmuteTrack }));
+  }
 
   webrtc.emit(localEventType, { trackId });
 }