From 24477f607d64fd368c2301ac6cda5d6d09ac50f6 Mon Sep 17 00:00:00 2001
From: heliguy4599 <heliguy4599@hotmail.com>
Date: Fri, 11 Oct 2024 20:07:38 -0400
Subject: [PATCH] Add change version worker

---
 .../change_version_worker.py                  | 66 +++++++++++++++++++
 src/meson.build                               |  1 +
 2 files changed, 67 insertions(+)
 create mode 100644 src/change_version_page/change_version_worker.py

diff --git a/src/change_version_page/change_version_worker.py b/src/change_version_page/change_version_worker.py
new file mode 100644
index 0000000..aae2c46
--- /dev/null
+++ b/src/change_version_page/change_version_worker.py
@@ -0,0 +1,66 @@
+from gi.repository import Adw, Gtk, GLib, Gio
+from .host_info import HostInfo
+import subprocess, re
+
+class ChangeVersionWorker:
+	process = None
+	callback = None
+	error_callback = None
+	loading_status = None
+	cancelled = False
+	
+	@classmethod
+	def update_status(this, package_ratio, complete, total):
+		final_ratio = (package_ratio + complete) / (total or 1)
+		
+		print(f"fr: {final_ratio:.2f}")
+		print("r:", package_ratio, ", c:", complete, ", t:", total)
+		print("=======================================")
+		
+		if not this.loading_status is None:	
+			GLib.idle_add(lambda *_: this.loading_status.progress_bar.set_fraction(final_ratio))
+			
+	@classmethod
+	def change_version_thread(this, ref, commit):
+		pass
+		
+	@classmethod
+	def cancel(this):
+		if this.process is None:
+			return
+			
+		try:
+			this.cancelled = True
+			this.process.terminate()
+			this.process.wait(timeout=10)
+		except Exception as e:
+			this.on_error(_("Could not cancel installation"), str(e))
+			
+	@classmethod
+	def on_done(this, *args):
+		this.process = None
+		this.cancelled = False
+		HostInfo.main_window.remove_refresh_lockout("changing version")
+		if not this.loading_status is None:
+			this.loading_status.progress_bar.set_fraction(0.0)
+			
+		if not this.callback is None:
+			this.callback()
+			
+	@classmethod
+	def on_error(this, user_facing_label, error_message):
+		if not this.error_callback is None:
+			this.error_callback(user_facing_label, error_message)
+			
+	@classmethod
+	def change_version(this, ref, commit, loading_status=None, callback=None, error_callback=None):
+		if not this.process is None:
+			this.on_error(_("Could not install packages"), _("Packages are currently being installed."))
+			return False
+			
+		this.loading_status = loading_status
+		this.callback = callback
+		this.error_callback = error_callback
+		HostInfo.main_window.add_refresh_lockout("changing version")
+		Gio.Task.new(None, None, this.on_done).run_in_thread(lambda *_: this.change_version_thread(ref, commit))
+		return True
diff --git a/src/meson.build b/src/meson.build
index e2c679d..3b6a47a 100644
--- a/src/meson.build
+++ b/src/meson.build
@@ -86,6 +86,7 @@ warehouse_sources = [
   'packages_page/filters_page.py',
   'properties_page/properties_page.py',
   'change_version_page/change_version_page.py',
+  'change_version_page/change_version_worker.py',
   'user_data_page/data_box.py',
   'user_data_page/user_data_page.py',
   'user_data_page/data_subpage.py',