diff --git a/src/Python/flask/web/app.py b/src/Python/flask/web/app.py index 365ff8f..32bdbe3 100644 --- a/src/Python/flask/web/app.py +++ b/src/Python/flask/web/app.py @@ -50,39 +50,21 @@ def control(): @app.route('/move', methods=['POST']) def move(): - try: - # Haal de richting op van de request - data = request.get_json() - direction = data.get("direction") + data = request.get_json() + direction = data.get("direction") - if not direction: - return jsonify({"status": "error", "message": "Direction is required"}), 400 - - # Maak verbinding met de database - conn = get_db() - cursor = conn.cursor() - - # Sla de richting op in de database - cursor.execute("INSERT INTO command (direction) VALUES (%s)", (direction,)) - conn.commit() - - # Sluit de cursor en de verbinding - cursor.close() - conn.close() - - # Verstuur de richting via MQTT + # Verstuur de richting via MQTT + if direction: mqtt_client.publish("home/commands", direction) - return jsonify({"status": "success", "direction": direction}) - - except mysql.connector.Error as e: - # Foutafhandeling voor databasefouten - return jsonify({"status": "error", "message": str(e)}), 500 - - except Exception as e: - # Algemene foutafhandeling - return jsonify({"status": "error", "message": "An error occurred", "details": str(e)}), 500 - + db_connection = get_db() + cursor = db_connection.cursor() + cursor.execute("INSERT INTO command (direction) VALUES (%s)", (direction,)) + db_connection.commit() + cursor.close() + db_connection.close() + + return jsonify({"status": "success", "direction": direction}) @app.route('/data', methods=['GET']) def data():