[arch] fix -> some environment variables are not available during the common operations (install, upgrade, ...)

CHANGELOG.md

@@ -64,6 +64,7 @@ The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/).
         - info dialog of installed packages displays the latest PKGBUILD file instead of the one used for installation/upgrade/downgrade (the fix will only work for new installed packages)
         - multi-threaded download: not retrieving correctly some source files URLs (e.g: linux-xanmod-lts)
         - importing PGP keys (Generic error). Now the key server is specified: `gpg --keyserver SERVER --recv-key KEYID` (the server address is retrieved from [bauh-files](https://github.com/vinifmor/bauh-files/blob/master/arch/gpgservers.txt))
+    - some environment variables are not available during the common operations (install, upgrade, downgrade, uninstall, makepkg)
 - Flatpak
     - downgrading crashing with version 1.8.X
     - history: the top commit is returned as "(null)" in version 1.8.X

bauh/commons/system.py

@@ -26,20 +26,20 @@ SIZE_MULTIPLIERS = ((0.001, 'Kb'), (0.000001, 'Mb'), (0.000000001, 'Gb'), (0.000
 
 
 def gen_env(global_interpreter: bool, lang: str = DEFAULT_LANG, extra_paths: Set[str] = None) -> dict:
-    res = {}
+    custom_env = dict(os.environ)
 
     if lang:
-        res['LANG'] = lang
+        custom_env['LANG'] = lang
 
     if global_interpreter:  # to avoid subprocess calls to the virtualenv python interpreter instead of the global one.
-        res['PATH'] = GLOBAL_INTERPRETER_PATH
+        custom_env['PATH'] = GLOBAL_INTERPRETER_PATH
     else:
-        res['PATH'] = PATH
+        custom_env['PATH'] = PATH
 
     if extra_paths:
-        res['PATH'] = ':'.join(extra_paths) + ':' + res['PATH']
+        custom_env['PATH'] = ':'.join(extra_paths) + ':' + custom_env['PATH']
 
-    return res
+    return custom_env
 
 
 class SystemProcess:
@@ -65,9 +65,11 @@ class SimpleProcess:
 
     def __init__(self, cmd: List[str], cwd: str = '.', expected_code: int = 0,
                  global_interpreter: bool = USE_GLOBAL_INTERPRETER, lang: str = DEFAULT_LANG, root_password: str = None,
-                 extra_paths: Set[str] = None, error_phrases: Set[str] = None, wrong_error_phrases: Set[str] = None):
+                 extra_paths: Set[str] = None, error_phrases: Set[str] = None, wrong_error_phrases: Set[str] = None,
+                 shell: bool = False):
         pwdin, final_cmd = None, []
 
+        self.shell = shell
         if root_password is not None:
             final_cmd.extend(['sudo', '-S'])
             pwdin = self._new(['echo', root_password], cwd, global_interpreter, lang).stdout
@@ -86,13 +88,14 @@ class SimpleProcess:
             "stderr": subprocess.STDOUT,
             "bufsize": -1,
             "cwd": cwd,
-            "env": gen_env(global_interpreter, lang, extra_paths=extra_paths)
+            "env": gen_env(global_interpreter, lang, extra_paths=extra_paths),
+            "shell": self.shell
         }
 
         if stdin:
             args['stdin'] = stdin
 
-        return subprocess.Popen(cmd, **args)
+        return subprocess.Popen(args=' '.join(cmd) if self.shell else cmd, **args)
 
 
 class ProcessHandler:
@@ -160,7 +163,7 @@ class ProcessHandler:
         return process.subproc.returncode is None or process.subproc.returncode == 0
 
     def handle_simple(self, proc: SimpleProcess, output_handler=None) -> Tuple[bool, str]:
-        self._notify_watcher(' '.join(proc.instance.args) + '\n')
+        self._notify_watcher((proc.instance.args if proc.shell else ' '.join(proc.instance.args)) + '\n')
 
         output = StringIO()
         for o in proc.instance.stdout:

bauh/gems/arch/controller.py

@@ -932,8 +932,10 @@ class ArchManager(SoftwareManager):
                                                   pkgs_to_remove=len(to_remove))
         output_handler.start()
         try:
-            success = handler.handle(pacman.remove_several(pkgnames=to_remove, root_password=root_password, skip_checks=True),
-                                     output_handler=output_handler.handle)
+            success, _ = handler.handle_simple(pacman.remove_several(pkgnames=to_remove,
+                                                                     root_password=root_password,
+                                                                     skip_checks=True),
+                                               output_handler=output_handler.handle)
 
             if not success:
                 self.logger.error("Could not remove packages: {}".format(', '.join(to_remove)))

bauh/gems/arch/makepkg.py

@@ -28,7 +28,7 @@ def check(pkgdir: str, optimize: bool, missing_deps: bool, handler: ProcessHandl
         else:
             handler.watcher.print('Custom optimized makepkg.conf ( {} ) not found'.format(CUSTOM_MAKEPKG_FILE))
 
-    success, output = handler.handle_simple(SimpleProcess(cmd, cwd=pkgdir))
+    success, output = handler.handle_simple(SimpleProcess(cmd, cwd=pkgdir, shell=True))
 
     if missing_deps and 'Missing dependencies' in output:
         res['missing_deps'] = RE_DEPS_PATTERN.findall(output)
@@ -54,7 +54,7 @@ def make(pkgdir: str, optimize: bool, handler: ProcessHandler) -> Tuple[bool, st
         else:
             handler.watcher.print('Custom optimized makepkg.conf ( {} ) not found'.format(CUSTOM_MAKEPKG_FILE))
 
-    return handler.handle_simple(SimpleProcess(cmd, cwd=pkgdir))
+    return handler.handle_simple(SimpleProcess(cmd, cwd=pkgdir, shell=True))
 
 
 def update_srcinfo(project_dir: str) -> bool:

bauh/gems/arch/pacman.py

@@ -149,7 +149,8 @@ def install_as_process(pkgpaths: Iterable[str], root_password: str, file: bool,
     return SimpleProcess(cmd=cmd,
                          root_password=root_password,
                          cwd=pkgdir,
-                         error_phrases={"error: failed to prepare transaction", 'error: failed to commit transaction', 'error: target not found'})
+                         error_phrases={"error: failed to prepare transaction", 'error: failed to commit transaction', 'error: target not found'},
+                         shell=True)
 
 
 def list_desktop_entries(pkgnames: Set[str]) -> List[str]:
@@ -731,25 +732,24 @@ def upgrade_several(pkgnames: Iterable[str], root_password: str, overwrite_confl
 
     return SimpleProcess(cmd=cmd,
                          root_password=root_password,
-                         error_phrases={'error: failed to prepare transaction', 'error: failed to commit transaction', 'error: target not found'})
+                         error_phrases={'error: failed to prepare transaction', 'error: failed to commit transaction', 'error: target not found'},
+                         shell=True)
 
 
 def download(root_password: str, *pkgnames: str) -> SimpleProcess:
     return SimpleProcess(cmd=['pacman', '-Swdd', *pkgnames, '--noconfirm'],
                          root_password=root_password,
-                         error_phrases={'error: failed to prepare transaction', 'error: failed to commit transaction', 'error: target not found'})
+                         error_phrases={'error: failed to prepare transaction', 'error: failed to commit transaction', 'error: target not found'},
+                         shell=True)
 
 
-def remove_several(pkgnames: Iterable[str], root_password: str, skip_checks: bool = False) -> SystemProcess:
+def remove_several(pkgnames: Iterable[str], root_password: str, skip_checks: bool = False) -> SimpleProcess:
     cmd = ['pacman', '-R', *pkgnames, '--noconfirm']
 
     if skip_checks:
         cmd.append('-dd')
 
-    if root_password:
-        return SystemProcess(new_root_subprocess(cmd, root_password), wrong_error_phrase='warning:')
-    else:
-        return SystemProcess(new_subprocess(cmd), wrong_error_phrase='warning:')
+    return SimpleProcess(cmd=cmd, root_password=root_password, wrong_error_phrases={'warning:'}, shell=True)
 
 
 def map_optional_deps(names: Iterable[str], remote: bool, not_installed: bool = False) -> Dict[str, Dict[str, str]]: