GIT_REPOSITORIES/LPP/Users/mperrinel/SciQLop-fork Commit - r379:0abce98e1e41

Amda provider (2)...

Alexandre Leroux -

r379:0abce98e1e41

parent child

Context file:

r379:0abce98e1e41

Collapse all files

plugins/amda/include/AmdaProvider.h +2 0

             #ifndef SCIQLOP_AMDAPROVIDER_H
             #define SCIQLOP_AMDAPROVIDER_H
             #include "AmdaGlobal.h"
             #include <Common/spimpl.h>
             #include <Data/IDataProvider.h>
             #include <QLoggingCategory>
             Q_DECLARE_LOGGING_CATEGORY(LOG_AmdaProvider)
             /**
              * @brief The AmdaProvider class is an example of how a data provider can generate data
              */
             class SCIQLOP_AMDA_EXPORT AmdaProvider : public IDataProvider {
             public:
                 explicit AmdaProvider();
                 void requestDataLoading(QUuid token, const QVector<SqpDateTime> &dateTimeList) override;
             private:
                 void retrieveData(QUuid token, const DataProviderParameters &parameters) const;
                 class AmdaProviderPrivate;
                 spimpl::unique_impl_ptr<AmdaProviderPrivate> impl;
             private slots:
                 void httpFinished() noexcept;
+                void httpDownloadFinished() noexcept;
+                void httpDownloadReadyRead() noexcept;
             };
             #endif // SCIQLOP_AMDAPROVIDER_H

plugins/amda/src/AmdaProvider.cpp +46 -1

             #include "AmdaProvider.h"
             #include <Data/DataProviderParameters.h>
             #include <QNetworkAccessManager>
             #include <QNetworkReply>
+            #include <QTemporaryFile>
             Q_LOGGING_CATEGORY(LOG_AmdaProvider, "AmdaProvider")
             namespace {
             /// URL format for a request on AMDA server. The parameters are as follows:
             /// - %1: start date
             /// - %2: end date
             /// - %3: parameter id
             const auto AMDA_URL_FORMAT = QStringLiteral(
                 "http://amda.irap.omp.eu/php/rest/"
                 "getParameter.php?startTime=%1&stopTime=%2&parameterID=%3&sampling=60&outputFormat=ASCII&"
                 "timeFormat=ISO8601&gzip=0");
             /// Dates format passed in the URL (e.g 2013-09-23T09:00)
             const auto AMDA_TIME_FORMAT = QStringLiteral("yyyy-MM-ddThh:ss");
             /// Formats a time to a date that can be passed in URL
             QString dateFormat(double sqpDateTime) noexcept
             {
                 auto dateTime = QDateTime::fromMSecsSinceEpoch(sqpDateTime * 1000.);
                 return dateTime.toString(AMDA_TIME_FORMAT);
             }
             } // namespace
             struct AmdaProvider::AmdaProviderPrivate {
                 DataProviderParameters m_Params{};
                 std::unique_ptr<QNetworkAccessManager> m_AccessManager{nullptr};
                 QNetworkReply *m_Reply{nullptr};
                 std::unique_ptr<QTemporaryFile> m_File{nullptr};
                 QUuid m_Token;
             };
             AmdaProvider::AmdaProvider() : impl{spimpl::make_unique_impl<AmdaProviderPrivate>()}
             {
             }
             void AmdaProvider::requestDataLoading(QUuid token, const QVector<SqpDateTime> &dateTimeList)
             {
                 // NOTE: Try to use multithread if possible
                 for (const auto &dateTime : dateTimeList) {
                     retrieveData(token, DataProviderParameters{dateTime});
                 }
             }
             void AmdaProvider::retrieveData(QUuid token, const DataProviderParameters &parameters) const
             {
                 // /////////// //
                 // Creates URL //
                 // /////////// //
                 auto startDate = dateFormat(parameters.m_Time.m_TStart);
                 auto endDate = dateFormat(parameters.m_Time.m_TEnd);
                 auto productId = QStringLiteral("imf(0)");
                 auto url = QUrl{QString{AMDA_URL_FORMAT}.arg(startDate, endDate, productId)};
                 // //////////////// //
                 // Executes request //
                 // //////////////// //
                 impl->m_Token = token;
                 impl->m_Params = parameters;
                 impl->m_AccessManager = std::make_unique<QNetworkAccessManager>();
                 impl->m_Reply = impl->m_AccessManager->get(QNetworkRequest{url});
                 connect(impl->m_Reply, &QNetworkReply::finished, this, &AmdaProvider::httpFinished);
             }
             void AmdaProvider::httpFinished() noexcept
             {
-                /// @todo ALX
+                // ////////////////////// //
+                // Gets download file url //
+                // ////////////////////// //
+                auto downloadFileUrl = QUrl{QString{impl->m_Reply->readAll()}};
+                // ///////////////////////////////////// //
+                // Executes request for downloading file //
+                // ///////////////////////////////////// //
+                // Deletes old reply
+                impl->m_Reply->deleteLater();
+                impl->m_Reply = nullptr;
+                // Creates destination file
+                impl->m_File = std::make_unique<QTemporaryFile>();
+                if (impl->m_File->open()) {
+                    qCDebug(LOG_AmdaProvider()) << "Temp file: " << impl->m_File->fileName();
+                    // Executes request
+                    impl->m_AccessManager = std::make_unique<QNetworkAccessManager>();
+                    impl->m_Reply = impl->m_AccessManager->get(QNetworkRequest{downloadFileUrl});
+                    connect(impl->m_Reply, &QNetworkReply::finished, this,
+                            &AmdaProvider::httpDownloadReadyRead);
+                    connect(impl->m_Reply, &QNetworkReply::finished, this, &AmdaProvider::httpDownloadFinished);
+                }
+            }
+            void AmdaProvider::httpDownloadFinished() noexcept
+            {
+                if (impl->m_File) {
+                    impl->m_File->close();
+                    impl->m_File = nullptr;
+                }
+                // Deletes reply
+                impl->m_Reply->deleteLater();
+                impl->m_Reply = nullptr;
+            }
+            void AmdaProvider::httpDownloadReadyRead() noexcept
+            {
+                if (impl->m_File) {
+                    impl->m_File->write(impl->m_Reply->readAll());
+                }
             }

General Comments 0

Write
Preview

You need to be logged in to leave comments. Login now

No TODOs yet

	Site-wide shortcuts
/	Use quick search box
g h	Goto home page
g g	Goto my private gists page
g G	Goto my public gists page
g 0-9	Goto bookmarked items from 0-9
n r	New repository page
n g	New gist page

	Repositories
g s	Goto summary page
g c	Goto changelog page
g f	Goto files page
g F	Goto files page with file search activated
g p	Goto pull requests page
g o	Goto repository settings
g O	Goto repository access permissions settings
t s	Toggle sidebar on some pages