#include "MQTT.h"
#include <DHT.h>
DHT dht(13, DHT22);
MQTT mqtt;
long lastMsg = 0;
void setup ( void )
{
  Serial.begin(115200);
  mqtt.setup_WiFi();
  mqtt.set_MQTT_server();
  mqtt.set_MQTT_callback();
  dht.begin();
}

void loop ( void )
{
  delay (10);
  mqtt.reconnect_MQTT();
  long now = millis();
  if (now - lastMsg > 2000)
  {
    lastMsg = now;
    float h = dht.readHumidity();
    float t = dht.readTemperature();
    if (isnan(h) || isnan(t)) {
    Serial.println(F("Failed to read from DHT sensor!"));
    return;
  }
    String payload = String(t) + "," + String(h);
    mqtt.publish_MQTT(payload);
    Serial.println(payload);
  }
}