// mengakses file-file library
#include <WiFi.h>           //library bekerja dengan wifi
#include <PubSubClient.h>   //library MQTT
#include <DHTesp.h>         //library DHT

// data akun konek ke SSID
const char* ssid = "Wokwi-GUEST";
const char* password = "";

// data akun MQTT server/broker
const char* mqttServer = "broker.hivemq.com";
int mqttPort = 1883;
const char* topicMQTT = "ilham/LEDsuhu";

// membuat object untuk mengelola koneksi wifi
WiFiClient espClient;

//membuat object untuk mengelola layanan MQTT
//diberi nama clientMQTT
PubSubClient clientMQTT(espClient);


// Mendeklarasikan function
void connectToInternet();  // function untuk melayani koneksi ke SSID
void setupMQTT();          // function seting data koneksi ke MQTT server
void reconnectMQTT();      // function koneksi ulang ke MQTT server, jika koneksi dengan MQTT server putus

#define dhtPin 15

DHTesp dht;

float TempC = 0; // Variabel untuk menyimpan suhu

// Konfigurasi umum
void setup() {
  //konfigurasi Serial monitor
  Serial.begin(115200);
  dht.setup(dhtPin, DHTesp::DHT22);

  // Konek ke Wifi - memanggil function connectToInternet()
  connectToInternet();

  // Konek ke MQTT Broker
  setupMQTT();
}

void loop() {
  // cek koneksi ke MQTT
  if ( !clientMQTT.connected() )   {
    //Konek ke MQTT server
    reconnectMQTT();
  }
  clientMQTT.loop();
  TempAndHumidity DataDHT = dht.getTempAndHumidity();
  TempC = DataDHT.temperature;

  Serial.println("Temp: " + String(TempC, 2) + "°C");

  clientMQTT.publish(topicMQTT,String(TempC).c_str());

  delay(2000);
}

// Detil function
//------------------------------------------
// function connectToInternet()
// bertugas menjalankan tugas konek ke SSID
void connectToInternet(){
  WiFi.begin(ssid, password);   // Mencoba connect ke Wifi

  // Melakukan pengecekan terhadap status koneksi ke WI-Fi
  while (WiFi.status() != WL_CONNECTED) {
      delay(500);
      Serial.print(".");
    } 
    Serial.println("");
    Serial.println("Connected to Wi-Fi");
    Serial.print("IP Address : ");
    Serial.println(WiFi.localIP());
}
// ---------------------------------------------------------

// untuk melakukan koneksi ulang (reconnect) ke broker MQTT 
// jika klien kehilangan koneksi dengan broker 
// atau gagal melakukan koneksi saat pertama kali menjalankan program.
// ESP32 Reconnect to broker
void reconnectMQTT() {
  Serial.println("Connecting to MQTT Broker...");
  while (!clientMQTT.connected()) {
      Serial.println("Reconnecting to MQTT Broker..");

      //membuat Cliend ID untuk setiap device
      String clientId = "ESP32Client-";
      clientId += String(random(0xffff), HEX);
      
      // menampilkan pesan koneksi ke MTQQ broker sukses
      if (clientMQTT.connect(clientId.c_str())) { // Ubah mqttClient.connect menjadi clientMQTT.connect
        Serial.println("Connected.");
        Serial.print("Client ID : ");
        Serial.println(clientId);
        clientMQTT.publish(topicMQTT,clientId.c_str()); // Ubah mqttClient.publish menjadi clientMQTT.publish
      }      
  }
}

//-------------------------------------------------

// mengatur dan menginisialisasi koneksi ke broker MQTT 
void setupMQTT() {
  clientMQTT.setServer(mqttServer, mqttPort); // Mengatur detail broker target  yang digunakan
}