import network
import time
from umqtt.simple import MQTTClient

# WiFi credentials
WIFI_SSID = "Wokwi-GUEST"
WIFI_PASS = ""

# MQTT Broker settings
MQTT_BROKER = "broker.emqx.io"
MQTT_PORT = 1883
MQTT_TOPIC = b"esp32/test"

# Connect WiFi
def wifi_connect():
    wlan = network.WLAN(network.STA_IF)
    wlan.active(True)
    wlan.connect(WIFI_SSID, WIFI_PASS)
    while not wlan.isconnected():
        print("Connecting to WiFi...")
        time.sleep(1)
    print("Connected to WiFi:", wlan.ifconfig())

# Main
wifi_connect()
client = MQTTClient("esp32_pub", MQTT_BROKER, port=MQTT_PORT)
client.connect()
print("Connected to MQTT broker")

i = 0
while True:
    msg = "Hello from ESP32 - {}".format(i)
    client.publish(MQTT_TOPIC, msg)
    print("Published:", msg)
    i += 1
    time.sleep(2)