From afc69167b1043f5a0c562c750eb131bdd8fc67dd Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Ebbe=20Ba=C3=9F?= <ebbe.bass>
Date: Tue, 13 Feb 2024 00:26:26 +0100
Subject: [PATCH] updated mqtt code to v2
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Signed-off-by: Ebbe Baß <ebbe.bass>
---
 server/app.py | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/server/app.py b/server/app.py
index ede4e26..68a2f38 100644
--- a/server/app.py
+++ b/server/app.py
@@ -98,15 +98,15 @@ def get_eth0_ip():
         print(f"Error getting eth0 IP: {e}")
         return None
     
-def on_connect(client, rc, flags):
-        if rc == 0:
+def on_connect(client, userdata, flags, reason_code, properties):
+        if reason_code == 0:
             print("Connected to MQTT Broker!")
         else:
-            print("Failed to connect, return code %d\n", rc)
+            print("Failed to connect, return code %d\n", str(reason_code))
 
 def connect_mqtt():
     # Set Connecting Client ID
-    client = mqtt.Client("mqtt_client_id")
+    client = mqtt.Client(mqtt.CallbackAPIVersion.VERSION1)
     # client.username_pw_set(username, password)
     client.on_connect = on_connect
     client.connect("localhost", 1883)