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

#define WIFI_AP "Wokwi-GUEST"
#define WIFI_PASSWORD ""

#define TOKEN "nOZllllAl2ATWqhMxQri"

// DHT
#define DHTPIN 15
#define DHTTYPE DHT22

char thingsboardServer[] = "thingsboard.cloud";

WiFiClient client1;

// Initialize DHT sensor.
DHT dht(DHTPIN, DHTTYPE);

ThingsBoard device1(client1);

int status = WL_IDLE_STATUS;
unsigned long lastSend;

void setup()
{
  Serial.begin(115200);
  dht.begin();
  delay(10);
  InitWiFi();
  lastSend = 0;
}

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

  if ( millis() - lastSend > 1000 ) { // Update dan kirim tiap 1 detik
    kirimDataKeThingsboard();
    lastSend = millis();
  }

  device1.loop();
}

void kirimDataKeThingsboard()
{
  Serial.println("Mengambil data sensor");

  // Reading temperature atau humidity
  float humidity = dht.readHumidity();
  //  temperature dlm Celsius
  float temperature = dht.readTemperature();

  // cek jika gagal membaca sensor.
  if (isnan(humidity) || isnan(temperature)) {
    Serial.println("Gagal membaca sensor DHT!");
    return;
  }

  Serial.println("Mengirim data ke ThingsBoard:");
  Serial.print("Humidity: ");
  Serial.print(humidity);
  Serial.print(" %\t");
  Serial.print("Temperature: ");
  Serial.print(temperature);
  Serial.println(" °C ");

  device1.sendTelemetryFloat("temperature", temperature);
  device1.sendTelemetryFloat("humidity", humidity);
}

void InitWiFi()
{
  Serial.println("Menghubungkan ...");
  // mencoba koneksi ke WiFi

  WiFi.begin(WIFI_AP, WIFI_PASSWORD);
  while (WiFi.status() != WL_CONNECTED) {
    delay(500);
    Serial.print(".");
  }
  Serial.println("Berhasil terhubung!");
}

void reconnect() {
  // diulang sampai reconnected
  while (!device1.connected()) {
    status = WiFi.status();
    if ( status != WL_CONNECTED) {
      WiFi.begin(WIFI_AP, WIFI_PASSWORD);
      while (WiFi.status() != WL_CONNECTED) {
        delay(500);
        Serial.print(".");
      }
      Serial.println("Berhasil terhubung!");
    }
    Serial.print("Menghubungkan ke ThingsBoard node ...");
    if ( device1.connect(thingsboardServer, TOKEN) ) {
      Serial.println( "[DONE]" );
    } else {
      Serial.print( "[FAILED]" );
      Serial.println( " [ retrying in 5 seconds]" );
      // Wait 5 detik
      delay( 5000 );
    }
  }
}