From e39b2a2753ee81b9f7da714586b8e8140373a2cb Mon Sep 17 00:00:00 2001
From: waldluis <luis.waldhauser@web.de>
Date: Mon, 3 Apr 2023 10:09:53 +0200
Subject: [PATCH] Raspy MQTT Tests added

---
 software/roboter/raspy/mqtt_publish1.py  | 13 +++++++++++++
 software/roboter/raspy/mqtt_subscribe.py | 21 +++++++++++++++++++++
 2 files changed, 34 insertions(+)
 create mode 100644 software/roboter/raspy/mqtt_publish1.py
 create mode 100644 software/roboter/raspy/mqtt_subscribe.py

diff --git a/software/roboter/raspy/mqtt_publish1.py b/software/roboter/raspy/mqtt_publish1.py
new file mode 100644
index 0000000..9ab8174
--- /dev/null
+++ b/software/roboter/raspy/mqtt_publish1.py
@@ -0,0 +1,13 @@
+import paho.mqtt.client as mqtt
+import random
+import time
+
+mqttBroker = "mqtt.eclipseprojects.io"
+client = mqtt.Client("Temperature")
+client.connect(mqttBroker)
+
+while True: 
+    randNumber = random.randint(0, 20)
+    client.publish("TEMPERATURE", randNumber)
+    print("Published " + str(randNumber) + " to topic TEMPERATURE")
+    time.sleep(2)
\ No newline at end of file
diff --git a/software/roboter/raspy/mqtt_subscribe.py b/software/roboter/raspy/mqtt_subscribe.py
new file mode 100644
index 0000000..da46067
--- /dev/null
+++ b/software/roboter/raspy/mqtt_subscribe.py
@@ -0,0 +1,21 @@
+import paho.mqtt.client as mqtt
+
+
+def on_message_temp(client, userdata, message):
+    print("Received temp message: ", str(message.payload.decode("utf-8")))
+
+def on_message_hum(client, userdata, message):
+    print("Received hum message: ", str(message.payload.decode("utf-8")))
+    
+
+mqttBroker = "mqtt.eclipseprojects.io"
+client = mqtt.Client("Smartphone_temp")
+
+client.message_callback_add("TEMPERATURE", on_message_temp)
+client.message_callback_add("HUMIDITY", on_message_hum)
+
+client.connect(mqttBroker)
+client.subscribe("TEMPERATURE")
+client.subscribe("HUMIDITY")
+
+client.loop_forever()
\ No newline at end of file