import network
import time
from machine import Pin
import dht

import ujson
from umqtt.simple import MQTTClient

# Parámetros del servidor MQTT
MQTT_CLIENT_ID = "micropython-weather-demo"
MQTT_BROKER = "broker.mqttdashboard.com"
MQTT_USER = ""
MQTT_PASSWORD = ""
MQTT_TOPIC = "wokwi-clima"

# Configurar el sensor DHT22
sensor = dht.DHT22(Pin(15))

# Conectar a WiFi
print("Conectando a WiFi", end="")
sta_if = network.WLAN(network.STA_IF)
sta_if.active(True)
sta_if.connect('Wokwi-GUEST', '')  # Asegúrate de estar en una red Wi-Fi accesible

while not sta_if.isconnected():
    print(".", end="")
    time.sleep(0.1)
print(" Conectado!")

# Conectar al servidor MQTT
print("Conectando al servidor MQTT... ", end="")
client = MQTTClient(MQTT_CLIENT_ID, MQTT_BROKER, user=MQTT_USER, password=MQTT_PASSWORD)
client.connect()
print("Conectado!")

prev_weather = ""
while True:
    print("Midiendo condiciones del clima... ", end="")
    
    try:
        # Medir temperatura y humedad
        sensor.measure()
        temperature = sensor.temperature()  # Temperatura en °C
        humidity = sensor.humidity()  # Humedad en %

        # Crear el mensaje en formato JSON
        message = ujson.dumps({
            "temperatura": temperature,
            "humedad": humidity,
        })

        # Verificar si el mensaje ha cambiado y publicarlo en MQTT
        if message != prev_weather:
            print("¡Actualizado!")
            print("Reportando para el tópico MQTT {}: {}".format(MQTT_TOPIC, message))
            client.publish(MQTT_TOPIC, message)
            prev_weather = message
        else:
            print("Sin cambios")

    except Exception as e:
        print("Error al leer el sensor o publicar en MQTT:", e)

    # Esperar 1 segundo antes de la siguiente medición
    time.sleep(1)