import network
from dht import DHT22
from time import sleep_ms
from umqtt.robust import MQTTClient
from machine import Pin, Timer

dht = DHT22(Pin(5))
led = Pin(33, Pin.OUT)

def temperatura(timer):
    dht.measure()
    temp = dht.temperature()
    hum = dht.humidity()
    cliente.publish("topic1724/sensor1",str(temp))
    cliente.publish("topic1724/sensor2",str(hum))
    print("Temperature: ",temp,"C")
    print("Humedad: ",hum,"%RH")

def callback(topic,msg):
    mensaje = msg.decode()
    topic = topic.decode()

    if(topic == "topic1724/actuador1"):
        if(mensaje == "true"):
            led.value(1)
            print("123")
        elif(mensaje == "false"):
            led.value(0)
    print(mensaje)

red = network.WLAN(network.STA_IF)
red.active(True)

if not red.isconnected():
    red.connect("Wokwi-GUEST","")
    print("Conectado...")
    while not red.isconnected():
        sleep_ms(1000)
config = red.ifconfig()
print("Conectado con la IP {config[0]}")   

cliente = MQTTClient("don_nr_e33","test.mosquitto.org")#, port=1883
print("Conectando al servidor...........")
cliente.set_callback(callback)
cliente.connect()
cliente.subscribe("topic1724/actuador1")
print("Conectando............")

tim = Timer(0)
tim.init(period=5000, mode=Timer.PERIODIC, callback=temperatura)

while True:
    cliente.check_msg()

cliente.disconnect()