import network
import time
from machine import Pin
import dht
import ujson
from umqtt.simple import MQTTClient
# MQTT Server Parameters
MQTT_CLIENT_ID ="clientId-qCB3lEHvyt"
MQTT_BROKER ="mqtt-dashboard.com"
MQTT_USER ="      "
MQTT_PASSWORD ="       "
MQTT_TOPIC ="testtopic/#"
sensor =dht.DHT22(Pin(15))
print("Connecting to wifi",end=" ")
sta_if = network.WLAN(network.STA_IF)
sta_if.active(True)
sta_if.connect('wokwi-GUEST','')
while not sta_if.isconnected():
    print(".",end="")
    time.sleep(0.1)
print("connected!")
print("connecting to MQTT server...",end="")
client = MQTTclient(MQTT_CLIENT_ID,MQTT_BROKER,user=MQTT_USER,password=MQTT_PASSWORD)
client.connect()
print("connected!")
prev_weather =""
while True:
    print("Measuring weather conditions...",end="")
    sensor.measur()
    message = ujson.dumps({
        "temp":sensor.temperature(),
        "humidity":sensor.humidity(),
    })
    if message !=prev_weather:
        print("updated!")
        print("Reporting to MQTT topic {}:{}".format(MQTT_TOPIC,message))
        client.publish(MQTT_TOPIC,message)
        prev_weather =message
    else:
        print("No change")
    time.sleep(1)