import network
import time
from machine import Pin
import dht
import ujson
from umqtt.simple import MQTTClient

MQTT_CLIENT_ID = "Udaje"
MQTT_BROKER    = "broker.hivemq.com"

sensor = dht.DHT22(Pin(15))

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

print("Connecting to MQTT server... ", end="")
client = MQTTClient(MQTT_CLIENT_ID, MQTT_BROKER)
client.connect()

print("Connected!")

prev_weather = ''
message = ''
while True:
    print("Measuring weather conditions... ", end="")
    sensor.measure() 
    message = ujson.dumps({
    "temp": sensor.temperature(),
    "humidity": sensor.humidity(),
  })
    #f'Teplota: {sensor.temperature()} Vlhkosť: {sensor.humidity()}'
    if message != prev_weather:
        print("Updated!")
        print("Reporting to MQTT topic sos-it")
        client.publish('sos-it/', message)
        prev_weather = message