Added ice restart (#205)

ionorg · Oct 24, 2021 · a1f8afb · a1f8afb
1 parent 1e76031
commit a1f8afb
Showing 1 changed file with 10 additions and 2 deletions.
diff --git a/src/client.ts b/src/client.ts
@@ -177,6 +177,10 @@ export default class Client {
     stream.publish(this.transports[Role.pub]);
   }
 
+  restartIce() {
+    this.renegotiate(true)
+  }
+
   createDataChannel(label: string) {
     if (!this.transports) {
       throw Error(ERR_NO_SESSION);
@@ -222,15 +226,19 @@ export default class Client {
     }
   }
 
-  private async onNegotiationNeeded() {
+  private onNegotiationNeeded() {
+    this.renegotiate(false)
+  }
+
+  private async renegotiate(iceRestart: boolean) {
     if (!this.transports) {
       throw Error(ERR_NO_SESSION);
     }
 
     let offer: RTCSessionDescriptionInit | undefined;
     let answer: RTCSessionDescriptionInit | undefined;
     try {
-      offer = await this.transports[Role.pub].pc.createOffer();
+      offer = await this.transports[Role.pub].pc.createOffer({ iceRestart });
       await this.transports[Role.pub].pc.setLocalDescription(offer);
       answer = await this.signal.offer(offer);
       await this.transports[Role.pub].pc.setRemoteDescription(answer);