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"); }