Configure TURN server only once

src/webrtc/webRTCEndpoint.ts

@@ -560,12 +560,7 @@ export class WebRTCEndpoint<EndpointMetadata = any, TrackMetadata = any> extends
     let data;
     switch (deserializedMediaEvent.type) {
       case "offerData": {
-        const turnServers = deserializedMediaEvent.data.integratedTurnServers;
-        this.setTurns(turnServers);
-
-        const offerData = new Map<string, number>(Object.entries(deserializedMediaEvent.data.tracksTypes));
-
-        this.onOfferData(offerData);
+        this.onOfferData(deserializedMediaEvent);
         break;
       }
       case "tracksAdded": {
@@ -1678,8 +1673,11 @@ export class WebRTCEndpoint<EndpointMetadata = any, TrackMetadata = any> extends
   private checkIfTrackBelongToEndpoint = (trackId: string, endpoint: Endpoint<EndpointMetadata, TrackMetadata>) =>
     Array.from(endpoint.tracks.keys()).some((track) => trackId.startsWith(track));
 
-  private onOfferData = async (offerData: Map<string, number>) => {
+  private onOfferData = async (offerData: MediaEvent) => {
     if (!this.connection) {
+      const turnServers = offerData.data.integratedTurnServers;
+      this.setTurns(turnServers);
+
       this.connection = new RTCPeerConnection(this.rtcConfig);
       this.connection.onicecandidate = this.onLocalCandidate();
       this.connection.onicecandidateerror = this.onIceCandidateError as (event: Event) => void;
@@ -1692,10 +1690,15 @@ export class WebRTCEndpoint<EndpointMetadata = any, TrackMetadata = any> extends
 
       this.connection.getTransceivers().forEach((transceiver) => (transceiver.direction = "sendonly"));
     } else {
+      console.log(JSON.stringify(this.connection.getConfiguration()));
       this.connection.restartIce();
+      console.log("ICE restarted");
+      console.log(JSON.stringify(this.connection.getConfiguration()));
     }
 
-    this.addTransceiversIfNeeded(offerData);
+    const tracks = new Map<string, number>(Object.entries(offerData.data.tracksTypes));
+
+    this.addTransceiversIfNeeded(tracks);
 
     await this.createAndSendOffer();
   };