#include <Adafruit_Sensor.h>
#include <DHT_U.h>
#include <WiFi.h>
#include <WiFiClientSecure.h> // <-- PERBAIKAN 1: Gunakan client yang aman
#include <PubSubClient.h>
#include <Servo.h>
#include <FastLED.h>

// Defining Pins
#define DHTPIN 14
#define LED 12
#define SERVO_PIN 15
#define LED_PIN 2
#define NUM_LEDS 16

// DHT parameters
#define DHTTYPE DHT22
DHT_Unified dht(DHTPIN, DHTTYPE);

// Servo motor & LED Strip
Servo servo;
CRGB leds[NUM_LEDS];

// MQTT Credentials
const char* ssid = "Wokwi-GUEST";
const char* password = "";
const char* mqttServer = "714189e20da344da800fb2591cb480c1.s1.eu.hivemq.cloud";
const int mqttPort = 8883;
const char* mqttUserName = "armanyrs25";
const char* mqttPwd = "AHk2VJT2invz_72";
const char* clientID = "esp32-client-arman-123"; // <-- PERBAIKAN 2: Tambahkan ClientID yang unik
const char* topic = "Tempdata";

// Parameters for non-blocking delay
unsigned long previousMillis = 0;
const long interval = 2000; // Interval diubah jadi 2 detik
float temp, hum;

// Setting up WiFi and MQTT client
WiFiClientSecure espClient; // <-- PERBAIKAN 1: Gunakan WiFiClientSecure
PubSubClient client(espClient);

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

void reconnect() {
    while (!client.connected()) {
        Serial.print("Attempting MQTT connection...");
        // <-- PERBAIKAN 3: Gunakan username dan password saat konek
        if (client.connect(clientID, mqttUserName, mqttPwd)) {
            Serial.println("connected");
            client.subscribe("lights");
            client.subscribe("servo");
            client.subscribe("lights/neopixel");
        } else {
            Serial.print("failed, rc=");
            Serial.print(client.state());
            Serial.println(" try again in 5 seconds");
            delay(5000);
        }
    }
}

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

    if (String(topic) == "lights") {
        digitalWrite(LED, (data == "ON") ? HIGH : LOW);
    } else if (String(topic) == "servo") {
        int degree = data.toInt();
        servo.write(degree);
    } else if (String(topic) == "lights/neopixel") {
        int r, g, b;
        sscanf(data.c_str(), "%d,%d,%d", &r, &g, &b);
        fill_solid(leds, NUM_LEDS, CRGB(r, g, b));
        FastLED.show();
    }
}

void setup() {
    Serial.begin(115200);
    dht.begin();
    pinMode(LED, OUTPUT);
    servo.attach(SERVO_PIN);
    FastLED.addLeds<WS2812, LED_PIN, GRB>(leds, NUM_LEDS);
    
    setup_wifi();
    
    espClient.setInsecure(); // Untuk testing, lewati validasi sertifikat
    client.setServer(mqttServer, mqttPort);
    client.setCallback(callback);
}

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

    unsigned long currentMillis = millis();
    if (currentMillis - previousMillis >= interval) {
        previousMillis = currentMillis;

        sensors_event_t event;
        dht.temperature().getEvent(&event);
        if (!isnan(event.temperature)) {
            temp = event.temperature;
        }

        dht.humidity().getEvent(&event);
        if (!isnan(event.relative_humidity)) {
            hum = event.relative_humidity;
        }

        String msgStr = String(temp) + "," + String(hum);
        Serial.print("Publishing message: ");
        Serial.println(msgStr);
        client.publish(topic, msgStr.c_str());
    }
}