From 7a7d0c4f01d8798b8c51776c1cd92ce7c03b52b7 Mon Sep 17 00:00:00 2001 From: Sem van der Hoeven Date: Tue, 30 May 2023 22:30:25 +0200 Subject: [PATCH] fix sse? --- api/index.js | 12 +++++++----- 1 file changed, 7 insertions(+), 5 deletions(-) diff --git a/api/index.js b/api/index.js index 60b357cc..2080333a 100644 --- a/api/index.js +++ b/api/index.js @@ -18,9 +18,11 @@ var ws; var api_connected = false; function send_events_to_clients(data) { - console.log("sending events to clients"); - sse_clients.forEach((client) => - client.response.write(`${JSON.stringify(data)}\n\n`) + console.log("sending events to clients"); + sse_clients.forEach((client) => { + client.response.write("event: message\n"); + client.response.write("data:" + JSON.stringify(data) + "\n\n") + } ); } @@ -59,8 +61,8 @@ var connect_to_api = function () { ws.on("message", function message(message) { try { - var msg = JSON.parse(message); - send_events_to_clients(msg); + var msg = JSON.parse(message); + send_events_to_clients(msg); } catch (error) { console.log("could not parse as json"); }