//*Circuit Diagram #1 - PIR Motion Sensors*//
//**" The coding and solfware process of PIR Motion Sensors in smart home automation system "**//
//Smart Home Automation -> " SHA " (variable)
#include <PubSubClient.h> //Library Contact MQTT
#include <WiFi.h>         //Library Contact WiFi

#define PIR_Pin       22     //GPIO-22 to PIR
#define Relay_LED001  12     //GPIO-12 to 1st-LEDin 

#define TOPIC_SUBSCRIBE_LEDin_001   "SHA_on_off_LEDin001"
#define TOPIC_PUBLISH_PIR           "SHA/PIR"

#define PUBLISH_DELAY 2000  // Delay time for publish data to MQTT Broker
                            // millis() -> loop 2 second
#define ID_MQTT "ESP32_PIR" // 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 strMotion[10] = {0};

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);

/*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 (msg.equals("1")) {
      digitalWrite(Relay_LED001, HIGH);
      Serial.println("LEDin 1st status : 'ON'");
    }
    if (msg.equals("0")) {
      digitalWrite(Relay_LED001, LOW);
      Serial.println("LEDin 1st 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_001);

    }
    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 PIR_Sensor = 22;

int LEDin_1st = 12;

int MoveMent_PIR = 0;

unsigned long BeginLoop_Delay = 0;

//-------------------------------------------------------------------------------------//

void setup() 
{
  Serial.begin(115200); //Initialize Serial Moniter
  Serial.println("Get Started!!!");

  pinMode(PIR_Sensor, INPUT);
  pinMode(LEDin_1st, OUTPUT);

  Initial_WiFi();
  Initial_MQTT();
}

void loop() 
{
//-----------------------------------------------------//
  Serial.print("******************************\n");
  Serial.print("Check PIR Status : ");
  Serial.println(digitalRead(PIR_Sensor));
  
//-----------------------------------------------------//
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();

    MoveMent_PIR = digitalRead(PIR_Sensor);
    if(MoveMent_PIR == 1) {
    String text_1 = "Motion in PIR Detected!!!" ;
    Serial.println(text_1);
    digitalWrite(LEDin_1st, HIGH);
    } else {
    String text_2 = "Motion in PIR Stopped!!!" ;
    Serial.println(text_2);
    digitalWrite(LEDin_1st, LOW);
    }

    //Change format of the Data as String for send it via MQTT protocol
    sprintf(strMotion, "%d",digitalRead(PIR_Sensor));
    delay(1000);

    //Send data string to MQTT Broker
    MQTT.publish(TOPIC_PUBLISH_PIR, strMotion);

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