new OperationManager with queue management

and thread safe

src/backend/backup.py

@@ -1,9 +1,11 @@
 import os
 import yaml
+import uuid
 import tarfile
 import shutil
 from typing import NewType
 from gettext import gettext as _
+from gi.repository import GLib
 
 from .manager import Manager
 
@@ -39,6 +41,7 @@ def export_backup(
         It returns True if the backup was successful, False otherwise.
         '''
         BackupManager.operation_manager = OperationManager(window)
+        task_id = str(uuid.uuid4())
 
         if scope == "config":
             logging.info(
@@ -56,9 +59,11 @@ def export_backup(
             logging.info(
                 f"Backuping bottle: [{config['Name']}] in [{path}]"
             )
-            task_entry = BackupManager.operation_manager.new_task(
-                file_name=_("Backup {0}").format(config.get("Name")),
-                cancellable=False
+            GLib.idle_add(
+                BackupManager.operation_manager.new_task, 
+                task_id, 
+                _("Backup {0}").format(config.get("Name")),  
+                False
             )
             bottle_path = ManagerUtils.get_bottle_path(config)
             try:
@@ -71,7 +76,7 @@ def export_backup(
             except:
                 backup_created = False
 
-            task_entry.remove()
+            GLib.idle_add(BackupManager.operation_manager.remove_task, task_id)
 
         if backup_created:
             logging.info(f"Backup saved in path: {path}.")
@@ -91,11 +96,15 @@ def import_backup(window, scope: str, path: str, manager: Manager) -> bool:
         will also update the bottles' list), False otherwise.
         '''
         BackupManager.operation_manager = OperationManager(window)
+        task_id = str(uuid.uuid4())
         backup_name = path.split("/")[-1].split(".")
         import_status = False
 
-        task_entry = BackupManager.operation_manager.new_task(
-            _("Importing backup: {0}").format(backup_name), False
+        GLib.idle_add(
+            BackupManager.operation_manager.new_task, 
+            task_id, 
+            _("Importing backup: {0}").format(backup_name), 
+            False
         )
         logging.info(f"Importing backup: {backup_name}")
 
@@ -129,7 +138,7 @@ def import_backup(window, scope: str, path: str, manager: Manager) -> bool:
             except:
                 import_status = False
 
-        task_entry.remove()
+        GLib.idle_add(BackupManager.operation_manager.remove_task, task_id)
 
         if import_status:
             window.manager.update_bottles()

src/backend/component.py

@@ -17,6 +17,7 @@
 
 import os
 import yaml
+import uuid
 import shutil
 import tarfile
 import requests
@@ -192,11 +193,12 @@ def download(
         Add new entry to the download manager and set the update_func
         to the task_entry update_status function by default.
         '''
-        task_entry = self.__operation_manager.new_task(
-            file_name=file,
-            cancellable=False
+        task_id = str(uuid.uuid4())
+        GLib.idle_add(
+            self.__operation_manager.new_task, task_id, file,  False
         )
-        _update_func = task_entry.update_status
+
+        _update_func = self.__operation_manager.update_task
 
         if download_url.startswith("temp/"):
             '''
@@ -213,12 +215,13 @@ def download(
             _update_func = func
 
         def update_func(
+            task_id,
             count=False,
             block_size=False,
             total_size=False,
             completed=False
         ):
-            GLib.idle_add(_update_func, count, block_size, total_size, completed)
+            GLib.idle_add(_update_func, task_id, count, block_size, total_size, completed)
 
         existing_file = rename if rename else file
         just_downloaded = False
@@ -232,7 +235,7 @@ def update_func(
             logging.warning(
                 f"File [{existing_file}] already exists in temp, skipping."
             )
-            GLib.idle_add(update_func, False, False, False, True)
+            GLib.idle_add(update_func, task_id, False, False, False, True)
         else:
             '''
             As some urls can be redirect, we need to take care of this
@@ -245,7 +248,7 @@ def update_func(
                 download_url = response.url
                 req_code = urllib.request.urlopen(download_url).getcode()
             except:
-                GLib.idle_add(task_entry.remove)
+                GLib.idle_add(self.__operation_manager.remove_task, task_id)
                 return False
 
             if req_code == 200:
@@ -261,20 +264,20 @@ def update_func(
                         func=update_func
                     ).download()
                 except:
-                    GLib.idle_add(task_entry.remove)
+                    GLib.idle_add(self.__operation_manager.remove_task, task_id)
                     return False
 
                 if not os.path.isfile(f"{Paths.temp}/{file}"):
                     '''
                     If the file is not available in the /temp directory,
                     then the download failed.
                     '''
-                    GLib.idle_add(task_entry.remove)
+                    GLib.idle_add(self.__operation_manager.remove_task, task_id)
                     return False
 
                 just_downloaded = True
             else:
-                GLib.idle_add(task_entry.remove)
+                GLib.idle_add(self.__operation_manager.remove_task, task_id)
                 return False
 
         if rename and just_downloaded:
@@ -304,10 +307,10 @@ def update_func(
                 os.remove(file_path)
 
                 #os.remove(file_path)
-                GLib.idle_add(task_entry.remove)
+                GLib.idle_add(self.__operation_manager.remove_task, task_id)
                 return False
 
-        GLib.idle_add(task_entry.remove)
+        GLib.idle_add(self.__operation_manager.remove_task, task_id)
         return True
 
     def extract(self, name: str, component: str, archive: str) -> True:

src/backend/dependency.py

@@ -17,6 +17,7 @@
 
 import os
 import yaml
+import uuid
 import shutil
 import patoolib
 from glob import glob
@@ -115,6 +116,7 @@ def install(
         This function install a given dependency in a bottle. It will
         return True if the installation was successful.
         '''
+        task_id = str(uuid.uuid4())
         uninstaller = True
 
         if config["Versioning"]:
@@ -129,9 +131,8 @@ def install(
                 update=True
             )
 
-        task_entry = self.__operation_manager.new_task(
-            file_name=dependency[0],
-            cancellable=False
+        GLib.idle_add(
+            self.__operation_manager.new_task, task_id, dependency[0],  False
         )
 
         logging.info(
@@ -149,7 +150,7 @@ def install(
             If the manifest is not found, return a Result
             object with the error.
             '''
-            GLib.idle_add(task_entry.remove)
+            GLib.idle_add(self.__operation_manager.remove_task, task_id)
             return Result(
                 status=False,
                 message=f"Cannot find manifest for {dependency[0]}."
@@ -162,7 +163,7 @@ def install(
             '''
             res = self.__perform_steps(config, step)
             if not res.status:
-                GLib.idle_add(task_entry.remove)
+                GLib.idle_add(self.__operation_manager.remove_task, task_id)
                 return Result(
                     status=False,
                     message=f"One or more steps failed for {dependency[0]}."
@@ -202,8 +203,8 @@ def install(
             "Uninstallers"
         )
 
-        # Remove entry from download manager
-        GLib.idle_add(task_entry.remove)
+        # Remove entry from operation manager
+        GLib.idle_add(self.__operation_manager.remove_task, task_id)
 
         # Hide installation button and show remove button
         if not uninstaller:
@@ -244,7 +245,7 @@ def __perform_steps(
                 return Result(status=False)
 
         if step["action"] == "uninstall":
-            self.__step_uninstall(config=config, file_name=step["file_name"])
+            self.__step_uninstall(config=config, title=step["file_name"])
 
         if step["action"] == "cab_extract":
             uninstaller = False

src/backend/versioning.py

@@ -1,5 +1,6 @@
 import os
 import yaml
+import uuid
 import shutil
 from glob import glob
 from typing import NewType
@@ -25,7 +26,7 @@ class RunnerVersioning:
     def __init__(self, window, manager):
         self.window = window
         self.manager = manager
-        self.operation_manager = OperationManager(self.window)
+        self.__operation_manager = OperationManager(self.window)
 
     def create_state(
         self,
@@ -42,14 +43,17 @@ def create_state(
         the index file. It will return True if the state was created, 
         False otherwise.
         '''
+        task_id = str(uuid.uuid4())
         logging.info(
             f"Creating new state for bottle: [{config['Name']}] …"
         )
 
         bottle_path = ManagerUtils.get_bottle_path(config)
-        task_entry = self.operation_manager.new_task(
-            file_name=_("Generating state files index …"),
-            cancellable=False
+        GLib.idle_add(
+            self.__operation_manager.new_task, 
+            task_id, 
+            _("Generating state files index …"),  
+            False
         )
 
         # check if this is the first state
@@ -129,9 +133,14 @@ def create_state(
             state_id = 0
 
         state_path = "%s/states/%s" % (bottle_path, state_id)
-        task_entry.remove()
-        task_entry = self.operation_manager.new_task(
-            _("Creating a restore point …"), False)
+
+        GLib.idle_add(self.__operation_manager.remove_task, task_id)
+        GLib.idle_add(
+            self.__operation_manager.new_task, 
+            task_id, 
+            _("Creating a restore point …"),  
+            False
+        )
 
         try:
             '''
@@ -156,9 +165,13 @@ def create_state(
                 message=_("Could not create the state folder.")
             )
 
-        task_entry.remove()
-        task_entry = self.operation_manager.new_task(
-            _("Updating index …"), False)
+        GLib.idle_add(self.__operation_manager.remove_task, task_id)
+        GLib.idle_add(
+            self.__operation_manager.new_task, 
+            task_id, 
+            _("Updating index …"),  
+            False
+        )
 
         for file in cur_index["Files"]:
             '''
@@ -176,9 +189,13 @@ def create_state(
             target = "{0}/drive_c/{1}".format(state_path, file["file"])
             shutil.copyfile(source, target)
 
-        task_entry.remove()
-        task_entry = self.operation_manager.new_task(
-            _("Updating states …"), False)
+        GLib.idle_add(self.__operation_manager.remove_task, task_id)
+        GLib.idle_add(
+            self.__operation_manager.new_task, 
+            task_id, 
+            _("Updating states …"),  
+            False
+        )
 
         # update the states.yml file, appending the new state
         new_state = {