#include <LiquidCrystal_I2C.h>
#include <ESP32Servo.h>
#include <DHTesp.h>         // DHT for ESP32 library
#include <WiFi.h>           // WiFi control for ESP32
#include "ThingsBoard.h"

//Menghitung jumlah data dalam array
#define COUNT_OF(x) ((sizeof(x)/sizeof(0[x])) / ((size_t)(!(sizeof(x) % sizeof(0[x])))))

#define WIFI_AP_NAME              "Wokwi-GUEST"
#define WIFI_PASSWORD             ""
#define THINGSBOARD_SERVER        "thingsboard.cloud"
#define THINGSBOARD_ACCESSTOKEN   "Q4fulDL5VtECq2JW1BC0"

WiFiClient espClient;
ThingsBoard tb(espClient);
int status = WL_IDLE_STATUS;

LiquidCrystal_I2C lcd(0x27,20,4); 

DHTesp dhtSensor;
Servo servo;

const float GAMMA = 0.7;
const float RL10 = 50;
const int DHT_PIN = 15;
const int LDR = 34;
const int servoPin = 2; //rooftop
const int uv = 25; //led uv (ungu)
const int valve = 26; //led kuning
const int blower = 27; //led merah
const int fan = 33; //led hijau
const int heater = 18; //led putih
const int buzz = 32; //notifier


int i;
// Main application loop delay
int quant = 20; //delay pengiriman data
float control_tem = 0;

// Period of sending a temperature/humidity data.
int send_delay = 2000;

// Time passed after temperature/humidity data was sent, milliseconds.
int send_passed = 0;

// Set to true if application is subscribed for the RPC messages.
bool subscribed = false;

float temperature = 0;
float humidity = 0;

RPC_Response processTempChange(const RPC_Data &data)
{
  Serial.println("Received the set delay RPC method");

  // Process data

  control_tem = data;

  Serial.print("Atur suhu ke: ");
  Serial.println(control_tem);

  return String(control_tem);
}

RPC_Response processGetTemp(const RPC_Data &data)
{
  Serial.println("Received the get value method");
  return String(control_tem);
}


// RPC handlers
RPC_Callback callbacks[] = {
  { "setValue",         processTempChange },
  { "getValue",         processGetTemp },
};

void setup() {
  Serial.begin(115200);
  
  lcd.init();                      
  lcd.backlight();
  lcd.setCursor(5,0);
  lcd.print("Kelompok 4");
  delay(1000);
  lcd.clear();

  pinMode(uv,OUTPUT);
  pinMode(valve,OUTPUT);
  pinMode(blower, OUTPUT);
  pinMode(fan, OUTPUT);
  pinMode(buzz, OUTPUT);
  pinMode(heater, OUTPUT);
  
  servo.attach(servoPin, 500, 2400);
  dhtSensor.setup(DHT_PIN, DHTesp::DHT22);
}

