#include <WiFi.h>
#include <MQTT.h>
#include <DHT.h>

DHT dht(21, DHT22);

const char ssid[] = "Wokwi-GUEST";
const char pass[] = "";

WiFiClient net;
MQTTClient client;

unsigned long lastMillis = 0;

void connect() {
  Serial.print("Menghubungkan ke WiFi");
  while (WiFi.status() != WL_CONNECTED) {
    Serial.print(".");
    delay(1000);
  }

  Serial.print("\nMenghubungkan ke MQTT");
  while (!client.connect("bebasaja-irigasi", "wokwi-irigasi", "wokwi-irigasi")) {
    Serial.print(".");
    delay(1000);
  }

  Serial.println("\nconnected ke MQTT!");

  client.subscribe("data/led"); //topik
}

void messageReceived(String &topic, String &payload) {
  Serial.println("incoming: " + topic + " - " + payload);
  int led = payload.toInt();
  digitalWrite(5, led);
}

void setup() {
  Serial.begin(115200);
  dht.begin();
  pinMode (5, OUTPUT);
  WiFi.begin(ssid, pass);
  client.begin("wokwi-irigasi.cloud.shiftr.io", net); //alamat broker
  client.onMessage(messageReceived);
  connect();
}

void loop() {
  client.loop();
  delay(10); 
  if (!client.connected()) {
    connect();
  }
  float suhu = dht.readTemperature();
  float kelembapan = dht.readHumidity();
  // publish a message roughly every second.
  if (millis() - lastMillis > 1000) {
    lastMillis = millis();
    client.publish("data/suhu", String (suhu,2)); //topik, pesan
    client.publish("data/kelembapan", String(kelembapan, 2));
  }
}