Downloaded from https://wokwi.com/projects/402138561894055937

Simulate this project on https://wokwi.com


wokwi-project.txt

// ------------------ Librerías -------------------

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

// -------------- Variables constantes ------------

// Configuración Wifi
#define WIFI_NET "Wokwi-GUEST"
#define WIFI_PASS ""

// Configuración MQTT
#define MQTT_SERVER "broker.hivemq.com"
#define ALARM_SUBSCRIBE_TOPIC "/oso/alarm"

// Configuración pines
#define RELAY_PIN GPIO_NUM_4 // DEfino el PIN de relay


// ---------- Variables dinámicas globales -------------
long lastMsg = 0;
char msg[50];
int value = 0;

// ------------------------- Otros --------------------

//Servo myservo;
WiFiClient wifi_client;
PubSubClient mqtt_client(wifi_client);

// ------------------------- Funciones --------------------

// Función callback del mensaje MQTT
void message_callback(char* topic, byte* payload, unsigned int length) {

  Serial.print("Message arrived [");
  Serial.print(topic);
  Serial.print("] ");


  // Extraer mensaje
  String msg_string;
  for (int i = 0; i < length; i++) {
     msg_string+=((char)payload[i]);  
  }

  Serial.print(msg_string); 
  Serial.print(" ");
 // Check if the message is an alarm message
  if (msg_string == "alarm") {
    Serial.println("Alarm received, turning on the relay");
    digitalWrite(RELAY_PIN, HIGH); // Turn on the relay
  } else {
    Serial.println("Non-alarm message received, turning off the relay");
    digitalWrite(RELAY_PIN, LOW); // Turn off the relay
  }


}

void reconnect() {
 while (!mqtt_client.connected()) {
   Serial.print("Attempting MQTT connection...");
   if (mqtt_client.connect("ESPClient")){
     Serial.println("Connected");
     mqtt_client.publish("/oso/Publish_3", "Welcome");
     mqtt_client.subscribe("/oso/Subscribe_3");
     mqtt_client.subscribe(ALARM_SUBSCRIBE_TOPIC);
   } else {
     Serial.print("failed, rc=");
     Serial.print(mqtt_client.state());
     Serial.println(" try again in 5 seconds");
     delay(5000);
   }}
}


void setup() {

  Serial.begin(9600);

  // Conexión WiFi
  Serial.print("Connecting to WiFi");
  WiFi.begin(WIFI_NET, WIFI_PASS, 6);
  // WiFi.mode(WIFI_STA);
  while (WiFi.status() != WL_CONNECTED) {
    delay(100);
    Serial.print(".");
  }
  Serial.println(" Connected!");



  pinMode(RELAY_PIN, OUTPUT); // Inicializo el PIN como salida del Rele.
  
  // Conexión MQTT
  mqtt_client.setServer(MQTT_SERVER, 1883);
  mqtt_client.setCallback(message_callback);
  mqtt_client.subscribe(ALARM_SUBSCRIBE_TOPIC);

}


void loop() {

  if (!mqtt_client.connected()) {
    reconnect();
  }
  mqtt_client.loop(); 
  delay(100);

}

sketch.ino

diagram.json

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

PubSubClient
ESP32Servo
