ProtoClientConnection.h

#pragma once

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

// protobuffer PROTO
#include "message.pb.h"

class QTcpSocket;
class QTimer;
class Hyperion;

namespace proto {
class HyperionRequest;
}

class ProtoClientConnection : public QObject
{
    Q_OBJECT

public:
    explicit ProtoClientConnection(QTcpSocket* socket, const int &timeout, QObject *parent);

signals:
    void clientDisconnected();

public slots:
    void forceClose();

private slots:
    void readyRead();

    void disconnected();

private:
    void handleMessage(const proto::HyperionRequest &message);

    void handleColorCommand(const proto::ColorRequest & message);

    void handleImageCommand(const proto::ImageRequest & message);

    void handleClearCommand(const proto::ClearRequest & message);

    void handleClearallCommand();

    void handleNotImplemented();

    void sendMessage(const google::protobuf::Message &message);

    void sendSuccessReply();

    void sendErrorReply(const std::string & error);

private:
    Logger*_log;

    QTcpSocket* _socket;

    const QString _clientAddress;

    QTimer*_timeoutTimer;
    int _timeout;
    int _priority;

    Hyperion* _hyperion;

    QByteArray _receiveBuffer;
};