/** 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  "dsilvag" // Usuario
#define AIO_KEY       "aio_tXBD78ibczY7ysQ4YfGbvYK0ARUf" // 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 temperature_sensor = Adafruit_MQTT_Publish(&mqtt, AIO_USERNAME"/feeds/temperature_sensor"); 
Adafruit_MQTT_Publish humidity_sensor = Adafruit_MQTT_Publish(&mqtt, AIO_USERNAME"/feeds/humidity_sensor"); 

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(1000);
Serial.print(".");
}
Serial.println();
Serial.println("WiFi conectado"); //Conexión exitosa
Serial.println("IP address: "); // Direccionamiento IP
Serial.println(WiFi.localIP());
  randomSeed(analogRead(0));  // Inicializa la generación de números aleatorios con un valor analógico
}

/* Loop */

void loop()
{

MQTT_connect();

// Temperatura
//float tem = dht.readTemperature(); // del sensor, se lee la temperatura
      int temR= random(-40, 80);  // Genera un número aleatorio entre 1 y 6
          //displayNumber(temR);
Serial.print(F("\n Temperatura "));
Serial.print(temR);
delay(40000);
Serial.print("...");

if (! temperature_sensor.publish(temR)) {
Serial.println(F("Failed"));
mqtt.connected();
} else {
Serial.println(F("OK!"));
}
 //delay(5000);

// Humedad
//float hum = dht.readHumidity(); // del sensor, se lee la humedad
int humR= random(0, 100); 
Serial.print(F("\n Humedad "));
Serial.print(humR);
delay(40000);
Serial.print("...");

if (! humidity_sensor.publish(humR)) {
Serial.println(F("Failed"));
mqtt.connected();
} else {
Serial.println(F("OK!"));
}
 delay(5000);
}


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

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

uint8_t retries = 2;

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(100);
mqtt.connected();
delay(1000); // espera 5 segundos
retries--;
if (retries == 0) {
// Si la conexión falla y espera a que se reinicie
mqtt.disconnect();
delay(1000);
mqtt.connected();
delay(1000);
while (1);
}
}
Serial.println("MQTT Conectado!"); 
}