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


#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        "cloud.thingsboard.io"
#define THINGSBOARD_ACCESSTOKEN   "5kttCWYzoQLO4M2AHtfA" //9e2dNlgdFIbYEoo3ONZB Ubah Token

#define SERIAL_DEBUG_BAUD    115200

LiquidCrystal_I2C lcd(0x27, 16, 2);

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

// Array with relays that should be lit up one by one
uint8_t relay_cycling[] = { 21, 19, 18 };
// Array with relays that should be controlrelay from ThingsBoard, one by one
uint8_t relay_control[] = {0, 13, 12};

DHTesp dht;
#define DHT_PIN 15

DHTesp dht2;
#define DHT_PIN_2 26 

// Main application loop delay
int quant = 20;
// Initial period of relay cycling.
int relay_delay = 0;
// Period of sending a temperature/humidity data.
int send_delay = 2000;

// Time passed after relay was turned ON, milliseconds.
int relay_passed = 0;
// 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;
// relay number that is currenlty ON.
int current_relay = 0;


const int pinRelay = 4;

float temperature = 0;
float humidity = 0;
float temperature2 = 0;
float humidity2 = 0;

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

  // Process data

  relay_delay = data;

  Serial.print("Set new delay: ");
  Serial.println(relay_delay);

  return String(relay_delay);
}

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


// RPC handlers
RPC_Callback callbacks[] = {
  { "setValue",         processDelayChange },
  { "getValue",         processGetDelay },  
};

void setup() {
  
  Serial.begin(SERIAL_DEBUG_BAUD);
  WiFi.begin(WIFI_AP_NAME, WIFI_PASSWORD);
  InitWiFi();

  // Pinconfig
  for (size_t i = 0; i < COUNT_OF(relay_cycling); ++i) {
    pinMode(relay_cycling[i], OUTPUT);
  }

  for (size_t i = 0; i < COUNT_OF(relay_control); ++i) {
    pinMode(relay_control[i], OUTPUT);
  }

  // Initialize temperature sensor
  dht.setup(DHT_PIN, DHTesp::DHT22);
  dht2.setup(DHT_PIN_2, DHTesp::DHT22);

  pinMode(pinRelay, OUTPUT);
  digitalWrite(pinRelay, LOW);

  lcd.init();
  lcd.backlight();
  lcd.clear();
  

}

void loop() 
{
  delay(quant);

  relay_passed += quant;
  send_passed += quant;

  // Check if next relay should be lit up
  if (relay_passed > relay_delay) {
    // Turn off current relay
    digitalWrite(relay_cycling[current_relay], LOW);
    relay_passed = 0;
    current_relay = current_relay >= 2 ? 0 : (current_relay + 1);
    // Turn on next relay in a row
    digitalWrite(relay_cycling[current_relay], HIGH);
  }

  // Reconnect to WiFi, if needed
  if (WiFi.status() != WL_CONNECTED) {
    reconnect();
    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("Fairelay 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("Fairelay to subscribe for RPC");
      return;
    }

    Serial.println("Subscribe done");
    lcd.clear();
    lcd.setCursor(0,0);
    lcd.print("Welcome......!!!");
    lcd.setCursor(0,1);
    lcd.print("Siram Kuyyyy....");
    subscribed = true;
  }  



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

    if (isnan(lastValues.humidity) || isnan(lastValues.temperature)) {
      Serial.println("Fairelay to read from DHT sensor!");
    } else {
      humidity = lastValues.humidity;
      Serial.print("POT1 humidity: ");
      Serial.println(humidity);
      tb.sendTelemetryFloat("humidity", humidity);
    }
    
    if (isnan(lastValues2.humidity) || isnan(lastValues2.temperature)) {
      Serial.println("Fairelay to read from DHT sensor!");
    } else {
      humidity2 = lastValues2.humidity;
      Serial.print("POT2 humidity: ");
      Serial.println(humidity2);
      tb.sendTelemetryFloat("humidity2", humidity2);

    }

    if(relay_delay){
        digitalWrite(pinRelay, HIGH);
        Serial.println("Waterpump nyala");     
    }else{                   
      digitalWrite(pinRelay, LOW);
      Serial.println("Waterpump mati");    
    }

    lcd.clear();
    lcd.setCursor(0,0);
    lcd.print("POT1 HUM : ");
    lcd.setCursor(11,0);
    lcd.print(humidity);

    lcd.setCursor(0,1);
    lcd.print("POT2 HUM : ");
    lcd.setCursor(11,1);
    lcd.print(humidity2);
    delay(1000);

    lcd.clear();
    if(humidity>60){
      lcd.setCursor(0,0);
      lcd.print("P-1:SangatLembap");
    }else if(humidity>=40){
      lcd.setCursor(0,0);
      lcd.print("P-1:Lembap");
    }else if(humidity<40){
      lcd.setCursor(0,0);
      lcd.print("P-1:Kering");
    }

    if(humidity2>60){
      lcd.setCursor(0,1);
      lcd.print("P-2:SangatLembap");
    }else if(humidity2>=40){
      lcd.setCursor(0,1);
      lcd.print("P-2:Lembap");
    }else if(humidity2<40){
      lcd.setCursor(0,1);
      lcd.print("P-2:Kering");
    }
    delay(1000);

    lcd.clear();
    if(humidity<40 || humidity2<40){
      lcd.setCursor(0,0);
      lcd.print("Segera Siram..!!");
    }else{
      lcd.setCursor(0,0);
      lcd.print("Jangan Disiram..!!");
    }
    delay(1000);
    send_passed = 0;
  } 
  
  tb.loop();
  
  
}

void InitWiFi()
{
  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");
}

void reconnect() {
  // Loop until we're reconnected
  status = WiFi.status();
  if ( status != WL_CONNECTED) {
    WiFi.begin(WIFI_AP_NAME, WIFI_PASSWORD);
    while (WiFi.status() != WL_CONNECTED) {
      delay(500);
      Serial.print(".");
    }
    Serial.println("Connected to AP");
  }
}