import network
import time
from machine import Pin
import dht
import ujson
from umqtt.simple import MQTTClient
#MQTT server parameters
MQTT_CLIENT_ID = "clientId-Izd3fpsIrG"
MQTT_BROKER = "mqtt-dashboard.com"
MQTT_USER=""
MQTT_PASSWORD=""
MQTT_TOPIC = "Wokwi-weather"
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("Measure weather conditions... ",end="")
  sensor.measure()
  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)