Add loop_index configuration for janus (#49)

networked-aframe · Jun 21, 2023 · 07616e3 · 07616e3
1 parent 88f66e6
commit 07616e3
Show file tree

Hide file tree

Showing 2 changed files with 54 additions and 2 deletions.
diff --git a/package-lock.json b/package-lock.json
diff --git a/src/index.js b/src/index.js
@@ -175,6 +175,10 @@ class JanusAdapter {
     this.onReconnectionError = reconnectionErrorListener;
   }
 
+  setEventLoops(loops) {
+    this.loops = loops;
+  }
+
   connect() {
     debug(`connecting to ${this.serverUrl}`);
 
@@ -440,7 +444,7 @@ class JanusAdapter {
     var conn = new RTCPeerConnection(this.peerConnectionConfig || DEFAULT_PEER_CONNECTION_CONFIG);
 
     debug("pub waiting for sfu");
-    await handle.attach("janus.plugin.sfu");
+    await handle.attach("janus.plugin.sfu", this.loops && this.clientId ? parseInt(this.clientId) % this.loops : undefined);
 
     this.associate(conn, handle);
 
@@ -580,7 +584,7 @@ class JanusAdapter {
     var conn = new RTCPeerConnection(this.peerConnectionConfig || DEFAULT_PEER_CONNECTION_CONFIG);
 
     debug(occupantId + ": sub waiting for sfu");
-    await handle.attach("janus.plugin.sfu");
+    await handle.attach("janus.plugin.sfu", this.loops ? parseInt(occupantId) % this.loops : undefined);
 
     this.associate(conn, handle);