UDPListener.h

#pragma once

// system includes
#include <cstdint>

// Qt includes
#include <QSet>
#include <QHostAddress>
#include <QJsonDocument>

// Hyperion includes
#include <utils/Logger.h>
#include <utils/Components.h>
#include <utils/ColorRgb.h>

// settings
#include <utils/settings.h>

class BonjourServiceRegister;
class QUdpSocket;

class UDPListener : public QObject
{
    Q_OBJECT

public:
    UDPListener(const QJsonDocument& config);
    ~UDPListener();

    uint16_t getPort() const;

    bool active() { return _isActive; };

public slots:
    void start();

    void stop();

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

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

signals:
    void registerGlobalInput(const int priority, const hyperion::Components& component, const QString& origin = "System", const QString& owner = "", unsigned smooth_cfg = 0);

    const bool setGlobalInput(const int priority, const std::vector<ColorRgb>& ledColors, const int timeout_ms = -1, const bool& clearEffect = true);

private slots:
    void readPendingDatagrams();
    void processTheDatagram(const QByteArray * datagram, const QHostAddress * sender);

private:
    QUdpSocket * _server;

    int _priority;

    int _timeout;

    Logger * _log;

    BonjourServiceRegister* _serviceRegister = nullptr;

    bool _isActive;

    QHostAddress              _listenAddress;
    uint16_t                  _listenPort;
    QAbstractSocket::BindFlag _bondage;
};