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

MQTT_CLIENT_ID = "DILE-PUBLISHER"
MQTT_BROKER = "broker.emqx.io"
MQTT_USER = ""
MQTT_PASSWORD = ""
MQTT_TOPIC = "hsc418/fadhil/data_sensor"
MQTT_TOPIC_SUBSCRIBE = "hsc418/fadhil/aktuasi_led"

sensor = dht.DHT22(Pin(15))
led = Pin(14, Pin.OUT)

# WIFI Connection
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 on_message(topic, msg):
  if msg.decode('utf-8') == "ON":
    led.on()
  elif msg.decode('utf-8') == "OFF":
    led.off()
  
# Koneksi ke broker MQTT
client = MQTTClient(MQTT_CLIENT_ID, MQTT_BROKER, user=MQTT_USER, password=MQTT_PASSWORD)
client.set_callback(on_message)  # Menghubungkan callback
client.connect()
print("MQTT Connected!")

# Subscribe to topic
client.subscribe("/hsc418/fadhil/aktuasi_led")

prev_weather = ""

while True:
    # Membaca data dari sensor
    sensor.measure()
    message = ujson.dumps({
        "temp": sensor.temperature(),
        "humidity": sensor.humidity(),
    })

    # Mengirim data jika ada perubahan
    if message != prev_weather:
        print("Sending data..")
        client.publish(MQTT_TOPIC, message, qos=1)
        prev_weather = message
    else:
        print('Tidak ada perubahan')
    # Memeriksa pesan MQTT yang diterima
    client.check_msg()

    time.sleep(1)