const WebSocket = require("ws");

// Starte den WebSocket-Server auf Port 3001
const wss = new WebSocket.Server({ port: 3001 });

wss.on("connection", (ws) => {
  console.log("New WebSocket connection");

  ws.on("message", (message) => {
    // Konvertiere den Buffer in einen String
    const messageString = message.toString();

    console.log("Received:", messageString);

    // Versuche die Nachricht in JSON zu parsen
    try {
      const parsedMessage = JSON.parse(messageString);

      // Beispielnachricht an den Client zurücksenden
      if (parsedMessage.type === "test") {
        ws.send(JSON.stringify({ message: `Hallo zurück, ${parsedMessage.message}` }));
      }
    } catch (error) {
      console.error("Fehler beim Parsen der Nachricht:", error);
    }
  });

  ws.on("close", () => {
    console.log("WebSocket connection closed");
  });
});

console.log("WebSocket-Server läuft auf ws://localhost:3001");