void loop() {

delay(quant);

  send_passed += quant;

  // Reconnect to WiFi, if needed
  if (WiFi.status() != WL_CONNECTED) {
    connect();
    return;
  }

  // Reconnect to ThingsBoard, if needed
  if (!tb.connected()) {
    subscribed = false;
    // Connect to the ThingsBoard
    Serial.print("Connecting to: ");
    Serial.print(THINGSBOARD_SERVER);
    Serial.print(" with token ");
    Serial.println(THINGSBOARD_ACCESSTOKEN);
    if (!tb.connect(THINGSBOARD_SERVER, THINGSBOARD_ACCESSTOKEN)) {
      Serial.println("Failed to connect");
      return;
    }
  }

  // Subscribe for RPC, if needed
  if (!subscribed) {
    Serial.println("Subscribing for RPC... ");
    // Perform a subscription. All consequent data processing will happen in
    // callbacks as denoted by callbacks[] array.
    if (!tb.RPC_Subscribe(callbacks, COUNT_OF(callbacks))) {
      Serial.println("Failed to subscribe for RPC");
      return;
    }
    Serial.println("Subscribe done");
    subscribed = true;
  } 

  
  // Check if it is a time to send DHT22 temperature and humidity
  if (send_passed > send_delay) {
    Serial.println();
    Serial.print("Sending data... ");
    TempAndHumidity lastValues = dhtSensor.getTempAndHumidity();    

    if (isnan(lastValues.humidity) || isnan(lastValues.temperature)) {
      Serial.println("Failed to read from DHT sensor!");
    } else {
      temperature = lastValues.temperature;
      Serial.print("Suhu: ");
      Serial.print(temperature);
      humidity = lastValues.humidity;
      Serial.print(" Kelembaban: ");
      Serial.println(humidity);
      tb.sendTelemetryFloat("suhu", temperature);
      tb.sendTelemetryFloat("kelembaban", humidity);

      int analogValue = analogRead(LDR);
      float voltage = analogValue * 5/4095.0;
      float resistance = 2000 * voltage / (1 - voltage / 5);
      float lux = pow(RL10 * 1e3 * pow(10, GAMMA) / resistance, (1 / GAMMA));
      Serial.print("Lux: ");
      Serial.println(lux);
      tb.sendTelemetryFloat("lux", lux);
      
      lcd.clear();
      lcd.setCursor(14,3);
      lcd.print(String(temperature, 1) + "^C");
      lcd.setCursor(0,0);
      lcd.print("Kondisi Cuaca");
      lcd.setCursor(0,2);
      lcd.print("Kondisi Ruangan");

  if (lux <100){
    Serial.println("Status: Malam");//Night
    lcd.setCursor(0,1);
    lcd.print("Malam");
    servo.write(0); // Open Roof
    digitalWrite(uv, LOW); // Lampu UV mati
  } 

  if (lux >= 100 && lux <= 1500) {//Day ligth
    Serial.println("Status: Pagi Hari");
    lcd.setCursor(0,1);
    lcd.print("Pagi Hari");
    servo.write(0); // Open Roof
    digitalWrite(uv, LOW); // Lampu UV mati
  }
  
  if (lux > 1500 && lux <= 3000) {
    Serial.println("Status: Berawan");
    lcd.setCursor(0,1);
    lcd.print("Langit Berawan");
    servo.write(0); // Open Roof
    digitalWrite(uv, LOW); // Lampu UV mati
  }

  if (lux > 3000){
    Serial.println("Status: Cerah");
    lcd.setCursor(0,1);
    lcd.print("Langit Cerah");
    servo.write(180); // Close Roof
    digitalWrite(uv, HIGH); // Lampu UV Hidup
  }

   if (humidity < 80) {
    Serial.println("Status: Kering");
    lcd.setCursor(0,3);
    lcd.print("Kering");
    digitalWrite(blower, LOW);
    digitalWrite(valve, HIGH);
 }
  if (humidity >= 80 && humidity <= 90) {
    Serial.println("Status: Ideal");
    lcd.setCursor(0,3);
    lcd.print("Ideal");
    digitalWrite(blower, LOW);
    digitalWrite(valve, LOW);
  }

  if (humidity > 90) {
    Serial.println("Status: Basah");
    lcd.setCursor(0,3);
    lcd.print("Basah");
    digitalWrite(blower, HIGH);
    digitalWrite(valve, LOW);
  }
  
  if (temperature < 21) {
    Serial.println("Suhu: Dingin");
    digitalWrite(fan, LOW); 
    digitalWrite(heater, HIGH); 
    noTone(buzz);
  }

  if (temperature >=21 && temperature <= 27) {
    Serial.println("Suhu: Ideal");
    digitalWrite(fan, LOW); 
    digitalWrite(heater, LOW); 
    noTone(buzz);
  }

  if (temperature > 27) {
    Serial.println("Suhu: Panas");
    digitalWrite(fan, HIGH);
    digitalWrite(heater, LOW);
    tone(buzz,300);
    delay(1); // this speeds up the simulation
    //noTone(buzz);
  }
delay(1000);

    }
    send_passed = 0;
  }

  tb.loop();
}

void connect()
{
  Serial.println("Connecting to AP ...");
  // attempt to connect to WiFi network

  WiFi.begin(WIFI_AP_NAME, WIFI_PASSWORD);
  while (WiFi.status() != WL_CONNECTED) {
    delay(500);
    Serial.print(".");
  }
  Serial.println("Connected to AP");
}