Update app.js

app.js

@@ -1,162 +1,98 @@
-// server.js
-const path = require('path');
 const express = require('express');
 const http = require('http');
 const WebSocket = require('ws');
-const mediasoup = require('mediasoup');
 
 const app = express();
-const PORT = 7860;
-
-// Serve static files from ./public
-app.use(express.static(path.join(__dirname, 'public')));
-
-let worker, router;
-const producerTransports = new Map(); // ws → { transport, producer }
-const consumerTransports = new Map(); // ws → [ { transport, consumer } ]
-
-;(async () => {
-  // 1) Create the mediasoup Worker + Router
-  worker = await mediasoup.createWorker();
-  router = await worker.createRouter({
-    mediaCodecs: [
-      { kind: 'audio', mimeType: 'audio/opus', clockRate: 48000, channels: 2 },
-      { kind: 'video', mimeType: 'video/VP8', clockRate: 90000 }
-    ]
-  });
-
-  // 2) Expose RTP capabilities via HTTP for the clients
-  app.get('/rtpCapabilities', (req, res) => {
-    res.json({ rtpCapabilities: router.rtpCapabilities });
-  });
-
-  // 3) Create HTTP + WebSocket server
-  const server = http.createServer(app);
-  const wss = new WebSocket.Server({ server });
-
-  wss.on('connection', ws => {
-    ws.on('message', async msg => {
-      const { action, data } = JSON.parse(msg);
-
-      switch (action) {
-        case 'createProducerTransport': {
-          const transport = await router.createWebRtcTransport({
-            // listenIps: ['0.0.0.0'],
-            listenIps: ['127.0.0.1'],
-            enableUdp: true,
-            enableTcp: true
-          });
-          producerTransports.set(ws, { transport, producer: null });
-          ws.send(JSON.stringify({
-            action: 'producerTransportCreated',
-            data: {
-              id: transport.id,
-              iceParameters: transport.iceParameters,
-              iceCandidates: transport.iceCandidates,
-              dtlsParameters: transport.dtlsParameters
-            }
-          }));
-          break;
-        }
-
-        case 'connectProducerTransport': {
-          const { dtlsParameters } = data;
-          const { transport } = producerTransports.get(ws);
-          await transport.connect({ dtlsParameters });
-          ws.send(JSON.stringify({ action: 'producerTransportConnected' }));
-          break;
-        }
-
-        case 'produce': {
-          const { kind, rtpParameters } = data;
-          const { transport } = producerTransports.get(ws);
-          const producer = await transport.produce({ kind, rtpParameters });
-          producerTransports.get(ws).producer = producer;
-          ws.send(JSON.stringify({
-            action: 'produced',
-            data: { producerId: producer.id }
-          }));
-          break;
-        }
-
-        case 'createConsumerTransport': {
-          const transport = await router.createWebRtcTransport({
-            // listenIps: ['0.0.0.0'],
-            listenIps: ['127.0.0.1'],
-            enableUdp: true,
-            enableTcp: true
-          });
-          const arr = consumerTransports.get(ws) || [];
-          arr.push({ transport, consumer: null });
-          consumerTransports.set(ws, arr);
-          ws.send(JSON.stringify({
-            action: 'consumerTransportCreated',
-            data: {
-              id: transport.id,
-              iceParameters: transport.iceParameters,
-              iceCandidates: transport.iceCandidates,
-              dtlsParameters: transport.dtlsParameters
-            }
-          }));
-          break;
-        }
-
-        case 'connectConsumerTransport': {
-          const { dtlsParameters } = data;
-          const arr = consumerTransports.get(ws);
-          await arr[arr.length - 1].transport.connect({ dtlsParameters });
-          ws.send(JSON.stringify({ action: 'consumerTransportConnected' }));
-          break;
-        }
-
-        case 'consume': {
-          const producerEntry = [...producerTransports.values()].find(e => e.producer);
-          if (!producerEntry) {
-            ws.send(JSON.stringify({ action: 'consumeError', data: 'No producer available yet' }));
-            return;
-          }
-          const producer = producerEntry.producer;
-          const arr = consumerTransports.get(ws);
-          const { transport } = arr[arr.length - 1];
-
-          const consumer = await transport.consume({
-            producerId: producer.id,
-            rtpCapabilities: router.rtpCapabilities,
-            paused: false
-          });
-          arr[arr.length - 1].consumer = consumer;
-
-          ws.send(JSON.stringify({
-            action: 'consumed',
-            data: {
-              producerId: producer.id,
-              id: consumer.id,
-              kind: consumer.kind,
-              rtpParameters: consumer.rtpParameters
-            }
-          }));
-          break;
-        }
+const server = http.createServer(app);
+const wss = new WebSocket.Server({ server });
+
+const rooms = new Map();
+
+app.get('/', (req, res) => {
+  res.send(`<!doctype html>
+<html>
+<head>
+  <title>Dubem Realtime Rooms</title>
+</head>
+<body style="font-family:sans-serif">
+  <h2>Join a Room & Send Messages</h2>
+  <input id="room" placeholder="Room ID" />
+  <button onclick="joinRoom()">Join Room</button>
+  <div id="log"></div>
+  <input id="msg" placeholder="Type a message" />
+  <button onclick="sendMsg()">Send</button>
+
+  <script>
+    let ws, currentRoom = null;
+
+    function joinRoom() {
+      const roomId = document.getElementById('room').value;
+      ws = new WebSocket('ws://' + location.host);
+      ws.onopen = () => {
+        ws.send(JSON.stringify({ action: 'join', roomId }));
+        currentRoom = roomId;
+        log('Joined room: ' + roomId);
+      };
+      ws.onmessage = ({ data }) => {
+        const msg = JSON.parse(data);
+        log('[' + msg.roomId + '] ' + msg.message);
+      };
+      ws.onclose = () => log('Disconnected.');
+    }
+
+    function sendMsg() {
+      const txt = document.getElementById('msg').value;
+      if (ws && currentRoom) {
+        ws.send(JSON.stringify({ action: 'post', roomId: currentRoom, message: txt }));
       }
-    });
-
-    ws.on('close', () => {
-      // Clean up transports & producers/consumers for this ws
-      const pEntry = producerTransports.get(ws);
-      if (pEntry) {
-        pEntry.producer?.close();
-        pEntry.transport.close();
-        producerTransports.delete(ws);
+    }
+
+    function log(t) {
+      document.getElementById('log').innerHTML += '<p>' + t + '</p>';
+    }
+  </script>
+</body>
+</html>`);
+});
+
+wss.on('connection', ws => {
+  let currentRoom = null;
+
+  ws.on('message', raw => {
+    let msg;
+    try { msg = JSON.parse(raw); } catch (e) { return; }
+
+    if (msg.action === 'join' && msg.roomId) {
+      if (currentRoom && rooms.has(currentRoom)) {
+        rooms.get(currentRoom).delete(ws);
       }
-      const cEntries = consumerTransports.get(ws) || [];
-      cEntries.forEach(({ consumer, transport }) => {
-        consumer?.close();
-        transport.close();
+      currentRoom = msg.roomId;
+      if (!rooms.has(currentRoom)) rooms.set(currentRoom, new Set());
+      rooms.get(currentRoom).add(ws);
+    }
+
+    if (msg.action === 'post' && msg.roomId && msg.message) {
+      const clients = rooms.get(msg.roomId);
+      if (!clients) return;
+      const payload = JSON.stringify({
+        roomId: msg.roomId,
+        message: msg.message,
+        timestamp: Date.now()
       });
-      consumerTransports.delete(ws);
-    });
+      for (const client of clients) {
+        if (client.readyState === WebSocket.OPEN) {
+          client.send(payload);
+        }
+      }
+    }
+  });
+
+  ws.on('close', () => {
+    if (currentRoom && rooms.has(currentRoom)) {
+      rooms.get(currentRoom).delete(ws);
+    }
   });
+});
 
-  // 4) Start the server
-  server.listen(PORT, () => console.log(`SFU demo listening on http://localhost:${PORT}`));
-})();
+const PORT = process.env.PORT || 7860;
+server.listen(PORT, () => console.log(\`✅ Activity server running at http://localhost:\${PORT}/\`));