#if defined(ESP8266) //pengecekan mikrokontroller dan driver yang digunakan
#include <ESP8266WiFi.h>
#elif defined(ESP32)
#include <WiFi.h>
#endif
#include "ThingsBoard.h"
#include <PubSubClient.h>
#include "DHTesp.h"

#define ECHO_PIN 4 // deklarasi pin echo 
#define TRIG_PIN 2
const int DHT_PIN = 15;

DHTesp dhtSensor;

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

#define TOKEN "II9PtzPLAyLSlBuWpKNN" //Access token of device Display
const char* mqtt_server = "thingsboard.cloud";

WiFiClient wifiClient;
PubSubClient client(wifiClient); //deklarasi untuk menggabungkan wificlient dan pubsubclient
int status = WL_IDLE_STATUS;
void setup()
{
  Serial.begin(9600);
  delay(10);
  dhtSensor.setup(DHT_PIN, DHTesp::DHT22);
  pinMode(TRIG_PIN, OUTPUT); //trigger pin output
  pinMode(ECHO_PIN, INPUT); //echo pin input
  Serial.print(" Connect to : ");
  Serial.println(ssid);
  WiFi.begin(ssid, password);
//  WiFi.config(IP, NETWORK, NETMASK, DNS);
  while (WiFi.status() != WL_CONNECTED) //untuk mengecek wifi
  {
  delay(500);
  Serial.print("...");
  }
  Serial.print("\n");
  Serial.print("IP address : ");
  Serial.print(WiFi.localIP());
  Serial.print("\n");
  Serial.print("Connect to : ");
  Serial.println(ssid);    
  client.setServer( mqtt_server, 1883); //inisiasi broker MQTT
// client.setCallback(callback);
}

float readDistanceCM() {
  digitalWrite(TRIG_PIN, LOW);
  delayMicroseconds(2);
  digitalWrite(TRIG_PIN, HIGH);
  delayMicroseconds(10);
  digitalWrite(TRIG_PIN, LOW);
  int duration = pulseIn(ECHO_PIN, HIGH);
  return duration * 0.034 / 2;
}

void loop()
{
if ( !client.connected() ) //pengecekan wifi
{
    reconnect();
}
getData(); //mengeksekusi perintah pada void getData
  delay(5000);
}

void getData() //perintah untuk membaca, mengkonversi data intensitas cahaya dan mengirimkan data
{
  TempAndHumidity data = dhtSensor.getTempAndHumidity();
  float distance = readDistanceCM();

  Serial.println(data.temperature);
  Serial.println(data.humidity);
  Serial.println(distance); 

  String payload = "{"; //membuat variabel payload
  payload += "\"Suhu\":";payload += data.temperature;  //membuat folder menggunakan += pada satu baris
  payload += ",";
  payload += "\"humiditas\":";payload += data.humidity;
  payload += ",";
  payload += "\"jarak\":";payload += distance;
  payload += "}"; ///hasil {"Intensitas Cahaya":lux} challange buat "Temperature":suhu}

  char attributes[1000]; //pembuatan untuk array attributes yang akan dikirimkan ke server thingsboard
  payload.toCharArray( attributes, 1000 ); //variabel payload kita konversi ke nama attributes dengan nilai 1000
  client.publish( "v1/devices/me/telemetry",attributes); //perintah untuk publish data dari ke attributes
  client.publish( "v1/devices/me/attributes",attributes);
  Serial.println( attributes );   
}

void reconnect() { //untuk mengkoneksikan ulang ke thingsboard apabila wifi terbutus
  // Loop until we're reconnected
  while (!client.connected()) {
    status = WiFi.status();
    if ( status != WL_CONNECTED) {
      WiFi.begin(ssid, password);
      while (WiFi.status() != WL_CONNECTED) {
        delay(500);
        Serial.print(".");
      }
      Serial.println("Connected to AP");
    }
    Serial.print("Connecting to ThingsBoard node ...");
    // Attempt to connect (clientId, username, password)
    if ( client.connect("3a90f960-1ad1-11ed-b480-cbe4cea4aa70", TOKEN, "") ) {
      Serial.println( "[DONE]" );
    } else {
      Serial.print( "[FAILED] [ rc = " );
      Serial.println( " : retrying in 5 seconds]" );
      delay( 500 );
    }
  }
}