WebSocketConnection.h

Go to the documentation of this file.

#pragma once
#include "DLLInfo.h"
#include <NDEVR/Connection.h>
#include "Base/Headers/TranslatedString.h"
class QWebSocket;
namespace NDEVR
{
    class NDEVR_WEB_SOCKET_API WebSocketConnection : public ConnectionBackend
    {
        Q_OBJECT
    public:
        WebSocketConnection(LogPtr log);
        ~WebSocketConnection();
        virtual uint04 peek(char*, uint04 size) const override;
        virtual uint04 rx(char*, uint04 size = Constant<uint04>::Max) override;
        virtual void tx(const StringView& command) override;
        void txInThread(const StringView& command);
        virtual bool open(const ConnectionInfo& request) override;
        virtual void close() override;
        virtual bool isOpen() const override;
        virtual uint04 bytesAvailable() const override;
        virtual TranslatedString lastError() const override;
        virtual bool setPort(QWebSocket* tcp_port);
        virtual bool waitForReadyRead(const TimeSpan& span) override;
        virtual bool waitForConnection(QWebSocket* socket, const ConnectionInfo& request);
        void setSocket(QWebSocket* socket);
    protected slots:
        void handleSocketErrorSlot(int error);
        void binaryMessageReceived(const QByteArray& array);
        void textMessageReceived(const QString& message);
    protected:
        QWebSocket* m_socket = nullptr;     
        TranslatedString m_last_error;      
        String m_data;                      
    };
    class WebSocketConnectionFactory : public ConnectionFactory
    {
    public:
        virtual bool handlesType(const StringView& request) const override;
        virtual ConnectionBackend* createConnection(const ConnectionInfo& request) override;
        virtual Buffer<ConnectionInfo> availableConnections(const ConnectionSearchParameters& params) override;
        virtual Buffer<ConnectionCategory> availableConnectionCategories() override;
    };
}