shitted this out in 5 mins

server.js

@@ -0,0 +1,45 @@
+const express = require("express");
+const app = express();
+const http = require("http");
+const server = http.createServer(app);
+const { Server } = require("socket.io");
+const io = new Server(server);
+
+app.use(express.static("public"));
+
+io.on("connection", (socket) => {
+  console.log("a user connected:", socket.id);
+
+  // When the broadcaster starts sharing
+  socket.on("broadcaster", () => {
+    socket.broadcast.emit("broadcaster");
+  });
+
+  // When a viewer joins
+  socket.on("viewer", () => {
+    socket.broadcast.emit("viewer", socket.id);
+  });
+
+  // WebRTC Signaling
+  socket.on("offer", (id, message) => {
+    socket.to(id).emit("offer", socket.id, message);
+  });
+
+  socket.on("answer", (id, message) => {
+    socket.to(id).emit("answer", socket.id, message);
+  });
+
+  socket.on("candidate", (id, message) => {
+    socket.to(id).emit("candidate", socket.id, message);
+  });
+
+  socket.on("disconnect", () => {
+    console.log("user disconnected", socket.id);
+    socket.broadcast.emit("disconnectPeer", socket.id);
+  });
+});
+
+const PORT = process.env.PORT || 3000;
+server.listen(PORT, () => {
+  console.log(`listening on *:${PORT}`);
+});