WebRTCSocket.h

//
//  WebRTCSocket.h
//  libraries/networking/src/webrtc
//
//  Created by David Rowe on 21 Jun 2021.
//  Copyright 2021 Vircadia contributors.
//
 
#ifndef overte_WebRTCSocket_h
#define overte_WebRTCSocket_h
 
#include <shared/WebRTC.h>
 
#if defined(WEBRTC_DATA_CHANNELS)
 
#include <QAbstractSocket>
#include <QObject>
#include <QQueue>
 
#include "WebRTCDataChannels.h"
 
 
 
class WebRTCSocket : public QObject {
    Q_OBJECT
 
public:
 
    WebRTCSocket(QObject* parent);
 
 
    void setSocketOption(QAbstractSocket::SocketOption option, const QVariant& value);
 
    QVariant socketOption(QAbstractSocket::SocketOption option);
 
    bool bind(const QHostAddress& address, quint16 port = 0, QAbstractSocket::BindMode mode
        = QAbstractSocket::DefaultForPlatform);
 
    QAbstractSocket::SocketState state() const;
 
    void abort();
 
    quint16 localPort() const { return 0; }
 
    qintptr socketDescriptor() const { return -1; }
 
 
    qint64 writeDatagram(const QByteArray& datagram, const SockAddr& destination);
 
    qint64 bytesToWrite(const SockAddr& destination) const;
 
    bool hasPendingDatagrams() const;
 
    qint64 pendingDatagramSize() const;
 
    qint64 readDatagram(char* data, qint64 maxSize, QHostAddress* address = nullptr, quint16* port = nullptr);
 
 
    QAbstractSocket::SocketError error() const;
 
    QString errorString() const;
 
public slots:
 
    void onDataChannelReceivedMessage(const SockAddr& source, const QByteArray& message);
 
signals:
 
    void stateChanged(QAbstractSocket::SocketState socketState);
 
    void readyRead();
 
    void onSignalingMessage(const QJsonObject& json);
 
    void sendSignalingMessage(const QJsonObject& message);
 
 
private:
 
    void setError(QAbstractSocket::SocketError errorType, QString errorString);
    void clearError();
 
    WebRTCDataChannels _dataChannels;
 
    bool _isBound { false };
 
    QQueue<QPair<SockAddr, QByteArray>> _receivedQueue;  // Messages received are queued for reading from the "socket".
 
    QAbstractSocket::SocketError _lastErrorType { QAbstractSocket::UnknownSocketError };
    QString _lastErrorString;
};
 
 
 
#endif // WEBRTC_DATA_CHANNELS
 
#endif // overte_WebRTCSocket_h