torcwebsocketthread.h

Go to the documentation of this file.

#ifndef TORCWEBSOCKETTHREAD_H
#define TORCWEBSOCKETTHREAD_H

// Qt
#include <QObject>

// Torc
#include "torcwebsocket.h"
#include "torcrpcrequest.h"

class TorcWebSocketThread : public TorcQThread
{
    Q_OBJECT

  public:
    TorcWebSocketThread (qintptr SocketDescriptor, bool Secure);
    TorcWebSocketThread (const QHostAddress &Address, quint16 Port, bool Secure,
                         TorcWebSocketReader::WSSubProtocol Protocol = TorcWebSocketReader::SubProtocolJSONRPC);
    ~TorcWebSocketThread() = default;

    void                Start    (void) override;
    void                Finish   (void) override;
    void                RemoteRequest         (TorcRPCRequest *Request);
    void                CancelRequest         (TorcRPCRequest *Request);
    bool                IsSecure              (void);

  signals:
    void                ConnectionEstablished (void);
    void                ConnectionUpgraded    (void);
    void                RemoteRequestSignal   (TorcRPCRequest *Request);
    void                CancelRequestSignal   (TorcRPCRequest *Request);

  private:
    static void         SetupSSL              (void);
    static bool         CreateCerts           (const QString &CertFile, const QString &KeyFile);

  private:
    TorcWebSocket      *m_webSocket;
    bool                m_secure;
    // incoming
    qintptr             m_socketDescriptor;

    // outgoing
    const QHostAddress  m_address;
    quint16             m_port;
    TorcWebSocketReader::WSSubProtocol m_protocol;

  private:
    Q_DISABLE_COPY(TorcWebSocketThread)
};

#endif // TORCWEBSOCKETTHREAD_H