server.js

import http from "http";
import { WebSocketServer } from "ws";

const wss = new WebSocketServer({ port: 8080 });

console.log("WebSocket server running on ws://localhost:8080");

wss.on("connection", ws => {
  ws.send(JSON.stringify({ message: "Welcome to realtime server!" }));

  ws.on("message", raw => {
    const data = JSON.parse(raw);
    console.log("Message received:", data);

    // Broadcast to all clients
    wss.clients.forEach(client => {
      if (client.readyState === ws.OPEN) {
        client.send(JSON.stringify(data));
      }
    });
  });
});

const server = http.createServer((req, res) => {
  if (req.method === "POST" && req.url === "/broadcast") {
    console.log("Received broadcast request");
    let body = "";

    req.on("data", chunk => body += chunk);
    req.on("end", () => {

      try {
        const data = JSON.parse(body);
        console.log("data to broadcast:", data);
        console.log("Number of connected clients:", wss.clients.size);
        // broadcast to all ws clients
        wss.clients.forEach(client => {
          console.log("Broadcasting to client");
          client.send(JSON.stringify(data));
        });

        res.writeHead(200);
        res.end("OK");
      } catch (e) {
        res.writeHead(400);
        res.end("Invalid JSON..." + e.message);
      }
    });
  }
});

server.listen(3001, () => {
  console.log("HTTP endpoint: http://localhost:3001/broadcast");
});

/*
setInterval(() => {
  const message = {
    type: "task-created",
    task: {
      id: Math.floor(Math.random() * 1000),
      title: "New Task " + Date.now(),
      x: (new Date()).toLocaleTimeString(),
      y: Math.floor(Math.random() * 500)
    }
  };

  for (const client of wss.clients) {
    client.send(JSON.stringify(message));
  }
}, 1000);
*/