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

# MQTT Server Parameters
MQTT_CLIENT_ID = "bkacad-mqtt-123"
MQTT_BROKER    = "mqtt-dashboard.com"
MQTT_TOPIC     = "smarthome/led/1"

connect_internet()

led = Pin(25, Pin.OUT)

# Khi co nguoi dung publish thong bao vao kenh topic 
def sub_cb(topic, msg):
    if(msg == b'ON'):
        led.on()
    else:
        led.off()


print("Connecting to MQTT server... ")
client = MQTTClient(MQTT_CLIENT_ID, MQTT_BROKER,keepalive=60 )
client.set_callback(sub_cb)
client.connect()
client.subscribe(MQTT_TOPIC)
print("Connected!")

while True:
    try:
        client.check_msg()
    except Exception as e:
        print(e)
        
        
print("Disconnecting...")
client.disconnect()