//*Circuit Diagram #2 - Double LDR Brightness & Darkness Sensor
//**" The coding and solfware process of LDR Brightness & Darkness Sensors in smart home automation system "**//
//Smart Home Automation -> " SHA " (variable)
#include <PubSubClient.h> //Library Contact MQTT
#include <WiFi.h>         //Library Contact WiFi

//Configuration of Topic to MQTT
#define LDR_Pin001    34  //GPIO-34 to 1st-LDR
#define LDR_Pin002    33  //GPIO-33 to 2nd-LDR
#define Relay_LED003  15  //GPIO-15 to 3rd-LEDin 
#define Relay_LED004  14  //GPIO-14 to 4th-LEDin 

#define TOPIC_SUBSCRIBE_LEDin_003B   "SHA_on_off_LEDin003B"
#define TOPIC_SUBSCRIBE_LEDin_004B   "SHA_on_off_LEDin004B"
#define TOPIC_PUBLISH_LDR_001B       "SHA/LDR001B"
#define TOPIC_PUBLISH_LDR_002B       "SHA/LDR002B"

#define PUBLISH_DELAY 2000  // Delay time for publish data to MQTT Broker
                            // millis() -> loop 2 second
#define ID_MQTT "ESP32_Double_LDRs" // Device ID for connect to MQTT Broker

const char SSID[] = "Wokwi-GUEST";   //Enter WiFi SSID
const char PASSWORD[] = "";   //Enter WiFi Password

//URL for MQTT broker
const char *BROKER_MQTT = "broker.hivemq.com";
int BROKER_PORT = 1883; //Port of Broker MQTT

unsigned long Publish_Update;

static char strBrightDark[10] = {0};

//Variable for WiFi Client Object
WiFiClient espClient;
PubSubClient MQTT(espClient);

void Initial_WiFi(void);
void Initial_MQTT(void);
void Callback_MQTT(char *topic, byte *payload, unsigned int length);
void Reconnect_MQTT(void);
void Reconnect_WiFi(void);
void Check_WiFiAndMQTT(void);
void Detect_Darkness_LDR_2nd(void);

/*Start Beginning of WiFi*/
void Initial_WiFi(void) 
{
  delay(10);
  Serial.println("------Connect to WI-FI------");
  Serial.print("Connecting to : ");
  Serial.println(SSID);

  Reconnect_WiFi();
}

/*Start Beginning of MQTT*/
void Initial_MQTT(void) 
{
  MQTT.setServer(BROKER_MQTT, BROKER_PORT); 
  MQTT.setCallback(Callback_MQTT);
}

// Function Callback: Receive Message from another MQTT Client publish message pass through the MQTT Broker
void Callback_MQTT(char *topic, byte *payload, unsigned int length) 
{
  String msg;

  //Obtem a string do payload recebido
  for (int i = 0; i < length; i++) {
    char c = (char)payload[i];
    msg += c;
  }

  Serial.printf("Receive string via MQTT : %s on topic : %s\n", msg, topic);

  if(String(topic) == TOPIC_SUBSCRIBE_LEDin_003B) {
    if (msg.equals("1")) {
      digitalWrite(Relay_LED003, HIGH);
      Serial.println("LEDin 3rd status : 'ON'");
    }
    if (msg.equals("0")) {
      digitalWrite(Relay_LED003, LOW);
      Serial.println("LEDin 3rd status : 'OFF'");
    }
  }

  if(String(topic) == TOPIC_SUBSCRIBE_LEDin_004B) {
    if (msg.equals("1")) {
      digitalWrite(Relay_LED004, HIGH);
      Serial.println("LEDin 4th status : 'ON'");
    }
    if (msg.equals("0")) {
      digitalWrite(Relay_LED004, LOW);
      Serial.println("LEDin 4th status : 'OFF'");
    }
  }
}
//Function Reconnect MQTT Broker
void Reconnect_MQTT(void) 
{
  while (!MQTT.connected()) {
    Serial.print("Connecting MQTT Broker : ");
    Serial.println(BROKER_MQTT);
    if (MQTT.connect(ID_MQTT)) {
      Serial.println("Connecting the MQTT Broker success!\n");

      MQTT.subscribe(TOPIC_SUBSCRIBE_LEDin_003B);
      MQTT.subscribe(TOPIC_SUBSCRIBE_LEDin_004B);

    }
    else {
      Serial.println("Fail! to connect then reconnect MQTT Broker again in 2 seconds.\n");
      delay(2000);
    }
  }
}
//Function Reconnect WiFi Router
void Reconnect_WiFi(void) 
{
  if (WiFi.status() == WL_CONNECTED)
    return;
  
  WiFi.begin(SSID, PASSWORD); 
  
  while (WiFi.status() != WL_CONNECTED) {
    delay(100);
    Serial.print("#.....#\n");
  }
  Serial.print("Connected WiFi success!\n");
  Serial.print(SSID);
  Serial.println("IP Address : ");
  Serial.println(WiFi.localIP());
}
// Function checking connected to WiFi Router and MQTT Broker */
void Check_WiFiAndMQTT(void) 
{
  if (!MQTT.connected())
    Reconnect_MQTT();
  Reconnect_WiFi();
}
//-------------------------------------------------------------------------------------//

