Update app.js

app.js

@@ -1,54 +1,57 @@
 const express = require('express');
 const app = express();
 const bodyParser = require('body-parser');
-const webrtc = require('wrtc');
+const webrtc = require("wrtc");
 
-// Instead of one global stream, keep one per room
-const roomStreams = {};  // { [roomId]: MediaStream }
+let senderStream;
 
 app.use(express.static('public'));
 app.use(bodyParser.json());
 app.use(bodyParser.urlencoded({ extended: true }));
 
-// Consumer endpoint: front-end must POST { sdp, roomId }
 app.post("/consumer", async ({ body }, res) => {
-  const { sdp, roomId } = body;
-  const stream = roomStreams[roomId];
-  if (!stream) {
-    return res.status(404).json({ error: "No broadcast for room " + roomId });
-  }
-
-  const peer = new webrtc.RTCPeerConnection({
-    iceServers: [{ urls: "stun:stun.stunprotocol.org" }]
-  });
-
-  // add the broadcaster’s tracks for this room
-  stream.getTracks().forEach(track => peer.addTrack(track, stream));
-
-  await peer.setRemoteDescription(new webrtc.RTCSessionDescription(sdp));
-  const answer = await peer.createAnswer();
-  await peer.setLocalDescription(answer);
-
-  res.json({ sdp: peer.localDescription });
+    const peer = new webrtc.RTCPeerConnection({
+        iceServers: [
+            {
+                urls: "stun:stun.stunprotocol.org"
+            }
+        ]
+    });
+    const desc = new webrtc.RTCSessionDescription(body.sdp);
+    await peer.setRemoteDescription(desc);
+    senderStream.getTracks().forEach(track => peer.addTrack(track, senderStream));
+    const answer = await peer.createAnswer();
+    await peer.setLocalDescription(answer);
+    const payload = {
+        sdp: peer.localDescription
+    }
+
+    res.json(payload);
 });
 
-// Broadcast endpoint: front-end must POST { sdp, roomId }
-app.post("/broadcast", async ({ body }, res) => {
-  const { sdp, roomId } = body;
-  const peer = new webrtc.RTCPeerConnection({
-    iceServers: [{ urls: "stun:stun.stunprotocol.org" }]
-  });
-
-  peer.ontrack = ({ streams }) => {
-    // store the incoming stream under its roomId
-    roomStreams[roomId] = streams[0];
-  };
+app.post('/broadcast', async ({ body }, res) => {
+    const peer = new webrtc.RTCPeerConnection({
+        iceServers: [
+            {
+                urls: "stun:stun.stunprotocol.org"
+            }
+        ]
+    });
+    peer.ontrack = (e) => handleTrackEvent(e, peer);
+    const desc = new webrtc.RTCSessionDescription(body.sdp);
+    await peer.setRemoteDescription(desc);
+    const answer = await peer.createAnswer();
+    await peer.setLocalDescription(answer);
+    const payload = {
+        sdp: peer.localDescription
+    }
+
+    res.json(payload);
+});
 
-  await peer.setRemoteDescription(new webrtc.RTCSessionDescription(sdp));
-  const answer = await peer.createAnswer();
-  await peer.setLocalDescription(answer);
+function handleTrackEvent(e, peer) {
+    senderStream = e.streams[0];
+};
 
-  res.json({ sdp: peer.localDescription });
-});
 
-app.listen(7860, () => console.log('SFU server running on port 5000'));
+app.listen(5000, () => console.log('server started'));