#include "globals.h"
#include <WiFi.h>
#include <PubSubClient.h>

// Prototypes
void setupWiFi();
void reconnectMQTT();
void setupWebServer();
void setupOTA();
void taskCore1(void *pvParameters);
void taskCore2(void *pvParameters);
String createJsonMessage2(int sensorValue);

void setup() {
  Serial.begin(115200);

  // Configura o Wi-Fi e MQTT
  setupWiFi();
  setupMQTT();
  reconnectMQTT();

  // Inicializa o servidor web e OTA
  setupWebServer();
  setupOTA();

  // Cria as tarefas para os núcleos
  xTaskCreatePinnedToCore(
    taskCore1,
    "TaskCore1",
    10000,
    NULL,
    1,
    NULL,
    0);

  xTaskCreatePinnedToCore(
    taskCore2,
    "TaskCore2",
    10000,
    NULL,
    1,
    NULL,
    1);
}

void loop() {
  // A função loop ficará vazia, pois as tarefas são executadas nos núcleos
}

sketch.ino

diagram.json

#ifndef GLOBALS_H
#define GLOBALS_H

#include <WiFi.h>
#include <PubSubClient.h>
#include <ESPAsyncWebServer.h>
#include <AsyncElegantOTA.h> // Biblioteca para OTA

const char* ssid = "Wokwi-GUEST";
const char* password = "";

const char* mqtt_topic = "smartcampus/arcomprimido";
const char* mqttUID = "esp32_arcomprimido";
const char* mqtt_server = "broker.hivemq.com";
const int mqtt_port = 1883;


// Variáveis globais
extern WiFiClient espClient;
extern PubSubClient client;
extern AsyncWebServer server;

const int sensorPin = 34; // Pino do sensor
const int numReadings = 10; // Número de leituras a serem armazenadas
extern int readings[numReadings]; // Array para armazenar as leituras
extern int readIndex; // Índice da próxima posição de leitura
extern int sensorValue = 0;

#endif


globals.h

#include "globals.h"

int readings[numReadings];  // Array para armazenar as leituras
int readIndex = 0;          // Índice da próxima posição de leitura

void taskCore1(void *pvParameters) {
  while (true) {

    sensorValue = analogRead(sensorPin);
    readings[readIndex] = sensorValue;
    readIndex = (readIndex + 1) % numReadings;

    vTaskDelay(1000 / portTICK_PERIOD_MS);  // Aguarda 1 segundo
  }
}

core1.ino

#include "globals.h"

void taskCore2(void *pvParameters) {
  while (true) {
    if (WiFi.status() != WL_CONNECTED) {
      setupWiFi();
    }

    if (!client.connected()) {
      reconnectMQTT();
    } else {
      String jsonMessage = createJsonMessage2(sensorValue);
      if (client.publish(mqtt_topic, jsonMessage.c_str()) == true) {
        Serial.println("Success sending message");
      } else {
        Serial.println("Error sending message");
      }
    }
    client.loop();

    setupWebServer();
    vTaskDelay(10 / portTICK_PERIOD_MS);  // Aguarda 10 ms
  }
}

core2.ino

#include "globals.h"

WiFiClient espClient;
PubSubClient client(espClient);
AsyncWebServer server(80);  // Modificado para AsyncWebServer

void setupWiFi() {
  WiFi.disconnect(true);
  delay(10);
  Serial.println();
  Serial.print("Conectando a ");
  Serial.println(ssid);

  WiFi.begin(ssid, password);

  unsigned long startAttemptTime = millis();
  while (WiFi.status() != WL_CONNECTED && millis() - startAttemptTime < 10000) {
    delay(500);
    Serial.print(".");
  }

  if (WiFi.status() != WL_CONNECTED) {
    Serial.println("Falha na conexão WiFi");
  } else {
    Serial.println("");
    Serial.println("WiFi conectado");
    Serial.print("Endereço IP: ");
    Serial.println(WiFi.localIP());
  }
}

void setupMQTT() {
  client.setServer(mqtt_server, mqtt_port);
  reconnectMQTT();
}

void reconnectMQTT() {
  while (!client.connected()) {
    Serial.print("Conectando ao MQTT...");
    if (client.connect(mqttUID)) {
      Serial.println("conectado");
    } else {
      Serial.print("falha, rc=");
      Serial.print(client.state());
      Serial.println(" tentaremos novamente em 5 segundos");
      delay(5000);
    }
  }
}


connection.ino

#include "globals.h"

