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

add connect function

Browse Source
This commit is contained in:
Sem van der Hoeven
2023-05-30 10:40:19 +02:00
parent a6226ef99a
commit fe958e7e05
1 changed files with 26 additions and 23 deletions
Download Patch File Download Diff File Expand all files Collapse all files

49
api/index.js
View File

@@ -13,30 +13,32 @@ app.use(express.json());
var ws; var ws;
var api_connected = false; var api_connected = false;
ws.on("open", function open() { var connect_to_api = function () {
console.log("connected with websockets to API!"); ws = new WebSocket("ws://10.100.0.40:9001/");
api_connected = true;
});
ws.on("message", function message(message) { ws.on("open", function open() {
var msg = JSON.parse(message); console.log("connected with websockets to API!");
if (msg.type == "STATUS") { api_connected = true;
last_status = msg.data; });
} else if (msg.type == "IMAGE") {
console.log("got picture"); ws.on("message", function message(message) {
console.log(msg.image); var msg = JSON.parse(message);
last_image = msg.image; if (msg.type == "STATUS") {
received_picture = true; last_status = msg.data;
} } else if (msg.type == "IMAGE") {
console.log("got picture");
console.log(msg.image);
last_image = msg.image;
received_picture = true;
}
});
ws.on("error", function error(err) {
console.error("error: " + err);
received_error = true;
});
}
// console.log("got type: " + msg.type);
// console.log("RECEIVED: " + msg.data);
});
ws.on("error", function error(err) {
console.error("error: " + err);
received_error = true;
});
// set the view engine to ejs // set the view engine to ejs
app.set("view engine", "ejs"); app.set("view engine", "ejs");
@@ -77,11 +79,12 @@ app.post("/move", function (req, res) {
app.get("/connect", function (req, res) { app.get("/connect", function (req, res) {
console.log("got connect request"); console.log("got connect request");
ws = new WebSocket("ws://10.100.0.40:9001/"); connect_to_api();
while (api_connected == false && received_error == false) { } while (api_connected == false && received_error == false) { }
if (api_connected) { if (api_connected) {
res.status(200).json({ connected: true }); res.status(200).json({ connected: true });
} else { } else {
received_error = false;
res.status(400).json({ connected: false }); res.status(400).json({ connected: false });
} }