sem/5g_drone_ROS2
1
0
Fork 0
Code Issues 1 Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix sse?

Browse Source
This commit is contained in:
Sem van der Hoeven
2023-05-30 22:30:25 +02:00
parent 294e45b9b7
commit 7a7d0c4f01
1 changed files with 7 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
api/index.js
View File

@@ -18,9 +18,11 @@ var ws;
var api_connected = false; var api_connected = false;
function send_events_to_clients(data) { function send_events_to_clients(data) {
console.log("sending events to clients"); console.log("sending events to clients");
sse_clients.forEach((client) => sse_clients.forEach((client) => {
client.response.write(`${JSON.stringify(data)}\n\n`) 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) { ws.on("message", function message(message) {
try { try {
var msg = JSON.parse(message); var msg = JSON.parse(message);
send_events_to_clients(msg); send_events_to_clients(msg);
} catch (error) { } catch (error) {
console.log("could not parse as json"); console.log("could not parse as json");
} }