AmdaProvider.cpp
145 lines
| 4.9 KiB
| text/x-c
|
CppLexer
Alexandre Leroux
|
r348 | #include "AmdaProvider.h" | ||
|
Alexandre Leroux
|
r380 | #include "AmdaDefs.h" | ||
|
Alexandre Leroux
|
r351 | #include "AmdaResultParser.h" | ||
|
Alexandre Leroux
|
r349 | #include <Data/DataProviderParameters.h> | ||
| r358 | #include <Network/NetworkController.h> | |||
| #include <SqpApplication.h> | ||||
| #include <Variable/Variable.h> | ||||
|
Alexandre Leroux
|
r349 | |||
| #include <QNetworkAccessManager> | ||||
| #include <QNetworkReply> | ||||
|
Alexandre Leroux
|
r350 | #include <QTemporaryFile> | ||
| r358 | #include <QThread> | |||
|
Alexandre Leroux
|
r348 | |||
| Q_LOGGING_CATEGORY(LOG_AmdaProvider, "AmdaProvider") | ||||
|
Alexandre Leroux
|
r349 | 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¶meterID=%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 | ||||
|
Alexandre Leroux
|
r376 | AmdaProvider::AmdaProvider() | ||
|
Alexandre Leroux
|
r348 | { | ||
| r358 | qCDebug(LOG_NetworkController()) << tr("AmdaProvider::AmdaProvider") | |||
| << QThread::currentThread(); | ||||
| if (auto app = sqpApp) { | ||||
| auto &networkController = app->networkController(); | ||||
|
Alexandre Leroux
|
r383 | connect(this, SIGNAL(requestConstructed(QNetworkRequest, QUuid, | ||
| std::function<void(QNetworkReply *, QUuid)>)), | ||||
| &networkController, | ||||
| SLOT(onProcessRequested(QNetworkRequest, QUuid, | ||||
| std::function<void(QNetworkReply *, QUuid)>))); | ||||
| r391 | ||||
| connect(&sqpApp->networkController(), SIGNAL(replyDownloadProgress(QUuid, double)), this, | ||||
| SIGNAL(dataProvidedProgress(QUuid, double))); | ||||
| r358 | } | |||
|
Alexandre Leroux
|
r348 | } | ||
|
Alexandre Leroux
|
r375 | void AmdaProvider::requestDataLoading(QUuid token, const DataProviderParameters ¶meters) | ||
|
Alexandre Leroux
|
r348 | { | ||
| // NOTE: Try to use multithread if possible | ||||
|
Alexandre Leroux
|
r375 | const auto times = parameters.m_Times; | ||
|
Alexandre Leroux
|
r380 | const auto data = parameters.m_Data; | ||
|
Alexandre Leroux
|
r375 | for (const auto &dateTime : qAsConst(times)) { | ||
|
Alexandre Leroux
|
r380 | retrieveData(token, dateTime, data); | ||
|
Alexandre Leroux
|
r348 | } | ||
| } | ||||
| r388 | void AmdaProvider::requestDataAborting(QUuid identifier) | |||
| { | ||||
| if (auto app = sqpApp) { | ||||
| auto &networkController = app->networkController(); | ||||
| networkController.onReplyCanceled(identifier); | ||||
| } | ||||
| } | ||||
|
Alexandre Leroux
|
r380 | void AmdaProvider::retrieveData(QUuid token, const SqpDateTime &dateTime, const QVariantHash &data) | ||
|
Alexandre Leroux
|
r349 | { | ||
|
Alexandre Leroux
|
r380 | // Retrieves product ID from data: if the value is invalid, no request is made | ||
| auto productId = data.value(AMDA_XML_ID_KEY).toString(); | ||||
| if (productId.isNull()) { | ||||
| qCCritical(LOG_AmdaProvider()) << tr("Can't retrieve data: unknown product id"); | ||||
| return; | ||||
| } | ||||
|
Alexandre Leroux
|
r349 | // /////////// // | ||
| // Creates URL // | ||||
| // /////////// // | ||||
|
Alexandre Leroux
|
r375 | auto startDate = dateFormat(dateTime.m_TStart); | ||
| auto endDate = dateFormat(dateTime.m_TEnd); | ||||
|
Alexandre Leroux
|
r349 | |||
| auto url = QUrl{QString{AMDA_URL_FORMAT}.arg(startDate, endDate, productId)}; | ||||
| r358 | auto tempFile = std::make_shared<QTemporaryFile>(); | |||
|
Alexandre Leroux
|
r349 | |||
| r358 | // LAMBDA | |||
|
Alexandre Leroux
|
r376 | auto httpDownloadFinished | ||
| = [this, dateTime, tempFile, token](QNetworkReply *reply, QUuid dataId) noexcept { | ||||
| Q_UNUSED(dataId); | ||||
| r397 | // Don't do anything if the reply was abort | |||
| if (reply->error() != QNetworkReply::OperationCanceledError) { | ||||
| if (tempFile) { | ||||
| auto replyReadAll = reply->readAll(); | ||||
| if (!replyReadAll.isEmpty()) { | ||||
| tempFile->write(replyReadAll); | ||||
| } | ||||
| tempFile->close(); | ||||
| // Parse results file | ||||
| if (auto dataSeries = AmdaResultParser::readTxt(tempFile->fileName())) { | ||||
| emit dataProvided(token, dataSeries, dateTime); | ||||
| } | ||||
| else { | ||||
| /// @todo ALX : debug | ||||
| } | ||||
|
Alexandre Leroux
|
r376 | } | ||
| } | ||||
| }; | ||||
| r397 | auto httpFinishedLambda | |||
| = [this, httpDownloadFinished, tempFile](QNetworkReply *reply, QUuid dataId) noexcept { | ||||
|
Alexandre Leroux
|
r350 | |||
| r397 | // Don't do anything if the reply was abort | |||
| if (reply->error() != QNetworkReply::OperationCanceledError) { | ||||
| auto downloadFileUrl = QUrl{QString{reply->readAll()}}; | ||||
| r388 | ||||
|
Alexandre Leroux
|
r350 | |||
| r397 | // Executes request for downloading file // | |||
| r358 | ||||
| r397 | // Creates destination file | |||
| if (tempFile->open()) { | ||||
| // Executes request | ||||
| emit requestConstructed(QNetworkRequest{downloadFileUrl}, dataId, | ||||
| httpDownloadFinished); | ||||
| } | ||||
| } | ||||
| }; | ||||
| r358 | ||||
| // //////////////// // | ||||
| // Executes request // | ||||
| // //////////////// // | ||||
| emit requestConstructed(QNetworkRequest{url}, token, httpFinishedLambda); | ||||
|
Alexandre Leroux
|
r348 | } | ||
