import network
import time
from machine import Pin
import dht
import ujson
import ubinascii
from umqtt.simple import MQTTClient

from machine import Pin, unique_id, reset

# MQTT Server Parameters
MQTT_CLIENT_ID = ubinascii.hexlify(unique_id())
MQTT_BROKER = "mqtt-dashboard.com"
MQTT_TOPIC = "temp/1"

sensor_pin = Pin(15)
sensor = dht.DHT22(sensor_pin)

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

while not wifi_interface.isconnected():
    print(".", end="")
    time.sleep(0.1)

print(" Connected!")

print("Connecting to MQTT server... ", end="")
mqtt_client = MQTTClient(MQTT_CLIENT_ID, MQTT_BROKER)
mqtt_client.connect()

print("Connected!")

previous_weather = ""
while True:
    print("Measuring weather conditions... ", end="")
    sensor.measure()
    message = ujson.dumps({
        "temperature": sensor.temperature(),
        "humidity": sensor.humidity(),
    })
    
    if message != previous_weather:
        print("Updated!")
        print("Reporting to MQTT topic {}: {}".format(MQTT_TOPIC, message))
        mqtt_client.publish(MQTT_TOPIC, message)
        previous_weather = message
    else:
        print("No change")
    
    time.sleep(1)