diff options
| author | Mehmet Samet Duman <yongdohyun@projecttick.org> | 2026-04-02 18:45:07 +0300 |
|---|---|---|
| committer | Mehmet Samet Duman <yongdohyun@projecttick.org> | 2026-04-02 18:45:07 +0300 |
| commit | 31b9a8949ed0a288143e23bf739f2eb64fdc63be (patch) | |
| tree | 8a984fa143c38fccad461a77792d6864f3e82cd3 /meshmc/launcher/tasks | |
| parent | 934382c8a1ce738589dee9ee0f14e1cec812770e (diff) | |
| parent | fad6a1066616b69d7f5fef01178efdf014c59537 (diff) | |
| download | Project-Tick-31b9a8949ed0a288143e23bf739f2eb64fdc63be.tar.gz Project-Tick-31b9a8949ed0a288143e23bf739f2eb64fdc63be.zip | |
Add 'meshmc/' from commit 'fad6a1066616b69d7f5fef01178efdf014c59537'
git-subtree-dir: meshmc
git-subtree-mainline: 934382c8a1ce738589dee9ee0f14e1cec812770e
git-subtree-split: fad6a1066616b69d7f5fef01178efdf014c59537
Diffstat (limited to 'meshmc/launcher/tasks')
| -rw-r--r-- | meshmc/launcher/tasks/SequentialTask.cpp | 77 | ||||
| -rw-r--r-- | meshmc/launcher/tasks/SequentialTask.h | 50 | ||||
| -rw-r--r-- | meshmc/launcher/tasks/Task.cpp | 189 | ||||
| -rw-r--r-- | meshmc/launcher/tasks/Task.h | 131 |
4 files changed, 447 insertions, 0 deletions
diff --git a/meshmc/launcher/tasks/SequentialTask.cpp b/meshmc/launcher/tasks/SequentialTask.cpp new file mode 100644 index 0000000000..12dcd92818 --- /dev/null +++ b/meshmc/launcher/tasks/SequentialTask.cpp @@ -0,0 +1,77 @@ +/* SPDX-FileCopyrightText: 2026 Project Tick + * SPDX-FileContributor: Project Tick + * SPDX-License-Identifier: GPL-3.0-or-later + * + * MeshMC - A Custom Launcher for Minecraft + * Copyright (C) 2026 Project Tick + * + * This program is free software: you can redistribute it and/or modify + * it under the terms of the GNU General Public License as published by + * the Free Software Foundation, either version 3 of the License, or + * (at your option) any later version. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License + * along with this program. If not, see <https://www.gnu.org/licenses/>. + */ + +#include "SequentialTask.h" + +SequentialTask::SequentialTask(QObject* parent) + : Task(parent), m_currentIndex(-1) +{ +} + +void SequentialTask::addTask(Task::Ptr task) +{ + m_queue.append(task); +} + +void SequentialTask::executeTask() +{ + m_currentIndex = -1; + startNext(); +} + +void SequentialTask::startNext() +{ + if (m_currentIndex != -1) { + Task::Ptr previous = m_queue[m_currentIndex]; + disconnect(previous.get(), 0, this, 0); + } + m_currentIndex++; + if (m_queue.isEmpty() || m_currentIndex >= m_queue.size()) { + emitSucceeded(); + return; + } + Task::Ptr next = m_queue[m_currentIndex]; + connect(next.get(), SIGNAL(failed(QString)), this, + SLOT(subTaskFailed(QString))); + connect(next.get(), SIGNAL(status(QString)), this, + SLOT(subTaskStatus(QString))); + connect(next.get(), SIGNAL(progress(qint64, qint64)), this, + SLOT(subTaskProgress(qint64, qint64))); + connect(next.get(), SIGNAL(succeeded()), this, SLOT(startNext())); + next->start(); +} + +void SequentialTask::subTaskFailed(const QString& msg) +{ + emitFailed(msg); +} +void SequentialTask::subTaskStatus(const QString& msg) +{ + setStatus(msg); +} +void SequentialTask::subTaskProgress(qint64 current, qint64 total) +{ + if (total == 0) { + setProgress(0, 100); + return; + } + setProgress(current, total); +} diff --git a/meshmc/launcher/tasks/SequentialTask.h b/meshmc/launcher/tasks/SequentialTask.h new file mode 100644 index 0000000000..ae2117cac2 --- /dev/null +++ b/meshmc/launcher/tasks/SequentialTask.h @@ -0,0 +1,50 @@ +/* SPDX-FileCopyrightText: 2026 Project Tick + * SPDX-FileContributor: Project Tick + * SPDX-License-Identifier: GPL-3.0-or-later + * + * MeshMC - A Custom Launcher for Minecraft + * Copyright (C) 2026 Project Tick + * + * This program is free software: you can redistribute it and/or modify + * it under the terms of the GNU General Public License as published by + * the Free Software Foundation, either version 3 of the License, or + * (at your option) any later version. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License + * along with this program. If not, see <https://www.gnu.org/licenses/>. + */ + +#pragma once + +#include "Task.h" +#include "QObjectPtr.h" + +#include <QQueue> + +class SequentialTask : public Task +{ + Q_OBJECT + public: + explicit SequentialTask(QObject* parent = 0); + virtual ~SequentialTask() {}; + + void addTask(Task::Ptr task); + + protected: + void executeTask(); + + private slots: + void startNext(); + void subTaskFailed(const QString& msg); + void subTaskStatus(const QString& msg); + void subTaskProgress(qint64 current, qint64 total); + + private: + QQueue<Task::Ptr> m_queue; + int m_currentIndex; +}; diff --git a/meshmc/launcher/tasks/Task.cpp b/meshmc/launcher/tasks/Task.cpp new file mode 100644 index 0000000000..9f55b38699 --- /dev/null +++ b/meshmc/launcher/tasks/Task.cpp @@ -0,0 +1,189 @@ +/* SPDX-FileCopyrightText: 2026 Project Tick + * SPDX-FileContributor: Project Tick + * SPDX-License-Identifier: GPL-3.0-or-later + * + * MeshMC - A Custom Launcher for Minecraft + * Copyright (C) 2026 Project Tick + * + * This program is free software: you can redistribute it and/or modify + * it under the terms of the GNU General Public License as published by + * the Free Software Foundation, either version 3 of the License, or + * (at your option) any later version. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License + * along with this program. If not, see <https://www.gnu.org/licenses/>. + * + * This file incorporates work covered by the following copyright and + * permission notice: + * + * Copyright 2013-2021 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 "Task.h" + +#include <QDebug> +#include <QPointer> + +Task::Task(QObject* parent) : QObject(parent) {} + +void Task::setStatus(const QString& new_status) +{ + if (m_status != new_status) { + m_status = new_status; + emit status(m_status); + } +} + +void Task::setProgress(qint64 current, qint64 total) +{ + m_progress = current; + m_progressTotal = total; + emit progress(m_progress, m_progressTotal); +} + +void Task::start() +{ + switch (m_state) { + case State::Inactive: { + qDebug() << "Task" << describe() << "starting for the first time"; + break; + } + case State::AbortedByUser: { + qDebug() << "Task" << describe() + << "restarting for after being aborted by user"; + break; + } + case State::Failed: { + qDebug() << "Task" << describe() + << "restarting for after failing at first"; + break; + } + case State::Succeeded: { + qDebug() << "Task" << describe() + << "restarting for after succeeding at first"; + break; + } + case State::Running: { + qWarning() << "MeshMC tried to start task" << describe() + << "while it was already running!"; + return; + } + } + // NOTE: only fall thorugh to here in end states + m_state = State::Running; + emit started(); + executeTask(); +} + +void Task::emitFailed(QString reason) +{ + // Don't fail twice. + if (!isRunning()) { + qCritical() << "Task" << describe() + << "failed while not running!!!!: " << reason; + return; + } + m_state = State::Failed; + m_failReason = reason; + qCritical() << "Task" << describe() << "failed: " << reason; + QPointer<Task> guard(this); + emit failed(reason); + if (guard) + emit finished(); +} + +void Task::emitAborted() +{ + // Don't abort twice. + if (!isRunning()) { + qCritical() << "Task" << describe() << "aborted while not running!!!!"; + return; + } + m_state = State::AbortedByUser; + m_failReason = "Aborted."; + qDebug() << "Task" << describe() << "aborted."; + QPointer<Task> guard(this); + emit failed(m_failReason); + if (guard) + emit finished(); +} + +void Task::emitSucceeded() +{ + // Don't succeed twice. + if (!isRunning()) { + qCritical() << "Task" << describe() + << "succeeded while not running!!!!"; + return; + } + m_state = State::Succeeded; + qDebug() << "Task" << describe() << "succeeded"; + QPointer<Task> guard(this); + emit succeeded(); + if (guard) + emit finished(); +} + +QString Task::describe() +{ + QString outStr; + QTextStream out(&outStr); + out << metaObject()->className() << QChar('('); + auto name = objectName(); + if (name.isEmpty()) { + out << QString("0x%1").arg((quintptr)this, 0, 16); + } else { + out << name; + } + out << QChar(')'); + out.flush(); + return outStr; +} + +bool Task::isRunning() const +{ + return m_state == State::Running; +} + +bool Task::isFinished() const +{ + return m_state != State::Running && m_state != State::Inactive; +} + +bool Task::wasSuccessful() const +{ + return m_state == State::Succeeded; +} + +QString Task::failReason() const +{ + return m_failReason; +} + +void Task::logWarning(const QString& line) +{ + qWarning() << line; + m_Warnings.append(line); +} + +QStringList Task::warnings() const +{ + return m_Warnings; +} diff --git a/meshmc/launcher/tasks/Task.h b/meshmc/launcher/tasks/Task.h new file mode 100644 index 0000000000..8019c9bd9c --- /dev/null +++ b/meshmc/launcher/tasks/Task.h @@ -0,0 +1,131 @@ +/* SPDX-FileCopyrightText: 2026 Project Tick + * SPDX-FileContributor: Project Tick + * SPDX-License-Identifier: GPL-3.0-or-later + * + * MeshMC - A Custom Launcher for Minecraft + * Copyright (C) 2026 Project Tick + * + * This program is free software: you can redistribute it and/or modify + * it under the terms of the GNU General Public License as published by + * the Free Software Foundation, either version 3 of the License, or + * (at your option) any later version. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License + * along with this program. If not, see <https://www.gnu.org/licenses/>. + * + * This file incorporates work covered by the following copyright and + * permission notice: + * + * Copyright 2013-2021 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 <QObject> +#include <QString> +#include <QStringList> + +#include "QObjectPtr.h" + +class Task : public QObject +{ + Q_OBJECT + public: + using Ptr = shared_qobject_ptr<Task>; + + enum class State { Inactive, Running, Succeeded, Failed, AbortedByUser }; + + public: + explicit Task(QObject* parent = 0); + virtual ~Task() {}; + + bool isRunning() const; + bool isFinished() const; + bool wasSuccessful() const; + + /*! + * Returns the string that was passed to emitFailed as the error message + * when the task failed. If the task hasn't failed, returns an empty string. + */ + QString failReason() const; + + virtual QStringList warnings() const; + + virtual bool canAbort() const + { + return false; + } + + QString getStatus() + { + return m_status; + } + + qint64 getProgress() + { + return m_progress; + } + + qint64 getTotalProgress() + { + return m_progressTotal; + } + + protected: + void logWarning(const QString& line); + + private: + QString describe(); + + signals: + void started(); + void progress(qint64 current, qint64 total); + void finished(); + void succeeded(); + void failed(QString reason); + void status(QString status); + + public slots: + virtual void start(); + virtual bool abort() + { + return false; + }; + + protected: + virtual void executeTask() = 0; + + protected slots: + virtual void emitSucceeded(); + virtual void emitAborted(); + virtual void emitFailed(QString reason); + + public slots: + void setStatus(const QString& status); + void setProgress(qint64 current, qint64 total); + + private: + State m_state = State::Inactive; + QStringList m_Warnings; + QString m_failReason = ""; + QString m_status; + int m_progress = 0; + int m_progressTotal = 100; +}; |
