/****************************************
 * Include Libraries
 ****************************************/
#include <DHT.h>           //Cargamos la librería DHT
#include <WiFi.h>
#include <PubSubClient.h>
#include <stdio.h>


/****************************************
 * Define Constants
 ****************************************/
#define DHTTYPE  DHT22   //Definimos el modelo del sensor DHT22
#define DHTPIN    27     // Se define el pin D27 del ESP32 para conectar el sensor DHT22 

//#define TOKEN "BBFF-OVdMNwNY3ABCuDOo5sfiiXIvebu5lk" // Put your Ubidots' TOKEN
#define TOKEN "BBFF-3jtwjAz9PLdaOmM6bqLnwZKeNKMBuy"

#define VARIABLE_LABEL "temperatura" // Assing the variable label
#define VARIABLE_LABEL2 "humedad" // Assing the variable label
#define DEVICE_LABEL "dispositivoprueba" // Assig the device label
#define MQTT_CLIENT_NAME "0001" // MQTT client Name, put a Random ASCII

const char* WIFISSID = "Wokwi-GUEST";
const char* PASSWORD = "";

char mqttBroker[] = "industrial.api.ubidots.com";
char payload[700];
char topic[150];

// Space to store values to send
char str_val[6];
char str_val2[6];

/****************************************
 * Initializate constructors for objects
 ****************************************/

//ESP8266WiFiMulti WiFiMulti;
WiFiClient ubidots;
PubSubClient client(ubidots);

DHT dht(DHTPIN, DHTTYPE, 22); 

/****************************************
 * Auxiliar Functions
 ****************************************/
 
void callback(char* topic, byte* payload, unsigned int length) {} 

void reconnect() {
  // Loop until we're reconnected
  while (!client.connected()) {
  Serial.println("Attempting MQTT connection...");

  // Attempt to connect
  if (client.connect(MQTT_CLIENT_NAME, TOKEN,"")) {
    Serial.println("connected");
  } else {
    Serial.print("failed, rc=");
    Serial.print(client.state());
    Serial.println(" try again in 2 seconds");
    // Wait 2 seconds before retrying
    delay(2000);
  }
  }
}


/****************************************
 * Main Functions
 ****************************************/

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

  dht.begin(); 

  WiFi.begin(WIFISSID, PASSWORD);
  Serial.println();
  Serial.println();
  Serial.print("Wait for WiFi... ");

  while(WiFi.status() != WL_CONNECTED) {
    Serial.print(".");
    delay(500);
  }

  Serial.println("");
  Serial.println("WiFi connected");
  Serial.println("IP address: ");
  Serial.println(WiFi.localIP());
  client.setServer(mqttBroker, 1883);
  client.setCallback(callback);
}

void loop() {

  if (!client.connected()) {
    reconnect();
  }

  float hum = dht.readHumidity(); //Se lee la humedad y se asigna el valor a "h"
  float temp = dht.readTemperature(); //Se lee la temperatura y se asigna el valor a "t"

  /*Datos hacia Ubidots*/
  //cabecera
  sprintf(topic, "%s", ""); // Cleans the topic content
  sprintf(topic, "%s%s", "/v1.6/devices/", DEVICE_LABEL);
  //inicio
  sprintf(payload, "%s", ""); // Cleans the payload content
  sprintf(payload, "{\"%s\":", VARIABLE_LABEL); // Adds the variable label   
  sprintf(payload, "%s {\"value\": %s", payload, String(temp)); // Adds the value
  //intermedio
  sprintf(payload, "%s },\"%s\":", payload, VARIABLE_LABEL2); // Adds the variable label2
  sprintf(payload, "%s {\"value\": %s", payload, String(hum)); // Adds the value2
  
  //cierre
  sprintf(payload, "%s } }", payload); // Closes the dictionary brackets
  Serial.println(String(payload));
  client.publish(topic, payload);
  client.loop();
  delay(10000);
  
}