diff --git a/src/C++/Driver/src/main.cpp b/src/C++/Driver/src/main.cpp index e5c7f22..aa0c5aa 100644 --- a/src/C++/Driver/src/main.cpp +++ b/src/C++/Driver/src/main.cpp @@ -27,9 +27,11 @@ int main() setup(); std::thread safety([&]() { robot.robotSafety(&message); }); std::thread sendMqtt([&]() { sendKobukiData(robot.parser.data); }); + while(true){ parseMQTT(readMQTT()); } + sendMqtt.join(); safety.join(); return 0; } diff --git a/src/Python/flask/web/app.py b/src/Python/flask/web/app.py index e49edcf..8f5ae04 100644 --- a/src/Python/flask/web/app.py +++ b/src/Python/flask/web/app.py @@ -23,6 +23,13 @@ def move(): mqtt_client.publish("home/commands", direction) # Het topic kan aangepast worden return jsonify({"status": "success", "direction": direction}) -# Run the Flask application in debug mode + + +@app.route('/data', methods=['GET']) +def data(): + data = mqtt_client.subscribe("kobuki/data") + if data: + return jsonify({data}) + if __name__ == '__main__': app.run(debug=True) \ No newline at end of file