Test Merge

.gitignore

@@ -8,3 +8,4 @@ BUILD
 compile_commands.json
 .clangd
 .cache
+MQTT

Codigo_ESP32.ino

@@ -0,0 +1,155 @@
+#include <WiFi.h>
+#include <PubSubClient.h>
+
+WiFiClient esp32Client;
+PubSubClient mqttClient(esp32Client);
+
+const char* ssid     = "Telecentro-5401";
+const char* password = "Z2NKJZ3WYJFD";
+
+char *server = "192.168.0.43";
+int port = 1883;
+
+int ledpin = 23;          // Nuevo pin para el LED
+int mqttStatusPin = 21;   // Pin para indicar estado MQTT
+int messagePin = 19;      // Pin para indicar que se recibión un mensaje y se reenvió por UART
+int var = 0;
+
+#define RXD2 16
+#define TXD2 17
+
+void wifiInit() {
+    Serial.print("Conectándose a ");
+    Serial.print(ssid);
+    Serial.print("\n");
+
+    WiFi.begin(ssid, password);
+
+    while (WiFi.status() != WL_CONNECTED) {
+        Serial.print(".");
+        delay(500);  
+    }
+    Serial.print("\n");
+    Serial.print("Conectado a WiFi");
+    Serial.print("\n");
+    Serial.print("Dirección IP: ");
+    Serial.print(WiFi.localIP());
+}
+
+void callback(char* topic, byte* payload, unsigned int length) {
+    char payload_string[length + 1];
+    memcpy(payload_string, payload, length);
+    payload_string[length] = '\0';
+
+    if (strcmp(topic, "ProyectoTranquera/TestMQTT") == 0) {
+      int resultI = atoi(payload_string);
+      var = resultI;
+    }
+
+    Serial.print("Mensaje recibido [");
+    Serial.print(topic);
+    Serial.print("]: ");
+    Serial.print(payload_string);
+    Serial.print("\n");
+
+    // Reenviar el mensaje por UART
+    Serial2.print(topic);
+    Serial2.print(":");
+    Serial2.print(payload_string);
+    Serial2.print("\n");
+
+    digitalWrite(messagePin, HIGH);
+    digitalWrite(messagePin, LOW);   // Hago un pulso cuando envié un mensaje
+}
+
+void reconnect() {
+    while (!mqttClient.connected()) {
+        Serial.print("Intentando conectarse MQTT...");
+        Serial.print("\n");
+        digitalWrite(mqttStatusPin, LOW); // Indicar que está desconectado
+
+        if (mqttClient.connect("ESP32")) {
+            Serial.print("Conectado");
+            Serial.print("\n");
+            digitalWrite(mqttStatusPin, HIGH); // Indicar que está conectado
+            mqttClient.subscribe("ProyectoTranquera/TestMQTT");
+        } else {
+            Serial.print("Fallo, rc=");
+            Serial.print(mqttClient.state());
+            Serial.print(" intentar de nuevo en 5 segundos");
+            Serial.print("\n");
+            delay(5000);
+        }
+    }
+}
+
+void setup() {
+    pinMode(ledpin, OUTPUT);
+    pinMode(mqttStatusPin, OUTPUT); // Configurar el pin de estado MQTT como salida
+    pinMode(messagePin, OUTPUT);  // Configurar el pin de mensaje como salida
+    Serial.begin(115200);
+    Serial2.begin(115200, SERIAL_8N1, RXD2, TXD2); // Configuración UART2 a 115200 baudios
+    delay(10);
+    wifiInit();
+    mqttClient.setServer(server, port);
+    mqttClient.setCallback(callback);
+    digitalWrite(mqttStatusPin, LOW);   // El Pin empieza en LOW
+    digitalWrite(messagePin, LOW);   // El Pin empieza en LOW
+}
+
+void loop() {
+    if (!mqttClient.connected()) {
+        reconnect();
+    } else {
+        digitalWrite(mqttStatusPin, HIGH); // Mantener en HIGH si está conectado
+    }
+    mqttClient.loop();
+
+    if (var == 0) {
+        digitalWrite(ledpin, LOW);
+    } else if (var == 1) {
+        digitalWrite(ledpin, HIGH);
+    }
+
+    if (Serial2.available()) {
+        String uartMessage = Serial2.readStringUntil('\n'); // Leer mensaje UART
+        int separatorIndex = uartMessage.indexOf(':');
+
+        if (separatorIndex != -1) {
+            String command = uartMessage.substring(0, separatorIndex);
+            String argument = uartMessage.substring(separatorIndex + 1);
+
+            if (command == "subscribe") {
+                mqttClient.subscribe(argument.c_str());
+                Serial.print("Suscrito a: ");
+                Serial.print(argument);
+                Serial.print("\n");
+                Serial2.print("subscribed:");
+                Serial2.print(argument);
+                Serial2.print("\n");
+                digitalWrite(messagePin, HIGH);
+                digitalWrite(messagePin, LOW);   // Hago un pulso cuando envié un mensaje
+            } else if (command == "unsubscribe") {
+                mqttClient.unsubscribe(argument.c_str());
+                Serial.print("Desuscrito de: ");
+                Serial.print(argument);
+                Serial.print("\n");
+                Serial2.print("unsubscribed:");
+                Serial2.print(argument);
+                Serial2.print("\n");
+                digitalWrite(messagePin, HIGH);
+                digitalWrite(messagePin, LOW);   // Hago un pulso cuando envié un mensaje
+            } else {
+                // Publicar mensaje en MQTT
+                mqttClient.publish(command.c_str(), argument.c_str());
+                Serial.print("Mensaje enviado: ");
+                Serial.print("\n");
+                Serial.print("Tópico: ");
+                Serial.print(command);
+                Serial.print(", Mensaje: ");
+                Serial.print(argument);
+                Serial.print("\n");
+            }
+        }
+    }
+}

