// Pastikan Anda menginstal library berikut di Arduino IDE:
// 1. DHT sensor library by Adafruit
// 2. Adafruit Unified Sensor library
// 3. NewPing library (untuk sensor jarak HC-SR04)
// 4. WiFi library untuk ESP32
// 5. PubSubClient untuk MQTT (Node-RED)

#include <Arduino.h>
#include <DHT.h>
#include <NewPing.h>
#include <WiFi.h>
#include <PubSubClient.h>

// WiFi credentials
const char* ssid = "Wokwi-GUEST";
const char* password = "";
const char* mqtt_server = "157.15.124.96";

WiFiClient espClient;
PubSubClient client(espClient);

// Pin koneksi
#define DHTPIN 4        // Pin untuk DHT22
#define DHTTYPE DHT22   // Jenis DHT
#define LDRPIN 34       // Pin untuk LDR (gunakan pin ADC ESP32)
#define TRIG_PIN 5      // Pin Trigger untuk HC-SR04
#define ECHO_PIN 18     // Pin Echo untuk HC-SR04
#define MAX_DISTANCE 200 // Maksimum jarak dalam cm
// #define SOIL_MOISTURE_PIN 32 // Pin sensor kelembaban tanah
// #define GAS_SENSOR_PIN 35 // Pin sensor gas MQ-2

// Inisialisasi sensor
DHT dht(DHTPIN, DHTTYPE);
NewPing sonar(TRIG_PIN, ECHO_PIN, MAX_DISTANCE);

void setup_wifi() {
    delay(10);
    Serial.println("Connecting to WiFi...");
    WiFi.begin(ssid, password);
    while (WiFi.status() != WL_CONNECTED) {
        delay(500);
        Serial.print(".");
    }
    Serial.println("\nWiFi connected");
}

void callback(char* topic, byte* payload, unsigned int length) {
    Serial.print("Message arrived [");
    Serial.print(topic);
    Serial.print("] ");
    for (int i = 0; i < length; i++) {
        Serial.print((char)payload[i]);
    }
    Serial.println();
}

void reconnect() {
    while (!client.connected()) {
        Serial.print("Attempting MQTT connection...");
        String clientId = "mqttx_e27920ac";
        clientId += String(random(0xffff), HEX);
        if (client.connect(clientId.c_str())) {
            Serial.println("Connected");
            client.publish("ThinkIOT/Publish", "Welcome");
            client.subscribe("ThinkIOT/Subscribe");
        } else {
            Serial.print("failed, rc=");
            Serial.print(client.state());
            Serial.println(" try again in 5 seconds");
            delay(5000);
        }
    }
}

void setup() {
    Serial.begin(115200);
    dht.begin();
    pinMode(LDRPIN, INPUT);
    // pinMode(SOIL_MOISTURE_PIN, INPUT);
    // pinMode(GAS_SENSOR_PIN, INPUT);
    setup_wifi();
    client.setServer(mqtt_server, 1883);
    client.setCallback(callback);
}

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

    // Membaca data dari DHT22
    float temperature = dht.readTemperature();
    float humidity = dht.readHumidity();
    
    // Membaca data dari LDR
    int ldrValue = analogRead(LDRPIN);
    
    // Membaca jarak dari sensor ultrasonik
    int distance = sonar.ping_cm();
    
    // Membaca kelembaban tanah
    // int soilMoisture = analogRead(SOIL_MOISTURE_PIN);
    
    // Membaca kadar gas
    // int gasLevel = analogRead(GAS_SENSOR_PIN);
    
    // Cetak data ke Serial Monitor
    Serial.print("Suhu: "); Serial.print(temperature); Serial.print(" C, ");
    Serial.print("Kelembaban: "); Serial.print(humidity); Serial.print(" %, ");
    Serial.print("Cahaya: "); Serial.print(ldrValue); Serial.print(" ADC, ");
    Serial.print("Jarak: "); Serial.print(distance); Serial.print(" cm, ");
    // Serial.print("Kelembaban Tanah: "); Serial.print(soilMoisture); Serial.print(" ADC, ");
    // Serial.print("Kadar Gas: "); Serial.println(gasLevel);
    
    // Kirim data ke Node-RED melalui MQTT
    String tempStr = String(temperature, 2);
    client.publish("ThinkIOT/temp", tempStr.c_str());
    
    String humStr = String(humidity, 1);
    client.publish("ThinkIOT/hum", humStr.c_str());
    
    String ldrStr = String(ldrValue);
    client.publish("ThinkIOT/light", ldrStr.c_str());
    
    String distStr = String(distance);
    client.publish("ThinkIOT/distance", distStr.c_str());
    
    // String soilStr = String(soilMoisture);
    // client.publish("/ThinkIOT/soil", soilStr.c_str());
    
    // String gasStr = String(gasLevel);
    // client.publish("/ThinkIOT/gas", gasStr.c_str());
    
    delay(2000); // Delay 2 detik
}