import network
import json
from umqtt.simple import MQTTClient
from time import sleep

print("Connecting to Internet", end="")
sta=network.WLAN(network.STA_IF)
sta.active(True)
sta.connect('Wokwi-GUEST','')

while not sta.isconnected():
    print(",",end="")
    sleep(0.1)
print("CONNECTED")

mqtt_broker = "broker.hivemq.com"
mqtt_port = 1883
mqtt_topic = "T"
mqtt_topic_1 = "A"
client_id = "Harris"

mqtt = MQTTClient(client_id, mqtt_broker, port=mqtt_port)

def connect_mqtt():
    try:
        print("connecting to MQTT")
        mqtt.connect()
    except Exception as e:
        print("Error Connecting to MQTT broker:", str(e))
        
connect_mqtt()

while True:
    t="30"
    a="45"
    mqtt.publish(mqtt_topic,t)
    mqtt.publish(mqtt_topic_1,a)
    print("Published "+ t +" topic Temp")
    print("Published "+ a +" topic Temp")