#include "logger.h"
#include "mqtt_client.h"
#include <stdio.h>

#define BROKER_ADDRESS "192.168.1.101"
#define BROKER_PORT 1883
#define TOPIC "device/echo/in"
#define CSV_FILE "rtt_throughput_log.csv"

int main() {
  mqtt_client_t client;

  logger_init(CSV_FILE);

  if (mqtt_client_init(&client, BROKER_ADDRESS, BROKER_PORT, TOPIC) != 0) {
    fprintf(stderr, "MQTT initialization error\n");
    return 1;
  }

  printf("Connection established.Waiting for messages...\n");
  mqtt_client_loop(&client);

  logger_cleanup();
  mqtt_client_cleanup(&client);

  return 0;
}