Merge branch 'hotfix/2022.3.2'

shiguredo · Feb 10, 2023 · 6a55d1a · 6a55d1a
2 parents de0e714 + fe054dd
commit 6a55d1a
Show file tree

Hide file tree

Showing 7 changed files with 57 additions and 12 deletions.
diff --git a/CHANGES.md b/CHANGES.md
@@ -11,6 +11,11 @@
 
 ## develop
 
+## 2022.3.2
+
+- [FIX] ミュート状態で接続すると、replace(Video|Audio)Track しても画像・音声データが送信されないのを修正
+    - @melpon
+
 ## 2022.3.1
 
 - [FIX] e2ee が有効で無い場合の判定は null かどうかに修正する

diff --git a/dist/base.d.ts b/dist/base.d.ts
@@ -145,6 +145,10 @@ export default class ConnectionBase {
      * Lyra インスタンス
      */
     private lyra?;
+    /**
+     * キーとなる sender が setupSenderTransform で初期化済みかどうか
+     */
+    private senderStreamInitialized;
     constructor(signalingUrlCandidates: string | string[], role: string, channelId: string, metadata: JSONType, options: ConnectionOptions, debug: boolean);
     /**
      * SendRecv Object で発火するイベントのコールバックを設定するメソッド

diff --git a/dist/sora.js b/dist/sora.js
@@ -1,7 +1,7 @@
 /**
  * sora-js-sdk
  * WebRTC SFU Sora JavaScript SDK
- * @version: 2022.3.1
+ * @version: 2022.3.2
  * @author: Shiguredo Inc.
  * @license: Apache-2.0
  **/
@@ -2252,7 +2252,7 @@
 	    }
 	    const message = {
 	        type: "connect",
-	        sora_client: "Sora JavaScript SDK 2022.3.1",
+	        sora_client: "Sora JavaScript SDK 2022.3.2",
 	        environment: window.navigator.userAgent,
 	        role: role,
 	        channel_id: channelId,
@@ -2598,6 +2598,10 @@
 	         * カスタム音声コーデックが有効になっていない場合には空のままとなる
 	         */
 	        this.midToAudioCodecType = new Map();
+	        /**
+	         * キーとなる sender が setupSenderTransform で初期化済みかどうか
+	         */
+	        this.senderStreamInitialized = new WeakSet();
 	        this.role = role;
 	        this.channelId = channelId;
 	        this.metadata = metadata;
@@ -2810,6 +2814,7 @@
 	        }
 	        stream.addTrack(audioTrack);
 	        await transceiver.sender.replaceTrack(audioTrack);
+	        await this.setupSenderTransform(transceiver.sender);
 	    }
 	    /**
 	     * video track を入れ替えするメソッド
@@ -2840,6 +2845,7 @@
 	        }
 	        stream.addTrack(videoTrack);
 	        await transceiver.sender.replaceTrack(videoTrack);
+	        await this.setupSenderTransform(transceiver.sender);
 	    }
 	    /**
 	     * connect 処理中に例外が発生した場合の切断処理をするメソッド
@@ -3741,6 +3747,10 @@
 	        if ((this.e2ee === null && this.lyra === undefined) || sender.track === null) {
 	            return;
 	        }
+	        // 既に初期化済み
+	        if (this.senderStreamInitialized.has(sender)) {
+	            return;
+	        }
 	        // TODO(sile): WebRTC Encoded Transform の型が提供されるようになったら ignore を外す
 	        // @ts-ignore
 	        // eslint-disable-next-line
@@ -3760,6 +3770,7 @@
 	        else {
 	            readable.pipeTo(senderStreams.writable).catch((e) => console.warn(e));
 	        }
+	        this.senderStreamInitialized.add(sender);
 	    }
 	    /**
 	     * E2EE あるいはカスタムコーデックが有効になっている場合に、受信側の WebRTC Encoded Transform をセットアップする
@@ -5154,7 +5165,7 @@
 	     * @public
 	     */
 	    version: function () {
-	        return "2022.3.1";
+	        return "2022.3.2";
 	    },
 	    /**
 	     * WebRTC のユーティリティ関数群

diff --git a/dist/sora.mjs b/dist/sora.mjs
@@ -1,7 +1,7 @@
 /**
  * sora-js-sdk
  * WebRTC SFU Sora JavaScript SDK
- * @version: 2022.3.1
+ * @version: 2022.3.2
  * @author: Shiguredo Inc.
  * @license: Apache-2.0
  **/
