import network
import time
from umqtt.simple import MQTTClient
import ubinascii
import machine

# WiFi credentials
SSID = "Wokwi-GUEST"
PASSWORD = ""

# MQTT settings
MQTT_BROKER = "test.mosquitto.org"
MQTT_PORT = 1883
MQTT_TOPIC = b"KT/KPT/001"
CLIENT_ID = ubinascii.hexlify(machine.unique_id())

# Connect to WiFi
wlan = network.WLAN(network.STA_IF)
wlan.active(True)
if not wlan.isconnected():
    print("Connecting to WiFi...", end="")
    wlan.connect(SSID, PASSWORD)
    while not wlan.isconnected():
        print(".", end="")
        time.sleep(1)
print("\nConnected to WiFi:", wlan.ifconfig())

# Connect to MQTT broker
try:
    client = MQTTClient(CLIENT_ID, MQTT_BROKER, port=MQTT_PORT)
    client.connect()
    print("Publisher connected to MQTT broker:", MQTT_BROKER)
except Exception as e:
    print("Failed to connect to MQTT broker:", e)

# Publish messages continuously
try:
    count = 0
    while True:
        msg = "Hello ESP32! Message #" + str(count)
        client.publish(MQTT_TOPIC, msg)
        pr