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

#define DHT22PIN 13
#define LEDmerah 15
#define LEDhijau 2

// 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 = "yumna/mqtt/dht";

// 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

DHT dht(DHT22PIN, DHT22);

void setup() {
  //konfigurasi Serial monitor
  Serial.begin(115200);

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

  // Konek ke MQTT Broker
  setupMQTT();

  // memanggil function callback()
  clientMQTT.setCallback(callback); //perintah menghubungkan ke mqtt broker untuk subscribe data

  pinMode(LEDmerah, OUTPUT);
  pinMode(LEDhijau, OUTPUT);

  // Start the DHT22 Sensor 
  dht.begin();
}

void loop() {
  // float humi = dht.readHumidity();
  int temp = dht.readTemperature();

  //Mengecek koneksi ke MQTT Broker
  if (!clientMQTT.connected()){
    reconnectMQTT(); // jika putus koneksi, dicoba lagi  
  }

  // Mempublish message
  clientMQTT.publish(topicMQTT, String(temp).c_str());

  delay(300);

  if(temp < 20 || temp > 23){
    digitalWrite(LEDhijau, LOW);
    digitalWrite(LEDmerah, HIGH);
  }else{
    digitalWrite(LEDhijau, HIGH);
    digitalWrite(LEDmerah, LOW);
  }
  delay(500);
}

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());
}


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


// 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())) {
        Serial.println("Connected.");
      }      
  }
}

void callback(String topicMQTT, byte* payload, unsigned int length)
{
  // variabel untuk menyimpan data sementara dalam tipe string
  // nama variabel messageTemp
  String messageTemp;

  //menampilkan pesan di Serial
  Serial.print("Pesan diterima di topic : ");
  Serial.println(topicMQTT);

  Serial.print("Isi pesan yang diterima dari broker: ");
  for (int i = 0; i<length; i++)
  {
    Serial.print( (char)payload[i] );
    //mengumpulkan data menjadi string
    messageTemp += (char)payload[i];
  }
  Serial.println("");
  Serial.println(messageTemp);
}