import sys
print("INICIANDO…")
sys.stdout.flush()

import network
from umqtt.simple import MQTTClient
import time

# ---------- Wi-Fi ----------
ssid = 'Wokwi-GUEST'
password = ''

wifi = network.WLAN(network.STA_IF)
wifi.active(True)
wifi.connect(ssid, password)

while not wifi.isconnected():
    time.sleep(1)

print("Wi-Fi conectado:", wifi.ifconfig())

# ---------- MQTT ----------
BROKER = "broker.hivemq.com"
PORT = 1883
CLIENT_ID = "doorsos-esp32-001"
TOPIC = b"doorsos/test"

def on_message(topic, msg):
    print("Mensagem recebida:", topic, msg)

client = MQTTClient(
    client_id=CLIENT_ID,
    server=BROKER,
    port=PORT
)

client.set_callback(on_message)
client.connect()
client.subscribe(TOPIC)

print("Conectado ao MQTT e inscrito no tópico")

# ---------- Loop ----------
while True:
    client.check_msg()
    time.sleep(0.2)