AdaptiveWebServer.h

#pragma once
#include <NDEVR/NDEVRCommunicationLogic.h>
#include <NDEVR/Buffer.h>
#include <NDEVR/QueueBuffer.h>
#include <NDEVR/Dictionary.h>
#include <NDEVR/UUID.h>
#include <NDEVR/ApplicationOption.h>
#include <QWebSocketServer>
#include <NDEVR/TimeSpan.h>
#include <QElapsedTimer>
#include <QTimer>
namespace NDEVR
{
    class AdaptiveWebServer : public QObject, public NDEVRCommunicationLogic
    {
        Q_OBJECT
    public:
        enum PrivateKeyAlgorithm
        {
            e_opaque,   
            e_rsa,      
            e_dsa,      
            e_ec,       
            e_dh        
        };
        explicit AdaptiveWebServer(QObject* parent = nullptr);
        String start(quint16 port);
        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 void updateWindowSize(NDEVRConnectionData& state) override;
        virtual void wait(const TimeSpan& span, LogPtr log = nullptr) override;
        void* connectTo(const NDEVRServerInfo& info) override;
        virtual void disconnectFrom(void* socket);
        void setSocketServer(QWebSocketServer* server); 
        virtual bool isOpen(void* socket = nullptr) const override;
    public:
        static ApplicationOption<String> certificate_file;          
        static ApplicationOption<String> key_file;                  
        static ApplicationOption<uint02> default_port;              
        static ApplicationOption<TimeSpan> service_time;            
        static ApplicationOption<uint08> window_size;               
        static ApplicationOption<PrivateKeyAlgorithm> key_algorithm; 
        static ApplicationOption<bool> use_ssl;                     
    private slots:
        void onBinaryMessageReceived(const QByteArray& message, bool last);
        void onBinaryMessageSent(qint64 send_size);
        void onSendTick();
        void onNewConnection();
        void onErrorOccurredSlot(QAbstractSocket::SocketError error);
    private:
        QTimer m_send_timer;                    
        QWebSocketServer* m_server = nullptr;   
    };
}