/**
 * @file debugMqtt.cpp
 * @author Alexander Klein (alex@kleiax.de)
 * @brief Implemention of the class debugMqtt.h
 * @see debugMqtt.h
 * @version 0.1
 * @date 2021-12-13
 *
 * @copyright Copyright (c) 2021
 *
 */
#include "debugMqtt.h"

PubSubClient *DebugMqtt::client;
Loglevel DebugMqtt::loglevel;
bool DebugMqtt::isInit = false;
char DebugMqtt::msg[MQTT_BUFFER_SIZE];
char DebugMqtt::topic[MQTT_BUFFER_SIZE];

DebugMqtt::DebugMqtt(const char *name, uint8_t bufSize)
    : name{name}
{
    if (bufSize != 0)
    {
        this->bufSize = bufSize;
    }
    this->buf = new char[this->bufSize];
}

DebugMqtt::~DebugMqtt()
{
    delete this->buf;
}

void DebugMqtt::sendMsg(Loglevel loglevel, String topic, String msg)
{
    snprintf(static_cast<char *>(DebugMqtt::msg), MQTT_BUFFER_SIZE, static_cast<const char *>("%s: %s"), this->name, msg.c_str());
    this->sendData(loglevel, topic, static_cast<const char *>(DebugMqtt::msg));
}

void DebugMqtt::sendMsg(Loglevel loglevel, String msg)
{
    this->sendMsg(loglevel, "", msg);
}

void DebugMqtt::sendData(Loglevel loglevel, String topic, String data)
{
    if (!DebugMqtt::isInit)
    {
        return;
    }

    if (loglevel <= DebugMqtt::loglevel && loglevel > Loglevel::none)
    {
        snprintf(static_cast<char *>(DebugMqtt::topic), MQTT_BUFFER_SIZE, static_cast<const char *>("%s%s"), DebugMqtt::enum_to_string(loglevel).c_str(), topic.c_str());
        snprintf(static_cast<char *>(DebugMqtt::msg), MQTT_BUFFER_SIZE, static_cast<const char *>("%s"), data.c_str());
        client->publish(DebugMqtt::topic, static_cast<const char *>(DebugMqtt::msg));
    }
}

void DebugMqtt::sendData(Loglevel loglevel, String data)
{
    DebugMqtt::sendData(loglevel, "", data);
}

void DebugMqtt::writeToInflux(String measurement_name, String field_set, float measurement, uint64_t nanos)
{
    // Example String: "weather temperature=82 1465839830100400200";

    snprintf(static_cast<char *>(DebugMqtt::msg), MQTT_BUFFER_SIZE, static_cast<const char *>("%s %s=%f %llu"), measurement_name.c_str(), field_set.c_str(), measurement, nanos);
    this->sendData(Loglevel::influx, static_cast<const char *>(DebugMqtt::msg));
}

void DebugMqtt::addCharacter(char character)
{
    this->buf[this->bufPos] = character;
    this->bufPos++;
    if (character == '\n' || this->bufPos >= this->bufSize - 1)
    {
        this->buf[this->bufPos - 1] = '\0';
        this->sendMsg(Loglevel::info, buf);
        this->bufPos = 0;
    }
}

void DebugMqtt::init(PubSubClient *client, Loglevel max_loglevel)
{
    DebugMqtt::client = client;
    DebugMqtt::loglevel = max_loglevel;
    DebugMqtt::isInit = true;
}

void DebugMqtt::changeLoglevel(Loglevel loglevel)
{
    DebugMqtt::loglevel = loglevel;
}

String DebugMqtt::enum_to_string(Loglevel loglevel)
{
    String topic = "";
    topic += MQTT_DEBUG_TOPIC;
    switch (loglevel)
    {
    case Loglevel::error:
        topic += "/Error";
        break;
    case Loglevel::warn:
        topic += "/Warn";
        break;
    case Loglevel::info:
        topic += "/Info";
        break;
    case Loglevel::debug:
        topic += "/Debug";
        break;
    case Loglevel::influx:
        topic += "/Influx";
        break;
    default:
        topic += "/NoLoglovel";
        break;
    }
    return topic;
}