summaryrefslogtreecommitdiffstats
path: root/api/logic/minecraft/flame/FileResolvingTask.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'api/logic/minecraft/flame/FileResolvingTask.cpp')
-rw-r--r--api/logic/minecraft/flame/FileResolvingTask.cpp66
1 files changed, 66 insertions, 0 deletions
diff --git a/api/logic/minecraft/flame/FileResolvingTask.cpp b/api/logic/minecraft/flame/FileResolvingTask.cpp
new file mode 100644
index 00000000..582e4a07
--- /dev/null
+++ b/api/logic/minecraft/flame/FileResolvingTask.cpp
@@ -0,0 +1,66 @@
+#include "FileResolvingTask.h"
+#include "Json.h"
+
+const char * metabase = "https://cursemeta.dries007.net";
+
+Flame::FileResolvingTask::FileResolvingTask(Flame::Manifest& toProcess)
+ : m_toProcess(toProcess)
+{
+}
+
+void Flame::FileResolvingTask::executeTask()
+{
+ setStatus(tr("Resolving mod IDs..."));
+ setProgress(0, m_toProcess.files.size());
+ m_dljob.reset(new NetJob("Mod id resolver"));
+ results.resize(m_toProcess.files.size());
+ int index = 0;
+ for(auto & file: m_toProcess.files)
+ {
+ auto projectIdStr = QString::number(file.projectId);
+ auto fileIdStr = QString::number(file.fileId);
+ QString metaurl = QString("%1/%2/%3.json").arg(metabase, projectIdStr, fileIdStr);
+ auto dl = Net::Download::makeByteArray(QUrl(metaurl), &results[index]);
+ m_dljob->addNetAction(dl);
+ index ++;
+ }
+ connect(m_dljob.get(), &NetJob::finished, this, &Flame::FileResolvingTask::netJobFinished);
+ m_dljob->start();
+}
+
+void Flame::FileResolvingTask::netJobFinished()
+{
+ bool failed = false;
+ int index = 0;
+ for(auto & bytes: results)
+ {
+ try
+ {
+ auto doc = Json::requireDocument(bytes);
+ auto obj = Json::requireObject(doc);
+ // result code signifies true failure.
+ if(obj.contains("code"))
+ {
+ failed = true;
+ continue;
+ }
+ auto & out = m_toProcess.files[index];
+ out.fileName = Json::requireString(obj, "FileNameOnDisk");
+ out.url = Json::requireString(obj, "DownloadURL");
+ out.resolved = true;
+ }
+ catch(JSONValidationError & e)
+ {
+ failed = true;
+ }
+ index++;
+ }
+ if(!failed)
+ {
+ emitSucceeded();
+ }
+ else
+ {
+ emitFailed(tr("Some mod ID resolving tasks failed."));
+ }
+}