File indexing completed on 2024-12-22 04:57:54

 /*
     SPDX-License-Identifier: BSD-2-Clause
 */
 
 #pragma once
 
 #include <QByteArray>
 #include <QNetworkAccessManager>
 #include <QNetworkReply>
 #include <QNetworkRequest>
 #include <QObject>
 #include <QUrl>
 
 #include "o2/o2reply.h"
 
 class O2;
 
 /// Makes authenticated requests.
 class O2Requestor : public QObject
 {
     Q_OBJECT
 
 public:
     explicit O2Requestor(QNetworkAccessManager *manager, O2 *authenticator, QObject *parent = nullptr);
     ~O2Requestor() override;
 
 public Q_SLOTS:
     /// Make a GET request.
     /// @return Request ID or -1 if there are too many requests in the queue.
     int get(const QNetworkRequest &req);
 
     /// Make a POST request.
     /// @return Request ID or -1 if there are too many requests in the queue.
     int post(const QNetworkRequest &req, const QByteArray &data);
 
     /// Make a PUT request.
     /// @return Request ID or -1 if there are too many requests in the queue.
     int put(const QNetworkRequest &req, const QByteArray &data);
 
 Q_SIGNALS:
     /// Emitted when a request has been completed or failed.
     void finished(int id, QNetworkReply::NetworkError error, QByteArray data);
 
     /// Emitted when an upload has progressed.
     void uploadProgress(int id, qint64 bytesSent, qint64 bytesTotal);
 
 protected Q_SLOTS:
     /// Handle refresh completion.
     void onRefreshFinished(QNetworkReply::NetworkError error);
 
     /// Handle request finished.
     void onRequestFinished();
 
     /// Handle request error.
     void onRequestError(QNetworkReply::NetworkError error);
 
     /// Re-try request (after successful token refresh).
     void retry();
 
     /// Finish the request, Q_EMIT finished() signal.
     void finish();
 
     /// Handle upload progress.
     void onUploadProgress(qint64 uploaded, qint64 total);
 
 protected:
     int setup(const QNetworkRequest &request, QNetworkAccessManager::Operation operation);
 
     enum Status {
         Idle,
         Requesting,
         ReRequesting,
     };
 
     QNetworkAccessManager *manager_ = nullptr;
     O2 *authenticator_ = nullptr;
     QNetworkRequest request_;
     QByteArray data_;
     QNetworkReply *reply_ = nullptr;
     Status status_;
     int id_;
     QNetworkAccessManager::Operation operation_;
     QUrl url_;
     O2ReplyList timedReplies_;
     QNetworkReply::NetworkError error_;
 };