Allow setting RtpEncodingParameters for individual encodings

lib/Producer.d.ts

@@ -144,7 +144,7 @@ export declare class Producer extends EnhancedEventEmitter {
     /**
      * Sets the DSCP value.
      */
-    setRtpEncodingParameters(params: RTCRtpEncodingParameters): Promise<void>;
+    setRtpEncodingParameters(params: RTCRtpEncodingParameters, idx?: number): Promise<void>;
     private _onTrackEnded;
     private _handleTrack;
     private _destroyTrack;

lib/Producer.js

@@ -252,12 +252,12 @@ class Producer extends EnhancedEventEmitter_1.EnhancedEventEmitter {
     /**
      * Sets the DSCP value.
      */
-    async setRtpEncodingParameters(params) {
+    async setRtpEncodingParameters(params, idx) {
         if (this._closed)
             throw new errors_1.InvalidStateError('closed');
         else if (typeof params !== 'object')
             throw new TypeError('invalid params');
-        await this.safeEmitAsPromise('@setrtpencodingparameters', params);
+        await this.safeEmitAsPromise('@setrtpencodingparameters', params, idx);
     }
     _onTrackEnded() {
         logger.debug('track "ended" event');

lib/Transport.js

@@ -494,8 +494,8 @@ class Transport extends EnhancedEventEmitter_1.EnhancedEventEmitter {
                 .then(callback)
                 .catch(errback);
         });
-        producer.on('@setrtpencodingparameters', (params, callback, errback) => {
-            this._awaitQueue.push(async () => (this._handler.setRtpEncodingParameters(producer.localId, params)), 'producer @setrtpencodingparameters event')
+        producer.on('@setrtpencodingparameters', (params, idx, callback, errback) => {
+            this._awaitQueue.push(async () => (this._handler.setRtpEncodingParameters(producer.localId, params, idx)), 'producer @setrtpencodingparameters event')
                 .then(callback)
                 .catch(errback);
         });

lib/handlers/Chrome55.d.ts

@@ -32,7 +32,7 @@ export declare class Chrome55 extends HandlerInterface {
     stopSending(localId: string): Promise<void>;
     replaceTrack(localId: string, track: MediaStreamTrack | null): Promise<void>;
     setMaxSpatialLayer(localId: string, spatialLayer: number): Promise<void>;
-    setRtpEncodingParameters(localId: string, params: any): Promise<void>;
+    setRtpEncodingParameters(localId: string, params: any, idx?: number): Promise<void>;
     getSenderStats(localId: string): Promise<RTCStatsReport>;
     sendDataChannel({ ordered, maxPacketLifeTime, maxRetransmits, label, protocol }: HandlerSendDataChannelOptions): Promise<HandlerSendDataChannelResult>;
     receive({ trackId, kind, rtpParameters }: HandlerReceiveOptions): Promise<HandlerReceiveResult>;

lib/handlers/Chrome55.js

@@ -293,7 +293,7 @@ class Chrome55 extends HandlerInterface_1.HandlerInterface {
         throw new errors_1.UnsupportedError(' not implemented');
     }
     // eslint-disable-next-line @typescript-eslint/no-unused-vars
-    async setRtpEncodingParameters(localId, params) {
+    async setRtpEncodingParameters(localId, params, idx) {
         throw new errors_1.UnsupportedError('not supported');
     }
     // eslint-disable-next-line @typescript-eslint/no-unused-vars

lib/handlers/Chrome67.d.ts

@@ -32,7 +32,7 @@ export declare class Chrome67 extends HandlerInterface {
     stopSending(localId: string): Promise<void>;
     replaceTrack(localId: string, track: MediaStreamTrack | null): Promise<void>;
     setMaxSpatialLayer(localId: string, spatialLayer: number): Promise<void>;
-    setRtpEncodingParameters(localId: string, params: any): Promise<void>;
+    setRtpEncodingParameters(localId: string, params: any, idx?: number): Promise<void>;
     getSenderStats(localId: string): Promise<RTCStatsReport>;
     sendDataChannel({ ordered, maxPacketLifeTime, maxRetransmits, label, protocol }: HandlerSendDataChannelOptions): Promise<HandlerSendDataChannelResult>;
     receive({ trackId, kind, rtpParameters }: HandlerReceiveOptions): Promise<HandlerReceiveResult>;

lib/handlers/Chrome67.js

@@ -322,16 +322,21 @@ class Chrome67 extends HandlerInterface_1.HandlerInterface {
         });
         await rtpSender.setParameters(parameters);
     }
-    async setRtpEncodingParameters(localId, params) {
+    async setRtpEncodingParameters(localId, params, idx) {
         this._assertSendDirection();
         logger.debug('setRtpEncodingParameters() [localId:%s, params:%o]', localId, params);
         const rtpSender = this._mapSendLocalIdRtpSender.get(localId);
         if (!rtpSender)
             throw new Error('associated RTCRtpSender not found');
         const parameters = rtpSender.getParameters();
-        parameters.encodings.forEach((encoding, idx) => {
-            parameters.encodings[idx] = Object.assign(Object.assign({}, encoding), params);
-        });
+        if (idx == null) {
+            parameters.encodings.forEach((encoding, idx) => {
+                parameters.encodings[idx] = Object.assign(Object.assign({}, encoding), params);
+            });
+        }
+        else {
+            parameters.encodings[idx] = Object.assign(Object.assign({}, parameters.encodings[idx]), params);
+        }
         await rtpSender.setParameters(parameters);
     }
     async getSenderStats(localId) {