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

# MQTT Server Parameters
MQTT_CLIENT_ID = "micropython-weather-demo"
MQTT_BROKER    = "broker.mqttdashboard.com"
MQTT_USER      = ""
MQTT_PASSWORD  = ""
MQTT_TOPIC     = "wokwi-kipas"

relay_pin = 21
led_pin = 26

sensor = dht.DHT22(Pin(15))
relay = Pin(relay_pin, Pin.OUT)
led = Pin(led_pin, Pin.OUT)

def connect_to_wifi():
    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!")

def connect_to_mqtt():
    print("Connecting to MQTT server... ", end="")
    client = MQTTClient(MQTT_CLIENT_ID, MQTT_BROKER, user=MQTT_USER, password=MQTT_PASSWORD)
    client.connect()
    print("Connected!")
    return client

def main():
    connect_to_wifi()
    mqtt_client = connect_to_mqtt()

    prev_weather = ""
    while True:
        print("Measuring weather conditions... ", end="")
        sensor.measure()
        temperature = sensor.temperature()
        humidity = sensor.humidity()

        if humidity > 30 and temperature > 30:
            print("Humidity and Temperature above threshold. Turning on LED and Relay")
            led.on()
            relay.on()
        else:
            print("Humidity or Temperature below threshold. Turning off LED and Relay")
            led.off()
            relay.off()

        message = ujson.dumps({
            "temp": temperature,
            "humidity": humidity,
        })

        if message != prev_weather:
            print("Updated!")
            print("Reporting to MQTT topic {}: {}".format(MQTT_TOPIC, message))
            mqtt_client.publish(MQTT_TOPIC, message)
            prev_weather = message
        else:
            print("No change")
        time.sleep(1)

if __name__ == "__main__":
    main()