"Nutrindo o Futuro: Crescendo Conhecimento, Colhendo Sustentabilidade."

#include <WiFi.h>
#include <PubSubClient.h>
 
//-------------------------------
// Dados da Rede
const char* ssid = "NomeDaRede";                          // Nome da Rede
const char* password = "SenhaDaRede";                  // Senha da Rede
const char* mqtt_server = "MQTT";               // Endereço do Servidor MQTT
 
#define mqttuser "homeassistant"
#define mqttpass "eide4Che4ahsohphohvesheeVaiFuijaish2sai9oojiuli4uoqu0shahch0laey"
 
// Declaração de Variáveis Específicas e Funções da Biblioteca
WiFiClient espClient;                    // Chama a Biblioteca WifiClient como espClient
PubSubClient client(espClient);          // Chama a Biblioteca PubSubClient como client, passando o cliente wifi
#define MSG_BUFFER_SIZE	(50)             // define o tamanho limite da mensagem como 50 caracteres
char msg[MSG_BUFFER_SIZE];               // cria uma lista de carctéres "mensagem", com o tamanho limite
 
// Variáveis comuns ao código
byte pirPin = 4;
byte pirState = 0; // Lista com estado de cada botao
byte pirPState = 0; // Lista com estado prévio de cada botao
unsigned long lastBounce = 0; // reseta o relogio
unsigned long pirTimer = 0; // timer do botao
 
int pirTimeOut = 100;
 
 
//-------------------------------
// Inicializando a Conexão Wifi
void setup_wifi() {
  delay(10);
 
  Serial.println();
  Serial.print("Conectando a: ");
  Serial.println(ssid);
 
  WiFi.mode(WIFI_STA);                        // Define o modo do Wifi como Station --> Conecta em uma rede
  WiFi.begin(ssid, password);                 // Inicia o wifi, passando rede e senha
 
  while (WiFi.status() != WL_CONNECTED) {     // Executa o código em looping enquanto o resultado não for 
    delay(500);                               // WL_CONNECTED --> Wifi conectado
    Serial.print(".");
  }
 
  Serial.println("");
  Serial.println("WiFi conectado");
  Serial.println("Endereço IP: ");
  Serial.println(WiFi.localIP());
}
 
//-------------------------------
// Caso uma mensagem for recebida
void callback(char* topic, byte* payload, unsigned int length) {
  Serial.print("Mensagem recebida [");
  Serial.print(topic);                         // Printa o tópico da mensagem
  Serial.print("] ");                          
  for (int i = 0; i < length; i++) {
    Serial.print((char)payload[i]);           // Printa a mensagem caractére por caractére
  }
  Serial.println();
}
 
//-------------------------------
// Reconectando
void reconnect() {
  // Looping enquanto não reconectar
  client.setServer(mqtt_server, 1883);
 
  while (!client.connected()) {
    Serial.println("Conectando ao Broker MQTT");
    client.connect("esp8266",mqttuser,mqttpass);
    delay(3000);
  } Serial.println("MQTT conectado");
 
  // Tentando conectar
  if (client.connected()) {            // Se o returno da função for True, então conecta
    Serial.println("conectado");
 
    // Assim que conectado, faz uma públicação inicial nos tópicos desejados...
    client.publish("esp8266/ENERGY_ESCADA_1/state", "SensConnected");
  } 
}
 
//-------------------------------
void setup() {
  pinMode(pirPin, INPUT); // define o pino do PIR como um sensor
  Serial.begin(115200);
 
  setup_wifi();                                   // inicializa o wifi
  client.setServer(mqtt_server, 1883);            // seleciona o servidor do cliente
  client.setCallback(callback);                   // seleciona a função de retorno do esp
}
 
//-------------------------------
void loop() {
  if (!client.connected()) {                      // se o cliente estiver desconectado,
    reconnect();                                  // executa a função para reconectar
  }
  client.loop();                                  // 'refresca' a conexão MQTT com o servidor
 
  // Tratamento de dados e leitura de sensores
  pir();
}
 
//------------------------------
void pir() {
  pirState = digitalRead(pirPin);
  pirTimer = millis() - lastBounce; // corre o timer
 
  if (pirTimer > pirTimeOut) {
 
    if (pirState != pirPState) {
 
      lastBounce = millis();
 
      if (pirState == 1) {
        Serial.print("Sensor on");
 
        snprintf(msg, MSG_BUFFER_SIZE, "on");
        Serial.print("Mensagem publicada: ");
        Serial.println(msg);
        client.publish("esp8266/ENERGY_ESCADA_1/state", msg);
      } else {
        Serial.print("Sensor off");
      }
 
      pirPState = pirState;
    }
  }  
}