#include "main.h"

Connection *conn;
MqttClient *mqttClient;

// Sensor Daten etc. speichern
#define SENSOR_COUNT 1
Sensor *sensoren[] {new DemoSensor()};

// Method to setup everything
void setup() {
  Serial.begin(115200);
  Serial.println("setup()");
  conn = new_Connection();
  mqttClient = new MqttClient(conn->getClient());

  delay(1000);

  mqttClient->connect();
}

// Method to publish the sensor data in a specific frequence
void loop() {
  Serial.println("loop()");
  if (conn->connected()) {
    if (!mqttClient->connected()) {
      mqttClient->connect();
    }

    // Sensordaten publishen
    Serial.println("Publish data...");
    for (auto &i : sensoren) {
      if (!i->publish(mqttClient)) {
        Serial.println(String(i->getName()) + " failed to publish");
      }
    }
  } else {
    delete conn;
    sleep(1000);
    conn = new_Connection();
  }

  sleep(1000);
}