Add files via upload

server.js

@@ -0,0 +1,65 @@
+require("dotenv").config();
+const express = require("express");
+const http = require("http");
+const { Server } = require("socket.io");
+const path = require("path");
+
+const app = express();
+const server = http.createServer(app);
+const io = new Server(server, {
+  path: process.env.SOCKET_IO_PATH || "/socket.io", // Custom socket.io path
+});
+
+// Serve static files from the public directory
+app.use(express.static(path.join(__dirname, process.env.STATIC_FILES_PATH || "public")));
+
+let expectedResponses = 0; // Number of connected clients
+let receivedResponses = 0; // Number of clients that acknowledged an action
+let emitData = {}; // Data to synchronize across clients
+
+// Serve the main HTML file
+app.get("/", (req, res) => {
+  res.sendFile(path.join(__dirname, "index.html"));
+});
+
+// Handle socket.io connections
+io.on("connection", (socket) => {
+  console.log(`User connected: ${socket.id}`);
+
+  // Listen for the user's name
+  socket.on("setName", (name) => {
+    socket.data.name = name; // Store the user's name in the socket object
+    expectedResponses++;
+    io.emit("notification", { message: `${name} connected`, color: "green" });
+  });
+
+  // Handle actions (e.g., play/pause, seek)
+  socket.on("action", (data) => {
+    io.emit("make", data); // Broadcast the action to all clients
+    emitData = data; // Save the action data
+    receivedResponses = 0; // Reset the acknowledgment counter
+  });
+
+  // Handle acknowledgment from clients
+  socket.on("ok", (receivedData) => {
+    if (JSON.stringify(receivedData) === JSON.stringify(emitData)) {
+      receivedResponses++;
+      if (receivedResponses === expectedResponses) {
+        io.emit("allOk", emitData); // Notify all clients that everyone is synchronized
+      }
+    }
+  });
+
+  // Handle disconnections
+  socket.on("disconnect", () => {
+    const name = socket.data.name || "Unknown User";
+    console.log(`User disconnected: ${name}`);
+    expectedResponses--;
+    io.emit("notification", { message: `${name} disconnected`, color: "red" });
+  });
+});
+
+// Start the server
+server.listen(process.env.PORT || 3000, () => {
+  console.log(`Listening on *:${process.env.PORT || 3000}`);
+});