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

# ──────────────────── Configuración MQTT ────────────────────
MQTT_CLIENT_ID = "invernadero_ags"
MQTT_BROKER    = "broker.mqttdashboard.com"
MQTT_USER      = ""
MQTT_PASSWORD  = ""
MQTT_TOPIC     = "sensores_invernadero"

# ──────────────────── Sensores ────────────────────
sensorTH = dht.DHT22(Pin(15))

sensorLDR = ADC(Pin(34))
sensorLDR.atten(ADC.ATTN_11DB)  # rango 0-3.3 V

# ──────────────────── Conexión WiFi ────────────────────
print("Conectando a 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(" ¡OK!")

# ──────────────────── Conexión MQTT ────────────────────
print("Conectando MQTT... ", end="")
client = MQTTClient(MQTT_CLIENT_ID, MQTT_BROKER,
                    user=MQTT_USER, password=MQTT_PASSWORD)
client.connect()
print("¡OK!")

# ──────────────────── Bucle principal ────────────────────
ultimo_json = ""  # para evitar publicaciones repetidas

while True:
    # 1. Medición
    sensorTH.measure()
    temperatura = sensorTH.temperature()
    humedad     = sensorTH.humidity()
    ldr_raw     = sensorLDR.read()
    oscuridad = round(ldr_raw / 4095 * 100)  # 0=claro 100=oscuro

    # 2. Publicación MQTT (solo si hay cambios)
    payload = ujson.dumps({
        "temperatura": temperatura,
        "humedad"   : humedad,
        "oscuridad" : oscuridad
    })

    if payload != ultimo_json:
        client.publish(MQTT_TOPIC, payload)
        ultimo_json = payload

    time.sleep(2)      # ritmo de refresco