MessageForwarder.h

#pragma once

// STL includes
#include <vector>
#include <map>
#include <cstdint>
#include <limits>

// QT includes
#include <QList>
#include <QStringList>
#include <QHostAddress>
#include <QJsonObject>
#include <QJsonArray>
#include <QJsonDocument>

// Utils includes
#include <utils/ColorRgb.h>
#include <utils/settings.h>
#include <utils/Logger.h>
#include <utils/Components.h>
#include <utils/Image.h>

// Hyperion includes
#include <hyperion/PriorityMuxer.h>

// Forward declaration
class Hyperion;
class QTcpSocket;
class FlatBufferConnection;

class MessageForwarder : public QObject
{
    Q_OBJECT
public:
    MessageForwarder(Hyperion* hyperion);
    ~MessageForwarder();

    void addJsonSlave(QString slave);
    void addProtoSlave(QString slave);

private slots:
    void handleSettingsUpdate(const settings::type &type, const QJsonDocument &config);

    void componentStateChanged(const hyperion::Components component, bool enable);

    void handlePriorityChanges(const quint8 &priority);

    void forwardJsonMessage(const QJsonObject &message);

    void forwardProtoMessage(const QString& name, const Image<ColorRgb> &image);

    void sendJsonMessage(const QJsonObject &message, QTcpSocket *socket);

private:
    Hyperion *_hyperion;

    Logger   *_log;

    PriorityMuxer *_muxer;

    // JSON connection for forwarding
    QStringList   _jsonSlaves;

    QStringList _protoSlaves;
    QList<FlatBufferConnection*> _forwardClients;

    bool _forwarder_enabled = true;

    const int _priority;
};