#include "MQTT.h"
#include <DHT.h>
#define DHTPIN 4
#define DHTTYPE DHT11
DHT dht(DHTPIN, DHTTYPE);
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();
    String payload = String(t) + "," + String(h);
    mqtt.publish_MQTT(payload);
    Serial.println(payload);
  }
}