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

# Configuración Wi-Fi
ssid = "Wokwi-GUEST"
password = ""

# Configuración MQTT con Adafruit IO
AIO_SERVER = "io.adafruit.com"
AIO_PORT = 1883
AIO_USER = "drubine101"
AIO_KEY = "aio_NuTa661DyzjhFgL9uKizge91kDNj"
AIO_FEED = "drubine101/feeds/testing"

# Pin del sensor DHT22
dht_pin = machine.Pin(15)
sensor = dht.DHT22(dht_pin)

# Función para conectar al Wi-Fi
def connect_wifi():
    wlan = network.WLAN(network.STA_IF)
    wlan.active(True)
    wlan.connect(ssid, password)
    print("Conectando a Wi-Fi...", end="")
    while not wlan.isconnected():
        print(".", end="")
        time.sleep(0.5)
    print("\nConectado! IP:", wlan.ifconfig()[0])

# Función para conectar al servidor MQTT
def connect_mqtt():
    client = MQTTClient("esp32", AIO_SERVER, port=AIO_PORT, user=AIO_USER, password=AIO_KEY)
    client.connect()
    print("Conectado a MQTT")
    return client

# Programa principal
connect_wifi()
mqtt_client = connect_mqtt()

while True:
    try:
        sensor.measure()
        temperature = sensor.temperature()
        print("Temperatura:", temperature, "°C")

        mqtt_client.publish(AIO_FEED, str(temperature))
        print("Publicado en el feed de Adafruit.")
    except Exception as e:
        print("Error al medir o publicar:", e)

    time.sleep(20)