From 836e286178324914fc7eae3ce31de923ad490a80 Mon Sep 17 00:00:00 2001
From: Max <m.giller.dev@gmail.com>
Date: Fri, 5 Jul 2024 20:15:42 +0200
Subject: [PATCH] MQTT client test app

---
 mqtt-test/main.py          | 27 +++++++++++++++++++++++++++
 mqtt-test/requirements.txt |  1 +
 2 files changed, 28 insertions(+)
 create mode 100644 mqtt-test/main.py
 create mode 100644 mqtt-test/requirements.txt

diff --git a/mqtt-test/main.py b/mqtt-test/main.py
new file mode 100644
index 0000000..a10a420
--- /dev/null
+++ b/mqtt-test/main.py
@@ -0,0 +1,27 @@
+import paho.mqtt.client as mqtt
+
+
+# The callback for when the client receives a CONNACK response from the server.
+def on_connect(client, userdata, flags, reason_code, properties):
+    print(f"Connected with result code {reason_code}")
+    # Subscribing in on_connect() means that if we lose the connection and
+    # reconnect then subscriptions will be renewed.
+    client.subscribe("zigbee2mqtt/#")
+
+
+# The callback for when a PUBLISH message is received from the server.
+def on_message(client, userdata, msg):
+    print(msg.topic + " " + str(msg.payload))
+
+
+mqttc = mqtt.Client(mqtt.CallbackAPIVersion.VERSION2)
+mqttc.on_connect = on_connect
+mqttc.on_message = on_message
+
+mqttc.connect("raspberrypi", 1883, 60)
+
+# Blocking call that processes network traffic, dispatches callbacks and
+# handles reconnecting.
+# Other loop*() functions are available that give a threaded interface and a
+# manual interface.
+mqttc.loop_forever()
diff --git a/mqtt-test/requirements.txt b/mqtt-test/requirements.txt
new file mode 100644
index 0000000..d173f65
--- /dev/null
+++ b/mqtt-test/requirements.txt
@@ -0,0 +1 @@
+paho-mqtt
\ No newline at end of file