#Imports requeridos
import network
from machine import Pin
from time import sleep
from umqtt.simple import MQTTClient

#Definir propiedades con el servidor
MQTT_BROKER="broker.hivemq.com"
MQTT_CLIENT_ID=""
MQTT_USER=""
MQTT_PASSWORD=""
MQTT_PORT= 1883
MQTT_TOPIC="ego/led"

#Funcion para conexion wifi
def conectar_wifi():
    print("Conectando", end="")
    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.3)
    print("WiFi conectada!")

#conectar_wifi()

#funcion de que enciende y apaga un led 
#De acuerdo al mensaje recibido del servidor
def llegada_mensaje(topic,msg):
    print("Mensaje: ", msg)
    if msg==b'1':
        led.value(1)
    elif msg==b'0':
        led.value(0)
    else:
        print("Mensaje no valido")

#Función que permite la suscripcion al servidor (broken)
#Devuelve un cliente mqtt
def suscribir():
    client=MQTTClient(MQTT_CLIENT_ID,
                       MQTT_BROKER,
                       port=MQTT_PORT,
                       user=MQTT_USER,
                       password=MQTT_PASSWORD,
                       keepalive=0)
    client.set_callback(llegada_mensaje)
    client.connect()
    client.subscribe(MQTT_TOPIC)
    print("Conectada a: ", MQTT_BROKER,
            "en el topico: ",MQTT_TOPIC)
    return client

#Declaración de variable para led
led=Pin(4, Pin.OUT)
led.value(0)

#Conexion wifi
conectar_wifi()

#Creamos objeto mqtt y nos suscribimos a un topico
client=suscribir()

#Ciclo infinito donde el cliente mqtt espera mensaje
while True:
    client.wait_msg()