#include <Wire.h>
#include <LiquidCrystal_I2C.h>
#include <WiFi.h>
#include <PubSubClient.h>
#include <DHT.h>

// Inisialisasi LCD dengan alamat I2C (0x27) dan ukuran 16x2
LiquidCrystal_I2C lcd(0x27, 16, 2);

// Konfigurasi Wi-Fi
const char* ssid = "Wokwi-GUEST";  // Nama SSID
const char* password = "";         // Password (kosong untuk Wokwi-GUEST)

// Konfigurasi MQTT
const char* mqtt_server = "broker.hivemq.com";  // Alamat broker MQTT
const int mqtt_port = 1883;                    // Port broker MQTT
const char* topic = "wokwi/dht22";             // Topik untuk publikasi data

WiFiClient espClient;
PubSubClient client(espClient);

// Konfigurasi DHT22
#define DHTPIN 14
#define DHTTYPE DHT22
DHT dht(DHTPIN, DHTTYPE);

void setup() {
  // Inisialisasi Serial Monitor
  Serial.begin(115200);
  Serial.println("ESP32 dengan LCD I2C, DHT22, dan MQTT");

  // Inisialisasi LCD
  lcd.init();
  lcd.backlight();
  lcd.setCursor(0, 0);
  lcd.print("Menghubungkan");
  lcd.setCursor(0, 1);
  lcd.print("ke WiFi...");

  // Menghubungkan ke WiFi
  connectToWiFi();

  // Konfigurasi MQTT
  client.setServer(mqtt_server, mqtt_port);

  // Inisialisasi DHT
  dht.begin();
}

void loop() {
  if (!client.connected()) {
    reconnectMQTT();
  }
  client.loop();

  // Membaca data dari DHT22
  float temp = dht.readTemperature();
  float hum = dht.readHumidity();

  if (isnan(temp) || isnan(hum)) {
    Serial.println("Gagal membaca dari sensor DHT!");
    lcd.setCursor(0, 0);
    lcd.print("Sensor Error   ");
    lcd.setCursor(0, 1);
    lcd.print("               ");
  } else {
    // Menampilkan data di Serial Monitor
    Serial.print("Temperature: ");
    Serial.print(temp);
    Serial.print(" C, Humidity: ");
    Serial.print(hum);
    Serial.println(" %");

    // Menampilkan data di LCD
    lcd.setCursor(0, 0);
    lcd.print("Temp: ");
    lcd.print(temp, 1);
    lcd.print(" C     ");
    lcd.setCursor(0, 1);
    lcd.print("Hum: ");
    lcd.print(hum, 1);
    lcd.print(" %     ");

    // Mengirim data ke MQTT broker
    String payload = String("{\"temperature\":") + temp + ",\"humidity\":" + hum + "}";
    client.publish(topic, payload.c_str());
    Serial.println("Data terkirim ke MQTT: " + payload);
  }

  delay(5000);  // Kirim data setiap 5 detik
}

// Fungsi untuk menghubungkan ke WiFi
void connectToWiFi() {
  WiFi.begin(ssid, password);
  while (WiFi.status() != WL_CONNECTED) {
    delay(500);
    Serial.print(".");
  }
  Serial.println("\nWiFi terhubung!");
  lcd.setCursor(0, 0);
  lcd.print("WiFi Terhubung!");
  lcd.setCursor(0, 1);
  lcd.print(WiFi.localIP());
  delay(2000);
}

// Fungsi untuk menyambungkan kembali ke broker MQTT
void reconnectMQTT() {
  while (!client.connected()) {
    Serial.print("Menghubungkan ke MQTT...");
    if (client.connect("ESP32Client")) {
      Serial.println("Berhasil terhubung!");
    } else {
      Serial.print("Gagal (rc=");
      Serial.print(client.state());
      Serial.println("). Coba lagi...");
      delay(2000);
    }
  }
}