fix(JitsiConference): handles mute state updates arriving before track creation (jitsi#2956)

* feat(JitsiParticipant): Add participant-level mute state change events

   Adds TRACK_AUDIO_MUTED_CHANGED and TRACK_VIDEO_MUTED_CHANGED events that emit when a participant's aggregate mute state changes. A participant is considered unmuted
    if ANY source for that media type is unmuted.

   Also fixes bug where sources weren't added when media type map didn't exist.

* fix(JitsiConference): Emit TRACK_MUTE_CHANGED for initial remote track mute state

* fix(JitsiConference): handle mute state updates arriving before track creation

Author: mihhu

JitsiConference.ts

@@ -3546,6 +3546,16 @@ export default class JitsiConference extends Listenable {
         );
 
         emitter.emit(JitsiConferenceEvents.TRACK_ADDED, track);
+
+        // Apply any pending mute state that arrived before the track was created
+        // Always call setMute when there's a pending state, even if it matches current state,
+        // because setMute() is designed to emit on the first call regardless of state change
+        const pendingMutedState = track._getPendingMuteState();
+
+        if (pendingMutedState !== undefined) {
+            track._clearPendingMuteState();
+            track.setMute(pendingMutedState);
+        }
     }
 
 

modules/RTC/JitsiRemoteTrack.ts

@@ -47,7 +47,9 @@ export default class JitsiRemoteTrack extends JitsiTrack {
     private _rtc: RTC;
     private _muted: boolean;
     private _hasBeenMuted: boolean;
+    private _setMuteCalled: boolean;
     private _ssrc: number;
+    private _pendingMuteState?: boolean;
 
     public ownerEndpointId: string;
     public isP2P: boolean;
@@ -101,6 +103,7 @@ export default class JitsiRemoteTrack extends JitsiTrack {
         this._ssrc = ssrc;
         this.ownerEndpointId = ownerEndpointId;
         this._muted = muted;
+        this._setMuteCalled = false;
         this.isP2P = isP2P;
         this._sourceName = sourceName;
         this._trackStreamingStatus = null;
@@ -423,6 +426,37 @@ export default class JitsiRemoteTrack extends JitsiTrack {
         return this._enteredForwardedSourcesTimestamp;
     }
 
+    /**
+     * Sets the pending mute state for this track,
+     * received before the track was fully initialized.
+     *
+     * @param {boolean | undefined} state - The pending mute state
+     * @internal
+     */
+    _setPendingMuteState(state: boolean | undefined): void {
+        this._pendingMuteState = state;
+    }
+
+    /**
+     * Returns the pending mute state for this track,
+     * received before the track was fully initialized.
+     *
+     * @returns {boolean | undefined} the pending mute state
+     * @internal
+     */
+    _getPendingMuteState(): boolean | undefined {
+        return this._pendingMuteState;
+    }
+
+    /**
+     * Clears the pending mute state for this track.
+     *
+     * @internal
+     */
+    _clearPendingMuteState(): void {
+        this._pendingMuteState = undefined;
+    }
+
     /**
      * Removes attached event listeners and dispose TrackStreamingStatus .
      *
@@ -444,10 +478,16 @@ export default class JitsiRemoteTrack extends JitsiTrack {
      * @internal
      */
     setMute(value: boolean): void {
-        if (this._muted === value) {
+        const isFirstCall = !this._setMuteCalled;
+        const stateChanged = this._muted !== value;
+
+        // Skip if state didn't change, unless this is the first call (to emit initial state)
+        if (!stateChanged && !isFirstCall) {
             return;
         }
 
+        this._setMuteCalled = true;
+
         if (value) {
             this._hasBeenMuted = true;
         }

modules/RTC/TraceablePeerConnection.ts

@@ -157,6 +157,7 @@ export default class TraceablePeerConnection {
     private _pcId: string;
     private _remoteUfrag: string;
     private _signalingLayer: SignalingLayer;
+    private _pendingMuteUpdates: Map<string, boolean>;
     /**
      * @internal
      */
@@ -324,6 +325,13 @@ export default class TraceablePeerConnection {
          */
         this.remoteTracks = new Map();
 
+        /**
+         * Stores pending mute updates for sources that haven't had tracks created yet.
+         * @type {Map<string, boolean>}
+         * @private
+         */
+        this._pendingMuteUpdates = new Map();
+
         /**
          * A map which stores local tracks mapped by {@link JitsiLocalTrack.rtcId}
          * @type {Map<number, JitsiLocalTrack>}
@@ -1203,11 +1211,14 @@ export default class TraceablePeerConnection {
         const track = this.getRemoteTracks().slice().reverse().find(t => t.getSourceName() === sourceName);
 
         if (!track) {
-            logger.debug(`Remote track not found for source=${sourceName}, mute update failed!`);
+            // Store the pending mute update to be applied when the track is created
+            this._pendingMuteUpdates.set(sourceName, isMuted);
 
             return;
         }
 
+        // Clear any pending mute update since we're applying the current state to an existing track
+        this._pendingMuteUpdates.delete(sourceName);
         track.setMute(isMuted);
     }
 
@@ -1692,6 +1703,14 @@ export default class TraceablePeerConnection {
             userTracksByMediaType.add(remoteTrack);
         }
 
+        // Store pending mute update on the track itself so JitsiConference can apply it after attaching listeners
+        if (this._pendingMuteUpdates.has(sourceName)) {
+            const pendingMutedState = this._pendingMuteUpdates.get(sourceName);
+
+            remoteTrack._setPendingMuteState(pendingMutedState);
+            this._pendingMuteUpdates.delete(sourceName);
+        }
+
         this.eventEmitter.emit(RTCEvents.REMOTE_TRACK_ADDED, remoteTrack, this);
     }