import time
import network
import ujson
from neopixel import NeoPixel
from machine import Pin
from time import sleep
from umqtt.simple import MQTTClient

pixels = NeoPixel(Pin(13), 16)
pixels.fill((0, 0, 0))
pixels.write()

def mqtt_message(topic, msg):
  print("Mensagem recebida do broker hivemq.com:", msg)
  try:
    msg = ujson.loads(msg)
    pixels.fill((msg[0], msg[1], msg[2]))
    pixels.write()
  except Exception as e:
    print("Error:", e)

print("Conectando ao WiFi...", end="")
import network
wifi = network.WLAN(network.STA_IF)
wifi.active(True)
wifi.connect("Wokwi-GUEST", "")
while not wifi.isconnected():
  sleep(0.5)
  print(".", end="")
print("Conectado!")

print("Conectando ao MQTT...")
client = MQTTClient("wokwi1", "broker.hivemq.com")
client.set_callback(mqtt_message)
client.connect()
client.subscribe("remoticon")
client.publish("remoticon","[255,0,0]")
client.publish("remoticon","[0,255,0]")
client.publish("remoticon","[0,0,255]")
client.publish("remoticon","[255,255,255]")
print("Conectado!")

while True:
  client.wait_msg()
  time.sleep_ms(2000)