#include <queue>
#include <AsyncMqttClient.h>

#define MQTT_HOST IPAddress(192, 168, 5, 138)
#define MQTT_PORT 1883

namespace Mqtt {

    void publishCommand();
    void publishBmp280();
    Task tPublish(TASK_SECOND, TASK_FOREVER, publishCommand, &ts);
    Task tPublishBmp(5 * TASK_MINUTE, TASK_FOREVER, publishBmp280, &ts);

    AsyncMqttClient client;

    struct {
        const char* topic = "esp_clock/sensor/ir/value";
        std::queue<uint8_t> queue;
        uint8_t getCurrent() {
            return queue.empty() ? 0 : queue.front();
        }
        void push(uint8_t el) {
            queue.push(el);
        }
        void pop() {
            queue.pop();
        }
    } commands;

    const char* bmpTopic = "esp_clock/sensor/bmp280/data";

    void publishCommand() {
        if (!commands.queue.empty() && client.connected()) {
            char message[32];
            uint8_t cmd = commands.queue.front();
            sprintf(message, "%X", cmd);
            if (client.publish(commands.topic, 0, true, message) != 0) {
                Serial.print(cmd, HEX);
                Serial.println();
                commands.queue.pop();
            }
        }
    }

    void publishBmp280() {
        if (client.connected()) {
            Bmp::data.readAll();
            char message[255];
            sprintf(message, "{\"temperature\":%.2f, \"pressure\":%.2f, \"altitude\": %.2f}", Bmp::data.temp, Bmp::data.pressure, Bmp::data.altitude);
            client.publish(bmpTopic, 0, true, message);
        }
    }

    void setup() {
        client.onConnect([](bool sessionPresent) {
            tPublish.enableDelayed();
            tPublishBmp.enable();
            Serial.println("Connected to MQTT");
            });
        client.onDisconnect([](AsyncMqttClientDisconnectReason reason) {
            tPublish.disable();
            tPublishBmp.disable();
            Serial.println("Disconnected from MQTT");
            });
        client.setServer(MQTT_HOST, MQTT_PORT);
        Serial.println("Connecting to MQTT...");
    }
}