This commit is contained in:
Sem van der Hoeven
2023-05-30 22:33:15 +02:00
parent 7a7d0c4f01
commit 1c8229ad98
2 changed files with 9 additions and 7 deletions

View File

@@ -18,7 +18,7 @@ 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("event: message\n"); client.response.write("event: message\n");
client.response.write("data:" + JSON.stringify(data) + "\n\n") client.response.write("data:" + JSON.stringify(data) + "\n\n")
@@ -62,7 +62,12 @@ 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);
if (msg.type != "IMAGE") {
send_events_to_clients(msg); send_events_to_clients(msg);
} else {
console.log("got image");
//TODO handle image
}
} catch (error) { } catch (error) {
console.log("could not parse as json"); console.log("could not parse as json");
} }
@@ -85,10 +90,6 @@ app.get("/", function (req, res) {
res.render("index", { api_connected: api_connected }); res.render("index", { api_connected: api_connected });
}); });
app.get("/status", function (req, res) {
res.status(200).json(last_status);
});
app.get("/events", handle_sse_client); app.get("/events", handle_sse_client);
app.get("/image", function (req, res) { app.get("/image", function (req, res) {

View File

@@ -68,6 +68,7 @@
} }
events.onmessage = (event) => { events.onmessage = (event) => {
//TODO handling status, failsafe etc
const parsedData = JSON.parse(event.data); const parsedData = JSON.parse(event.data);
console.log("RECEIVED EVENT"); console.log("RECEIVED EVENT");
console.log(parsedData); console.log(parsedData);