AdaptiveWebClient.h

#pragma once
#include <NDEVR/NDEVRCommunicationLogic.h>
#include <NDEVR/String.h>
#include <NDEVR/QueueBuffer.h>
#include <QWebSocket>
#include <QTimer>
namespace NDEVR
{
    class AdaptiveWebClient : public QObject, public NDEVRCommunicationLogic
    {
        Q_OBJECT
    public:
        explicit AdaptiveWebClient(QObject* parent = nullptr);
        void connectToServer(const StringView& host, uint04 port, bool secure);
        virtual uint08 rx(void* socket, NDEVRDataPacket& packet) override;
        virtual uint08 tx(void* socket, NDEVRDataPacket& packet, uint08 size) override;
        virtual uint08 bytesAvailable(void* socket) override;
        virtual bool isOpen(void* socket = nullptr) const override;
        void* connectTo(const NDEVRServerInfo& info) override;
        virtual void wait(const TimeSpan& span, LogPtr log = nullptr) override;
        void updateWindowSize(NDEVRConnectionData& state) override;
        virtual void disconnectFrom(void* socket) override;
    private slots:
        void onConnected();
        void onSendTick();
        void onBinaryMessageReceived(const QByteArray& message);
        void onBinaryFrameReceived(const QByteArray& message, bool is_last);
        void onBinaryMessageSent(qint64 message);
        void onReconnectTimeout();
    protected:
        QTimer m_reconnect_timer;       
        QTimer m_send_timer;            
        QWebSocket* m_server_socket;    
        bool m_should_be_open = false;  
        bool m_is_open_received = false;
    };
}