diff --git a/public/main.js b/public/main.js index 307c724..7b3c8ad 100644 --- a/public/main.js +++ b/public/main.js @@ -12,7 +12,14 @@ ws.onmessage = (event) => { function sendMessage() { const text = input.value; if (text.trim()) { - ws.send(text); + ws.send( + JSON.stringify({ + type: "send", + data: { + content: text, + }, + }), + ); input.value = ""; } } diff --git a/src/sockets/chatSocket.js b/src/sockets/chatSocket.js index e8b6867..de7006d 100644 --- a/src/sockets/chatSocket.js +++ b/src/sockets/chatSocket.js @@ -4,7 +4,16 @@ function setupChatSocket(wss) { wss.on("connection", (ws) => { ws.send("Welcome."); ws.on("message", (message) => { - chatService.broadcast(wss, message, ws); + const data = JSON.parse(message); + if (data["type"] === "send") { + const sendEventPacket = JSON.stringify({ + type: "send-event", + data: { + content: data["data"]["content"], + }, + }); + chatService.broadcast(wss, sendEventPacket, ws); + } }); }); }