NOISSUE add archived projects

Signed-off-by: Mehmet Samet Duman <yongdohyun@projecttick.org>

1 files changed, 231 insertions, 0 deletions

diff --git a/archived/projt-launcher/launcher/net/NetJob.cpp b/archived/projt-launcher/launcher/net/NetJob.cpp
new file mode 100644
index 0000000000..f85bd932b9
--- /dev/null
+++ b/archived/projt-launcher/launcher/net/NetJob.cpp
@@ -0,0 +1,231 @@
+// SPDX-License-Identifier: GPL-3.0-only
+// SPDX-FileCopyrightText: 2026 Project Tick
+// SPDX-FileContributor: Project Tick Team
+/*
+ *  ProjT Launcher - Minecraft Launcher
+ *  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, version 3.
+ *
+ *  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, write to the Free Software Foundation,
+ *  Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
+ *
+ * === Upstream License Block (Do Not Modify) ==============================
+ *
+ *
+ *
+ *  Prism Launcher - Minecraft Launcher
+ *  Copyright (c) 2022 flowln <flowlnlnln@gmail.com>
+ *  Copyright (C) 2022 Sefa Eyeoglu <contact@scrumplex.net>
+ *  Copyright (C) 2023 Rachel Powers <508861+Ryex@users.noreply.github.com>
+ *
+ *  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, version 3.
+ *
+ *  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, write to the Free Software Foundation,
+ *  Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
+ *
+ * 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 "NetJob.h"
+#include <QNetworkReply>
+#include "net/NetRequest.h"
+#include "tasks/ConcurrentTask.h"
+#if defined(LAUNCHER_APPLICATION)
+#include "Application.h"
+#include "ui/dialogs/CustomMessageBox.h"
+#endif
+
+NetJob::NetJob(QString job_name, shared_qobject_ptr<QNetworkAccessManager> network, int max_concurrent)
+	: ConcurrentTask(job_name),
+	  m_network(network)
+{
+#if defined(LAUNCHER_APPLICATION)
+	if (APPLICATION_DYN && max_concurrent < 0)
+		max_concurrent = APPLICATION->settings()->get("NumberOfConcurrentDownloads").toInt();
+#endif
+	if (max_concurrent > 0)
+		setMaxConcurrent(max_concurrent);
+}
+
+auto NetJob::addNetAction(Net::NetRequest::Ptr action) -> bool
+{
+	action->setNetwork(m_network);
+
+	addTask(action);
+
+	return true;
+}
+
+void NetJob::executeNextSubTask()
+{
+	// We're finished, check for failures and retry if we can (up to 3 times)
+	if (isRunning() && m_queue.isEmpty() && m_doing.isEmpty() && !m_failed.isEmpty() && m_try < 3)
+	{
+		m_try += 1;
+		const auto failedTasks = m_failed.keys();
+		for (auto* failedTask : failedTasks)
+		{
+			auto task = m_failed.take(failedTask);
+			m_done.remove(task.get());
+			m_queue.enqueue(task);
+		}
+	}
+	ConcurrentTask::executeNextSubTask();
+}
+
+auto NetJob::size() const -> int
+{
+	return m_queue.size() + m_doing.size() + m_done.size();
+}
+
+auto NetJob::canAbort() const -> bool
+{
+	bool canFullyAbort = true;
+
+	// can abort the downloads on the queue?
+	for (auto part : m_queue)
+		canFullyAbort &= part->canAbort();
+
+	// can abort the active downloads?
+	for (auto part : m_doing)
+		canFullyAbort &= part->canAbort();
+
+	return canFullyAbort;
+}
+
+auto NetJob::abort() -> bool
+{
+	bool fullyAborted = true;
+
+	// fail all downloads on the queue
+	for (auto task : m_queue)
+		m_failed.insert(task.get(), task);
+	m_queue.clear();
+
+	// abort active downloads
+	auto toKill = m_doing.values();
+	for (auto part : toKill)
+	{
+		fullyAborted &= part->abort();
+	}
+
+	if (fullyAborted)
+		emitAborted();
+	else
+		emitFailed(tr("Failed to abort all tasks in the NetJob!"));
+
+	return fullyAborted;
+}
+
+auto NetJob::getFailedActions() -> QList<Net::NetRequest*>
+{
+	QList<Net::NetRequest*> failed;
+	for (auto index : m_failed)
+	{
+		failed.push_back(dynamic_cast<Net::NetRequest*>(index.get()));
+	}
+	return failed;
+}
+
+auto NetJob::getFailedFiles() -> QList<QString>
+{
+	QList<QString> failed;
+	for (auto index : m_failed)
+	{
+		failed.append(static_cast<Net::NetRequest*>(index.get())->url().toString());
+	}
+	return failed;
+}
+
+void NetJob::updateState()
+{
+	emit progress(m_done.count(), totalSize());
+	setStatus(
+		tr("Executing %1 task(s) (%2 out of %3 are done)")
+			.arg(QString::number(m_doing.count()), QString::number(m_done.count()), QString::number(totalSize())));
+}
+
+bool NetJob::isOnline()
+{
+	// check some errors that are ussually associated with the lack of internet
+	for (auto job : getFailedActions())
+	{
+		auto err = job->error();
+		if (err != QNetworkReply::HostNotFoundError && err != QNetworkReply::NetworkSessionFailedError)
+		{
+			return true;
+		}
+	}
+	return false;
+};
+
+void NetJob::emitFailed(QString reason)
+{
+#if defined(LAUNCHER_APPLICATION)
+
+	if (APPLICATION_DYN && m_ask_retry && m_manual_try < APPLICATION->settings()->get("NumberOfManualRetries").toInt()
+		&& isOnline())
+	{
+		m_manual_try++;
+		auto response =
+			CustomMessageBox::selectable(nullptr,
+										 "Confirm retry",
+										 "The tasks failed.\n"
+										 "Failed urls\n"
+											 + getFailedFiles().join("\n\t")
+											 + ".\n"
+											   "If this continues to happen please check the logs of the application.\n"
+											   "Do you want to retry?",
+										 QMessageBox::Warning,
+										 QMessageBox::Yes | QMessageBox::No,
+										 QMessageBox::No)
+				->exec();
+
+		if (response == QMessageBox::Yes)
+		{
+			m_try = 0;
+			executeNextSubTask();
+			return;
+		}
+	}
+#endif
+	ConcurrentTask::emitFailed(reason);
+}
+
+void NetJob::setAskRetry(bool askRetry)
+{
+	m_ask_retry = askRetry;
+}