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

# MQTT Server Parameters
MQTT_CLIENT_ID = "clientId-EM"
MQTT_BROKER    = "broker.hivemq.com"
MQTT_USER      = "kavi"
MQTT_PASSWORD  = "1234"
MQTT_TOPIC     = "environment-monitoring"

#sensor setup in ESP32
sensor = dht.DHT22(Pin(4))

#WiFi connection for ESP32
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!")

#MQTT broker(Hivemp)
print("Connecting to MQTT server... ")
client = MQTTClient(MQTT_CLIENT_ID, MQTT_BROKER,
        user=MQTT_USER, password=MQTT_PASSWORD)
client.connect()
print("Connected!")

#Measuring Environment Conditions and publishing
print("Measuring Environment Conditions... ")
while True:
  sensor.measure() 
  message = ujson.dumps({"temperature": sensor.temperature(),
        "humidity": sensor.humidity()})

  #simulation report
  print('Temperature: ',sensor.temperature(),
        ' Humidity: ',sensor.humidity())

  #publish to broker
  client.publish(MQTT_TOPIC, message)

  time.sleep(1)