@@ -2246,7 +2246,7 @@ function createSignalingMessage(offerSDP, role, channelId, metadata, options, re
     }
     const message = {
         type: "connect",
-        sora_client: "Sora JavaScript SDK 2022.3.1",
+        sora_client: "Sora JavaScript SDK 2022.3.2",
         environment: window.navigator.userAgent,
         role: role,
         channel_id: channelId,
@@ -2592,6 +2592,10 @@ class ConnectionBase {
          * カスタム音声コーデックが有効になっていない場合には空のままとなる
          */
         this.midToAudioCodecType = new Map();
+        /**
+         * キーとなる sender が setupSenderTransform で初期化済みかどうか
+         */
+        this.senderStreamInitialized = new WeakSet();
         this.role = role;
         this.channelId = channelId;
         this.metadata = metadata;
@@ -2804,6 +2808,7 @@ class ConnectionBase {
         }
         stream.addTrack(audioTrack);
         await transceiver.sender.replaceTrack(audioTrack);
+        await this.setupSenderTransform(transceiver.sender);
     }
     /**
      * video track を入れ替えするメソッド
@@ -2834,6 +2839,7 @@ class ConnectionBase {
         }
         stream.addTrack(videoTrack);
         await transceiver.sender.replaceTrack(videoTrack);
+        await this.setupSenderTransform(transceiver.sender);
     }
     /**
      * connect 処理中に例外が発生した場合の切断処理をするメソッド
@@ -3735,6 +3741,10 @@ class ConnectionBase {
         if ((this.e2ee === null && this.lyra === undefined) || sender.track === null) {
             return;
         }
+        // 既に初期化済み
+        if (this.senderStreamInitialized.has(sender)) {
+            return;
+        }
         // TODO(sile): WebRTC Encoded Transform の型が提供されるようになったら ignore を外す
         // @ts-ignore
         // eslint-disable-next-line
@@ -3754,6 +3764,7 @@ class ConnectionBase {
         else {
             readable.pipeTo(senderStreams.writable).catch((e) => console.warn(e));
         }
+        this.senderStreamInitialized.add(sender);
     }
     /**
      * E2EE あるいはカスタムコーデックが有効になっている場合に、受信側の WebRTC Encoded Transform をセットアップする
@@ -5148,7 +5159,7 @@ var sora = {
      * @public
      */
     version: function () {
-        return "2022.3.1";
+        return "2022.3.2";
     },
     /**
      * WebRTC のユーティリティ関数群

diff --git a/package-lock.json b/package-lock.json
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "sora-js-sdk",
-  "version": "2022.3.1",
+  "version": "2022.3.2",
   "description": "WebRTC SFU Sora JavaScript SDK",
   "main": "dist/sora.js",
   "module": "dist/sora.mjs",

diff --git a/packages/sdk/src/base.ts b/packages/sdk/src/base.ts
@@ -197,6 +197,10 @@ export default class ConnectionBase {
    * Lyra インスタンス
    */
   private lyra?: LyraState;
+  /**
+   * キーとなる sender が setupSenderTransform で初期化済みかどうか
+   */
+  private senderStreamInitialized: WeakSet<RTCRtpSender> = new WeakSet();
 
   constructor(
     signalingUrlCandidates: string | string[],
@@ -421,6 +425,7 @@ export default class ConnectionBase {
     }
     stream.addTrack(audioTrack);
     await transceiver.sender.replaceTrack(audioTrack);
+    await this.setupSenderTransform(transceiver.sender);
   }
 
   /**
@@ -452,6 +457,7 @@ export default class ConnectionBase {
     }
     stream.addTrack(videoTrack);
     await transceiver.sender.replaceTrack(videoTrack);
+    await this.setupSenderTransform(transceiver.sender);
   }
 
   /**
@@ -1390,6 +1396,10 @@ export default class ConnectionBase {
     if ((this.e2ee === null && this.lyra === undefined) || sender.track === null) {
       return;
     }
+    // 既に初期化済み
+    if (this.senderStreamInitialized.has(sender)) {
+      return;
+    }
 
     // TODO(sile): WebRTC Encoded Transform の型が提供されるようになったら ignore を外す
     // @ts-ignore
@@ -1409,6 +1419,7 @@ export default class ConnectionBase {
     } else {
       readable.pipeTo(senderStreams.writable).catch((e) => console.warn(e));
     }
+    this.senderStreamInitialized.add(sender);
   }
 
   /**