#include <DHT.h>
#include "DHTesp.h"
#include "EspMQTTClient.h"

// WiFi parameters
const char* ssid = "Wokwi-GUEST";
const char* password = "";


//configurações da conexão MQTT
EspMQTTClient client
(
  "Wokwi-GUEST", //nome da sua rede Wi-Fi
  "", //senha da sua rede Wi-Fi
  "mqtt.thinger.io",  // MQTT Broker server ip padrão da tago
  "Default",   // username
  "eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJqdGkiOiJwcm9mZXNzb3JkYW5pZWwiLCJzdnIiOiJ1cy1lYXN0LmF3cy50aGluZ2VyLmlvIiwidXNyIjoiZGFuYmF1bWFubiJ9.m1VK8LJ9QjVlxcPOY4SaoHiBd67IqXHcpIoiWoZiwDE",   // Código do Token 
  "TestClient",     // Client name that uniquely identify your device
  1883              // The MQTT port, default to 1883. this line can be omitted
);

// This function is called once everything is connected (Wifi and MQTT)
// WARNING : YOU MUST IMPLEMENT IT IF YOU USE EspMQTTClient
void onConnectionEstablished()
{}

// DHT parameters
const int DHT_PIN = 15;
DHTesp dhtSensor;

WiFiClient espClient;





void setup_wifi() {
  delay(10);
  Serial.println();
  Serial.print("Connecting to ");
  Serial.println(ssid);

  WiFi.begin(ssid, password);

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

  Serial.println("");
  Serial.println("WiFi connected");
  Serial.println("IP address: ");
  Serial.println(WiFi.localIP());
}

void callback(char* topic, byte* payload, unsigned int length) {
  Serial.print("Message arrived [");
  Serial.print(topic);
  Serial.print("] ");
  for (int i = 0; i < length; i++) {
    Serial.print((char)payload[i]);
  }
  Serial.println();
}



void setup() {
   Serial.begin(115200);
  dhtSensor.setup(DHT_PIN, DHTesp::DHT22);
  setup_wifi();
 
}

void loop() {
 

  TempAndHumidity  data = dhtSensor.getTempAndHumidity();
  Serial.println("Temp: " + String(data.temperature, 2) + "°C");
  Serial.println("Humidity: " + String(data.humidity, 1) + "%");
  Serial.println("---");

  // Construir a mensagem JSON
  String message = String("{\"temperature\":") + String(data.temperature, 2) + String(", \"humidity\":") + String(data.humidity, 1) + String("}");

  // Converter para um array de caracteres (char array)
  char msgBuffer[message.length() + 1];
  message.toCharArray(msgBuffer, message.length() + 1);
  Serial.println(msgBuffer);
  // Publicar a mensagem MQTT
  client.publish("sensor", msgBuffer);
   client.loop();

  delay(1000);
}