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

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

# Inicializar el sensor DHT22 en el pin 15
sensor = dht.DHT22(Pin(15))

# Imprimir mensaje de conexión a la red WiFi
print("Connecting to 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(" Connected!")

# Imprimir mensaje de conexión al servidor MQTT
print("Connecting to MQTT server... ", end="")
client = MQTTClient(MQTT_CLIENT_ID, MQTT_BROKER, user=MQTT_USER, password=MQTT_PASSWORD)
client.connect()
print("Connected!")

# Configurar el pin del servo
servo_pin = 0  # Ajustar el número del pin según tu configuración
servo = machine.PWM(machine.Pin(servo_pin), freq=50)  # Configurar el servo usando PWM con frecuencia de 50 Hz

def move_servo(angle):
    duty = int(((angle / 180.0) * 75) + 40)
    servo.duty(duty)

prev_weather = ""

try:
    while True:
        print("Measuring weather conditions... ", end="")
        sensor.measure()

        temperature = sensor.temperature()
        humidity = sensor.humidity()

        message = ujson.dumps({
            "temp": sensor.temperature(),
            "humidity": sensor.humidity(),
        })

        if message != prev_weather:
            print("Updated!")
            print("Reporting to MQTT topic {}: {}".format(MQTT_TOPIC, message))
            client.publish(MQTT_TOPIC, message)
            prev_weather = message
        else:
            print("No change")
            print(temperature)
        time.sleep(1)

        # Verificar si la temperatura supera un umbral
        if temperature > 26:
            # Mueve el servo de forma intermitente
            for angle in range(0, 181, 10):
                move_servo(angle)
                time.sleep(0.1)

            for angle in range(180, -1, -10):
                move_servo(angle)
                time.sleep(0.1)
        else:
            move_servo(0)  # Si no supera el umbral, mantener el servo en 0 grados
            time.sleep(1)

except KeyboardInterrupt:
    # Manejar interrupción de teclado (Ctrl+C) para detener el programa
    servo.duty(0)  # Detener el servo antes de salir
    servo.deinit()  # Liberar recursos del servo
    print("Programa detenido por el usuario.")