webrtc: fix reconnecting to server after a failure (#4022)

bluenviron · Jan 6, 2025 · 1342431 · 1342431
1 parent 6d7d0e6
commit 1342431
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/internal/servers/webrtc/publisher.js b/internal/servers/webrtc/publisher.js
@@ -264,7 +264,7 @@
       });
 
       this.pc.onicecandidate = (evt) => this.onLocalCandidate(evt);
-      this.pc.oniceconnectionstatechange = () => this.onConnectionState();
+      this.pc.onconnectionstatechange = () => this.onConnectionState();
 
       this.conf.stream.getTracks().forEach((track) => {
         this.pc.addTrack(track, this.conf.stream);
@@ -372,9 +372,9 @@
         return;
       }
 
-      if (this.pc.iceConnectionState === 'failed') {
+      if (this.pc.connectionState === 'failed') {
         this.handleError('peer connection closed');
-      } else if (this.pc.iceConnectionState === 'connected') {
+      } else if (this.pc.connectionState === 'connected') {
         if (this.conf.onConnected !== undefined) {
           this.conf.onConnected();
         }

diff --git a/internal/servers/webrtc/reader.js b/internal/servers/webrtc/reader.js
@@ -371,7 +371,7 @@
       this.pc.addTransceiver('audio', { direction });
 
       this.pc.onicecandidate = (evt) => this.onLocalCandidate(evt);
-      this.pc.oniceconnectionstatechange = () => this.onConnectionState();
+      this.pc.onconnectionstatechange = () => this.onConnectionState();
       this.pc.ontrack = (evt) => this.onTrack(evt);
 
       return this.pc.createOffer()
@@ -468,7 +468,7 @@
         return;
       }
 
-      if (this.pc.iceConnectionState === 'failed') {
+      if (this.pc.connectionState === 'failed') {
         this.handleError('peer connection closed');
       }
     };