JsonAPI.h

#pragma once

// hyperion includes
#include <utils/Logger.h>
#include <utils/jsonschema/QJsonSchemaChecker.h>
#include <utils/Components.h>
#include <hyperion/Hyperion.h>

// qt includes
#include <QJsonObject>
#include <QMutex>
#include <QString>

class JsonCB;

class JsonAPI : public QObject
{
    Q_OBJECT

public:
    JsonAPI(QString peerAddress, Logger* log, QObject* parent, bool noListener = false);

    void handleMessage(const QString & message);

public slots:
    void streamLedcolorsUpdate(const std::vector<ColorRgb>& ledColors);

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

    void incommingLogMessage(const Logger::T_LOG_MESSAGE&);

signals:
    void callbackMessage(QJsonObject);

    void forwardJsonMessage(QJsonObject);

private:
    // true if further callbacks are forbidden (http)
    bool _noListener;

    QString _peerAddress;

    Logger* _log;

    Hyperion* _hyperion;

    // The JsonCB instance which handles data subscription/notifications
    JsonCB* _jsonCB;

    // streaming buffers
    QJsonObject _streaming_leds_reply;
    QJsonObject _streaming_image_reply;
    QJsonObject _streaming_logging_reply;

    bool _streaming_logging_activated;

    QMutex _image_stream_mutex;

    QMutex _led_stream_mutex;

    volatile qint64 _image_stream_timeout;

    volatile qint64 _led_stream_timeout;

    void handleColorCommand(const QJsonObject & message, const QString &command, const int tan);

    void handleImageCommand(const QJsonObject & message, const QString &command, const int tan);

    void handleEffectCommand(const QJsonObject &message, const QString &command, const int tan);

    void handleCreateEffectCommand(const QJsonObject & message, const QString &command, const int tan);

    void handleDeleteEffectCommand(const QJsonObject & message, const QString &command, const int tan);

    void handleSysInfoCommand(const QJsonObject & message, const QString &command, const int tan);

    void handleServerInfoCommand(const QJsonObject & message, const QString &command, const int tan);

    void handleClearCommand(const QJsonObject & message, const QString &command, const int tan);

    void handleAdjustmentCommand(const QJsonObject & message, const QString &command, const int tan);

    void handleSourceSelectCommand(const QJsonObject & message, const QString &command, const int tan);

    void handleConfigCommand(const QJsonObject & message, const QString &command, const int tan);

    void handleSchemaGetCommand(const QJsonObject & message, const QString &command, const int tan);

    void handleConfigSetCommand(const QJsonObject & message, const QString &command, const int tan);

    void handleComponentStateCommand(const QJsonObject & message, const QString &command, const int tan);

    void handleLedColorsCommand(const QJsonObject & message, const QString &command, const int tan);

    void handleLoggingCommand(const QJsonObject & message, const QString &command, const int tan);

    void handleProcessingCommand(const QJsonObject & message, const QString &command, const int tan);

    void handleVideoModeCommand(const QJsonObject & message, const QString &command, const int tan);

    void handleClearallCommand(const QJsonObject & message, const QString &command, const int tan);

    void handleNotImplemented();

    void sendSuccessReply(const QString &command="", const int tan=0);

    void sendSuccessDataReply(const QJsonDocument &doc, const QString &command="", const int &tan=0);

    void sendErrorReply(const QString & error, const QString &command="", const int tan=0);
};