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

sse stuff

Browse Source
This commit is contained in:
Sem van der Hoeven
2023-05-30 22:20:42 +02:00
parent e6e1b11369
commit 6c0aa9e15f
2 changed files with 28 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files

36
api/index.js
View File

@@ -18,29 +18,33 @@ var ws;
var api_connected = false; var api_connected = false;
function send_events_to_clients(data) { function send_events_to_clients(data) {
sse_clients.forEach(client => client.response.write(`data: ${JSON.stringify(data)}\n\n`)); sse_clients.forEach((client) =>
client.response.write(`data: ${JSON.stringify(data)}\n\n`)
);
} }
function handle_sse_client(request, response, next) { function handle_sse_client(request, response, next) {
console.log("handling sse client");
const headers = { const headers = {
"Content-Type": "text/event-stream", "Content-Type": "text/event-stream",
'Connection': "keep-alive", Connection: "keep-alive",
"Cache-Control": "no-cache", "Cache-Control": "no-cache",
}; };
// response.writeHead(200, headers);
// response.write("yeet\n\n");
const clientID = Date.now();
const newClient = {
id: clientID,
response
};
sse_clients.push(newClient); response.writeHead(200, headers);
response.write(JSON.stringify("yeet") + "\n\n");
const clientID = Date.now();
const newClient = {
id: clientID,
response,
};
request.on("close", () => { sse_clients.push(newClient);
console.log(`${clientID} Connection closed`);
sse_clients = sse_clients.filter(client => client.id !== clientID); request.on("close", () => {
}); console.log(`${clientID} Connection closed`);
sse_clients = sse_clients.filter((client) => client.id !== clientID);
});
} }
var connect_to_api = function () { var connect_to_api = function () {
@@ -56,8 +60,8 @@ var connect_to_api = function () {
try { try {
var msg = JSON.parse(message); var msg = JSON.parse(message);
if (msg.type == "STATUS") { if (msg.type == "STATUS") {
last_status = msg.data; last_status = msg.data;
send_events_to_clients(message); send_events_to_clients(message);
} else if (msg.type == "IMAGE") { } else if (msg.type == "IMAGE") {
console.log("got picture"); console.log("got picture");
// console.log(msg.image); // console.log(msg.image);

14
api/views/index.ejs
View File

@@ -60,12 +60,14 @@
<script> <script>
var update_status = setInterval(update_status, 1000); var update_status = setInterval(update_status, 1000);
assign_button_callbacks(); assign_button_callbacks();
const events = new EventSource("/events"); window.onload = function () {
events.onmessage = (event) => { const events = new EventSource("/events");
const parsedData = JSON.parse(event.data); events.onmessage = (event) => {
console.log("RECEIVED EVENT"); const parsedData = JSON.parse(event.data);
console.log(parsedData); console.log("RECEIVED EVENT");
} console.log(parsedData);
}
};
function assign_button_callbacks() { function assign_button_callbacks() {
var buttons = document.getElementsByClassName("movebutton"); var buttons = document.getElementsByClassName("movebutton");