PrismLauncher/launcher/modplatform/legacy_ftb/PackInstallTask.cpp

215 lines
5.8 KiB
C++
Raw Normal View History

#include "PackInstallTask.h"
#include "Env.h"
#include "MMCZip.h"
#include "BaseInstance.h"
#include "FileSystem.h"
#include "settings/INISettingsObject.h"
#include "minecraft/MinecraftInstance.h"
#include "minecraft/PackProfile.h"
2018-03-12 14:09:07 +00:00
#include "minecraft/GradleSpecifier.h"
#include "BuildConfig.h"
2019-01-04 00:48:36 +00:00
#include <QtConcurrent>
namespace LegacyFTB {
PackInstallTask::PackInstallTask(Modpack pack, QString version)
{
2018-07-15 13:51:05 +01:00
m_pack = pack;
m_version = version;
}
void PackInstallTask::executeTask()
2018-03-19 01:36:12 +00:00
{
2018-07-15 13:51:05 +01:00
downloadPack();
}
void PackInstallTask::downloadPack()
2018-03-19 01:36:12 +00:00
{
2018-07-15 13:51:05 +01:00
setStatus(tr("Downloading zip for %1").arg(m_pack.name));
2018-03-19 01:36:12 +00:00
2018-07-15 13:51:05 +01:00
auto packoffset = QString("%1/%2/%3").arg(m_pack.dir, m_version.replace(".", "_"), m_pack.file);
auto entry = ENV.metacache()->resolveEntry("FTBPacks", packoffset);
NetJob *job = new NetJob("Download FTB Pack");
2018-03-19 01:36:12 +00:00
2018-07-15 13:51:05 +01:00
entry->setStale(true);
QString url;
if(m_pack.type == PackType::Private)
{
url = QString(BuildConfig.LEGACY_FTB_CDN_BASE_URL + "privatepacks/%1").arg(packoffset);
}
else
{
url = QString(BuildConfig.LEGACY_FTB_CDN_BASE_URL + "modpacks/%1").arg(packoffset);
}
2018-07-15 13:51:05 +01:00
job->addNetAction(Net::Download::makeCached(url, entry));
archivePath = entry->getFullPath();
2018-07-15 13:51:05 +01:00
netJobContainer.reset(job);
connect(job, &NetJob::succeeded, this, &PackInstallTask::onDownloadSucceeded);
connect(job, &NetJob::failed, this, &PackInstallTask::onDownloadFailed);
connect(job, &NetJob::progress, this, &PackInstallTask::onDownloadProgress);
2018-07-15 13:51:05 +01:00
job->start();
2018-07-15 13:51:05 +01:00
progress(1, 4);
}
void PackInstallTask::onDownloadSucceeded()
2018-03-19 01:36:12 +00:00
{
2018-07-15 13:51:05 +01:00
abortable = false;
unzip();
}
void PackInstallTask::onDownloadFailed(QString reason)
2018-03-19 01:36:12 +00:00
{
abortable = false;
2018-07-15 13:51:05 +01:00
emitFailed(reason);
}
void PackInstallTask::onDownloadProgress(qint64 current, qint64 total)
2018-03-19 01:36:12 +00:00
{
2018-07-15 13:51:05 +01:00
abortable = true;
progress(current, total * 4);
setStatus(tr("Downloading zip for %1 (%2%)").arg(m_pack.name).arg(current / 10));
}
void PackInstallTask::unzip()
2018-03-19 01:36:12 +00:00
{
2018-07-15 13:51:05 +01:00
progress(2, 4);
setStatus(tr("Extracting modpack"));
QDir extractDir(m_stagingPath);
m_packZip.reset(new QuaZip(archivePath));
if(!m_packZip->open(QuaZip::mdUnzip))
{
emitFailed(tr("Failed to open modpack file %1!").arg(archivePath));
return;
}
m_extractFuture = QtConcurrent::run(QThreadPool::globalInstance(), MMCZip::extractDir, archivePath, extractDir.absolutePath() + "/unzip");
connect(&m_extractFutureWatcher, &QFutureWatcher<QStringList>::finished, this, &PackInstallTask::onUnzipFinished);
connect(&m_extractFutureWatcher, &QFutureWatcher<QStringList>::canceled, this, &PackInstallTask::onUnzipCanceled);
2018-07-15 13:51:05 +01:00
m_extractFutureWatcher.setFuture(m_extractFuture);
}
void PackInstallTask::onUnzipFinished()
2018-03-19 01:36:12 +00:00
{
2018-07-15 13:51:05 +01:00
install();
}
void PackInstallTask::onUnzipCanceled()
2018-03-19 01:36:12 +00:00
{
2018-07-15 13:51:05 +01:00
emitAborted();
}
void PackInstallTask::install()
2018-03-19 01:36:12 +00:00
{
2018-07-15 13:51:05 +01:00
progress(3, 4);
setStatus(tr("Installing modpack"));
QDir unzipMcDir(m_stagingPath + "/unzip/minecraft");
if(unzipMcDir.exists())
{
//ok, found minecraft dir, move contents to instance dir
if(!QDir().rename(m_stagingPath + "/unzip/minecraft", m_stagingPath + "/.minecraft"))
{
emitFailed(tr("Failed to move unzipped minecraft!"));
return;
}
}
QString instanceConfigPath = FS::PathCombine(m_stagingPath, "instance.cfg");
auto instanceSettings = std::make_shared<INISettingsObject>(instanceConfigPath);
instanceSettings->suspendSave();
2018-07-15 13:51:05 +01:00
instanceSettings->registerSetting("InstanceType", "Legacy");
instanceSettings->set("InstanceType", "OneSix");
MinecraftInstance instance(m_globalSettings, instanceSettings, m_stagingPath);
auto components = instance.getPackProfile();
2018-07-15 13:51:05 +01:00
components->buildingFromScratch();
components->setComponentVersion("net.minecraft", m_pack.mcVersion, true);
bool fallback = true;
//handle different versions
QFile packJson(m_stagingPath + "/.minecraft/pack.json");
QDir jarmodDir = QDir(m_stagingPath + "/unzip/instMods");
if(packJson.exists())
{
packJson.open(QIODevice::ReadOnly | QIODevice::Text);
QJsonDocument doc = QJsonDocument::fromJson(packJson.readAll());
packJson.close();
//we only care about the libs
QJsonArray libs = doc.object().value("libraries").toArray();
foreach (const QJsonValue &value, libs)
{
QString nameValue = value.toObject().value("name").toString();
if(!nameValue.startsWith("net.minecraftforge"))
{
continue;
}
GradleSpecifier forgeVersion(nameValue);
components->setComponentVersion("net.minecraftforge", forgeVersion.version().replace(m_pack.mcVersion, "").replace("-", ""));
packJson.remove();
fallback = false;
break;
}
}
if(jarmodDir.exists())
{
qDebug() << "Found jarmods, installing...";
QStringList jarmods;
for (auto info: jarmodDir.entryInfoList(QDir::NoDotAndDotDot | QDir::Files))
{
qDebug() << "Jarmod:" << info.fileName();
jarmods.push_back(info.absoluteFilePath());
}
components->installJarMods(jarmods);
fallback = false;
}
//just nuke unzip directory, it s not needed anymore
FS::deletePath(m_stagingPath + "/unzip");
if(fallback)
{
//TODO: Some fallback mechanism... or just keep failing!
emitFailed(tr("No installation method found!"));
return;
}
components->saveNow();
progress(4, 4);
instance.setName(m_instName);
if(m_instIcon == "default")
{
m_instIcon = "ftb_logo";
}
instance.setIconKey(m_instIcon);
instanceSettings->resumeSave();
emitSucceeded();
}
bool PackInstallTask::abort()
{
2018-07-15 13:51:05 +01:00
if(abortable)
{
return netJobContainer->abort();
}
return false;
}
}