From 96c3285f04b161945a095b80b49d33517e092f3e Mon Sep 17 00:00:00 2001
From: Michael Weig <weigmi87303@th-nuernberg.de>
Date: Wed, 18 Feb 2026 18:12:19 +0000
Subject: [PATCH] was kann das ux team eigentlich

---
 mqtt_test.py | 81 ++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 81 insertions(+)
 create mode 100644 mqtt_test.py

diff --git a/mqtt_test.py b/mqtt_test.py
new file mode 100644
index 0000000..a68a737
--- /dev/null
+++ b/mqtt_test.py
@@ -0,0 +1,81 @@
+import paho.mqtt.client as mqtt
+import sys
+
+# ===== KONFIGURATION =====
+# BROKER = "141.75.215.233"
+PORT = 1883
+
+TOPIC = "PREDICTION"
+MESSAGE = "sad gummy bitches"
+
+USERNAME = None
+PASSWORD = None
+QOS = 0
+# ==========================
+
+import socket
+
+def get_local_ip():
+    s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
+    try:
+        s.connect(("8.8.8.8", 80))
+        ip = s.getsockname()[0]
+    finally:
+        s.close()
+    return ip
+
+
+
+def on_connect(client, userdata, flags, rc):
+    if rc == 0:
+        print("✅ Erfolgreich mit Broker verbunden")
+
+        # Subscribe
+        client.subscribe(TOPIC, qos=QOS)
+        print(f"📡 Abonniert Topic: '{TOPIC}'")
+
+        # Publish
+        client.publish(TOPIC, MESSAGE, qos=QOS)
+        print(f"📤 Nachricht gesendet an Topic '{TOPIC}': {MESSAGE}")
+
+    else:
+        print(f"❌ Verbindung fehlgeschlagen mit Code {rc}")
+
+
+def on_message(client, userdata, msg):
+    try:
+        payload = msg.payload.decode()
+    except:
+        payload = msg.payload
+
+    print("📥 Nachricht empfangen:")
+    print(f"   Topic: {msg.topic}")
+    print(f"   QoS: {msg.qos}")
+    print(f"   Payload: {payload}")
+    print("-" * 40)
+
+
+def on_disconnect(client, userdata, rc):
+    print("⚠ Verbindung getrennt")
+
+
+def main():
+    client = mqtt.Client()
+    BROKER = get_local_ip()
+    if USERNAME and PASSWORD:
+        client.username_pw_set(USERNAME, PASSWORD)
+
+    client.on_connect = on_connect
+    client.on_message = on_message
+    client.on_disconnect = on_disconnect
+
+    try:
+        client.connect(BROKER, PORT, 60)
+        client.loop_forever()
+    except Exception as e:
+        print("Fehler:", e)
+        sys.exit(1)
+
+
+if __name__ == "__main__":
+    main()