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

# MQTT Server Parameters
MQTT_CLIENT_ID = "DJoverdant"
MQTT_BROKER    = "broker.mqttdashboard.com"
MQTT_USER      = ""
MQTT_PASSWORD  = ""
MQTT_TOPIC1    = "led.send" #tópico para enviar mensagem
MQTT_TOPIC2    = "led.status"  #tópico para se inscrever


led = Pin(26,Pin.OUT)
move = Pin(27,Pin.INPUT)

# Função de callback para recebimento de mensagens MQTT
def callback(topic, msg):
    #print("Mensagem recebida: ", msg.decode())
    global status

    if(str(msg.decode()) == "On"):
        client.publish(MQTT_TOPIC2, "Ligado")  
        led.on()

    elif(str(msg.decode()) == "Off"):
        client.publish(MQTT_TOPIC2, "Desligado") 
        led.off()

         





# 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!")

print("Connecting to MQTT server... ", end="")
client = MQTTClient(MQTT_CLIENT_ID, MQTT_BROKER, user=MQTT_USER, password=MQTT_PASSWORD)
#Lembrem-se sempre é necessário ter um callback para receber informações.
client.set_callback(callback)
client.connect()
client.subscribe(MQTT_TOPIC1)
print("Connected!")

status = 0
while True:
    client.check_msg()
    time.sleep(1)