void handleRoot(AsyncWebServerRequest *request) {
  String html_start PROGMEM = R"rawliteral(
    <!DOCTYPE html>
    <html lang="pt-br">

    <head>
      <meta charset="UTF-8">
      <meta name="viewport" content="width=device-width, initial-scale=1.0">
      <title>ESP32 - Air Leak Detection - v0</title>
      <style>
        body {
          margin: 0;
          padding: 0;
          font-family: Raleway, Helvetica Neue, Helvetica, Roboto, Arial, sans-serif;
          line-height: 1.3;
        }

        .top-bar {
          background-color: #346786;
          color: #fff;
          padding: 10px 0;
          text-align: center;
        }

        .top-bar a {
          color: #fff;
          text-decoration: none;
          margin: 0 10px;
        }

        .logo-container {
          text-align: center;
          margin-top: 50px;
          text-align: center;
          width: 100%;
        }

        .logo-container img {
          max-width: 280px;
          height: auto;
          margin-bottom: 10px;
        }

        .main {
          max-width: 70%;
          margin: 0 auto;
          padding: 20px;
        }

        .content {
          width: 100%;
          display: flex;
          text-align: justify;
          flex-direction: column;
        }

        .iframe-container {
          width: 430px;
          height: 230px;
          overflow: hidden;
        }

        iframe {
          width: 100%;
          height: 100%;
          border: none;
        }

        .cta-button {
          display: inline-block;
          background-color: #346786;
          color: #fff;
          padding: 10px 20px;
          text-decoration: none;
          border-radius: 5px;
          font-size: 1.2em;
          transition: background-color 0.3s;
        }

        .cta-button:hover {
          background-color: #346686c5;
        }

        .footer {
          position: fixed;
          bottom: 0;
          left: 0;
          width: 100%;
          background-color: #346786;
          color: #fff;
          padding: 10px 0;
          text-align: center;
          font-size: small;
        }

        canvas {
          width: 100%;
          height: 400px;
        }
      </style>
      <script src="https://cdn.jsdelivr.net/npm/chart.js"></script>
    </head>

    <body>
      <div class="top-bar">
        <a href="https://www.feb.unesp.br/#!/pos-graduacao/ppgee">UNESP - PPGEE</a>
      </div>

      <div class="logo-container">
        <img src="https://www.feb.unesp.br/images/unesp-full-center.svg" alt="Logo"><br />
        <label>Faculdade de Engenharia - Câmpus de Sorocaba</label>
      </div>

      <div class="main">
        <h1>Detecção de Vazamento de Ar Comprimido em Redes Industriais</h1>
        <div class="content">
          <canvas id="myChart"></canvas>
        </div>
      </div>

      <div class="footer">
        &COPY; 2024 UNESP Sorocaba | https://www.sorocaba.unesp.br/
      </div>

      <script>
  )rawliteral";

  String html_end PROGMEM = R"rawliteral(
        const ctx = document.getElementById('myChart').getContext('2d');
        const myChart = new Chart(ctx, {
          type: 'line',
          data: {
            labels: labels,
            datasets: [{
              label: 'Pressão (bar)',
              data: dataValues,
              borderColor: 'rgba(52, 103, 134, 1)',
              backgroundColor: 'rgba(52, 103, 134, 0.2)',
              borderWidth: 1
            }]
          },
          options: {
            scales: {
              y: {
                beginAtZero: true
              }
            }
          }
        });
      </script>
    </body>

    </html>
  )rawliteral";

  String html = "const labels = [";
  for (int i = 0; i < numReadings; i++) {
    html += String(readings[i]);
    if (i < numReadings-1) {
      html += ", ";
    }
  }
  html += "];";

  html += "const dataValues = [";
  for (int i = 0; i < numReadings; i++) {
    html += String(readings[i]);
    if (i < numReadings-1) {
      html += ", ";
    }
  }
  html += "];";

  request->send(200, "text/html", html_start + html + html_end);
}

void setupWebServer() {
  server.on("/", HTTP_GET, handleRoot);
  server.begin();
}

void setupOTA() {
  AsyncElegantOTA.begin(&server);  // Inicia o OTA
  Serial.println("OTA configurado");
}


webserver.ino

# Wokwi Library List
# See https://docs.wokwi.com/guides/libraries

PubSubClient
ESPAsyncWebServer
AsyncElegantOTA
ArduinoJson


libraries.txt

#include <ArduinoJson.h>

String createJsonMessage2(int sensorValue) {
  // Pressão: Amostragem sensor de pressão.
  int p_analogica = sensorValue;               // Faz a leitura da pressão.
  float p_volts = p_analogica * (3.3 / 4095);  // Converte de valor digital para volts.
  // Serial.println("Digital: " + (String)p_analogica + "\n Tensão: " + (String)p_volts);

  // pressaoBar = { [ (pressaoVoltsLida - pressaoVoltsMax ) * ( -pressaoBarMax ) ] / (pressaoVoltsMin - pressaoVoltsMax) } + pressaoBarMax.
  float p_bar = (((p_volts - 3.3) * (-12)) / (0.25 - 3.3)) + 12;  // Interpolação linear Volts X Bar.
  if (p_bar < 0) p_bar = 0;

  StaticJsonDocument<200> jsonDocument;
  jsonDocument["ID"] = "S1";
  jsonDocument["Valor"] = p_bar;
  jsonDocument["Aplicacao"] = "Ar_Comprimido";
  jsonDocument["Local"] = "Compressor";
  jsonDocument["Tipo"] = "Sensor";
  jsonDocument["Variavel"] = "Pressao";
  jsonDocument["Unidade"] = "Bar";
  jsonDocument["Rede"] = "MQTT";
  jsonDocument["Professor"] = "Paciencia";


  // Converte o objeto JSON para uma string
  String jsonString;
  serializeJson(jsonDocument, jsonString);

  return jsonString;
}