#include <WiFi.h>
#include <PubSubClient.h>

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

// MQTT broker shiftr.io
const char* mqtt_server = "pings-112.cloud.shiftr.io";
const int   mqtt_port   = 1883;
const char* mqtt_user   = "pings-112";   // username shiftr.io
const char* mqtt_pass   = "pinsss";      // password shiftr.io

// Topik MQTT
const char* topic_sensor = "esp32/ldr_sensor";  

// Pin
#define LDR_PIN 34
#define LED_PIN 2

WiFiClient espClient;
PubSubClient client(espClient);

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

void reconnect() {
  while (!client.connected()) {
    Serial.print("Menghubungkan ke MQTT...");
    String clientId = "ESP32Client-" + String(random(0xffff), HEX);

    if (client.connect(clientId.c_str(), mqtt_user, mqtt_pass)) {
      Serial.println("TERHUBUNG ke broker MQTT");
    } else {
      Serial.print("Gagal, rc=");
      Serial.print(client.state());
      Serial.println(" coba lagi dalam 2 detik...");
      delay(2000);
    }
  }
}

void setup() {
  Serial.begin(115200);
  pinMode(LED_PIN, OUTPUT);
  setup_wifi();
  client.setServer(mqtt_server, mqtt_port);
}

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

  // Baca nilai LDR
  int ldrValue = analogRead(LDR_PIN);

  // Aturan: <300 nyalakan lampu
  if (ldrValue < 300) {
    digitalWrite(LED_PIN, HIGH);
  } else {
    digitalWrite(LED_PIN, LOW);
  }

  // Kirim nilai sensor ke MQTT
  char buffer[10];
  sprintf(buffer, "%d", ldrValue);
  client.publish(topic_sensor, buffer);

  Serial.print("Nilai LDR: ");
  Serial.println(ldrValue);

  delay(2000);
}