int LDR_Sensor_1st = 34 ;
int LDR_Sensor_2nd = 33 ;

int LEDin_3rd = 15 ;
int LEDin_4th = 14 ;

//int LDR_1st_Limit_Criterion = 40;
int LDR_2nd_Limit_Criterion = 40;

//int DarkNess_LDR1st = 0;
int DarkNess_LDR2nd = 0;

unsigned long BeginLoop_Delay = 0;

//-------------------------------------------------------------------------------------//
// "LDR Brightness & Darkness Sensor Function-2nd" //
void Detect_Darkness_LDR_2nd() 
{
  DarkNess_LDR2nd = analogRead(LDR_Sensor_2nd);
  DarkNess_LDR2nd = map(DarkNess_LDR2nd, 0, 4095, 0, 100);
  Serial.print("LDR 2nd Sensor Value : ");
  Serial.println(DarkNess_LDR2nd);

  if(DarkNess_LDR2nd <= LDR_2nd_Limit_Criterion) {
    String text_3 = "Darkness in LDR 2nd Detected!!!" ;
    Serial.println(text_3);
    digitalWrite(LEDin_4th, HIGH);
  }
  else {
    String text_4 = "Darkness in LDR 2nd Stopped!!!" ;
    Serial.println(text_4);
    digitalWrite(LEDin_4th, LOW);
  }
}
void setup() 
{
  Serial.begin(115200); //Initialize Serial Moniter
  Serial.println("Get Started!!!");

  pinMode(LDR_Sensor_1st, INPUT);
  pinMode(LDR_Sensor_2nd, INPUT);
  pinMode(LEDin_3rd, OUTPUT);
  pinMode(LEDin_4th, OUTPUT);

  Initial_WiFi();
  Initial_MQTT();
}

void loop() 
{
BeginLoop_Delay = millis();
if ((BeginLoop_Delay - Publish_Update) >= PUBLISH_DELAY) {
    Publish_Update = millis();
    //Verify the operation of the WiFi connection and go to the MQTT broker
    Check_WiFiAndMQTT();

    //-----------------------------------------------------//
    Serial.print("******************************\n");
    Serial.print("Check LDR 1st Status : ");
    Serial.println(analogRead(LDR_Sensor_1st));
    Serial.print("Check LDR 2nd Status : ");
    Serial.println(analogRead(LDR_Sensor_2nd));
    Serial.print("******************************\n");
    //-----------------------------------------------------//
    
    Detect_Darkness_LDR_2nd();

    //Change format of the Data as String for send it via MQTT protocol
    sprintf(strBrightDark, "%d",analogRead(LDR_Sensor_1st));
    //sprintf(strBrightDark002, "%d",analogRead(LDR_Sensor_2nd));
    delay(1000);

    //Send data string to MQTT Broker
    MQTT.publish(TOPIC_PUBLISH_LDR_001B, strBrightDark);
    //MQTT.publish(TOPIC_PUBLISH_LDR_002B, strBrightDark002);

    // Keep-alive for connected MQTT broker
    MQTT.loop();
  }
}