FlatBufferConnection.h

#pragma once

// Qt includes
#include <QString>
#include <QColor>
#include <QImage>
#include <QTcpSocket>
#include <QTimer>
#include <QMap>

// hyperion util
#include <utils/Image.h>
#include <utils/ColorRgb.h>
#include <utils/VideoMode.h>
#include <utils/Logger.h>

// flatbuffer FBS
#include "hyperion_reply_generated.h"
#include "hyperion_request_generated.h"

class FlatBufferConnection : public QObject
{

    Q_OBJECT

public:
    FlatBufferConnection(const QString& origin, const QString & address, const int& priority, const bool& skipReply);

    ~FlatBufferConnection();

    void setSkipReply(const bool& skip);

    void setRegister(const QString& origin, int priority);

    void setColor(const ColorRgb & color, int priority, int duration = 1);

    void clear(int priority);

    void clearAll();

    void sendMessage(const uint8_t* buffer, uint32_t size);

public slots:
    void setImage(const Image<ColorRgb> &image);

private slots:
    void connectToHost();

    void readData();

signals:

    void setVideoMode(const VideoMode videoMode);

private:

    bool parseReply(const hyperionnet::Reply *reply);

private:
    QTcpSocket _socket;

    QString _origin;
    int _priority;

    QString _host;

    uint16_t _port;

    QByteArray _receiveBuffer;

    QTimer _timer;
    QAbstractSocket::SocketState  _prevSocketState;

    Logger * _log;
    flatbuffers::FlatBufferBuilder _builder;

    bool _registered;
};