from machine import Pin
import utime
from time import sleep
import dht

pin_dht = Pin(5, Pin.IN)
sensor = dht.DHT22(pin_dht)

#Conexion wifi, manejar instancias de un cliente mqtt
import network
from umqtt.simple import MQTTClient

#Constantes para conexion con el cliente MQTT
MQTT_CLIENT_ID = ""
MQTT_BROKER = "broker.emqx.io"
MQTT_USER = ""
MQTT_PASSWORD = ""
MQTT_TOPIC = "humidity/level/jamb"
MQTT_PORT = 1883

def conectar_wifi():
    print('Conectando a WIFI')
    sta_if = network.WLAN(network.STA_IF)
    sta_if.active(True)
    sta_if.connect('Wokwi-GUEST', '')
    while not sta_if.isconnected():
        print(".", end="")
        sleep(0.1)
    print("Conectado!")

def mensaje_recibido(topico, msg):
    angulo = int(msg)

def conectar_broker():
    print("Conectando al broker: ", MQTT_BROKER)
    cliente = MQTTClient(MQTT_CLIENT_ID, 
                        MQTT_BROKER,
                        user=MQTT_USER,
                        password=MQTT_PASSWORD,
                        port=MQTT_PORT)
    cliente.set_callback(mensaje_recibido)
    cliente.connect()
    cliente.subscribe(MQTT_TOPIC)
    print("Conectado al topico: ", MQTT_TOPIC)
    return cliente

#Antes de iniciar el ciclo
conectar_wifi()
cliente = conectar_broker()

#Ciclo infinito
while True:
    try:
        sensor.measure()
        temperatura = sensor.temperature()
        cliente.publish(MQTT_TOPIC, str(temperatura))
        utime.sleep(2)

    except Exception as e:
        print("Error al leer el sensor DHT22:", e)