from wifi_lib import conecta
from umqtt.simple import MQTTClient
import urequests
import time
from machine import Pin

mqtt_server = "broker.mqttdashboard.com"
mqtt_port = 1883
mqtt_user = ""
mqtt_password = ""
mqtt_client_id = "clientId-Uwu2bBbcmM"

LED = Pin(5, Pin.OUT)

def recebi(topico, msg):
    if msg.decode() == "LIGA":
        LED.on()
    else:
        LED.off()

print("conectando...")
station = conecta ("Wokwi-GUEST", "")
if not station.isconnected():
    print("falha na conexão")
else:
    print("conectado")
    print("Conectando Broker MQTTP HIVE")
    client = MQTTClient(mqtt_client_id,
        mqtt_server,
        mqtt_port,
        mqtt_user,
        mqtt_password)
    client.connect()
    client.set_callback(recebi)
    client.subscribe("pucpr/iotmc/msg_esp32")
    client.sleep(600)
#PUBLISH
#client.publish("pucpr/iotmc/temperatura", "25,2")
#time.sleep(1)

#client.disconnect
station.disconnect()