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

# MQTT SERVER
SERVIDOR   = "broker.hivemq.com"
MQTT_TOPICO     = "wokwi-tempo"

sensor = dht.DHT22(Pin(15))

print("Conectando-se ao 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(" Conectado!")

print("Conectando-se ao servidor MQTT... ", end="")
client = MQTTClient("ESP32", SERVIDOR, 1883)
client.connect()

print("Conectado!")

prev_weather = ""
while True:
  print("Medindo as condições climáticas... ", end="")
  sensor.measure() 
  mensagem = ujson.dumps({
    "temperatura": sensor.temperature(),
    "umidade": sensor.humidity(),
  })
  if mensagem != prev_weather:
    print("Atualizado!")
    print("Enviando ao tópico MQTT {}: {}".format(MQTT_TOPICO, mensagem))
    client.publish(MQTT_TOPICO, mensagem)
    prev_weather = mensagem
  else:
    print("Sem atualizações!")
  time.sleep(1)