README.txt

@@ -0,0 +1,19 @@
+En este repositorio se encuentra el desarrollo de un proyecto para el control automático de tranqueras
+en mangas. Se incluye en este repositorio todo el firmware desarrollado, un esquemático del hardware
+usado, un archivo .apk para la instalación de una aplicación movil necesaria para el uso del sistema,
+un video demostrativo del funcionamiento, y una memoria del desarrollo del trabajo.
+
+Realizado entre abril y julio de 2024 por Augusto Villacampa Horta como trabajo final del seminario
+de Sistemas Embebidos de la Facultad de Ingeniería de la Universidad de Buenos Aires.
+
+Link al video demostrativo del funcionamiento:
+https://www.youtube.com/watch?v=cxtm0vdYiug
+
+Consideraciones:
+
+-   En el archivo mbed_app.json se configura el tamaño de los buffers internos de transmisión y
+    recepción desde la ESP32, es decir los mensajes que llegan por MQTT y otras configuraciones
+
+-   En el archivo global_defines.h se configuran varios parámetros para el funcionamiento del
+    sistema o de los módulos. En el ultimo caso, en los distintos módulos se verifica si estos
+    parámetros fueron definidos, y los define si no lo fueron. Esto como medida de seguridad.

main.cpp

@@ -1,13 +1,17 @@
 //=====[Libraries]=============================================================
 
-#include "smart_home_system.h"
+#include "mbed.h"
+#include "arm_book_lib.h"
+
+#include "system.h"
 
 //=====[Main function, the program entry point after power on or reset]========
 
 int main()
 {
-    smartHomeSystemInit();
+    system_init();
     while (true) {
-        smartHomeSystemUpdate();
+        system_update();
     }
-}
+}
+

mbed_app.json

@@ -1,7 +1,11 @@
 {
     "target_overrides": {
         "*": {
-            "target.printf_lib": "std"
+            "platform.stdio-convert-newlines": 1,
+            "target.printf_lib": "std",
+            "drivers.uart-serial-rxbuf-size": 1024,
+            "drivers.uart-serial-txbuf-size": 256
         }
     }
-}
+}
+