/** Sensores, Dispositivos, Redes y Protocolos de Comunicaciones
Actividad Grupal
Protocolos de comunicación en IoT y transmisión de datos
Gustavo Barco Cano
Luz Adriana Ceron Gomez
Mauro Restrepo Galvis
Andres Eduardo Zuñiga Lopez
ESP32 + DHT22 Wokwi Activity MQTT */

// Librerías del proyecto
#include <WiFi.h> 
#include "Adafruit_MQTT.h"
#include "Adafruit_MQTT_Client.h"

// Variables asociadas al sensor DHT22
#include <DHT.h> // Librería DHT
#define DHTTYPE DHT22 // Modelo del sensor DHT22
#define DHTPIN 4 // Sensor conectado al pin 4

DHT dht(DHTPIN, DHTTYPE); 

// Parámetros para la conexión WiFi cuando se requiera
#define WLAN_SSID       "FBI WiFi"  // Nombre de la WiFi        
#define WLAN_PASS       "*****"  // Contraseña de la WiFi

// Conexión con adafruit.io
#define AIO_SERVER "io.adafruit.com" // Sitio web
#define AIO_SERVERPORT 1883  // Puerto
#define AIO_USERNAME  "SensorGLatam1" // Usuario
#define AIO_KEY       "aio_hnnS24g0eavlowsSZoUCj2KJCj9o" // Credencial

// Para conexión al MQTT se define la clase WiFiClient
WiFiClient client;

// Para conexión SSL al MQTT se define la clase WiFiClientSecure
// WiFiClientSecure client;

// Conexión cliente MQTT
// Se envía Cliente WiFi, servidor, puerto, usuario y llave
Adafruit_MQTT_Client mqtt(&client, AIO_SERVER, AIO_SERVERPORT, AIO_USERNAME, AIO_KEY);

// feeds de io.adafruit.com
// https://io.adafruit.com/SensorGLatam1/feeds/temperatura
// https://io.adafruit.com/SensorGLatam1/feeds/humedad

// Configuracion para publicar en los feeds
Adafruit_MQTT_Publish temperatura = Adafruit_MQTT_Publish(&mqtt, AIO_USERNAME"/feeds/temperatura"); 
Adafruit_MQTT_Publish humedad = Adafruit_MQTT_Publish(&mqtt, AIO_USERNAME"/feeds/humedad"); 

void MQTT_connect();

// Inicializando el sensor/

void setup()
{
dht.begin(); 
 pinMode(DHTPIN, INPUT);
  Serial.begin(115200);
  delay(10);

// Conexión a la WiFi

Serial.println();
Serial.print("Connecting to ");
Serial.println(WLAN_SSID);

// Conexión WiFI. WiFi.begin(WLAN_SSID, WLAN_PASS);
WiFi.begin("Wokwi-GUEST", "", 6);
while (WiFi.status() != WL_CONNECTED) {
delay(500);
Serial.print(".");
}
Serial.println();
Serial.println("WiFi conectado"); //Conexión exitosa
Serial.println("IP address: "); // Direccionamiento IP
Serial.println(WiFi.localIP());
}

/* Loop */

void loop()
{

MQTT_connect();

// Temperatura
float tem = dht.readTemperature(); // del sensor, se lee la temperatura

Serial.print(F("\n Temperatura "));
Serial.print(tem);
Serial.print("...");

if (! temperatura.publish(tem)) {
Serial.println(F("Failed"));
} else {
Serial.println(F("OK!"));
}
 delay(10000);

// Humedad
float hum = dht.readHumidity(); // del sensor, se lee la humedad
Serial.print(F("\n Humedad "));
Serial.print(hum);
Serial.print("...");

if (! humedad.publish(hum)) {
Serial.println(F("Failed"));
} else {
Serial.println(F("OK!"));
}
 delay(10000);
}


void MQTT_connect() {
int8_t ret;
// Detener si ya está conectado
if (mqtt.connected()) {
return;
}

Serial.print("Conectando a MQTT... ");

uint8_t retries = 3;

while ((ret = mqtt.connect()) != 0) { // connect devolverá 0 para conectado
Serial.println(mqtt.connectErrorString(ret));
Serial.println("Re-intentando la conexión MQTT en 5 segundos...");
mqtt.disconnect();
delay(5000); // espera 5 segundos
retries--;
if (retries == 0) {
// Si la conexión falla y espera a que se reinicie
while (1);
}
}
Serial.println("MQTT Conectado!"); 
}