import network
import time
import umqtt.robust
import dht
from machine import Pin

print("Connecting to WiFi", end="")
wlan = network.WLAN(network.STA_IF) 
wlan.active(True) 
wlan.connect('Wokwi-GUEST', '') 
while not wlan.isconnected():
  print(".", end="")
  time.sleep(0.1)
print(" Connected!")

CLIENT_ID = "Ron"
BROKER = "mqtt.chaos4all.de"

mq = umqtt.robust.MQTTClient(CLIENT_ID,BROKER)
print("Verbinde mit Broker")
mq.connect()

# TOPIC1 = "Ron"
# NACHRICHT1 = "Hello Broker"
# mq.publish(TOPIC1,NACHRICHT1)

sensor = dht.DHT22(Pin(12))

while True:
    sensor.measure()
    humidity = sensor.humidity()
    temperature = sensor.temperature()

    humidity_msg = "{} %".format(humidity)
    temperature_msg = "{} °C".format(temperature)

    humidity_msg_encoded = humidity_msg.encode('utf-8')
    temperature_msg_encoded = temperature_msg.encode('utf-8')

    print("Publishing humidity to MQTT:", sensor.humidity(),"%")       
    print("Publishing temperature to MQTT:", sensor.temperature(),"°C")  

    mq.publish("ron/humidity", humidity_msg_encoded)
    mq.publish("ron/temperatur", temperature_msg_encoded)

    time.sleep(1)