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

WIFI_SSID      = "Wokwi-GUEST"
WIFI_PASSWORD  = ""

MQTT_BROKER     = "mqtt3.thingspeak.com"
MQTT_CLIENT_ID  = "NigsDxcPDiUoGiMPIAAPCiE"
MQTT_USER       = "NigsDxcPDiUoGiMPIAAPCiE"
MQTT_PASSWORD   = "YYiS2vIfaZL1cm/S6GHlog4P"

MQTT_TOPIC_TEMPERATURE    = "channels/2559409/publish/fields/field1"
MQTT_TOPIC_HUMIDITY       = "channels/2559409/publish/fields/field2"

sensor = dht.DHT22(Pin(15))

print("Connecting to WiFi...", end="")
sta_if = network.WLAN(network.STA_IF)
sta_if.active(True)
sta_if.connect(WIFI_SSID, WIFI_PASSWORD)

while not sta_if.isconnected():
  print(".", end="")
  time.sleep(0.1)
  
print("Successfully connected to WiFi")

print("Connecting to MQTT server...\n", end="")
client = MQTTClient(MQTT_CLIENT_ID, MQTT_BROKER, user=MQTT_USER, password=MQTT_PASSWORD)
client.connect()
print("Successfully connected MQTT server")

while True:
  print("Measuring weather conditions...\n", end="")
  sensor.measure() 

  temp = str(sensor.temperature())
  humidity = str(sensor.humidity())

  client.publish(MQTT_TOPIC_TEMPERATURE, temp)
  print("Reported to MQTT {}: {}".format(MQTT_TOPIC_TEMPERATURE, temp))
  time.sleep(10)
  client.publish(MQTT_TOPIC_HUMIDITY, humidity)
  print("Reported to MQTT {}: {}".format(MQTT_TOPIC_HUMIDITY, humidity))

  time.sleep(20)