summaryrefslogtreecommitdiff
path: root/src/downloadmanager.cpp
diff options
context:
space:
mode:
authorMikaël Capelle <capelle.mikael@gmail.com>2022-05-17 11:47:01 +0200
committerMikaël Capelle <capelle.mikael@gmail.com>2023-07-09 17:20:40 +0200
commitd13f6bb870cdda71257f665367be8ef9fca86255 (patch)
tree52e214718478f1e52856572f5aa1a2ac58537f9f /src/downloadmanager.cpp
parent86bb01ba9eac879d3685c439ac9da0028bc4bc80 (diff)
Apply clang-format.
Diffstat (limited to 'src/downloadmanager.cpp')
-rw-r--r--src/downloadmanager.cpp1060
1 files changed, 573 insertions, 487 deletions
diff --git a/src/downloadmanager.cpp b/src/downloadmanager.cpp
index 5bf91c01..6fb88c3b 100644
--- a/src/downloadmanager.cpp
+++ b/src/downloadmanager.cpp
@@ -19,76 +19,79 @@ along with Mod Organizer. If not, see <http://www.gnu.org/licenses/>.
#include "downloadmanager.h"
-#include "organizercore.h"
-#include "nxmurl.h"
+#include "bbcode.h"
+#include "envfs.h"
+#include "filesystemutilities.h"
+#include "iplugingame.h"
#include "nexusinterface.h"
#include "nxmaccessmanager.h"
-#include "iplugingame.h"
-#include "envfs.h"
-#include <nxmurl.h>
-#include <taskprogressmanager.h>
-#include "utility.h"
+#include "nxmurl.h"
+#include "organizercore.h"
#include "selectiondialog.h"
-#include "bbcode.h"
#include "shared/util.h"
-#include <utility.h>
+#include "utility.h"
+#include <nxmurl.h>
#include <report.h>
-#include "filesystemutilities.h"
+#include <taskprogressmanager.h>
+#include <utility.h>
-#include <QTimer>
-#include <QFileInfo>
-#include <QDirIterator>
+#include <QCoreApplication>
#include <QDesktopServices>
+#include <QDirIterator>
+#include <QFileInfo>
+#include <QHttp2Configuration>
#include <QInputDialog>
#include <QMessageBox>
-#include <QCoreApplication>
#include <QTextDocument>
-#include <QHttp2Configuration>
+#include <QTimer>
#include <boost/bind/bind.hpp>
#include <regex>
-
using namespace MOBase;
-
-// TODO limit number of downloads, also display download during nxm requests, store modid/fileid with downloads
-
+// TODO limit number of downloads, also display download during nxm requests, store
+// modid/fileid with downloads
static const char UNFINISHED[] = ".unfinished";
unsigned int DownloadManager::DownloadInfo::s_NextDownloadID = 1U;
-int DownloadManager::m_DirWatcherDisabler = 0;
-
+int DownloadManager::m_DirWatcherDisabler = 0;
-DownloadManager::DownloadInfo *DownloadManager::DownloadInfo::createNew(const ModRepositoryFileInfo *fileInfo, const QStringList &URLs)
+DownloadManager::DownloadInfo*
+DownloadManager::DownloadInfo::createNew(const ModRepositoryFileInfo* fileInfo,
+ const QStringList& URLs)
{
- DownloadInfo *info = new DownloadInfo;
+ DownloadInfo* info = new DownloadInfo;
info->m_DownloadID = s_NextDownloadID++;
info->m_StartTime.start();
- info->m_PreResumeSize = 0LL;
- info->m_Progress = std::make_pair<int, QString>(0, "0.0 B/s ");
- info->m_ResumePos = 0;
- info->m_FileInfo = new ModRepositoryFileInfo(*fileInfo);
- info->m_Urls = URLs;
- info->m_CurrentUrl = 0;
- info->m_Tries = AUTOMATIC_RETRIES;
- info->m_State = STATE_STARTED;
+ info->m_PreResumeSize = 0LL;
+ info->m_Progress = std::make_pair<int, QString>(0, "0.0 B/s ");
+ info->m_ResumePos = 0;
+ info->m_FileInfo = new ModRepositoryFileInfo(*fileInfo);
+ info->m_Urls = URLs;
+ info->m_CurrentUrl = 0;
+ info->m_Tries = AUTOMATIC_RETRIES;
+ info->m_State = STATE_STARTED;
info->m_TaskProgressId = TaskProgressManager::instance().getId();
- info->m_Reply = nullptr;
+ info->m_Reply = nullptr;
return info;
}
-DownloadManager::DownloadInfo *DownloadManager::DownloadInfo::createFromMeta(
- const QString &filePath, bool showHidden, const QString outputDirectory,
- std::optional<uint64_t> fileSize)
+DownloadManager::DownloadInfo*
+DownloadManager::DownloadInfo::createFromMeta(const QString& filePath, bool showHidden,
+ const QString outputDirectory,
+ std::optional<uint64_t> fileSize)
{
- DownloadInfo *info = new DownloadInfo;
+ DownloadInfo* info = new DownloadInfo;
QString metaFileName = filePath + ".meta";
QFileInfo metaFileInfo(metaFileName);
- if (QDir::fromNativeSeparators(metaFileInfo.path()).compare(QDir::fromNativeSeparators(outputDirectory), Qt::CaseInsensitive) != 0) return nullptr;
+ if (QDir::fromNativeSeparators(metaFileInfo.path())
+ .compare(QDir::fromNativeSeparators(outputDirectory), Qt::CaseInsensitive) !=
+ 0)
+ return nullptr;
QSettings metaFile(metaFileName, QSettings::IniFormat);
if (!showHidden && metaFile.value("removed", false).toBool()) {
return nullptr;
@@ -99,8 +102,8 @@ DownloadManager::DownloadInfo *DownloadManager::DownloadInfo::createFromMeta(
QString fileName = QFileInfo(filePath).fileName();
if (fileName.endsWith(UNFINISHED)) {
- info->m_FileName = fileName.mid(
- 0, fileName.length() - static_cast<int>(strlen(UNFINISHED)));
+ info->m_FileName =
+ fileName.mid(0, fileName.length() - static_cast<int>(strlen(UNFINISHED)));
info->m_State = STATE_PAUSED;
} else {
info->m_FileName = fileName;
@@ -118,33 +121,34 @@ DownloadManager::DownloadInfo *DownloadManager::DownloadInfo::createFromMeta(
info->m_DownloadID = s_NextDownloadID++;
info->m_Output.setFileName(filePath);
- info->m_TotalSize = fileSize ? *fileSize : QFileInfo(filePath).size();
- info->m_PreResumeSize = info->m_TotalSize;
- info->m_CurrentUrl = 0;
- info->m_Urls = metaFile.value("url", "").toString().split(";");
- info->m_Tries = 0;
+ info->m_TotalSize = fileSize ? *fileSize : QFileInfo(filePath).size();
+ info->m_PreResumeSize = info->m_TotalSize;
+ info->m_CurrentUrl = 0;
+ info->m_Urls = metaFile.value("url", "").toString().split(";");
+ info->m_Tries = 0;
info->m_TaskProgressId = TaskProgressManager::instance().getId();
- QString gameName = metaFile.value("gameName", "").toString();
- int modID = metaFile.value("modID", 0).toInt();
- int fileID = metaFile.value("fileID", 0).toInt();
- info->m_FileInfo = new ModRepositoryFileInfo(gameName, modID, fileID);
- info->m_FileInfo->name = metaFile.value("name", "").toString();
+ QString gameName = metaFile.value("gameName", "").toString();
+ int modID = metaFile.value("modID", 0).toInt();
+ int fileID = metaFile.value("fileID", 0).toInt();
+ info->m_FileInfo = new ModRepositoryFileInfo(gameName, modID, fileID);
+ info->m_FileInfo->name = metaFile.value("name", "").toString();
if (info->m_FileInfo->name == "0") {
// bug in earlier version
info->m_FileInfo->name = "";
}
- info->m_FileInfo->modName = metaFile.value("modName", "").toString();
- info->m_FileInfo->gameName = gameName;
- info->m_FileInfo->modID = modID;
- info->m_FileInfo->fileID = fileID;
+ info->m_FileInfo->modName = metaFile.value("modName", "").toString();
+ info->m_FileInfo->gameName = gameName;
+ info->m_FileInfo->modID = modID;
+ info->m_FileInfo->fileID = fileID;
info->m_FileInfo->description = metaFile.value("description").toString();
info->m_FileInfo->version.parse(metaFile.value("version", "0").toString());
- info->m_FileInfo->newestVersion.parse(metaFile.value("newestVersion", "0").toString());
- info->m_FileInfo->categoryID = metaFile.value("category", 0).toInt();
+ info->m_FileInfo->newestVersion.parse(
+ metaFile.value("newestVersion", "0").toString());
+ info->m_FileInfo->categoryID = metaFile.value("category", 0).toInt();
info->m_FileInfo->fileCategory = metaFile.value("fileCategory", 0).toInt();
- info->m_FileInfo->repository = metaFile.value("repository", "Nexus").toString();
- info->m_FileInfo->userData = metaFile.value("userData").toMap();
- info->m_Reply = nullptr;
+ info->m_FileInfo->repository = metaFile.value("repository", "Nexus").toString();
+ info->m_FileInfo->userData = metaFile.value("userData").toMap();
+ info->m_Reply = nullptr;
return info;
}
@@ -154,16 +158,13 @@ void DownloadManager::startDisableDirWatcher()
DownloadManager::m_DirWatcherDisabler++;
}
-
void DownloadManager::endDisableDirWatcher()
{
- if (DownloadManager::m_DirWatcherDisabler > 0)
- {
+ if (DownloadManager::m_DirWatcherDisabler > 0) {
if (DownloadManager::m_DirWatcherDisabler == 1)
QCoreApplication::processEvents();
DownloadManager::m_DirWatcherDisabler--;
- }
- else {
+ } else {
DownloadManager::m_DirWatcherDisabler = 0;
}
}
@@ -171,7 +172,7 @@ void DownloadManager::endDisableDirWatcher()
void DownloadManager::DownloadInfo::setName(QString newName, bool renameFile)
{
QString oldMetaFileName = QString("%1.meta").arg(m_FileName);
- m_FileName = QFileInfo(newName).fileName();
+ m_FileName = QFileInfo(newName).fileName();
if ((m_State == DownloadManager::STATE_STARTED) ||
(m_State == DownloadManager::STATE_DOWNLOADING) ||
(m_State == DownloadManager::STATE_PAUSED)) {
@@ -180,7 +181,9 @@ void DownloadManager::DownloadInfo::setName(QString newName, bool renameFile)
}
if (renameFile) {
if ((newName != m_Output.fileName()) && !m_Output.rename(newName)) {
- reportError(tr("failed to rename \"%1\" to \"%2\"").arg(m_Output.fileName()).arg(newName));
+ reportError(tr("failed to rename \"%1\" to \"%2\"")
+ .arg(m_Output.fileName())
+ .arg(newName));
return;
}
@@ -204,22 +207,22 @@ QString DownloadManager::DownloadInfo::currentURL()
return m_Urls[m_CurrentUrl];
}
-
-DownloadManager::DownloadManager(NexusInterface *nexusInterface, QObject *parent) :
- m_NexusInterface(nexusInterface), m_DirWatcher(), m_ShowHidden(false),
- m_ParentWidget(nullptr)
+DownloadManager::DownloadManager(NexusInterface* nexusInterface, QObject* parent)
+ : m_NexusInterface(nexusInterface), m_DirWatcher(), m_ShowHidden(false),
+ m_ParentWidget(nullptr)
{
m_OrganizerCore = dynamic_cast<OrganizerCore*>(parent);
- connect(&m_DirWatcher, SIGNAL(directoryChanged(QString)), this, SLOT(directoryChanged(QString)));
+ connect(&m_DirWatcher, SIGNAL(directoryChanged(QString)), this,
+ SLOT(directoryChanged(QString)));
m_TimeoutTimer.setSingleShot(false);
- //connect(&m_TimeoutTimer, SIGNAL(timeout()), this, SLOT(checkDownloadTimeout()));
+ // connect(&m_TimeoutTimer, SIGNAL(timeout()), this, SLOT(checkDownloadTimeout()));
m_TimeoutTimer.start(5 * 1000);
}
-
DownloadManager::~DownloadManager()
{
- for (QVector<DownloadInfo*>::iterator iter = m_ActiveDownloads.begin(); iter != m_ActiveDownloads.end(); ++iter) {
+ for (QVector<DownloadInfo*>::iterator iter = m_ActiveDownloads.begin();
+ iter != m_ActiveDownloads.end(); ++iter) {
delete *iter;
}
m_ActiveDownloads.clear();
@@ -232,7 +235,8 @@ void DownloadManager::setParentWidget(QWidget* w)
bool DownloadManager::downloadsInProgress()
{
- for (QVector<DownloadInfo*>::iterator iter = m_ActiveDownloads.begin(); iter != m_ActiveDownloads.end(); ++iter) {
+ for (QVector<DownloadInfo*>::iterator iter = m_ActiveDownloads.begin();
+ iter != m_ActiveDownloads.end(); ++iter) {
if ((*iter)->m_State < STATE_READY) {
return true;
}
@@ -242,7 +246,8 @@ bool DownloadManager::downloadsInProgress()
bool DownloadManager::downloadsInProgressNoPause()
{
- for (QVector<DownloadInfo*>::iterator iter = m_ActiveDownloads.begin(); iter != m_ActiveDownloads.end(); ++iter) {
+ for (QVector<DownloadInfo*>::iterator iter = m_ActiveDownloads.begin();
+ iter != m_ActiveDownloads.end(); ++iter) {
if ((*iter)->m_State < STATE_READY && (*iter)->m_State != STATE_PAUSED) {
return true;
}
@@ -250,7 +255,6 @@ bool DownloadManager::downloadsInProgressNoPause()
return false;
}
-
void DownloadManager::pauseAll()
{
@@ -263,13 +267,13 @@ void DownloadManager::pauseAll()
::Sleep(100);
- bool done = false;
+ bool done = false;
QTime startTime = QTime::currentTime();
// further loops: busy waiting for all downloads to complete. This could be neater...
while (!done && (startTime.secsTo(QTime::currentTime()) < 5)) {
QCoreApplication::processEvents();
done = true;
- foreach (DownloadInfo *info, m_ActiveDownloads) {
+ foreach (DownloadInfo* info, m_ActiveDownloads) {
if ((info->m_State < STATE_CANCELED) ||
(info->m_State == STATE_FETCHINGFILEINFO) ||
(info->m_State == STATE_FETCHINGMODINFO) ||
@@ -282,11 +286,10 @@ void DownloadManager::pauseAll()
::Sleep(100);
}
}
-
}
-
-void DownloadManager::setOutputDirectory(const QString &outputDirectory, const bool refresh)
+void DownloadManager::setOutputDirectory(const QString& outputDirectory,
+ const bool refresh)
{
QStringList directories = m_DirWatcher.directories();
if (directories.length() != 0) {
@@ -305,7 +308,7 @@ void DownloadManager::setShowHidden(bool showHidden)
refreshList();
}
-void DownloadManager::setPluginContainer(PluginContainer *pluginContainer)
+void DownloadManager::setPluginContainer(PluginContainer* pluginContainer)
{
m_NexusInterface->setPluginContainer(pluginContainer);
}
@@ -315,14 +318,16 @@ void DownloadManager::refreshList()
TimeThis tt("DownloadManager::refreshList()");
try {
- //avoid triggering other refreshes
+ // avoid triggering other refreshes
startDisableDirWatcher();
int downloadsBefore = m_ActiveDownloads.size();
// remove finished downloads
- for (QVector<DownloadInfo*>::iterator iter = m_ActiveDownloads.begin(); iter != m_ActiveDownloads.end();) {
- if (((*iter)->m_State == STATE_READY) || ((*iter)->m_State == STATE_INSTALLED) || ((*iter)->m_State == STATE_UNINSTALLED)) {
+ for (QVector<DownloadInfo*>::iterator iter = m_ActiveDownloads.begin();
+ iter != m_ActiveDownloads.end();) {
+ if (((*iter)->m_State == STATE_READY) || ((*iter)->m_State == STATE_INSTALLED) ||
+ ((*iter)->m_State == STATE_UNINSTALLED)) {
delete *iter;
iter = m_ActiveDownloads.erase(iter);
} else {
@@ -330,7 +335,8 @@ void DownloadManager::refreshList()
}
}
- const QStringList supportedExtensions = m_OrganizerCore->installationManager()->getSupportedExtensions();
+ const QStringList supportedExtensions =
+ m_OrganizerCore->installationManager()->getSupportedExtensions();
std::vector<std::wstring> nameFilters;
for (const auto& extension : supportedExtensions) {
nameFilters.push_back(L"." + extension.toLower().toStdWString());
@@ -338,13 +344,13 @@ void DownloadManager::refreshList()
nameFilters.push_back(QString(UNFINISHED).toLower().toStdWString());
-
QDir dir(QDir::fromNativeSeparators(m_OutputDirectory));
- // find orphaned meta files and delete them (sounds cruel but it's better for everyone)
+ // find orphaned meta files and delete them (sounds cruel but it's better for
+ // everyone)
QStringList orphans;
QStringList metaFiles = dir.entryList(QStringList() << "*.meta");
- foreach (const QString &metaFile, metaFiles) {
+ foreach (const QString& metaFile, metaFiles) {
QString baseFile = metaFile.left(metaFile.length() - 5);
if (!QFile::exists(dir.absoluteFilePath(baseFile))) {
orphans.append(dir.absoluteFilePath(metaFile));
@@ -355,7 +361,6 @@ void DownloadManager::refreshList()
shellDelete(orphans, true);
}
-
std::set<std::wstring> seen;
struct Context
@@ -369,54 +374,54 @@ void DownloadManager::refreshList()
for (auto&& d : m_ActiveDownloads) {
cx.seen.insert(d->m_FileName.toLower().toStdWString());
- cx.seen.insert(QFileInfo(d->m_Output.fileName()).fileName().toLower().toStdWString());
+ cx.seen.insert(
+ QFileInfo(d->m_Output.fileName()).fileName().toLower().toStdWString());
}
-
env::forEachEntry(
- QDir::toNativeSeparators(m_OutputDirectory).toStdWString(), &cx, nullptr, nullptr,
- [](void* data, std::wstring_view f, FILETIME, uint64_t size) {
- auto& cx = *static_cast<Context*>(data);
+ QDir::toNativeSeparators(m_OutputDirectory).toStdWString(), &cx, nullptr,
+ nullptr, [](void* data, std::wstring_view f, FILETIME, uint64_t size) {
+ auto& cx = *static_cast<Context*>(data);
- std::wstring lc = MOShared::ToLowerCopy(f);
+ std::wstring lc = MOShared::ToLowerCopy(f);
- bool interestingExt = false;
- for (auto&& ext : cx.extensions) {
- if (lc.ends_with(ext)) {
- interestingExt = true;
- break;
+ bool interestingExt = false;
+ for (auto&& ext : cx.extensions) {
+ if (lc.ends_with(ext)) {
+ interestingExt = true;
+ break;
+ }
}
- }
- if (!interestingExt) {
- return;
- }
+ if (!interestingExt) {
+ return;
+ }
- if (cx.seen.contains(lc)) {
- return;
- }
+ if (cx.seen.contains(lc)) {
+ return;
+ }
- QString fileName =
- QDir::fromNativeSeparators(cx.self.m_OutputDirectory) + "/" +
- QString::fromWCharArray(f.data(), f.size());
+ QString fileName = QDir::fromNativeSeparators(cx.self.m_OutputDirectory) +
+ "/" + QString::fromWCharArray(f.data(), f.size());
- DownloadInfo *info = DownloadInfo::createFromMeta(
- fileName, cx.self.m_ShowHidden, cx.self.m_OutputDirectory, size);
+ DownloadInfo* info = DownloadInfo::createFromMeta(
+ fileName, cx.self.m_ShowHidden, cx.self.m_OutputDirectory, size);
- if (info == nullptr) {
- return;
- }
+ if (info == nullptr) {
+ return;
+ }
- cx.self.m_ActiveDownloads.push_front(info);
- cx.seen.insert(std::move(lc));
- cx.seen.insert(QFileInfo(info->m_Output.fileName()).fileName().toLower().toStdWString());
- });
+ cx.self.m_ActiveDownloads.push_front(info);
+ cx.seen.insert(std::move(lc));
+ cx.seen.insert(
+ QFileInfo(info->m_Output.fileName()).fileName().toLower().toStdWString());
+ });
log::debug("saw {} downloads", m_ActiveDownloads.size());
emit update(-1);
- //let watcher trigger refreshes again
+ // let watcher trigger refreshes again
endDisableDirWatcher();
} catch (const std::bad_alloc&) {
@@ -424,9 +429,8 @@ void DownloadManager::refreshList()
}
}
-
-bool DownloadManager::addDownload(const QStringList &URLs, QString gameName,
- int modID, int fileID, const ModRepositoryFileInfo *fileInfo)
+bool DownloadManager::addDownload(const QStringList& URLs, QString gameName, int modID,
+ int fileID, const ModRepositoryFileInfo* fileInfo)
{
QString fileName = QFileInfo(URLs.first()).fileName();
if (fileName.isEmpty()) {
@@ -436,31 +440,36 @@ bool DownloadManager::addDownload(const QStringList &URLs, QString gameName,
QUrl preferredUrl = QUrl::fromEncoded(URLs.first().toLocal8Bit());
log::debug("selected download url: {}", preferredUrl.toString());
QHttp2Configuration h2Conf;
- h2Conf.setSessionReceiveWindowSize(16777215); // 16 MiB, based on Chrome and Firefox values
+ h2Conf.setSessionReceiveWindowSize(
+ 16777215); // 16 MiB, based on Chrome and Firefox values
h2Conf.setStreamReceiveWindowSize(16777215);
QNetworkRequest request(preferredUrl);
- request.setHeader(QNetworkRequest::UserAgentHeader, m_NexusInterface->getAccessManager()->userAgent());
+ request.setHeader(QNetworkRequest::UserAgentHeader,
+ m_NexusInterface->getAccessManager()->userAgent());
request.setHttp2Configuration(h2Conf);
- return addDownload(m_NexusInterface->getAccessManager()->get(request), URLs, fileName, gameName, modID, fileID, fileInfo);
+ return addDownload(m_NexusInterface->getAccessManager()->get(request), URLs, fileName,
+ gameName, modID, fileID, fileInfo);
}
-
-bool DownloadManager::addDownload(QNetworkReply *reply, const ModRepositoryFileInfo *fileInfo)
+bool DownloadManager::addDownload(QNetworkReply* reply,
+ const ModRepositoryFileInfo* fileInfo)
{
QString fileName = getFileNameFromNetworkReply(reply);
if (fileName.isEmpty()) {
fileName = "unknown";
}
- return addDownload(reply, QStringList(reply->url().toString()), fileName, fileInfo->gameName, fileInfo->modID, fileInfo->fileID, fileInfo);
+ return addDownload(reply, QStringList(reply->url().toString()), fileName,
+ fileInfo->gameName, fileInfo->modID, fileInfo->fileID, fileInfo);
}
-
-bool DownloadManager::addDownload(QNetworkReply *reply, const QStringList &URLs, const QString &fileName,
- QString gameName, int modID, int fileID, const ModRepositoryFileInfo *fileInfo)
+bool DownloadManager::addDownload(QNetworkReply* reply, const QStringList& URLs,
+ const QString& fileName, QString gameName, int modID,
+ int fileID, const ModRepositoryFileInfo* fileInfo)
{
- // download invoked from an already open network reply (i.e. download link in the browser)
- DownloadInfo *newDownload = DownloadInfo::createNew(fileInfo, URLs);
+ // download invoked from an already open network reply (i.e. download link in the
+ // browser)
+ DownloadInfo* newDownload = DownloadInfo::createNew(fileInfo, URLs);
QString baseName = fileName;
if (!fileInfo->fileName.isEmpty()) {
@@ -475,8 +484,7 @@ bool DownloadManager::addDownload(QNetworkReply *reply, const QStringList &URLs,
// baseName could be a URL at this point so strip out the URL query
int queryIndex = baseName.indexOf("?");
- if (queryIndex >= 0)
- {
+ if (queryIndex >= 0) {
baseName.truncate(queryIndex);
}
@@ -485,26 +493,27 @@ bool DownloadManager::addDownload(QNetworkReply *reply, const QStringList &URLs,
endDisableDirWatcher();
startDownload(reply, newDownload, false);
-// emit update(-1);
+ // emit update(-1);
return true;
}
-
void DownloadManager::removePending(QString gameName, int modID, int fileID)
{
QString gameShortName = gameName;
QStringList games(m_ManagedGame->validShortNames());
games += m_ManagedGame->gameShortName();
for (auto game : games) {
- MOBase::IPluginGame *gamePlugin = m_OrganizerCore->getGame(game);
- if (gamePlugin != nullptr && gamePlugin->gameNexusName().compare(gameName, Qt::CaseInsensitive) == 0) {
+ MOBase::IPluginGame* gamePlugin = m_OrganizerCore->getGame(game);
+ if (gamePlugin != nullptr &&
+ gamePlugin->gameNexusName().compare(gameName, Qt::CaseInsensitive) == 0) {
gameShortName = gamePlugin->gameShortName();
break;
}
}
emit aboutToUpdate();
for (auto iter : m_PendingDownloads) {
- if (gameShortName.compare(std::get<0>(iter), Qt::CaseInsensitive) == 0 && (std::get<1>(iter) == modID) && (std::get<2>(iter) == fileID)) {
+ if (gameShortName.compare(std::get<0>(iter), Qt::CaseInsensitive) == 0 &&
+ (std::get<1>(iter) == modID) && (std::get<2>(iter) == fileID)) {
m_PendingDownloads.removeAt(m_PendingDownloads.indexOf(iter));
break;
}
@@ -512,10 +521,11 @@ void DownloadManager::removePending(QString gameName, int modID, int fileID)
emit update(-1);
}
-
-void DownloadManager::startDownload(QNetworkReply *reply, DownloadInfo *newDownload, bool resume)
+void DownloadManager::startDownload(QNetworkReply* reply, DownloadInfo* newDownload,
+ bool resume)
{
- reply->setReadBufferSize(1024 * 1024); // don't read more than 1MB at once to avoid memory troubles
+ reply->setReadBufferSize(
+ 1024 * 1024); // don't read more than 1MB at once to avoid memory troubles
newDownload->m_Reply = reply;
setState(newDownload, STATE_DOWNLOADING);
if (newDownload->m_Urls.count() == 0) {
@@ -532,18 +542,23 @@ void DownloadManager::startDownload(QNetworkReply *reply, DownloadInfo *newDownl
if (!newDownload->m_Output.open(mode)) {
reportError(tr("failed to download %1: could not open output file: %2")
- .arg(reply->url().toString()).arg(newDownload->m_Output.fileName()));
+ .arg(reply->url().toString())
+ .arg(newDownload->m_Output.fileName()));
return;
}
- connect(newDownload->m_Reply, SIGNAL(downloadProgress(qint64, qint64)), this, SLOT(downloadProgress(qint64, qint64)));
- connect(newDownload->m_Reply, SIGNAL(errorOccurred(QNetworkReply::NetworkError)), this, SLOT(downloadError(QNetworkReply::NetworkError)));
+ connect(newDownload->m_Reply, SIGNAL(downloadProgress(qint64, qint64)), this,
+ SLOT(downloadProgress(qint64, qint64)));
+ connect(newDownload->m_Reply, SIGNAL(errorOccurred(QNetworkReply::NetworkError)),
+ this, SLOT(downloadError(QNetworkReply::NetworkError)));
connect(newDownload->m_Reply, SIGNAL(readyRead()), this, SLOT(downloadReadyRead()));
- connect(newDownload->m_Reply, SIGNAL(metaDataChanged()), this, SLOT(metaDataChanged()));
+ connect(newDownload->m_Reply, SIGNAL(metaDataChanged()), this,
+ SLOT(metaDataChanged()));
if (!resume) {
newDownload->m_PreResumeSize = newDownload->m_Output.size();
- removePending(newDownload->m_FileInfo->gameName, newDownload->m_FileInfo->modID, newDownload->m_FileInfo->fileID);
+ removePending(newDownload->m_FileInfo->gameName, newDownload->m_FileInfo->modID,
+ newDownload->m_FileInfo->fileID);
emit aboutToUpdate();
m_ActiveDownloads.append(newDownload);
@@ -554,9 +569,13 @@ void DownloadManager::startDownload(QNetworkReply *reply, DownloadInfo *newDownl
if (QFile::exists(m_OutputDirectory + "/" + newDownload->m_FileName)) {
setState(newDownload, STATE_PAUSING);
QCoreApplication::processEvents();
- if (QMessageBox::question(m_ParentWidget, tr("Download again?"), tr("A file with the same name \"%1\" has already been downloaded. "
- "Do you want to download it again? The new file will receive a different name.").arg(newDownload->m_FileName),
- QMessageBox::Yes | QMessageBox::No) == QMessageBox::No) {
+ if (QMessageBox::question(
+ m_ParentWidget, tr("Download again?"),
+ tr("A file with the same name \"%1\" has already been downloaded. "
+ "Do you want to download it again? The new file will receive a "
+ "different name.")
+ .arg(newDownload->m_FileName),
+ QMessageBox::Yes | QMessageBox::No) == QMessageBox::No) {
if (reply->isFinished())
setState(newDownload, STATE_CANCELED);
else
@@ -573,13 +592,11 @@ void DownloadManager::startDownload(QNetworkReply *reply, DownloadInfo *newDownl
} else
connect(newDownload->m_Reply, SIGNAL(finished()), this, SLOT(downloadFinished()));
-
QCoreApplication::processEvents();
if (newDownload->m_State != STATE_DOWNLOADING &&
- newDownload->m_State != STATE_READY &&
- newDownload->m_State != STATE_FETCHINGMODINFO &&
- reply->isFinished()) {
+ newDownload->m_State != STATE_READY &&
+ newDownload->m_State != STATE_FETCHINGMODINFO && reply->isFinished()) {
downloadFinished(indexByInfo(newDownload));
return;
}
@@ -587,8 +604,7 @@ void DownloadManager::startDownload(QNetworkReply *reply, DownloadInfo *newDownl
connect(newDownload->m_Reply, SIGNAL(finished()), this, SLOT(downloadFinished()));
}
-
-void DownloadManager::addNXMDownload(const QString &url)
+void DownloadManager::addNXMDownload(const QString& url)
{
NXMUrl nxmInfo(url);
@@ -608,77 +624,90 @@ void DownloadManager::addNXMDownload(const QString &url)
continue;
}
- if (
- nxmInfo.game().compare(gamePlugin->gameShortName(), Qt::CaseInsensitive) == 0 ||
- nxmInfo.game().compare(gamePlugin->gameNexusName(), Qt::CaseInsensitive) == 0
- ) {
+ if (nxmInfo.game().compare(gamePlugin->gameShortName(), Qt::CaseInsensitive) == 0 ||
+ nxmInfo.game().compare(gamePlugin->gameNexusName(), Qt::CaseInsensitive) == 0) {
foundGame = gamePlugin;
break;
}
}
log::debug("add nxm download: {}", url);
if (foundGame == nullptr) {
- log::debug("download requested for wrong game (game: {}, url: {})", m_ManagedGame->gameShortName(), nxmInfo.game());
- QMessageBox::information(m_ParentWidget, tr("Wrong Game"), tr("The download link is for a mod for \"%1\" but this instance of MO "
- "has been set up for \"%2\".").arg(nxmInfo.game()).arg(m_ManagedGame->gameShortName()), QMessageBox::Ok);
+ log::debug("download requested for wrong game (game: {}, url: {})",
+ m_ManagedGame->gameShortName(), nxmInfo.game());
+ QMessageBox::information(
+ m_ParentWidget, tr("Wrong Game"),
+ tr("The download link is for a mod for \"%1\" but this instance of MO "
+ "has been set up for \"%2\".")
+ .arg(nxmInfo.game())
+ .arg(m_ManagedGame->gameShortName()),
+ QMessageBox::Ok);
return;
}
for (auto tuple : m_PendingDownloads) {
- if (std::get<0>(tuple).compare(foundGame->gameShortName(), Qt::CaseInsensitive) == 0, std::get<1>(tuple) == nxmInfo.modId() && std::get<2>(tuple) == nxmInfo.fileId()) {
+ if (std::get<0>(tuple).compare(foundGame->gameShortName(), Qt::CaseInsensitive) ==
+ 0,
+ std::get<1>(tuple) == nxmInfo.modId() &&
+ std::get<2>(tuple) == nxmInfo.fileId()) {
const auto infoStr =
- tr("There is already a download queued for this file.\n\nMod %1\nFile %2")
- .arg(nxmInfo.modId()).arg(nxmInfo.fileId());
+ tr("There is already a download queued for this file.\n\nMod %1\nFile %2")
+ .arg(nxmInfo.modId())
+ .arg(nxmInfo.fileId());
- log::debug(
- "download requested is already queued (mod: {}, file: {})",
- nxmInfo.modId(), nxmInfo.fileId());
+ log::debug("download requested is already queued (mod: {}, file: {})",
+ nxmInfo.modId(), nxmInfo.fileId());
- QMessageBox::information(m_ParentWidget, tr("Already Queued"), infoStr, QMessageBox::Ok);
+ QMessageBox::information(m_ParentWidget, tr("Already Queued"), infoStr,
+ QMessageBox::Ok);
return;
}
}
- for (DownloadInfo *download : m_ActiveDownloads) {
- if (download->m_FileInfo->modID == nxmInfo.modId() && download->m_FileInfo->fileID == nxmInfo.fileId()) {
- if (download->m_State == STATE_DOWNLOADING || download->m_State == STATE_PAUSED || download->m_State == STATE_STARTED) {
- QString debugStr("download requested is already started (mod %1: %2, file %3: %4)");
- QString infoStr(tr("There is already a download started for this file.\n\nMod %1:\t%2\nFile %3:\t%4"));
+ for (DownloadInfo* download : m_ActiveDownloads) {
+ if (download->m_FileInfo->modID == nxmInfo.modId() &&
+ download->m_FileInfo->fileID == nxmInfo.fileId()) {
+ if (download->m_State == STATE_DOWNLOADING || download->m_State == STATE_PAUSED ||
+ download->m_State == STATE_STARTED) {
+ QString debugStr(
+ "download requested is already started (mod %1: %2, file %3: %4)");
+ QString infoStr(tr("There is already a download started for this file.\n\nMod "
+ "%1:\t%2\nFile %3:\t%4"));
// %1
debugStr = debugStr.arg(download->m_FileInfo->modID);
- infoStr = infoStr.arg(download->m_FileInfo->modID);
+ infoStr = infoStr.arg(download->m_FileInfo->modID);
// %2
if (!download->m_FileInfo->name.isEmpty()) {
debugStr = debugStr.arg(download->m_FileInfo->name);
- infoStr = infoStr.arg(download->m_FileInfo->name);
+ infoStr = infoStr.arg(download->m_FileInfo->name);
} else if (!download->m_FileInfo->modName.isEmpty()) {
debugStr = debugStr.arg(download->m_FileInfo->modName);
- infoStr = infoStr.arg(download->m_FileInfo->modName);
+ infoStr = infoStr.arg(download->m_FileInfo->modName);
} else {
debugStr = debugStr.arg(QStringLiteral("<blank>"));
- infoStr = infoStr.arg(QStringLiteral("<blank>"));
+ infoStr = infoStr.arg(QStringLiteral("<blank>"));
}
// %3
debugStr = debugStr.arg(download->m_FileInfo->fileID);
- infoStr = infoStr.arg(download->m_FileInfo->fileID);
+ infoStr = infoStr.arg(download->m_FileInfo->fileID);
// %4
if (!download->m_FileInfo->fileName.isEmpty()) {
debugStr = debugStr.arg(download->m_FileInfo->fileName);
- infoStr = infoStr.arg(download->m_FileInfo->fileName);
+ infoStr = infoStr.arg(download->m_FileInfo->fileName);
} else if (!download->m_FileName.isEmpty()) {
debugStr = debugStr.arg(download->m_FileName);
- infoStr = infoStr.arg(download->m_FileName);
+ infoStr = infoStr.arg(download->m_FileName);
} else {
debugStr = debugStr.arg(QStringLiteral("<blank>"));
- infoStr = infoStr.arg(QStringLiteral("<blank>"));
+ infoStr = infoStr.arg(QStringLiteral("<blank>"));
}
log::debug("{}", debugStr);
- QMessageBox::information(m_ParentWidget, tr("Already Started"), infoStr, QMessageBox::Ok);
+ QMessageBox::information(m_ParentWidget, tr("Already Started"), infoStr,
+ QMessageBox::Ok);
return;
}
}
@@ -686,32 +715,34 @@ void DownloadManager::addNXMDownload(const QString &url)
emit aboutToUpdate();
- m_PendingDownloads.append(std::make_tuple(foundGame->gameShortName(), nxmInfo.modId(), nxmInfo.fileId()));
+ m_PendingDownloads.append(
+ std::make_tuple(foundGame->gameShortName(), nxmInfo.modId(), nxmInfo.fileId()));
emit update(-1);
emit downloadAdded();
- ModRepositoryFileInfo *info = new ModRepositoryFileInfo();
+ ModRepositoryFileInfo* info = new ModRepositoryFileInfo();
- info->nexusKey = nxmInfo.key();
- info->nexusExpires = nxmInfo.expires();
+ info->nexusKey = nxmInfo.key();
+ info->nexusExpires = nxmInfo.expires();
info->nexusDownloadUser = nxmInfo.userId();
- QObject *test = info;
- m_RequestIDs.insert(m_NexusInterface->requestFileInfo(foundGame->gameShortName(), nxmInfo.modId(), nxmInfo.fileId(), this, QVariant::fromValue(test), ""));
+ QObject* test = info;
+ m_RequestIDs.insert(m_NexusInterface->requestFileInfo(
+ foundGame->gameShortName(), nxmInfo.modId(), nxmInfo.fileId(), this,
+ QVariant::fromValue(test), ""));
}
-
void DownloadManager::removeFile(int index, bool deleteFile)
{
- //Avoid triggering refreshes from DirWatcher
+ // Avoid triggering refreshes from DirWatcher
startDisableDirWatcher();
if (index >= m_ActiveDownloads.size()) {
throw MyException(tr("remove: invalid download index %1").arg(index));
}
- DownloadInfo *download = m_ActiveDownloads.at(index);
- QString filePath = m_OutputDirectory + "/" + download->m_FileName;
+ DownloadInfo* download = m_ActiveDownloads.at(index);
+ QString filePath = m_OutputDirectory + "/" + download->m_FileName;
if ((download->m_State == STATE_STARTED) ||
(download->m_State == STATE_DOWNLOADING)) {
// shouldn't have been possible
@@ -737,7 +768,7 @@ void DownloadManager::removeFile(int index, bool deleteFile)
}
} else {
QSettings metaSettings(filePath.append(".meta"), QSettings::IniFormat);
- if(!download->m_Hidden)
+ if (!download->m_Hidden)
metaSettings.setValue("removed", true);
}
m_DownloadRemoved(index);
@@ -748,64 +779,64 @@ void DownloadManager::removeFile(int index, bool deleteFile)
class LessThanWrapper
{
public:
- LessThanWrapper(DownloadManager *manager) : m_Manager(manager) {}
- bool operator()(int LHS, int RHS) {
- return m_Manager->getFileName(LHS).compare(m_Manager->getFileName(RHS), Qt::CaseInsensitive) < 0;
-
+ LessThanWrapper(DownloadManager* manager) : m_Manager(manager) {}
+ bool operator()(int LHS, int RHS)
+ {
+ return m_Manager->getFileName(LHS).compare(m_Manager->getFileName(RHS),
+ Qt::CaseInsensitive) < 0;
}
private:
- DownloadManager *m_Manager;
+ DownloadManager* m_Manager;
};
-
bool DownloadManager::ByName(int LHS, int RHS)
{
return m_ActiveDownloads[LHS]->m_FileName < m_ActiveDownloads[RHS]->m_FileName;
}
-
void DownloadManager::refreshAlphabeticalTranslation()
{
m_AlphabeticalTranslation.clear();
int pos = 0;
- for (QVector<DownloadInfo*>::iterator iter = m_ActiveDownloads.begin(); iter != m_ActiveDownloads.end(); ++iter, ++pos) {
+ for (QVector<DownloadInfo*>::iterator iter = m_ActiveDownloads.begin();
+ iter != m_ActiveDownloads.end(); ++iter, ++pos) {
m_AlphabeticalTranslation.push_back(pos);
}
- std::sort(m_AlphabeticalTranslation.begin(), m_AlphabeticalTranslation.end(), LessThanWrapper(this));
+ std::sort(m_AlphabeticalTranslation.begin(), m_AlphabeticalTranslation.end(),
+ LessThanWrapper(this));
}
-
void DownloadManager::restoreDownload(int index)
{
if (index < 0) {
- DownloadState minState = STATE_READY ;
- index = 0;
+ DownloadState minState = STATE_READY;
+ index = 0;
- for (QVector<DownloadInfo*>::const_iterator iter = m_ActiveDownloads.begin(); iter != m_ActiveDownloads.end(); ++iter ) {
+ for (QVector<DownloadInfo*>::const_iterator iter = m_ActiveDownloads.begin();
+ iter != m_ActiveDownloads.end(); ++iter) {
if ((*iter)->m_State >= minState) {
restoreDownload(index);
}
index++;
}
- }
- else {
+ } else {
if (index >= m_ActiveDownloads.size()) {
throw MyException(tr("restore: invalid download index: %1").arg(index));
}
- DownloadInfo *download = m_ActiveDownloads.at(index);
+ DownloadInfo* download = m_ActiveDownloads.at(index);
if (download->m_Hidden) {
download->m_Hidden = false;
QString filePath = m_OutputDirectory + "/" + download->m_FileName;
- //avoid dirWatcher triggering refreshes
+ // avoid dirWatcher triggering refreshes
startDisableDirWatcher();
- QSettings metaSettings(filePath.append(".meta"), QSettings::IniFormat);
+ QSettings metaSettings(filePath.append(".meta"), QSettings::IniFormat);
metaSettings.setValue("removed", false);
endDisableDirWatcher();
@@ -813,21 +844,21 @@ void DownloadManager::restoreDownload(int index)
}
}
-
void DownloadManager::removeDownload(int index, bool deleteFile)
{
try {
- //avoid dirWatcher triggering refreshes
+ // avoid dirWatcher triggering refreshes
startDisableDirWatcher();
emit aboutToUpdate();
if (index < 0) {
- bool removeAll = (index == -1);
+ bool removeAll = (index == -1);
DownloadState removeState = (index == -2 ? STATE_INSTALLED : STATE_UNINSTALLED);
index = 0;
- for (QVector<DownloadInfo*>::iterator iter = m_ActiveDownloads.begin(); iter != m_ActiveDownloads.end();) {
+ for (QVector<DownloadInfo*>::iterator iter = m_ActiveDownloads.begin();
+ iter != m_ActiveDownloads.end();) {
DownloadState downloadState = (*iter)->m_State;
if ((removeAll && (downloadState >= STATE_READY)) ||
(removeState == downloadState)) {
@@ -842,7 +873,7 @@ void DownloadManager::removeDownload(int index, bool deleteFile)
} else {
if (index >= m_ActiveDownloads.size()) {
reportError(tr("remove: invalid download index %1").arg(index));
- //emit update(-1);
+ // emit update(-1);
endDisableDirWatcher();
return;
}
@@ -853,13 +884,12 @@ void DownloadManager::removeDownload(int index, bool deleteFile)
}
emit update(-1);
endDisableDirWatcher();
- } catch (const std::exception &e) {
+ } catch (const std::exception& e) {
log::error("failed to remove download: {}", e.what());
}
refreshList();
}
-
void DownloadManager::cancelDownload(int index)
{
if ((index < 0) || (index >= m_ActiveDownloads.size())) {
@@ -872,7 +902,6 @@ void DownloadManager::cancelDownload(int index)
}
}
-
void DownloadManager::pauseDownload(int index)
{
if ((index < 0) || (index >= m_ActiveDownloads.size())) {
@@ -880,7 +909,7 @@ void DownloadManager::pauseDownload(int index)
return;
}
- DownloadInfo *info = m_ActiveDownloads.at(index);
+ DownloadInfo* info = m_ActiveDownloads.at(index);
if (info->m_State == STATE_DOWNLOADING) {
if ((info->m_Reply != nullptr) && (info->m_Reply->isRunning())) {
@@ -901,8 +930,8 @@ void DownloadManager::resumeDownload(int index)
reportError(tr("resume: invalid download index %1").arg(index));
return;
}
- DownloadInfo *info = m_ActiveDownloads[index];
- info->m_Tries = AUTOMATIC_RETRIES;
+ DownloadInfo* info = m_ActiveDownloads[index];
+ info->m_Tries = AUTOMATIC_RETRIES;
resumeDownloadInt(index);
}
@@ -912,11 +941,12 @@ void DownloadManager::resumeDownloadInt(int index)
reportError(tr("resume (int): invalid download index %1").arg(index));
return;
}
- DownloadInfo *info = m_ActiveDownloads[index];
+ DownloadInfo* info = m_ActiveDownloads[index];
// Check for finished download;
- if (info->m_TotalSize <= info->m_Output.size() && info->m_Reply != nullptr
- && info->m_Reply->isOpen() && info->m_Reply->isFinished() && info->m_State != STATE_ERROR) {
+ if (info->m_TotalSize <= info->m_Output.size() && info->m_Reply != nullptr &&
+ info->m_Reply->isOpen() && info->m_Reply->isFinished() &&
+ info->m_State != STATE_ERROR) {
setState(info, STATE_DOWNLOADING);
downloadFinished(index);
return;
@@ -931,9 +961,10 @@ void DownloadManager::resumeDownloadInt(int index)
}
}
}
- if ((info->m_Urls.size() == 0)
- || ((info->m_Urls.size() == 1) && (info->m_Urls[0].size() == 0))) {
- emit showMessage(tr("No known download urls. Sorry, this download can't be resumed."));
+ if ((info->m_Urls.size() == 0) ||
+ ((info->m_Urls.size() == 1) && (info->m_Urls[0].size() == 0))) {
+ emit showMessage(
+ tr("No known download urls. Sorry, this download can't be resumed."));
return;
}
if (info->m_State == STATE_ERROR) {
@@ -941,27 +972,31 @@ void DownloadManager::resumeDownloadInt(int index)
}
log::debug("request resume from url {}", info->currentURL());
QNetworkRequest request(QUrl::fromEncoded(info->currentURL().toLocal8Bit()));
- request.setHeader(QNetworkRequest::UserAgentHeader, m_NexusInterface->getAccessManager()->userAgent());
+ request.setHeader(QNetworkRequest::UserAgentHeader,
+ m_NexusInterface->getAccessManager()->userAgent());
if (info->m_State != STATE_ERROR) {
- info->m_ResumePos = info->m_Output.size();
+ info->m_ResumePos = info->m_Output.size();
QByteArray rangeHeader = "bytes=" + QByteArray::number(info->m_ResumePos) + "-";
request.setRawHeader("Range", rangeHeader);
}
- info->m_DownloadLast = 0;
+ info->m_DownloadLast = 0;
info->m_DownloadTimeLast = 0;
- info->m_DownloadAcc = accumulator_set<qint64, stats<tag::rolling_mean>>(tag::rolling_window::window_size = 200);
- info->m_DownloadTimeAcc = accumulator_set<qint64, stats<tag::rolling_mean>>(tag::rolling_window::window_size = 200);
+ info->m_DownloadAcc = accumulator_set<qint64, stats<tag::rolling_mean>>(
+ tag::rolling_window::window_size = 200);
+ info->m_DownloadTimeAcc = accumulator_set<qint64, stats<tag::rolling_mean>>(
+ tag::rolling_window::window_size = 200);
log::debug("resume at {} bytes", info->m_ResumePos);
startDownload(m_NexusInterface->getAccessManager()->get(request), info, true);
}
emit update(index);
}
-
-DownloadManager::DownloadInfo *DownloadManager::downloadInfoByID(unsigned int id)
+DownloadManager::DownloadInfo* DownloadManager::downloadInfoByID(unsigned int id)
{
auto iter = std::find_if(m_ActiveDownloads.begin(), m_ActiveDownloads.end(),
- [id](DownloadInfo *info) { return info->m_DownloadID == id; });
+ [id](DownloadInfo* info) {
+ return info->m_DownloadID == id;
+ });
if (iter != m_ActiveDownloads.end()) {
return *iter;
} else {
@@ -969,14 +1004,13 @@ DownloadManager::DownloadInfo *DownloadManager::downloadInfoByID(unsigned int id
}
}
-
void DownloadManager::queryInfo(int index)
{
if ((index < 0) || (index >= m_ActiveDownloads.size())) {
reportError(tr("query: invalid download index %1").arg(index));
return;
}
- DownloadInfo *info = m_ActiveDownloads[index];
+ DownloadInfo* info = m_ActiveDownloads[index];
if (info->m_FileInfo->repository != "Nexus") {
log::warn("re-querying file info is currently only possible with Nexus");
@@ -991,12 +1025,13 @@ void DownloadManager::queryInfo(int index)
if (info->m_FileInfo->modID <= 0) {
QString fileName = getFileName(index);
QString ignore;
- NexusInterface::interpretNexusFileName(fileName, ignore, info->m_FileInfo->modID, true);
+ NexusInterface::interpretNexusFileName(fileName, ignore, info->m_FileInfo->modID,
+ true);
if (info->m_FileInfo->modID < 0) {
- bool ok = false;
- int modId = QInputDialog::getInt(
- nullptr, tr("Please enter the nexus mod id"), tr("Mod ID:"), 1, 1,
- std::numeric_limits<int>::max(), 1, &ok);
+ bool ok = false;
+ int modId = QInputDialog::getInt(nullptr, tr("Please enter the nexus mod id"),
+ tr("Mod ID:"), 1, 1,
+ std::numeric_limits<int>::max(), 1, &ok);
// careful now: while the dialog was displayed, events were processed.
// the download list might have changed and our info-ptr invalidated.
if (ok)
@@ -1006,21 +1041,20 @@ void DownloadManager::queryInfo(int index)
}
if (info->m_FileInfo->gameName.size() == 0) {
- SelectionDialog selection(tr("Please select the source game code for %1").arg(getFileName(index)));
+ SelectionDialog selection(
+ tr("Please select the source game code for %1").arg(getFileName(index)));
- std::vector<std::pair<QString, QString>> choices = m_NexusInterface->getGameChoices(m_ManagedGame);
- if (choices.size() == 1)
- {
+ std::vector<std::pair<QString, QString>> choices =
+ m_NexusInterface->getGameChoices(m_ManagedGame);
+ if (choices.size() == 1) {
info->m_FileInfo->gameName = choices[0].first;
- }
- else {
+ } else {
for (auto choice : choices) {
selection.addChoice(choice.first, choice.second, choice.first);
}
if (selection.exec() == QDialog::Accepted) {
info->m_FileInfo->gameName = selection.getChoiceData().toString();
- }
- else {
+ } else {
info->m_FileInfo->gameName = m_ManagedGame->gameShortName();
}
}
@@ -1035,7 +1069,7 @@ void DownloadManager::queryInfoMd5(int index)
reportError(tr("query: invalid download index %1").arg(index));
return;
}
- DownloadInfo *info = m_ActiveDownloads[index];
+ DownloadInfo* info = m_ActiveDownloads[index];
if (info->m_FileInfo->repository != "Nexus") {
log::warn("re-querying file info is currently only possible with Nexus");
@@ -1052,7 +1086,8 @@ void DownloadManager::queryInfoMd5(int index)
QFile downloadFile(info->m_FileName);
if (!downloadFile.exists()) {
- downloadFile.setFileName(m_OrganizerCore->downloadsPath() + "\\" + info->m_FileName);
+ downloadFile.setFileName(m_OrganizerCore->downloadsPath() + "\\" +
+ info->m_FileName);
}
if (!downloadFile.exists()) {
log::error("Can't find download file '{}'", info->m_FileName);
@@ -1066,14 +1101,12 @@ void DownloadManager::queryInfoMd5(int index)
QCryptographicHash hash(QCryptographicHash::Md5);
const qint64 progressStep = 10 * 1024 * 1024;
QProgressDialog progress(tr("Hashing download file '%1'").arg(info->m_FileName),
- tr("Cancel"),
- 0,
- downloadFile.size() / progressStep);
+ tr("Cancel"), 0, downloadFile.size() / progressStep);
progress.setWindowModality(Qt::WindowModal);
progress.setMinimumDuration(1000);
for (qint64 i = 0; i < downloadFile.size(); i += progressStep) {
- progress.setValue(progress.value()+1);
+ progress.setValue(progress.value() + 1);
if (progress.wasCanceled()) {
break;
}
@@ -1087,7 +1120,7 @@ void DownloadManager::queryInfoMd5(int index)
progress.close();
downloadFile.close();
- info->m_Hash = hash.result();
+ info->m_Hash = hash.result();
info->m_ReQueried = true;
setState(info, STATE_FETCHINGMODINFO_MD5);
}
@@ -1098,7 +1131,7 @@ void DownloadManager::visitOnNexus(int index)
reportError(tr("VisitNexus: invalid download index %1").arg(index));
return;
}
- DownloadInfo *info = m_ActiveDownloads[index];
+ DownloadInfo* info = m_ActiveDownloads[index];
if (info->m_FileInfo->repository != "Nexus") {
log::warn("Visiting mod page is currently only possible with Nexus");
@@ -1114,8 +1147,7 @@ void DownloadManager::visitOnNexus(int index)
QString gameName = info->m_FileInfo->gameName;
if (modID > 0) {
shell::Open(QUrl(m_NexusInterface->getModURL(modID, gameName)));
- }
- else {
+ } else {
emit showMessage(tr("Nexus ID for this Mod is unknown"));
}
}
@@ -1137,21 +1169,21 @@ void DownloadManager::openFile(int index)
return;
}
-void DownloadManager::openMetaFile(int index) {
+void DownloadManager::openMetaFile(int index)
+{
if (index < 0 || index >= m_ActiveDownloads.size()) {
log::error("OpenMetaFile: invalid download index {}", index);
return;
}
- const auto path = QDir(m_OutputDirectory);
+ const auto path = QDir(m_OutputDirectory);
const auto filePath = getFilePath(index);
const auto metaPath = filePath + ".meta";
if (path.exists(metaPath)) {
shell::Open(metaPath);
return;
- }
- else {
+ } else {
QSettings metaFile(metaPath, QSettings::IniFormat);
metaFile.setValue("removed", false);
}
@@ -1176,8 +1208,7 @@ void DownloadManager::openInDownloadsFolder(int index)
if (QFile::exists(path)) {
shell::Explore(path);
return;
- }
- else {
+ } else {
const auto unfinished = path + ".unfinished";
if (QFile::exists(unfinished)) {
shell::Explore(unfinished);
@@ -1188,7 +1219,6 @@ void DownloadManager::openInDownloadsFolder(int index)
shell::Explore(m_OutputDirectory);
}
-
int DownloadManager::numTotalDownloads() const
{
return m_ActiveDownloads.size();
@@ -1220,14 +1250,22 @@ QString DownloadManager::getFilePath(int index) const
QString DownloadManager::getFileTypeString(int fileType)
{
switch (fileType) {
- case 1: return tr("Main");
- case 2: return tr("Update");
- case 3: return tr("Optional");
- case 4: return tr("Old");
- case 5: return tr("Miscellaneous");
- case 6: return tr("Deleted");
- case 7: return tr("Archived");
- default: return tr("Unknown");
+ case 1:
+ return tr("Main");
+ case 2:
+ return tr("Update");
+ case 3:
+ return tr("Optional");
+ case 4:
+ return tr("Old");
+ case 5:
+ return tr("Miscellaneous");
+ case 6:
+ return tr("Deleted");
+ case 7:
+ return tr("Archived");
+ default:
+ return tr("Unknown");
}
}
@@ -1237,14 +1275,15 @@ QString DownloadManager::getDisplayName(int index) const
throw MyException(tr("display name: invalid download index %1").arg(index));
}
- DownloadInfo *info = m_ActiveDownloads.at(index);
+ DownloadInfo* info = m_ActiveDownloads.at(index);
QTextDocument doc;
if (!info->m_FileInfo->name.isEmpty()) {
doc.setHtml(info->m_FileInfo->name);
- return QString("%1 (%2, v%3)").arg(doc.toPlainText())
- .arg(getFileTypeString(info->m_FileInfo->fileCategory))
- .arg(info->m_FileInfo->version.displayString());
+ return QString("%1 (%2, v%3)")
+ .arg(doc.toPlainText())
+ .arg(getFileTypeString(info->m_FileInfo->fileCategory))
+ .arg(info->m_FileInfo->version.displayString());
} else {
doc.setHtml(info->m_FileName);
return doc.toPlainText();
@@ -1266,7 +1305,7 @@ QDateTime DownloadManager::getFileTime(int index) const
throw MyException(tr("file time: invalid download index %1").arg(index));
}
- DownloadInfo *info = m_ActiveDownloads.at(index);
+ DownloadInfo* info = m_ActiveDownloads.at(index);
if (!info->m_Created.isValid()) {
QFileInfo fileInfo(info->m_Output);
info->m_Created = fileInfo.birthTime();
@@ -1288,7 +1327,6 @@ qint64 DownloadManager::getFileSize(int index) const
return m_ActiveDownloads.at(index)->m_TotalSize;
}
-
std::pair<int, QString> DownloadManager::getProgress(int index) const
{
if ((index < 0) || (index >= m_ActiveDownloads.size())) {
@@ -1298,7 +1336,6 @@ std::pair<int, QString> DownloadManager::getProgress(int index) const
return m_ActiveDownloads.at(index)->m_Progress;
}
-
DownloadManager::DownloadState DownloadManager::getState(int index) const
{
if ((index < 0) || (index >= m_ActiveDownloads.size())) {
@@ -1308,14 +1345,13 @@ DownloadManager::DownloadState DownloadManager::getState(int index) const
return m_ActiveDownloads.at(index)->m_State;
}
-
bool DownloadManager::isInfoIncomplete(int index) const
{
if ((index < 0) || (index >= m_ActiveDownloads.size())) {
throw MyException(tr("infocomplete: invalid download index %1").arg(index));
}
- DownloadInfo *info = m_ActiveDownloads.at(index);
+ DownloadInfo* info = m_ActiveDownloads.at(index);
if (info->m_FileInfo->repository != "Nexus") {
// other repositories currently don't support re-querying info anyway
return false;
@@ -1323,7 +1359,6 @@ bool DownloadManager::isInfoIncomplete(int index) const
return (info->m_FileInfo->fileID == 0) || (info->m_FileInfo->modID == 0);
}
-
int DownloadManager::getModID(int index) const
{
if ((index < 0) || (index >= m_ActiveDownloads.size())) {
@@ -1337,7 +1372,7 @@ QString DownloadManager::getDisplayGameName(int index) const
if ((index < 0) || (index >= m_ActiveDownloads.size())) {
throw MyException(tr("mod id: invalid download index %1").arg(index));
}
- QString gameName = m_ActiveDownloads.at(index)->m_FileInfo->gameName;
+ QString gameName = m_ActiveDownloads.at(index)->m_FileInfo->gameName;
IPluginGame* gamePlugin = m_OrganizerCore->getGame(gameName);
if (gamePlugin) {
gameName = gamePlugin->gameName();
@@ -1361,8 +1396,7 @@ bool DownloadManager::isHidden(int index) const
return m_ActiveDownloads.at(index)->m_Hidden;
}
-
-const ModRepositoryFileInfo *DownloadManager::getFileInfo(int index) const
+const ModRepositoryFileInfo* DownloadManager::getFileInfo(int index) const
{
if ((index < 0) || (index >= m_ActiveDownloads.size())) {
throw MyException(tr("file info: invalid download index %1").arg(index));
@@ -1371,17 +1405,16 @@ const ModRepositoryFileInfo *DownloadManager::getFileInfo(int index) const
return m_ActiveDownloads.at(index)->m_FileInfo;
}
-
void DownloadManager::markInstalled(int index)
{
if ((index < 0) || (index >= m_ActiveDownloads.size())) {
throw MyException(tr("mark installed: invalid download index %1").arg(index));
}
- //Avoid triggering refreshes from DirWatcher
+ // Avoid triggering refreshes from DirWatcher
startDisableDirWatcher();
- DownloadInfo *info = m_ActiveDownloads.at(index);
+ DownloadInfo* info = m_ActiveDownloads.at(index);
QSettings metaFile(info->m_Output.fileName() + ".meta", QSettings::IniFormat);
metaFile.setValue("installed", true);
metaFile.setValue("uninstalled", false);
@@ -1397,9 +1430,9 @@ void DownloadManager::markInstalled(QString fileName)
if (index >= 0) {
markInstalled(index);
} else {
- DownloadInfo *info = getDownloadInfo(fileName);
+ DownloadInfo* info = getDownloadInfo(fileName);
if (info != nullptr) {
- //Avoid triggering refreshes from DirWatcher
+ // Avoid triggering refreshes from DirWatcher
startDisableDirWatcher();
QSettings metaFile(info->m_Output.fileName() + ".meta", QSettings::IniFormat);
@@ -1423,10 +1456,10 @@ void DownloadManager::markUninstalled(int index)
throw MyException(tr("mark uninstalled: invalid download index %1").arg(index));
}
- //Avoid triggering refreshes from DirWatcher
+ // Avoid triggering refreshes from DirWatcher
startDisableDirWatcher();
- DownloadInfo *info = m_ActiveDownloads.at(index);
+ DownloadInfo* info = m_ActiveDownloads.at(index);
QSettings metaFile(info->m_Output.fileName() + ".meta", QSettings::IniFormat);
metaFile.setValue("uninstalled", true);
@@ -1435,18 +1468,17 @@ void DownloadManager::markUninstalled(int index)
setState(m_ActiveDownloads.at(index), STATE_UNINSTALLED);
}
-
void DownloadManager::markUninstalled(QString fileName)
{
int index = indexByName(fileName);
if (index >= 0) {
markUninstalled(index);
} else {
- QString filePath = QDir::fromNativeSeparators(m_OutputDirectory) + "/" + fileName;
- DownloadInfo *info = getDownloadInfo(filePath);
+ QString filePath = QDir::fromNativeSeparators(m_OutputDirectory) + "/" + fileName;
+ DownloadInfo* info = getDownloadInfo(filePath);
if (info != nullptr) {
- //Avoid triggering refreshes from DirWatcher
+ // Avoid triggering refreshes from DirWatcher
startDisableDirWatcher();
QSettings metaFile(info->m_Output.fileName() + ".meta", QSettings::IniFormat);
@@ -1458,13 +1490,13 @@ void DownloadManager::markUninstalled(QString fileName)
}
}
-
-QString DownloadManager::getDownloadFileName(const QString &baseName, bool rename) const
+QString DownloadManager::getDownloadFileName(const QString& baseName, bool rename) const
{
QString fullPath = m_OutputDirectory + "/" + MOBase::sanitizeFileName(baseName);
if (QFile::exists(fullPath) && rename) {
int i = 1;
- while (QFile::exists(QString("%1/%2_%3").arg(m_OutputDirectory).arg(i).arg(baseName))) {
+ while (QFile::exists(
+ QString("%1/%2_%3").arg(m_OutputDirectory).arg(i).arg(baseName))) {
++i;
}
@@ -1473,14 +1505,14 @@ QString DownloadManager::getDownloadFileName(const QString &baseName, bool renam
return fullPath;
}
-
-QString DownloadManager::getFileNameFromNetworkReply(QNetworkReply *reply)
+QString DownloadManager::getFileNameFromNetworkReply(QNetworkReply* reply)
{
if (reply->hasRawHeader("Content-Disposition")) {
std::regex exp("filename=\"(.*)\"");
std::cmatch result;
- if (std::regex_search(reply->rawHeader("Content-Disposition").constData(), result, exp)) {
+ if (std::regex_search(reply->rawHeader("Content-Disposition").constData(), result,
+ exp)) {
return MOBase::sanitizeFileName(QString::fromUtf8(result.str(1).c_str()));
}
}
@@ -1488,8 +1520,8 @@ QString DownloadManager::getFileNameFromNetworkReply(QNetworkReply *reply)
return QString();
}
-
-void DownloadManager::setState(DownloadManager::DownloadInfo *info, DownloadManager::DownloadState state)
+void DownloadManager::setState(DownloadManager::DownloadInfo* info,
+ DownloadManager::DownloadState state)
{
int row = 0;
for (int i = 0; i < m_ActiveDownloads.size(); ++i) {
@@ -1500,41 +1532,48 @@ void DownloadManager::setState(DownloadManager::DownloadInfo *info, DownloadMana
}
info->m_State = state;
switch (state) {
- case STATE_PAUSED: {
- info->m_Reply->abort();
- info->m_Output.close();
- m_DownloadPaused(row);
- } break;
- case STATE_ERROR: {
- info->m_Reply->abort();
- info->m_Output.close();
- m_DownloadFailed(row);
- } break;
- case STATE_CANCELED: {
- info->m_Reply->abort();
- m_DownloadFailed(row);
- } break;
- case STATE_FETCHINGMODINFO: {
- m_RequestIDs.insert(m_NexusInterface->requestDescription(info->m_FileInfo->gameName, info->m_FileInfo->modID, this, info->m_DownloadID, QString()));
- } break;
- case STATE_FETCHINGFILEINFO: {
- m_RequestIDs.insert(m_NexusInterface->requestFiles(info->m_FileInfo->gameName, info->m_FileInfo->modID, this, info->m_DownloadID, QString()));
- } break;
- case STATE_FETCHINGMODINFO_MD5: {
- log::debug("Searching {} for MD5 of {}", info->m_GamesToQuery[0], QString(info->m_Hash.toHex()));
- m_RequestIDs.insert(m_NexusInterface->requestInfoFromMd5(info->m_GamesToQuery[0], info->m_Hash, this, info->m_DownloadID, QString()));
- } break;
- case STATE_READY: {
- createMetaFile(info);
- m_DownloadComplete(row);
- } break;
- default: /* NOP */ break;
+ case STATE_PAUSED: {
+ info->m_Reply->abort();
+ info->m_Output.close();
+ m_DownloadPaused(row);
+ } break;
+ case STATE_ERROR: {
+ info->m_Reply->abort();
+ info->m_Output.close();
+ m_DownloadFailed(row);
+ } break;
+ case STATE_CANCELED: {
+ info->m_Reply->abort();
+ m_DownloadFailed(row);
+ } break;
+ case STATE_FETCHINGMODINFO: {
+ m_RequestIDs.insert(m_NexusInterface->requestDescription(
+ info->m_FileInfo->gameName, info->m_FileInfo->modID, this, info->m_DownloadID,
+ QString()));
+ } break;
+ case STATE_FETCHINGFILEINFO: {
+ m_RequestIDs.insert(m_NexusInterface->requestFiles(info->m_FileInfo->gameName,
+ info->m_FileInfo->modID, this,
+ info->m_DownloadID, QString()));
+ } break;
+ case STATE_FETCHINGMODINFO_MD5: {
+ log::debug("Searching {} for MD5 of {}", info->m_GamesToQuery[0],
+ QString(info->m_Hash.toHex()));
+ m_RequestIDs.insert(m_NexusInterface->requestInfoFromMd5(
+ info->m_GamesToQuery[0], info->m_Hash, this, info->m_DownloadID, QString()));
+ } break;
+ case STATE_READY: {
+ createMetaFile(info);
+ m_DownloadComplete(row);
+ } break;
+ default: /* NOP */
+ break;
}
emit stateChanged(row, state);
}
-
-DownloadManager::DownloadInfo *DownloadManager::findDownload(QObject *reply, int *index) const
+DownloadManager::DownloadInfo* DownloadManager::findDownload(QObject* reply,
+ int* index) const
{
// reverse search as newer, thus more relevant, downloads are at the end
for (int i = m_ActiveDownloads.size() - 1; i >= 0; --i) {
@@ -1548,7 +1587,6 @@ DownloadManager::DownloadInfo *DownloadManager::findDownload(QObject *reply, int
return nullptr;
}
-
void DownloadManager::downloadProgress(qint64 bytesReceived, qint64 bytesTotal)
{
if (bytesTotal == 0) {
@@ -1556,20 +1594,20 @@ void DownloadManager::downloadProgress(qint64 bytesReceived, qint64 bytesTotal)
}
int index = 0;
try {
- DownloadInfo *info = findDownload(this->sender(), &index);
+ DownloadInfo* info = findDownload(this->sender(), &index);
if (info != nullptr) {
info->m_HasData = true;
if (info->m_State == STATE_CANCELING) {
setState(info, STATE_CANCELED);
} else if (info->m_State == STATE_PAUSING) {
setState(info, STATE_PAUSED);
- }
- else {
+ } else {
if (bytesTotal > info->m_TotalSize) {
info->m_TotalSize = bytesTotal;
}
- int oldProgress = info->m_Progress.first;
- info->m_Progress.first = ((info->m_ResumePos + bytesReceived) * 100) / (info->m_ResumePos + bytesTotal);
+ int oldProgress = info->m_Progress.first;
+ info->m_Progress.first = ((info->m_ResumePos + bytesReceived) * 100) /
+ (info->m_ResumePos + bytesTotal);
qint64 elapsed = info->m_StartTime.elapsed();
info->m_DownloadAcc(bytesReceived - info->m_DownloadLast);
@@ -1578,16 +1616,19 @@ void DownloadManager::downloadProgress(qint64 bytesReceived, qint64 bytesTotal)
info->m_DownloadTimeLast = elapsed;
// calculate the download speed
- const double speed = rolling_mean(info->m_DownloadAcc) / (rolling_mean(info->m_DownloadTimeAcc) / 1000.0);;
+ const double speed = rolling_mean(info->m_DownloadAcc) /
+ (rolling_mean(info->m_DownloadTimeAcc) / 1000.0);
+ ;
const qint64 remaining = (bytesTotal - bytesReceived) / speed * 1000;
info->m_Progress.second = tr("%1% - %2 - ~%3")
- .arg(info->m_Progress.first)
- .arg(MOBase::localizedByteSpeed(speed))
- .arg(MOBase::localizedTimeRemaining(remaining));
+ .arg(info->m_Progress.first)
+ .arg(MOBase::localizedByteSpeed(speed))
+ .arg(MOBase::localizedTimeRemaining(remaining));
- TaskProgressManager::instance().updateProgress(info->m_TaskProgressId, bytesReceived, bytesTotal);
+ TaskProgressManager::instance().updateProgress(info->m_TaskProgressId,
+ bytesReceived, bytesTotal);
emit update(index);
}
}
@@ -1596,7 +1637,6 @@ void DownloadManager::downloadProgress(qint64 bytesReceived, qint64 bytesTotal)
}
}
-
void DownloadManager::downloadReadyRead()
{
try {
@@ -1606,13 +1646,13 @@ void DownloadManager::downloadReadyRead()
}
}
-
-void DownloadManager::createMetaFile(DownloadInfo *info)
+void DownloadManager::createMetaFile(DownloadInfo* info)
{
- //Avoid triggering refreshes from DirWatcher
+ // Avoid triggering refreshes from DirWatcher
startDisableDirWatcher();
- QSettings metaFile(QString("%1.meta").arg(info->m_Output.fileName()), QSettings::IniFormat);
+ QSettings metaFile(QString("%1.meta").arg(info->m_Output.fileName()),
+ QSettings::IniFormat);
metaFile.setValue("gameName", info->m_FileInfo->gameName);
metaFile.setValue("modID", info->m_FileInfo->modID);
metaFile.setValue("fileID", info->m_FileInfo->fileID);
@@ -1630,7 +1670,7 @@ void DownloadManager::createMetaFile(DownloadInfo *info)
metaFile.setValue("installed", info->m_State == DownloadManager::STATE_INSTALLED);
metaFile.setValue("uninstalled", info->m_State == DownloadManager::STATE_UNINSTALLED);
metaFile.setValue("paused", (info->m_State == DownloadManager::STATE_PAUSED) ||
- (info->m_State == DownloadManager::STATE_ERROR));
+ (info->m_State == DownloadManager::STATE_ERROR));
metaFile.setValue("removed", info->m_Hidden);
endDisableDirWatcher();
@@ -1642,8 +1682,8 @@ void DownloadManager::createMetaFile(DownloadInfo *info)
}
}
-
-void DownloadManager::nxmDescriptionAvailable(QString, int, QVariant userData, QVariant resultData, int requestID)
+void DownloadManager::nxmDescriptionAvailable(QString, int, QVariant userData,
+ QVariant resultData, int requestID)
{
std::set<int>::iterator idIter = m_RequestIDs.find(requestID);
if (idIter == m_RequestIDs.end()) {
@@ -1654,8 +1694,9 @@ void DownloadManager::nxmDescriptionAvailable(QString, int, QVariant userData, Q
QVariantMap result = resultData.toMap();
- DownloadInfo *info = downloadInfoByID(userData.toInt());
- if (info == nullptr) return;
+ DownloadInfo* info = downloadInfoByID(userData.toInt());
+ if (info == nullptr)
+ return;
info->m_FileInfo->categoryID = result["category_id"].toInt();
QTextDocument doc;
doc.setHtml(result["name"].toString().trimmed());
@@ -1667,7 +1708,8 @@ void DownloadManager::nxmDescriptionAvailable(QString, int, QVariant userData, Q
}
}
-void DownloadManager::nxmFilesAvailable(QString, int, QVariant userData, QVariant resultData, int requestID)
+void DownloadManager::nxmFilesAvailable(QString, int, QVariant userData,
+ QVariant resultData, int requestID)
{
std::set<int>::iterator idIter = m_RequestIDs.find(requestID);
if (idIter == m_RequestIDs.end()) {
@@ -1676,13 +1718,13 @@ void DownloadManager::nxmFilesAvailable(QString, int, QVariant userData, QVarian
m_RequestIDs.erase(idIter);
}
- DownloadInfo *info = downloadInfoByID(userData.toInt());
- if (info == nullptr) return;
+ DownloadInfo* info = downloadInfoByID(userData.toInt());
+ if (info == nullptr)
+ return;
QVariantMap result = resultData.toMap();
QVariantList files = result["files"].toList();
-
// MO sometimes prepends <digit>_ to the filename in case of duplicate downloads.
// this may muck up the file name comparison
QString alternativeLocalName = info->m_FileName;
@@ -1696,22 +1738,25 @@ void DownloadManager::nxmFilesAvailable(QString, int, QVariant userData, QVarian
bool found = false;
for (QVariant file : files) {
- QVariantMap fileInfo = file.toMap();
- QString fileName = fileInfo["file_name"].toString();
+ QVariantMap fileInfo = file.toMap();
+ QString fileName = fileInfo["file_name"].toString();
QString fileNameVariant = fileName.mid(0).replace(' ', '_');
- if ((fileName == info->m_RemoteFileName) || (fileNameVariant == info->m_RemoteFileName) ||
- (fileName == info->m_FileName) || (fileNameVariant == info->m_FileName) ||
- (fileName == alternativeLocalName) || (fileNameVariant == alternativeLocalName)) {
+ if ((fileName == info->m_RemoteFileName) ||
+ (fileNameVariant == info->m_RemoteFileName) || (fileName == info->m_FileName) ||
+ (fileNameVariant == info->m_FileName) || (fileName == alternativeLocalName) ||
+ (fileNameVariant == alternativeLocalName)) {
info->m_FileInfo->name = fileInfo["name"].toString();
info->m_FileInfo->version.parse(fileInfo["version"].toString());
if (!info->m_FileInfo->version.isValid()) {
info->m_FileInfo->version = info->m_FileInfo->newestVersion;
}
info->m_FileInfo->fileCategory = fileInfo["category_id"].toInt();
- info->m_FileInfo->fileTime = QDateTime::fromMSecsSinceEpoch(fileInfo["uploaded_timestamp"].toLongLong());
- info->m_FileInfo->fileID = fileInfo["file_id"].toInt();
+ info->m_FileInfo->fileTime =
+ QDateTime::fromMSecsSinceEpoch(fileInfo["uploaded_timestamp"].toLongLong());
+ info->m_FileInfo->fileID = fileInfo["file_id"].toInt();
info->m_FileInfo->fileName = fileInfo["file_name"].toString();
- info->m_FileInfo->description = BBCode::convertToHTML(fileInfo["description"].toString());
+ info->m_FileInfo->description =
+ BBCode::convertToHTML(fileInfo["description"].toString());
found = true;
break;
}
@@ -1721,40 +1766,46 @@ void DownloadManager::nxmFilesAvailable(QString, int, QVariant userData, QVarian
if (found) {
emit showMessage(tr("Information updated"));
} else if (result.count() == 0) {
- emit showMessage(tr("No matching file found on Nexus! Maybe this file is no longer available or it was renamed?"));
+ emit showMessage(tr("No matching file found on Nexus! Maybe this file is no "
+ "longer available or it was renamed?"));
} else {
- SelectionDialog selection(tr("No file on Nexus matches the selected file by name. Please manually choose the correct one."));
- std::sort(files.begin(), files.end(), [](const QVariant& lhs, const QVariant& rhs)
- {return lhs.toMap()["uploaded_timestamp"].toInt() > rhs.toMap()["uploaded_timestamp"].toInt();});
+ SelectionDialog selection(tr("No file on Nexus matches the selected file by "
+ "name. Please manually choose the correct one."));
+ std::sort(files.begin(), files.end(),
+ [](const QVariant& lhs, const QVariant& rhs) {
+ return lhs.toMap()["uploaded_timestamp"].toInt() >
+ rhs.toMap()["uploaded_timestamp"].toInt();
+ });
for (QVariant file : files) {
QVariantMap fileInfo = file.toMap();
if (fileInfo["category_id"].toInt() != NexusInterface::FileStatus::REMOVED &&
- fileInfo["category_id"].toInt() != NexusInterface::FileStatus::ARCHIVED)
+ fileInfo["category_id"].toInt() != NexusInterface::FileStatus::ARCHIVED)
selection.addChoice(fileInfo["file_name"].toString(), "", file);
}
if (selection.exec() == QDialog::Accepted) {
- QVariantMap fileInfo = selection.getChoiceData().toMap();
+ QVariantMap fileInfo = selection.getChoiceData().toMap();
info->m_FileInfo->name = fileInfo["name"].toString();
info->m_FileInfo->version.parse(fileInfo["version"].toString());
info->m_FileInfo->fileCategory = fileInfo["category_id"].toInt();
- info->m_FileInfo->fileID = fileInfo["file_id"].toInt();
+ info->m_FileInfo->fileID = fileInfo["file_id"].toInt();
} else {
- emit showMessage(tr("No matching file found on Nexus! Maybe this file is no longer available or it was renamed?"));
+ emit showMessage(tr("No matching file found on Nexus! Maybe this file is no "
+ "longer available or it was renamed?"));
}
}
} else {
if (info->m_FileInfo->fileID == 0) {
- log::warn(
- "could not determine file id for {} (state {})",
- info->m_FileName, info->m_State);
+ log::warn("could not determine file id for {} (state {})", info->m_FileName,
+ info->m_State);
}
}
setState(info, STATE_READY);
}
-
-void DownloadManager::nxmFileInfoAvailable(QString gameName, int modID, int fileID, QVariant userData, QVariant resultData, int requestID)
+void DownloadManager::nxmFileInfoAvailable(QString gameName, int modID, int fileID,
+ QVariant userData, QVariant resultData,
+ int requestID)
{
std::set<int>::iterator idIter = m_RequestIDs.find(requestID);
if (idIter == m_RequestIDs.end()) {
@@ -1763,17 +1814,19 @@ void DownloadManager::nxmFileInfoAvailable(QString gameName, int modID, int file
m_RequestIDs.erase(idIter);
}
- ModRepositoryFileInfo *info = qobject_cast<ModRepositoryFileInfo*>(qvariant_cast<QObject*>(userData));
+ ModRepositoryFileInfo* info =
+ qobject_cast<ModRepositoryFileInfo*>(qvariant_cast<QObject*>(userData));
QVariantMap result = resultData.toMap();
- info->name = result["name"].toString();
+ info->name = result["name"].toString();
info->version.parse(result["version"].toString());
if (!info->version.isValid()) {
info->version = info->newestVersion;
}
- info->fileName = result["file_name"].toString();
+ info->fileName = result["file_name"].toString();
info->fileCategory = result["category_id"].toInt();
- info->fileTime = QDateTime::fromMSecsSinceEpoch(result["uploaded_timestamp"].toLongLong());
+ info->fileTime =
+ QDateTime::fromMSecsSinceEpoch(result["uploaded_timestamp"].toLongLong());
info->description = BBCode::convertToHTML(result["description"].toString());
info->repository = "Nexus";
@@ -1781,31 +1834,33 @@ void DownloadManager::nxmFileInfoAvailable(QString gameName, int modID, int file
QStringList games(m_ManagedGame->validShortNames());
games += m_ManagedGame->gameShortName();
for (auto game : games) {
- MOBase::IPluginGame *gamePlugin = m_OrganizerCore->getGame(game);
- if (gamePlugin != nullptr && gamePlugin->gameNexusName().compare(gameName, Qt::CaseInsensitive) == 0) {
+ MOBase::IPluginGame* gamePlugin = m_OrganizerCore->getGame(game);
+ if (gamePlugin != nullptr &&
+ gamePlugin->gameNexusName().compare(gameName, Qt::CaseInsensitive) == 0) {
info->gameName = gamePlugin->gameShortName();
}
}
- info->modID = modID;
+ info->modID = modID;
info->fileID = fileID;
- QObject *test = info;
- m_RequestIDs.insert(m_NexusInterface->requestDownloadURL(info->gameName, info->modID, info->fileID, this, QVariant::fromValue(test), QString()));
+ QObject* test = info;
+ m_RequestIDs.insert(
+ m_NexusInterface->requestDownloadURL(info->gameName, info->modID, info->fileID,
+ this, QVariant::fromValue(test), QString()));
}
-static int evaluateFileInfoMap(
- const QVariantMap &map,
- const ServerList::container& preferredServers)
+static int evaluateFileInfoMap(const QVariantMap& map,
+ const ServerList::container& preferredServers)
{
- int preference = 0;
- bool found = false;
+ int preference = 0;
+ bool found = false;
const auto name = map["short_name"].toString();
for (const auto& server : preferredServers) {
if (server.name() == name) {
preference = server.preferred();
- found = true;
+ found = true;
break;
}
}
@@ -1814,21 +1869,20 @@ static int evaluateFileInfoMap(
return 0;
}
- return 100 + preference * 20;
+ return 100 + preference * 20;
}
// sort function to sort by best download server
//
-bool ServerByPreference(
- const ServerList::container& preferredServers,
- const QVariant &LHS, const QVariant &RHS)
+bool ServerByPreference(const ServerList::container& preferredServers,
+ const QVariant& LHS, const QVariant& RHS)
{
const auto a = evaluateFileInfoMap(LHS.toMap(), preferredServers);
const auto b = evaluateFileInfoMap(RHS.toMap(), preferredServers);
return (a > b);
}
-int DownloadManager::startDownloadURLs(const QStringList &urls)
+int DownloadManager::startDownloadURLs(const QStringList& urls)
{
ModRepositoryFileInfo info;
addDownload(urls, "", -1, -1, &info);
@@ -1838,7 +1892,10 @@ int DownloadManager::startDownloadURLs(const QStringList &urls)
int DownloadManager::startDownloadNexusFile(int modID, int fileID)
{
int newID = m_ActiveDownloads.size();
- addNXMDownload(QString("nxm://%1/mods/%2/files/%3").arg(m_ManagedGame->gameShortName()).arg(modID).arg(fileID));
+ addNXMDownload(QString("nxm://%1/mods/%2/files/%3")
+ .arg(m_ManagedGame->gameShortName())
+ .arg(modID)
+ .arg(fileID));
return newID;
}
@@ -1847,27 +1904,31 @@ QString DownloadManager::downloadPath(int id)
return getFilePath(id);
}
-boost::signals2::connection DownloadManager::onDownloadComplete(const std::function<void(int)>& callback)
+boost::signals2::connection
+DownloadManager::onDownloadComplete(const std::function<void(int)>& callback)
{
return m_DownloadComplete.connect(callback);
}
-boost::signals2::connection DownloadManager::onDownloadPaused(const std::function<void(int)>& callback)
+boost::signals2::connection
+DownloadManager::onDownloadPaused(const std::function<void(int)>& callback)
{
return m_DownloadPaused.connect(callback);
}
-boost::signals2::connection DownloadManager::onDownloadFailed(const std::function<void(int)>& callback)
+boost::signals2::connection
+DownloadManager::onDownloadFailed(const std::function<void(int)>& callback)
{
return m_DownloadFailed.connect(callback);
}
-boost::signals2::connection DownloadManager::onDownloadRemoved(const std::function<void(int)>& callback)
+boost::signals2::connection
+DownloadManager::onDownloadRemoved(const std::function<void(int)>& callback)
{
return m_DownloadRemoved.connect(callback);
}
-int DownloadManager::indexByName(const QString &fileName) const
+int DownloadManager::indexByName(const QString& fileName) const
{
for (int i = 0; i < m_ActiveDownloads.size(); ++i) {
if (m_ActiveDownloads[i]->m_FileName == fileName) {
@@ -1887,7 +1948,9 @@ int DownloadManager::indexByInfo(const DownloadInfo* info) const
return -1;
}
-void DownloadManager::nxmDownloadURLsAvailable(QString gameName, int modID, int fileID, QVariant userData, QVariant resultData, int requestID)
+void DownloadManager::nxmDownloadURLsAvailable(QString gameName, int modID, int fileID,
+ QVariant userData, QVariant resultData,
+ int requestID)
{
using namespace boost::placeholders;
@@ -1898,7 +1961,8 @@ void DownloadManager::nxmDownloadURLsAvailable(QString gameName, int modID, int
m_RequestIDs.erase(idIter);
}
- ModRepositoryFileInfo *info = qobject_cast<ModRepositoryFileInfo*>(qvariant_cast<QObject*>(userData));
+ ModRepositoryFileInfo* info =
+ qobject_cast<ModRepositoryFileInfo*>(qvariant_cast<QObject*>(userData));
QVariantList resultList = resultData.toList();
if (resultList.length() == 0) {
removePending(gameName, modID, fileID);
@@ -1908,23 +1972,21 @@ void DownloadManager::nxmDownloadURLsAvailable(QString gameName, int modID, int
const auto servers = m_OrganizerCore->settings().network().servers();
- std::sort(
- resultList.begin(),
- resultList.end(),
- boost::bind(&ServerByPreference, servers.getPreferred(), _1, _2));
+ std::sort(resultList.begin(), resultList.end(),
+ boost::bind(&ServerByPreference, servers.getPreferred(), _1, _2));
info->userData["downloadMap"] = resultList;
QStringList URLs;
- foreach (const QVariant &server, resultList) {
+ foreach (const QVariant& server, resultList) {
URLs.append(server.toMap()["URI"].toString());
}
addDownload(URLs, gameName, modID, fileID, info);
}
-
-void DownloadManager::nxmFileInfoFromMd5Available(QString gameName, QVariant userData, QVariant resultData, int requestID)
+void DownloadManager::nxmFileInfoFromMd5Available(QString gameName, QVariant userData,
+ QVariant resultData, int requestID)
{
std::set<int>::iterator idIter = m_RequestIDs.find(requestID);
if (idIter == m_RequestIDs.end()) {
@@ -1933,23 +1995,24 @@ void DownloadManager::nxmFileInfoFromMd5Available(QString gameName, QVariant use
m_RequestIDs.erase(idIter);
}
- DownloadInfo *info = downloadInfoByID(userData.toInt());
+ DownloadInfo* info = downloadInfoByID(userData.toInt());
- //This can come back with multiple results with the same file was uploaded multiple times (for whatever reason)
+ // This can come back with multiple results with the same file was uploaded multiple
+ // times (for whatever reason)
auto resultlist = resultData.toList();
- int chosenIdx = resultlist.count() > 1 ? -1 : 0;
+ int chosenIdx = resultlist.count() > 1 ? -1 : 0;
- //Look for the exact file name
+ // Look for the exact file name
if (chosenIdx < 0) {
for (int i = 0; i < resultlist.count(); i++) {
- auto results = resultlist[i].toMap();
+ auto results = resultlist[i].toMap();
auto fileDetails = results["file_details"].toMap();
- if (fileDetails["file_name"].toString().compare(info->m_FileName, Qt::CaseInsensitive) == 0) {
+ if (fileDetails["file_name"].toString().compare(info->m_FileName,
+ Qt::CaseInsensitive) == 0) {
if (chosenIdx < 0) {
- chosenIdx = i; //intentional to not break in order to check other results
- }
- else {
+ chosenIdx = i; // intentional to not break in order to check other results
+ } else {
log::debug("Multiple files with same name found during MD5 search.");
chosenIdx = -1;
break;
@@ -1958,16 +2021,16 @@ void DownloadManager::nxmFileInfoFromMd5Available(QString gameName, QVariant use
}
}
- //Look for the only active one
+ // Look for the only active one
if (chosenIdx < 0) {
for (int i = 0; i < resultlist.count(); i++) {
- auto results = resultlist[i].toMap();
+ auto results = resultlist[i].toMap();
auto fileDetails = results["file_details"].toMap();
if (fileDetails["category_id"].toInt() != NexusInterface::FileStatus::REMOVED &&
fileDetails["category_id"].toInt() != NexusInterface::FileStatus::ARCHIVED) {
if (chosenIdx < 0) {
- chosenIdx = i; //intentional to not break in order to check other results
+ chosenIdx = i; // intentional to not break in order to check other results
} else {
log::debug("Multiple active files found during MD5 search.");
chosenIdx = -1;
@@ -1977,36 +2040,38 @@ void DownloadManager::nxmFileInfoFromMd5Available(QString gameName, QVariant use
}
}
- //Unable to determine the correct mod / file. Revert to the old method
+ // Unable to determine the correct mod / file. Revert to the old method
if (chosenIdx < 0) {
- //don't use the normal state set function as we don't want to create a meta file
+ // don't use the normal state set function as we don't want to create a meta file
info->m_State = DownloadManager::STATE_READY;
queryInfo(m_ActiveDownloads.indexOf(info));
return;
}
- auto results = resultlist[chosenIdx].toMap();
+ auto results = resultlist[chosenIdx].toMap();
auto fileDetails = results["file_details"].toMap();
- auto modDetails = results["mod"].toMap();
+ auto modDetails = results["mod"].toMap();
- info->m_FileInfo->name = fileDetails["name"].toString();
+ info->m_FileInfo->name = fileDetails["name"].toString();
info->m_FileInfo->fileID = fileDetails["file_id"].toInt();
- info->m_FileInfo->description = BBCode::convertToHTML(fileDetails["description"].toString());
+ info->m_FileInfo->description =
+ BBCode::convertToHTML(fileDetails["description"].toString());
info->m_FileInfo->version.parse(fileDetails["version"].toString());
if (!info->m_FileInfo->version.isValid())
info->m_FileInfo->version.parse(fileDetails["mod_version"].toString());
info->m_FileInfo->fileCategory = fileDetails["category_id"].toInt();
- info->m_FileInfo->modID = modDetails["mod_id"].toInt();
- info->m_FileInfo->modName = modDetails["name"].toString();
+ info->m_FileInfo->modID = modDetails["mod_id"].toInt();
+ info->m_FileInfo->modName = modDetails["name"].toString();
info->m_FileInfo->categoryID = modDetails["category_id"].toInt();
QString gameShortName = gameName;
QStringList games(m_ManagedGame->validShortNames());
games += m_ManagedGame->gameShortName();
for (auto game : games) {
- MOBase::IPluginGame *gamePlugin = m_OrganizerCore->getGame(game);
- if (gamePlugin != nullptr && gamePlugin->gameNexusName().compare(gameName, Qt::CaseInsensitive) == 0) {
+ MOBase::IPluginGame* gamePlugin = m_OrganizerCore->getGame(game);
+ if (gamePlugin != nullptr &&
+ gamePlugin->gameNexusName().compare(gameName, Qt::CaseInsensitive) == 0) {
gameShortName = gamePlugin->gameShortName();
break;
}
@@ -2014,7 +2079,7 @@ void DownloadManager::nxmFileInfoFromMd5Available(QString gameName, QVariant use
info->m_FileInfo->gameName = gameShortName;
- //If the file description is not present, send another query to get it
+ // If the file description is not present, send another query to get it
if (!fileDetails["description"].isValid()) {
info->m_RemoteFileName = fileDetails["file_name"].toString();
setState(info, STATE_FETCHINGFILEINFO);
@@ -2023,8 +2088,9 @@ void DownloadManager::nxmFileInfoFromMd5Available(QString gameName, QVariant use
}
}
-
-void DownloadManager::nxmRequestFailed(QString gameName, int modID, int fileID, QVariant userData, int requestID, int errorCode, const QString &errorString)
+void DownloadManager::nxmRequestFailed(QString gameName, int modID, int fileID,
+ QVariant userData, int requestID, int errorCode,
+ const QString& errorString)
{
std::set<int>::iterator idIter = m_RequestIDs.find(requestID);
if (idIter == m_RequestIDs.end()) {
@@ -2033,12 +2099,13 @@ void DownloadManager::nxmRequestFailed(QString gameName, int modID, int fileID,
m_RequestIDs.erase(idIter);
}
- DownloadInfo *userDataInfo = downloadInfoByID(userData.toInt());
+ DownloadInfo* userDataInfo = downloadInfoByID(userData.toInt());
int index = 0;
- for (QVector<DownloadInfo*>::iterator iter = m_ActiveDownloads.begin(); iter != m_ActiveDownloads.end(); ++iter, ++index) {
- DownloadInfo *info = *iter;
+ for (QVector<DownloadInfo*>::iterator iter = m_ActiveDownloads.begin();
+ iter != m_ActiveDownloads.end(); ++iter, ++index) {
+ DownloadInfo* info = *iter;
if (info != userDataInfo)
continue;
@@ -2072,17 +2139,16 @@ void DownloadManager::nxmRequestFailed(QString gameName, int modID, int fileID,
emit showMessage(tr("Failed to request file info from nexus: %1").arg(errorString));
}
-
void DownloadManager::downloadFinished(int index)
{
- DownloadInfo *info;
+ DownloadInfo* info;
if (index)
info = m_ActiveDownloads[index];
else
info = findDownload(this->sender(), &index);
if (info != nullptr) {
- QNetworkReply *reply = info->m_Reply;
+ QNetworkReply* reply = info->m_Reply;
QByteArray data;
if (reply->isOpen() && info->m_HasData) {
data = reply->readAll();
@@ -2092,18 +2158,26 @@ void DownloadManager::downloadFinished(int index)
TaskProgressManager::instance().forgetMe(info->m_TaskProgressId);
bool error = false;
- if ((info->m_State != STATE_CANCELING) &&
- (info->m_State != STATE_PAUSING)) {
- bool textData = reply->header(QNetworkRequest::ContentTypeHeader).toString().startsWith("text", Qt::CaseInsensitive);
+ if ((info->m_State != STATE_CANCELING) && (info->m_State != STATE_PAUSING)) {
+ bool textData = reply->header(QNetworkRequest::ContentTypeHeader)
+ .toString()
+ .startsWith("text", Qt::CaseInsensitive);
if (textData)
- emit showMessage(tr("Warning: Content type is: %1").arg(reply->header(QNetworkRequest::ContentTypeHeader).toString()));
+ emit showMessage(
+ tr("Warning: Content type is: %1")
+ .arg(reply->header(QNetworkRequest::ContentTypeHeader).toString()));
if ((info->m_Output.size() == 0) ||
- ((reply->error() != QNetworkReply::NoError)
- && (reply->error() != QNetworkReply::OperationCanceledError))) {
+ ((reply->error() != QNetworkReply::NoError) &&
+ (reply->error() != QNetworkReply::OperationCanceledError))) {
if (reply->error() == QNetworkReply::UnknownContentError)
- emit showMessage(tr("Download header content length: %1 downloaded file size: %2").arg(reply->header(QNetworkRequest::ContentLengthHeader).toLongLong()).arg(info->m_Output.size()));
+ emit showMessage(
+ tr("Download header content length: %1 downloaded file size: %2")
+ .arg(reply->header(QNetworkRequest::ContentLengthHeader).toLongLong())
+ .arg(info->m_Output.size()));
if (info->m_Tries == 0) {
- emit showMessage(tr("Download failed: %1 (%2)").arg(reply->errorString()).arg(reply->error()));
+ emit showMessage(tr("Download failed: %1 (%2)")
+ .arg(reply->errorString())
+ .arg(reply->error()));
}
error = true;
setState(info, STATE_ERROR);
@@ -2125,7 +2199,9 @@ void DownloadManager::downloadFinished(int index)
delete info;
m_ActiveDownloads.erase(m_ActiveDownloads.begin() + index);
if (error)
- emit showMessage(tr("We were unable to download the file due to errors after four retries. There may be an issue with the Nexus servers."));
+ emit showMessage(
+ tr("We were unable to download the file due to errors after four retries. "
+ "There may be an issue with the Nexus servers."));
emit update(-1);
} else if (info->isPausedState() || info->m_State == STATE_PAUSING) {
info->m_Output.close();
@@ -2134,20 +2210,25 @@ void DownloadManager::downloadFinished(int index)
} else {
QString url = info->m_Urls[info->m_CurrentUrl];
if (info->m_FileInfo->userData.contains("downloadMap")) {
- foreach (const QVariant &server, info->m_FileInfo->userData["downloadMap"].toList()) {
+ foreach (const QVariant& server,
+ info->m_FileInfo->userData["downloadMap"].toList()) {
QVariantMap serverMap = server.toMap();
if (serverMap["URI"].toString() == url) {
int deltaTime = info->m_StartTime.elapsed() / 1000;
if (deltaTime > 5) {
- emit downloadSpeed(serverMap["short_name"].toString(), (info->m_TotalSize - info->m_PreResumeSize) / deltaTime);
- } // no division by zero please! Also, if the download is shorter than a few seconds, the result is way to inprecise
+ emit downloadSpeed(serverMap["short_name"].toString(),
+ (info->m_TotalSize - info->m_PreResumeSize) /
+ deltaTime);
+ } // no division by zero please! Also, if the download is shorter than a
+ // few seconds, the result is way to inprecise
break;
}
}
}
bool isNexus = info->m_FileInfo->repository == "Nexus";
- // need to change state before changing the file name, otherwise .unfinished is appended
+ // need to change state before changing the file name, otherwise .unfinished is
+ // appended
if (isNexus) {
setState(info, STATE_FETCHINGMODINFO);
} else {
@@ -2161,7 +2242,8 @@ void DownloadManager::downloadFinished(int index)
if (!newName.isEmpty() && (oldName.isEmpty())) {
info->setName(getDownloadFileName(newName), true);
} else {
- info->setName(m_OutputDirectory + "/" + info->m_FileName, true); // don't rename but remove the ".unfinished" extension
+ info->setName(m_OutputDirectory + "/" + info->m_FileName,
+ true); // don't rename but remove the ".unfinished" extension
}
endDisableDirWatcher();
@@ -2183,23 +2265,21 @@ void DownloadManager::downloadFinished(int index)
}
}
-
void DownloadManager::downloadError(QNetworkReply::NetworkError error)
{
if (error != QNetworkReply::OperationCanceledError) {
- QNetworkReply *reply = qobject_cast<QNetworkReply*>(sender());
+ QNetworkReply* reply = qobject_cast<QNetworkReply*>(sender());
log::warn("{} ({})",
- reply != nullptr ? reply->errorString() : "Download error occured",
- error);
+ reply != nullptr ? reply->errorString() : "Download error occured",
+ error);
}
}
-
void DownloadManager::metaDataChanged()
{
int index = 0;
- DownloadInfo *info = findDownload(this->sender(), &index);
+ DownloadInfo* info = findDownload(this->sender(), &index);
if (info != nullptr) {
QString newName = getFileNameFromNetworkReply(info->m_Reply);
if (!newName.isEmpty() && (info->m_FileName.isEmpty())) {
@@ -2207,7 +2287,8 @@ void DownloadManager::metaDataChanged()
info->setName(getDownloadFileName(newName), true);
endDisableDirWatcher();
refreshAlphabeticalTranslation();
- if (!info->m_Output.isOpen() && !info->m_Output.open(QIODevice::WriteOnly | QIODevice::Append)) {
+ if (!info->m_Output.isOpen() &&
+ !info->m_Output.open(QIODevice::WriteOnly | QIODevice::Append)) {
reportError(tr("failed to re-open %1").arg(info->m_FileName));
setState(info, STATE_CANCELING);
}
@@ -2219,11 +2300,11 @@ void DownloadManager::metaDataChanged()
void DownloadManager::directoryChanged(const QString&)
{
- if(DownloadManager::m_DirWatcherDisabler==0)
+ if (DownloadManager::m_DirWatcherDisabler == 0)
refreshList();
}
-void DownloadManager::managedGameChanged(MOBase::IPluginGame const *managedGame)
+void DownloadManager::managedGameChanged(MOBase::IPluginGame const* managedGame)
{
m_ManagedGame = managedGame;
}
@@ -2231,8 +2312,11 @@ void DownloadManager::managedGameChanged(MOBase::IPluginGame const *managedGame)
void DownloadManager::checkDownloadTimeout()
{
for (int i = 0; i < m_ActiveDownloads.size(); ++i) {
- if (m_ActiveDownloads[i]->m_StartTime.elapsed() - m_ActiveDownloads[i]->m_DownloadTimeLast > 5 * 1000 &&
- m_ActiveDownloads[i]->m_State == STATE_DOWNLOADING && m_ActiveDownloads[i]->m_Reply != nullptr &&
+ if (m_ActiveDownloads[i]->m_StartTime.elapsed() -
+ m_ActiveDownloads[i]->m_DownloadTimeLast >
+ 5 * 1000 &&
+ m_ActiveDownloads[i]->m_State == STATE_DOWNLOADING &&
+ m_ActiveDownloads[i]->m_Reply != nullptr &&
m_ActiveDownloads[i]->m_Reply->isOpen()) {
pauseDownload(i);
downloadFinished(i);
@@ -2241,21 +2325,23 @@ void DownloadManager::checkDownloadTimeout()
}
}
-void DownloadManager::writeData(DownloadInfo *info)
+void DownloadManager::writeData(DownloadInfo* info)
{
if (info != nullptr) {
qint64 ret = info->m_Output.write(info->m_Reply->readAll());
if (ret < info->m_Reply->size()) {
- QString fileName = info->m_FileName; // m_FileName may be destroyed after setState
+ QString fileName =
+ info->m_FileName; // m_FileName may be destroyed after setState
setState(info, DownloadState::STATE_CANCELED);
- log::error(
- "Unable to write download \"{}\" to drive (return {})",
- info->m_FileName, ret);
+ log::error("Unable to write download \"{}\" to drive (return {})",
+ info->m_FileName, ret);
reportError(tr("Unable to write download to drive (return %1).\n"
"Check the drive's available storage.\n\n"
- "Canceling download \"%2\"...").arg(ret).arg(fileName));
+ "Canceling download \"%2\"...")
+ .arg(ret)
+ .arg(fileName));
}
}
}
generated by cgit v1.3.1 (git 2.54.0) at 2026-07-22 00:44:38 +0000