#include <WiFi.h>
#include "ThingsBoard.h"
#include <PubSubClient.h>
#include <DHT.h>
 
#define LDR 34
const float GAMMA = 0.7;
const float RL10 = 50;

#define DHTPIN 15
#define DHTTYPE DHT22

DHT dht(DHTPIN, DHTTYPE);
 
const char *ssid = "Wokwi-GUEST";
const char *password = "";
 
#define TOKEN "3A63TacZaEQhjmw8hKt2" //Access token
#define DEVICE_ID "a0bde6d0-86a1-11ed-9d5c-c3af996a4729" //Device ID
const char* mqtt_server = "thingsboard.cloud";
 
WiFiClient wifiClient;
PubSubClient client(wifiClient);
int status = WL_IDLE_STATUS;
void setup()
{
  Serial.begin(9600);
  delay(10);
  pinMode(LDR, INPUT);
  dht.begin();
  delay(10);
  Serial.print(" Connect to : ");
  Serial.println(ssid);
  WiFi.begin(ssid, password);
  while (WiFi.status() != WL_CONNECTED)
  {
    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);
 
}
 
void loop()
{
  if ( !client.connected() )
  {
    reconnect();
  }
  getData();
  delay(5000);
}
 
void getData()
{
  int analogValue = analogRead(LDR);
  float voltage = (analogValue / 4095.) * 5;
  float resistance = 2000 * voltage / (1 - voltage / 5);
  float lux = pow(RL10 * 1e3 * pow(10, GAMMA) / resistance, (1 / GAMMA));
 
  //Serial.println(lux);
 
  String payload = "{";
  payload += "\"Intensitas_Cahaya\":";
  payload += lux;
  payload += "}";

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

  //Serial.print(humidity);
  String nilaikelembaban = "{";
  nilaikelembaban += "\"Kelembaban\":";
  nilaikelembaban += humidity;
  nilaikelembaban += "}";

 // Serial.print(temperature);
  String nilaisuhu = "{";
  nilaisuhu += "\"Suhu\":";
  nilaisuhu += temperature;
  nilaisuhu += "}";

  char attributes[1000];
  payload.toCharArray( attributes, 1000 );
  client.publish( "v1/devices/me/telemetry", attributes);
  client.publish( "v1/devices/me/attributes", attributes);

  char attributes2[1000];
  nilaikelembaban.toCharArray( attributes2, 1000 );
  client.publish( "v1/devices/me/telemetry", attributes2);
  client.publish( "v1/devices/me/attributes", attributes2);

  char attributes3[1000];
  nilaisuhu.toCharArray( attributes3, 1000 );
  client.publish( "v1/devices/me/telemetry", attributes3);
  client.publish( "v1/devices/me/attributes", attributes3);

  Serial.print(" \t");
  Serial.println( attributes );

  Serial.print(" \t");
  Serial.println( attributes2 );

  Serial.print(" \t");
  Serial.println( attributes3 );
}
 
void reconnect() {
  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 ...");
    if ( client.connect(DEVICE_ID, TOKEN, "") ) {
      Serial.println( "[DONE]" );
    } else {
      Serial.print( "[FAILED] [ rc = " );
      Serial.println( " : retrying in 5 seconds]" );
      delay( 5000 );
    }
  }
}