NOISSUE Wonko is the new Meta
And then Wonko was the Meta.
This commit is contained in:
Petr Mrázek
123
api/logic/meta/tasks/LocalLoadTask.cpp
Normal file
123
api/logic/meta/tasks/LocalLoadTask.cpp
Normal file
@ -0,0 +1,123 @@
|
||||
/* Copyright 2015-2017 MultiMC Contributors
|
||||
*
|
||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||
* you may not use this file except in compliance with the License.
|
||||
* You may obtain a copy of the License at
|
||||
*
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
*
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
|
||||
#include "LocalLoadTask.h"
|
||||
|
||||
#include <QFile>
|
||||
|
||||
#include "meta/format/Format.h"
|
||||
#include "meta/Util.h"
|
||||
#include "meta/Index.h"
|
||||
#include "meta/Version.h"
|
||||
#include "meta/VersionList.h"
|
||||
#include "Env.h"
|
||||
#include "Json.h"
|
||||
|
||||
namespace Meta
|
||||
{
|
||||
LocalLoadTask::LocalLoadTask(BaseEntity *entity, QObject *parent)
|
||||
: Task(parent), m_entity(entity)
|
||||
{
|
||||
}
|
||||
|
||||
void LocalLoadTask::executeTask()
|
||||
{
|
||||
const QString fname = Meta::localDir().absoluteFilePath(filename());
|
||||
if (!QFile::exists(fname))
|
||||
{
|
||||
emitFailed(tr("File doesn't exist"));
|
||||
return;
|
||||
}
|
||||
|
||||
setStatus(tr("Reading %1...").arg(name()));
|
||||
setProgress(0, 0);
|
||||
|
||||
try
|
||||
{
|
||||
parse(Json::requireObject(Json::requireDocument(fname, name()), name()));
|
||||
m_entity->notifyLocalLoadComplete();
|
||||
emitSucceeded();
|
||||
}
|
||||
catch (Exception &e)
|
||||
{
|
||||
emitFailed(tr("Unable to parse file %1: %2").arg(fname, e.cause()));
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
// INDEX
|
||||
IndexLocalLoadTask::IndexLocalLoadTask(Index *index, QObject *parent)
|
||||
: LocalLoadTask(index, parent)
|
||||
{
|
||||
}
|
||||
QString IndexLocalLoadTask::filename() const
|
||||
{
|
||||
return "index.json";
|
||||
}
|
||||
QString IndexLocalLoadTask::name() const
|
||||
{
|
||||
return tr("Metadata Index");
|
||||
}
|
||||
void IndexLocalLoadTask::parse(const QJsonObject &obj) const
|
||||
{
|
||||
Format::parseIndex(obj, dynamic_cast<Index *>(entity()));
|
||||
}
|
||||
|
||||
|
||||
// VERSION LIST
|
||||
VersionListLocalLoadTask::VersionListLocalLoadTask(VersionList *list, QObject *parent)
|
||||
: LocalLoadTask(list, parent)
|
||||
{
|
||||
}
|
||||
QString VersionListLocalLoadTask::filename() const
|
||||
{
|
||||
return list()->uid() + ".json";
|
||||
}
|
||||
QString VersionListLocalLoadTask::name() const
|
||||
{
|
||||
return tr("Version List for %1").arg(list()->humanReadable());
|
||||
}
|
||||
void VersionListLocalLoadTask::parse(const QJsonObject &obj) const
|
||||
{
|
||||
Format::parseVersionList(obj, list());
|
||||
}
|
||||
VersionList *VersionListLocalLoadTask::list() const
|
||||
{
|
||||
return dynamic_cast<VersionList *>(entity());
|
||||
}
|
||||
|
||||
|
||||
// VERSION
|
||||
VersionLocalLoadTask::VersionLocalLoadTask(Version *version, QObject *parent)
|
||||
: LocalLoadTask(version, parent)
|
||||
{
|
||||
}
|
||||
QString VersionLocalLoadTask::filename() const
|
||||
{
|
||||
return version()->uid() + "/" + version()->version() + ".json";
|
||||
}
|
||||
QString VersionLocalLoadTask::name() const
|
||||
{
|
||||
return tr(" Version for %1").arg(version()->name());
|
||||
}
|
||||
void VersionLocalLoadTask::parse(const QJsonObject &obj) const
|
||||
{
|
||||
Format::parseVersion(obj, version());
|
||||
}
|
||||
Version *VersionLocalLoadTask::version() const
|
||||
{
|
||||
return dynamic_cast<Version *>(entity());
|
||||
}
|
||||
}
|
||||
84
api/logic/meta/tasks/LocalLoadTask.h
Normal file
84
api/logic/meta/tasks/LocalLoadTask.h
Normal file
@ -0,0 +1,84 @@
|
||||
/* Copyright 2015-2017 MultiMC Contributors
|
||||
*
|
||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||
* you may not use this file except in compliance with the License.
|
||||
* You may obtain a copy of the License at
|
||||
*
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
*
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
|
||||
#pragma once
|
||||
|
||||
#include "tasks/Task.h"
|
||||
#include <memory>
|
||||
|
||||
namespace Meta
|
||||
{
|
||||
class BaseEntity;
|
||||
class Index;
|
||||
class VersionList;
|
||||
class Version;
|
||||
|
||||
class LocalLoadTask : public Task
|
||||
{
|
||||
Q_OBJECT
|
||||
public:
|
||||
explicit LocalLoadTask(BaseEntity *entity, QObject *parent = nullptr);
|
||||
|
||||
protected:
|
||||
virtual QString filename() const = 0;
|
||||
virtual QString name() const = 0;
|
||||
virtual void parse(const QJsonObject &obj) const = 0;
|
||||
|
||||
BaseEntity *entity() const { return m_entity; }
|
||||
|
||||
private:
|
||||
void executeTask() override;
|
||||
|
||||
BaseEntity *m_entity;
|
||||
};
|
||||
|
||||
class IndexLocalLoadTask : public LocalLoadTask
|
||||
{
|
||||
Q_OBJECT
|
||||
public:
|
||||
explicit IndexLocalLoadTask(Index *index, QObject *parent = nullptr);
|
||||
|
||||
private:
|
||||
QString filename() const override;
|
||||
QString name() const override;
|
||||
void parse(const QJsonObject &obj) const override;
|
||||
};
|
||||
class VersionListLocalLoadTask : public LocalLoadTask
|
||||
{
|
||||
Q_OBJECT
|
||||
public:
|
||||
explicit VersionListLocalLoadTask(VersionList *list, QObject *parent = nullptr);
|
||||
|
||||
private:
|
||||
QString filename() const override;
|
||||
QString name() const override;
|
||||
void parse(const QJsonObject &obj) const override;
|
||||
|
||||
VersionList *list() const;
|
||||
};
|
||||
class VersionLocalLoadTask : public LocalLoadTask
|
||||
{
|
||||
Q_OBJECT
|
||||
public:
|
||||
explicit VersionLocalLoadTask(Version *version, QObject *parent = nullptr);
|
||||
|
||||
private:
|
||||
QString filename() const override;
|
||||
QString name() const override;
|
||||
void parse(const QJsonObject &obj) const override;
|
||||
|
||||
Version *version() const;
|
||||
};
|
||||
}
|
||||
132
api/logic/meta/tasks/RemoteLoadTask.cpp
Normal file
132
api/logic/meta/tasks/RemoteLoadTask.cpp
Normal file
@ -0,0 +1,132 @@
|
||||
/* Copyright 2015-2017 MultiMC Contributors
|
||||
*
|
||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||
* you may not use this file except in compliance with the License.
|
||||
* You may obtain a copy of the License at
|
||||
*
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
*
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
|
||||
#include "RemoteLoadTask.h"
|
||||
|
||||
#include "net/Download.h"
|
||||
#include "net/HttpMetaCache.h"
|
||||
#include "net/NetJob.h"
|
||||
#include "meta/format/Format.h"
|
||||
#include "meta/Util.h"
|
||||
#include "meta/Index.h"
|
||||
#include "meta/Version.h"
|
||||
#include "meta/VersionList.h"
|
||||
#include "Env.h"
|
||||
#include "Json.h"
|
||||
|
||||
namespace Meta
|
||||
{
|
||||
|
||||
RemoteLoadTask::RemoteLoadTask(BaseEntity *entity, QObject *parent)
|
||||
: Task(parent), m_entity(entity)
|
||||
{
|
||||
}
|
||||
|
||||
void RemoteLoadTask::executeTask()
|
||||
{
|
||||
NetJob *job = new NetJob(name());
|
||||
|
||||
auto entry = ENV.metacache()->resolveEntry("meta", url().toString());
|
||||
entry->setStale(true);
|
||||
m_dl = Net::Download::makeCached(url(), entry);
|
||||
job->addNetAction(m_dl);
|
||||
connect(job, &NetJob::failed, this, &RemoteLoadTask::emitFailed);
|
||||
connect(job, &NetJob::succeeded, this, &RemoteLoadTask::networkFinished);
|
||||
connect(job, &NetJob::status, this, &RemoteLoadTask::setStatus);
|
||||
connect(job, &NetJob::progress, this, &RemoteLoadTask::setProgress);
|
||||
job->start();
|
||||
}
|
||||
|
||||
void RemoteLoadTask::networkFinished()
|
||||
{
|
||||
setStatus(tr("Parsing..."));
|
||||
setProgress(0, 0);
|
||||
|
||||
try
|
||||
{
|
||||
parse(Json::requireObject(Json::requireDocument(m_dl->getTargetFilepath(), name()), name()));
|
||||
m_entity->notifyRemoteLoadComplete();
|
||||
emitSucceeded();
|
||||
}
|
||||
catch (Exception &e)
|
||||
{
|
||||
emitFailed(tr("Unable to parse response: %1").arg(e.cause()));
|
||||
}
|
||||
}
|
||||
|
||||
// INDEX
|
||||
IndexRemoteLoadTask::IndexRemoteLoadTask(Index *index, QObject *parent)
|
||||
: RemoteLoadTask(index, parent)
|
||||
{
|
||||
}
|
||||
QUrl IndexRemoteLoadTask::url() const
|
||||
{
|
||||
return Meta::indexUrl();
|
||||
}
|
||||
QString IndexRemoteLoadTask::name() const
|
||||
{
|
||||
return tr("Metadata Index");
|
||||
}
|
||||
void IndexRemoteLoadTask::parse(const QJsonObject &obj) const
|
||||
{
|
||||
Format::parseIndex(obj, dynamic_cast<Index *>(entity()));
|
||||
}
|
||||
|
||||
|
||||
// VERSION LIST
|
||||
VersionListRemoteLoadTask::VersionListRemoteLoadTask(VersionList *list, QObject *parent)
|
||||
: RemoteLoadTask(list, parent)
|
||||
{
|
||||
}
|
||||
QUrl VersionListRemoteLoadTask::url() const
|
||||
{
|
||||
return Meta::versionListUrl(list()->uid());
|
||||
}
|
||||
QString VersionListRemoteLoadTask::name() const
|
||||
{
|
||||
return tr("Version List for %1").arg(list()->humanReadable());
|
||||
}
|
||||
void VersionListRemoteLoadTask::parse(const QJsonObject &obj) const
|
||||
{
|
||||
Format::parseVersionList(obj, list());
|
||||
}
|
||||
VersionList* Meta::VersionListRemoteLoadTask::list() const
|
||||
{
|
||||
return dynamic_cast<VersionList *>(entity());
|
||||
}
|
||||
|
||||
|
||||
// VERSION
|
||||
VersionRemoteLoadTask::VersionRemoteLoadTask(Version *version, QObject *parent)
|
||||
: RemoteLoadTask(version, parent)
|
||||
{
|
||||
}
|
||||
QUrl VersionRemoteLoadTask::url() const
|
||||
{
|
||||
return Meta::versionUrl(version()->uid(), version()->version());
|
||||
}
|
||||
QString VersionRemoteLoadTask::name() const
|
||||
{
|
||||
return tr("Meta Version for %1").arg(version()->name());
|
||||
}
|
||||
void VersionRemoteLoadTask::parse(const QJsonObject &obj) const
|
||||
{
|
||||
Format::parseVersion(obj, version());
|
||||
}
|
||||
Version *VersionRemoteLoadTask::version() const
|
||||
{
|
||||
return dynamic_cast<Version *>(entity());
|
||||
}
|
||||
}
|
||||
95
api/logic/meta/tasks/RemoteLoadTask.h
Normal file
95
api/logic/meta/tasks/RemoteLoadTask.h
Normal file
@ -0,0 +1,95 @@
|
||||
/* Copyright 2015-2017 MultiMC Contributors
|
||||
*
|
||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||
* you may not use this file except in compliance with the License.
|
||||
* You may obtain a copy of the License at
|
||||
*
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
*
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
|
||||
#pragma once
|
||||
|
||||
#include "tasks/Task.h"
|
||||
#include <memory>
|
||||
|
||||
namespace Net
|
||||
{
|
||||
class Download;
|
||||
}
|
||||
|
||||
namespace Meta
|
||||
{
|
||||
class BaseEntity;
|
||||
class Index;
|
||||
class VersionList;
|
||||
class Version;
|
||||
|
||||
class RemoteLoadTask : public Task
|
||||
{
|
||||
Q_OBJECT
|
||||
public:
|
||||
explicit RemoteLoadTask(BaseEntity *entity, QObject *parent = nullptr);
|
||||
|
||||
protected:
|
||||
virtual QUrl url() const = 0;
|
||||
virtual QString name() const = 0;
|
||||
virtual void parse(const QJsonObject &obj) const = 0;
|
||||
|
||||
BaseEntity *entity() const { return m_entity; }
|
||||
|
||||
private slots:
|
||||
void networkFinished();
|
||||
|
||||
private:
|
||||
void executeTask() override;
|
||||
|
||||
BaseEntity *m_entity;
|
||||
std::shared_ptr<Net::Download> m_dl;
|
||||
};
|
||||
|
||||
class IndexRemoteLoadTask : public RemoteLoadTask
|
||||
{
|
||||
Q_OBJECT
|
||||
public:
|
||||
explicit IndexRemoteLoadTask(Index *index, QObject *parent = nullptr);
|
||||
|
||||
private:
|
||||
QUrl url() const override;
|
||||
QString name() const override;
|
||||
void parse(const QJsonObject &obj) const override;
|
||||
};
|
||||
|
||||
class VersionListRemoteLoadTask : public RemoteLoadTask
|
||||
{
|
||||
Q_OBJECT
|
||||
public:
|
||||
explicit VersionListRemoteLoadTask(VersionList *list, QObject *parent = nullptr);
|
||||
|
||||
private:
|
||||
QUrl url() const override;
|
||||
QString name() const override;
|
||||
void parse(const QJsonObject &obj) const override;
|
||||
|
||||
VersionList *list() const;
|
||||
};
|
||||
|
||||
class VersionRemoteLoadTask : public RemoteLoadTask
|
||||
{
|
||||
Q_OBJECT
|
||||
public:
|
||||
explicit VersionRemoteLoadTask(Version *version, QObject *parent = nullptr);
|
||||
|
||||
private:
|
||||
QUrl url() const override;
|
||||
QString name() const override;
|
||||
void parse(const QJsonObject &obj) const override;
|
||||
|
||||
Version *version() const;
|
||||
};
|
||||
}
|
||||
Reference in New Issue
Block a user