Revert "fix(JitsiConference): handles mute state updates arriving before track creation (#2956)" (#2974)

This reverts commit 916ebe5.

Author: mihhu

JitsiConference.ts

@@ -3546,16 +3546,6 @@ 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,9 +47,7 @@ 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;
@@ -103,7 +101,6 @@ 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;
@@ -426,37 +423,6 @@ 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 .
      *
@@ -478,16 +444,10 @@ export default class JitsiRemoteTrack extends JitsiTrack {
      * @internal
      */
     setMute(value: boolean): void {
-        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) {
+        if (this._muted === value) {
             return;
         }
 
-        this._setMuteCalled = true;
-
         if (value) {
             this._hasBeenMuted = true;
         }

modules/RTC/TraceablePeerConnection.ts

@@ -157,7 +157,6 @@ export default class TraceablePeerConnection {
     private _pcId: string;
     private _remoteUfrag: string;
     private _signalingLayer: SignalingLayer;
-    private _pendingMuteUpdates: Map<string, boolean>;
     /**
      * @internal
      */
@@ -325,13 +324,6 @@ 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>}
@@ -1211,14 +1203,11 @@ export default class TraceablePeerConnection {
         const track = this.getRemoteTracks().slice().reverse().find(t => t.getSourceName() === sourceName);
 
         if (!track) {
-            // Store the pending mute update to be applied when the track is created
-            this._pendingMuteUpdates.set(sourceName, isMuted);
+            logger.debug(`Remote track not found for source=${sourceName}, mute update failed!`);
 
             return;
         }
 
-        // Clear any pending mute update since we're applying the current state to an existing track
-        this._pendingMuteUpdates.delete(sourceName);
         track.setMute(isMuted);
     }
 
@@ -1703,14 +1692,6 @@ 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);
     }