Some work about adaptive color scheme for Web UI (PR #19901)
http://[316:c51a:62a3:8b9::4]/d4708/qBittorrent/src/branch/adaptive-webui
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
221 lines
9.2 KiB
221 lines
9.2 KiB
/* |
|
* Bittorrent Client using Qt4 and libtorrent. |
|
* Copyright (C) 2006 Christophe Dumez |
|
* |
|
* This program is free software; you can redistribute it and/or |
|
* modify it under the terms of the GNU General Public License |
|
* as published by the Free Software Foundation; either version 2 |
|
* of the License, or (at your option) any later version. |
|
* |
|
* This program is distributed in the hope that it will be useful, |
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of |
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the |
|
* GNU General Public License for more details. |
|
* |
|
* You should have received a copy of the GNU General Public License |
|
* along with this program; if not, write to the Free Software |
|
* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA. |
|
* |
|
* In addition, as a special exception, the copyright holders give permission to |
|
* link this program with the OpenSSL project's "OpenSSL" library (or with |
|
* modified versions of it that use the same license as the "OpenSSL" library), |
|
* and distribute the linked executables. You must obey the GNU General Public |
|
* License in all respects for all of the code used other than "OpenSSL". If you |
|
* modify file(s), you may extend this exception to your version of the file(s), |
|
* but you are not obligated to do so. If you do not wish to do so, delete this |
|
* exception statement from your version. |
|
* |
|
* Contact : chris@qbittorrent.org |
|
*/ |
|
|
|
#include "downloadthread.h" |
|
#include <QTemporaryFile> |
|
#include <QSettings> |
|
#include <QNetworkAccessManager> |
|
#include <QNetworkRequest> |
|
#include <QNetworkProxy> |
|
|
|
enum ProxyType {HTTP=1, SOCKS5=2, HTTP_PW=3, SOCKS5_PW=4, SOCKS4=5}; |
|
|
|
/** Download Thread **/ |
|
|
|
downloadThread::downloadThread(QObject* parent) : QObject(parent) { |
|
networkManager = new QNetworkAccessManager(this); |
|
connect(networkManager, SIGNAL(finished (QNetworkReply*)), this, SLOT(processDlFinished(QNetworkReply*))); |
|
connect(networkManager, SIGNAL(sslErrors(QNetworkReply*,QList<QSslError>)), this, SLOT(ignoreSslErrors(QNetworkReply*,QList<QSslError>))); |
|
} |
|
|
|
downloadThread::~downloadThread(){ |
|
qDebug("Deleting network manager"); |
|
delete networkManager; |
|
qDebug("Deleted network manager"); |
|
} |
|
|
|
void downloadThread::processDlFinished(QNetworkReply* reply) { |
|
QString url = reply->url().toString(); |
|
if(reply->error() != QNetworkReply::NoError) { |
|
// Failure |
|
emit downloadFailure(url, errorCodeToString(reply->error())); |
|
} else { |
|
QVariant redirection = reply->attribute(QNetworkRequest::RedirectionTargetAttribute); |
|
if(redirection.isValid()) { |
|
// We should redirect |
|
qDebug("Redirecting from %s to %s", qPrintable(url), qPrintable(redirection.toUrl().toString())); |
|
redirect_mapping.insert(redirection.toUrl().toString(), url); |
|
downloadUrl(redirection.toUrl().toString()); |
|
return; |
|
} |
|
// Checking if it was redirecting, restoring initial URL |
|
if(redirect_mapping.contains(url)) { |
|
url = redirect_mapping.take(url); |
|
} |
|
// Success |
|
QString filePath; |
|
QTemporaryFile tmpfile; |
|
tmpfile.setAutoRemove(false); |
|
if (tmpfile.open()) { |
|
filePath = tmpfile.fileName(); |
|
qDebug("Temporary filename is: %s", qPrintable(filePath)); |
|
if(reply->open(QIODevice::ReadOnly)) { |
|
// TODO: Support GZIP compression |
|
tmpfile.write(reply->readAll()); |
|
reply->close(); |
|
tmpfile.close(); |
|
// Send finished signal |
|
emit downloadFinished(url, filePath); |
|
} else { |
|
// Error when reading the request |
|
tmpfile.close(); |
|
emit downloadFailure(url, tr("I/O Error")); |
|
} |
|
} else { |
|
emit downloadFailure(url, tr("I/O Error")); |
|
} |
|
} |
|
// Clean up |
|
reply->deleteLater(); |
|
} |
|
|
|
void downloadThread::downloadTorrentUrl(QString url){ |
|
QNetworkReply *reply = downloadUrl(url); |
|
connect(reply, SIGNAL(downloadProgress(qint64,qint64)), this, SLOT(checkDownloadSize(qint64,qint64))); |
|
} |
|
|
|
QNetworkReply* downloadThread::downloadUrl(QString url){ |
|
// Update proxy settings |
|
applyProxySettings(); |
|
// Process download request |
|
QNetworkRequest request; |
|
request.setUrl(QUrl::fromEncoded(url.toLocal8Bit())); |
|
// Spoof Firefox 3.5 user agent to avoid |
|
// Web server banning |
|
request.setRawHeader("User-Agent", "Mozilla/5.0 (X11; U; Linux i686 (x86_64); en-US; rv:1.9.1.5) Gecko/20091102 Firefox/3.5.5"); |
|
qDebug("Downloading %s...", qPrintable(request.url().toString())); |
|
return networkManager->get(request); |
|
} |
|
|
|
void downloadThread::checkDownloadSize(qint64 bytesReceived, qint64 bytesTotal) { |
|
if(bytesTotal > 0) { |
|
QNetworkReply *reply = static_cast<QNetworkReply*>(sender()); |
|
// Total number of bytes is available |
|
if(bytesTotal > 1048576) { |
|
// More than 1MB, this is probably not a torrent file, aborting... |
|
reply->abort(); |
|
} else { |
|
disconnect(reply, SIGNAL(downloadProgress(qint64,qint64)), this, SLOT(checkDownloadSize(qint64,qint64))); |
|
} |
|
} else { |
|
if(bytesReceived > 1048576) { |
|
// More than 1MB, this is probably not a torrent file, aborting... |
|
QNetworkReply *reply = static_cast<QNetworkReply*>(sender()); |
|
reply->abort(); |
|
} |
|
} |
|
} |
|
|
|
void downloadThread::applyProxySettings() { |
|
QNetworkProxy proxy; |
|
QSettings settings("qBittorrent", "qBittorrent"); |
|
int intValue = settings.value(QString::fromUtf8("Preferences/Connection/HTTPProxyType"), 0).toInt(); |
|
if(intValue > 0) { |
|
// Proxy enabled |
|
QString IP = settings.value(QString::fromUtf8("Preferences/Connection/HTTPProxy/IP"), "0.0.0.0").toString(); |
|
proxy.setHostName(IP); |
|
QString port = settings.value(QString::fromUtf8("Preferences/Connection/HTTPProxy/Port"), 8080).toString(); |
|
qDebug("Using proxy: %s", qPrintable(IP)); |
|
proxy.setPort(port.toUShort()); |
|
// Default proxy type is HTTP, we must change if it is SOCKS5 |
|
if(intValue == SOCKS5 || intValue == SOCKS5_PW) { |
|
qDebug("Proxy is SOCKS5, not HTTP"); |
|
proxy.setType(QNetworkProxy::Socks5Proxy); |
|
} else { |
|
proxy.setType(QNetworkProxy::HttpProxy); |
|
} |
|
// Authentication? |
|
if(intValue > 2) { |
|
qDebug("Proxy requires authentication, authenticating"); |
|
QString username = settings.value(QString::fromUtf8("Preferences/Connection/HTTPProxy/Username"), QString()).toString(); |
|
proxy.setUser(username); |
|
QString password = settings.value(QString::fromUtf8("Preferences/Connection/HTTPProxy/Password"), QString()).toString(); |
|
proxy.setPassword(password); |
|
} |
|
|
|
} else { |
|
proxy.setType(QNetworkProxy::NoProxy); |
|
} |
|
networkManager->setProxy(proxy); |
|
} |
|
|
|
QString downloadThread::errorCodeToString(QNetworkReply::NetworkError status) { |
|
switch(status){ |
|
case QNetworkReply::HostNotFoundError: |
|
return tr("The remote host name was not found (invalid hostname)"); |
|
case QNetworkReply::OperationCanceledError: |
|
return tr("The operation was canceled"); |
|
case QNetworkReply::RemoteHostClosedError: |
|
return tr("The remote server closed the connection prematurely, before the entire reply was received and processed"); |
|
case QNetworkReply::TimeoutError: |
|
return tr("The connection to the remote server timed out"); |
|
case QNetworkReply::SslHandshakeFailedError: |
|
return tr("SSL/TLS handshake failed"); |
|
case QNetworkReply::ConnectionRefusedError: |
|
return tr("The remote server refused the connection"); |
|
case QNetworkReply::ProxyConnectionRefusedError: |
|
return tr("The connection to the proxy server was refused"); |
|
case QNetworkReply::ProxyConnectionClosedError: |
|
return tr("The proxy server closed the connection prematurely"); |
|
case QNetworkReply::ProxyNotFoundError: |
|
return tr("The proxy host name was not found"); |
|
case QNetworkReply::ProxyTimeoutError: |
|
return tr("The connection to the proxy timed out or the proxy did not reply in time to the request sent"); |
|
case QNetworkReply::ProxyAuthenticationRequiredError: |
|
return tr("The proxy requires authentication in order to honour the request but did not accept any credentials offered"); |
|
case QNetworkReply::ContentAccessDenied: |
|
return tr("The access to the remote content was denied (401)"); |
|
case QNetworkReply::ContentOperationNotPermittedError: |
|
return tr("The operation requested on the remote content is not permitted"); |
|
case QNetworkReply::ContentNotFoundError: |
|
return tr("The remote content was not found at the server (404)"); |
|
case QNetworkReply::AuthenticationRequiredError: |
|
return tr("The remote server requires authentication to serve the content but the credentials provided were not accepted"); |
|
case QNetworkReply::ProtocolUnknownError: |
|
return tr("The Network Access API cannot honor the request because the protocol is not known"); |
|
case QNetworkReply::ProtocolInvalidOperationError: |
|
return tr("The requested operation is invalid for this protocol"); |
|
case QNetworkReply::UnknownNetworkError: |
|
return tr("An unknown network-related error was detected"); |
|
case QNetworkReply::UnknownProxyError: |
|
return tr("An unknown proxy-related error was detected"); |
|
case QNetworkReply::UnknownContentError: |
|
return tr("An unknown error related to the remote content was detected"); |
|
case QNetworkReply::ProtocolFailure: |
|
return tr("A breakdown in protocol was detected"); |
|
default: |
|
return tr("Unknown error"); |
|
} |
|
} |
|
|
|
void downloadThread::ignoreSslErrors(QNetworkReply* reply,QList<QSslError> errors) { |
|
// Ignore all SSL errors |
|
reply->ignoreSslErrors(errors); |
|
}
|
|
|