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

# Configuración de WiFi
def conectar_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(" Conectado!")

# Configuración de pines
sensor_pir = Pin(4, Pin.IN)
buzzer = Pin(2, Pin.OUT)

# Configuración de MQTT
MQTT_CLIENT_ID = "ESP32" 
MQTT_BROKER    = "broker.mqttdashboard.com"
MQTT_USER      = ""
MQTT_PASSWORD  = ""
MQTT_TOPIC     = "alarma" 

def conectar_mqtt():
    print("Conectando a servidor MQTT... ", end="")
    client = MQTTClient(MQTT_CLIENT_ID, MQTT_BROKER, user=MQTT_USER, password=MQTT_PASSWORD)
    client.connect()
    print("Conectado")
    return client  # Devuelve el cliente conectado



def enviar_mensaje(client, estado):
    message = str(estado)
    client.publish(MQTT_TOPIC, message)
    print(f"Estado de la alarma: {message}")

def activar_alarma(client):
    buzzer.value(1)
    print('¡Movimiento detectado! Alarma activada.')
    estado = "activada"
    enviar_mensaje(client, estado)

def desactivar_alarma(client):
    buzzer.value(0)
    estado = "desactivada"
    enviar_mensaje(client, estado)


def debounce_sensor():
    time.sleep(0.5)
    return sensor_pir.value() == 1

def main():
    conectar_wifi()
    client = None
    
    try:
        client = conectar_mqtt()
        while True:
            if debounce_sensor():
                activar_alarma(client)
                time.sleep(10)  # Espera que la alarma esté activada
                desactivar_alarma(client)
            else:
                print('No se detecta movimiento.')
                time.sleep(1)
    except Exception as e:
        print("Error en el bucle principal:", e)
    finally:
        if client:
            client.disconnect()
        buzzer.value(0)

if __name__ == "__main__":
    main()