NTRIPHttpSession.h

Go to the documentation of this file.

#pragma once
 
#include <chrono>
 
#include <QtCore/QByteArray>
#include <QtCore/QByteArrayView>
#include <QtCore/QDateTime>
#include <QtCore/QList>
#include <QtCore/QObject>
#include <QtCore/QString>
 
#include "NTRIPError.h"
#include "NTRIPHttpCodec.h"
#include "ScheduledTask.h"
 
struct NTRIPConnectionConfig;
class QSslError;
class QSslSocket;
class QTcpSocket;
class RuntimeScheduler;
 
class NTRIPHttpSession : public QObject
{
    Q_OBJECT
    friend class NTRIPHttpSessionTest;
    friend class NTRIPHttpTransportTest;
 
public:
    static constexpr qint64 READ_BUFFER_BYTES = 64 * 1024;
    static constexpr qint64 READ_CHUNK_BYTES = 16 * 1024;
    static constexpr std::chrono::milliseconds ERROR_BODY_TIMEOUT{250};
 
    explicit NTRIPHttpSession(QObject* parent = nullptr, RuntimeScheduler* scheduler = nullptr,
                              NTRIPHttpPurpose purpose = NTRIPHttpPurpose::Corrections);
 
    QString open(const NTRIPConnectionConfig& config);
    bool write(const QByteArray& bytes);
    bool isConnected() const;
 
    bool awaitingErrorBody() const { return _decoder.awaitingErrorBody(); }
 
    void abort();
    void retire();
 
signals:
    void certificatePinned(const QString& pin);
    void responseStarted();
    void bodyReceived(const QByteArray& body, qint64 receivedAtMs);
    void failed(const NTRIPFailure& failure);
    void finished();
 
private:
    void _attach(QTcpSocket* socket);
    void _verifyCertificate(QSslSocket* socket, const QList<QSslError>& errors);
    void _establish();
    void _read();
    void _receive(QByteArrayView bytes, qint64 receivedAtMs, const QDateTime& utcNow = QDateTime::currentDateTimeUtc());
    void _publish(const NTRIPHttpDecoder::Result& result, qint64 receivedAtMs);
    void _finishResponse();
    void _fail(NTRIPError code, const QString& message);
    void _end();
 
    RuntimeScheduler* const _scheduler;
    const NTRIPHttpPurpose _purpose;
    ScheduledTask _errorBodyTask;
    NTRIPHttpDecoder _decoder;
    QByteArray _request;
    QTcpSocket* _socket = nullptr;
    QString _endpoint;
    QString _pinnedCertificate;
    QString _newPin;
    bool _allowSelfSignedCerts = false;
    bool _reading = false;
    bool _ended = false;
};