05fc3aef53
Replace the current license disclaimer in files by a SPDX-License-Identifier. Files that have to be modified by hand are modified. License files are organized under LICENSES directory. Task-number: QTBUG-67283 Change-Id: Id880c92784c40f3bbde861c0d93f58151c18b9f1 Reviewed-by: Qt CI Bot <qt_ci_bot@qt-project.org> Reviewed-by: Lars Knoll <lars.knoll@qt.io> Reviewed-by: Jörg Bornemann <joerg.bornemann@qt.io>
126 lines
4.1 KiB
C++
126 lines
4.1 KiB
C++
// Copyright (C) 2016 The Qt Company Ltd.
|
|
// SPDX-License-Identifier: LicenseRef-Qt-Commercial OR GPL-3.0-only WITH Qt-GPL-exception-1.0
|
|
|
|
#include "qget.h"
|
|
#include <QAuthenticator>
|
|
#include <QCoreApplication>
|
|
#include <QDebug>
|
|
#include <QSslError>
|
|
|
|
DownloadManager::DownloadManager()
|
|
: queueMode (Parallel)
|
|
{
|
|
connect(&nam, SIGNAL(finished(QNetworkReply*)), this, SLOT(finished(QNetworkReply*)));
|
|
connect(&nam, SIGNAL(authenticationRequired(QNetworkReply*,QAuthenticator*)), this, SLOT(authenticationRequired(QNetworkReply*,QAuthenticator*)));
|
|
connect(&nam, SIGNAL(proxyAuthenticationRequired(QNetworkProxy,QAuthenticator*)), this, SLOT(proxyAuthenticationRequired(QNetworkProxy,QAuthenticator*)));
|
|
#ifndef QT_NO_SSL
|
|
connect(&nam, SIGNAL(sslErrors(QNetworkReply*,QList<QSslError>)), this, SLOT(sslErrors(QNetworkReply*,QList<QSslError>)));
|
|
#endif
|
|
}
|
|
|
|
DownloadManager::~DownloadManager()
|
|
{
|
|
|
|
}
|
|
|
|
void DownloadManager::get(const QNetworkRequest &request, const QString &user, const QString &password)
|
|
{
|
|
DownloadItem *dl = new DownloadItem(request, user, password, nam);
|
|
transfers.append(dl);
|
|
connect(dl, SIGNAL(downloadFinished(TransferItem*)), SLOT(downloadFinished(TransferItem*)));
|
|
}
|
|
|
|
void DownloadManager::upload(const QNetworkRequest &request, const QString &user, const QString &password, const QString &filename, TransferItem::Method method)
|
|
{
|
|
QScopedPointer<QFile> file(new QFile(filename));
|
|
if (!file->open(QFile::ReadOnly)) {
|
|
qDebug() << "Can't open input file" << file->fileName() << file->errorString();
|
|
return;
|
|
}
|
|
UploadItem *ul = new UploadItem(request, user, password, nam, file.take(), method);
|
|
transfers.append(ul);
|
|
connect(ul, SIGNAL(downloadFinished(TransferItem*)), SLOT(downloadFinished(TransferItem*)));
|
|
}
|
|
|
|
void DownloadManager::finished(QNetworkReply *)
|
|
{
|
|
}
|
|
|
|
void DownloadManager::downloadFinished(TransferItem *item)
|
|
{
|
|
qDebug() << "finished " << item->reply->url() << " with http status: " << item->reply->attribute(QNetworkRequest::HttpStatusCodeAttribute).toInt();
|
|
if (item->reply->error() != QNetworkReply::NoError)
|
|
qDebug() << "and error: " << item->reply->error() << item->reply->errorString();
|
|
transfers.removeOne(item);
|
|
item->deleteLater();
|
|
checkForAllDone();
|
|
}
|
|
|
|
void DownloadManager::checkForAllDone()
|
|
{
|
|
if (transfers.isEmpty()) {
|
|
qDebug() << "All Done.";
|
|
QCoreApplication::quit();
|
|
}
|
|
|
|
foreach (TransferItem *item, transfers) {
|
|
if (!item->reply) {
|
|
item->start();
|
|
//by default multiple downloads are processed in parallel.
|
|
//but in serial mode, only start one transfer at a time.
|
|
if (queueMode == Serial)
|
|
break;
|
|
}
|
|
}
|
|
|
|
}
|
|
|
|
void DownloadManager::authenticationRequired(QNetworkReply *reply, QAuthenticator *auth)
|
|
{
|
|
qDebug() << "authenticationRequired" << reply;
|
|
TransferItem *transfer = findTransfer(reply);
|
|
//provide the credentials exactly once, so that it fails if credentials are incorrect.
|
|
if ((transfer && !transfer->user.isEmpty()) || !transfer->password.isEmpty()) {
|
|
auth->setUser(transfer->user);
|
|
auth->setPassword(transfer->password);
|
|
transfer->user.clear();
|
|
transfer->password.clear();
|
|
}
|
|
}
|
|
|
|
void DownloadManager::proxyAuthenticationRequired(const QNetworkProxy &, QAuthenticator *auth)
|
|
{
|
|
//provide the credentials exactly once, so that it fails if credentials are incorrect.
|
|
if (!proxyUser.isEmpty() || !proxyPassword.isEmpty()) {
|
|
auth->setUser(proxyUser);
|
|
auth->setPassword(proxyPassword);
|
|
proxyUser.clear();
|
|
proxyPassword.clear();
|
|
}
|
|
}
|
|
|
|
#ifndef QT_NO_SSL
|
|
void DownloadManager::sslErrors(QNetworkReply *, const QList<QSslError> &errors)
|
|
{
|
|
qDebug() << "sslErrors";
|
|
foreach (const QSslError &error, errors) {
|
|
qDebug() << error.errorString();
|
|
qDebug() << error.certificate().toPem();
|
|
}
|
|
}
|
|
#endif
|
|
|
|
TransferItem *DownloadManager::findTransfer(QNetworkReply *reply)
|
|
{
|
|
foreach (TransferItem *item, transfers) {
|
|
if (item->reply == reply)
|
|
return item;
|
|
}
|
|
return 0;
|
|
}
|
|
|
|
void DownloadManager::setQueueMode(QueueMode mode)
|
|
{
|
|
queueMode = mode;
|
|
}
|