mirror of
https://github.com/Snigdha-OS/snigdhaos-pkgbuilds.git
synced 2025-12-07 08:23:52 +01:00
refactor(cng): rename the packages && dir
This commit is contained in:
Eshan Roy (Eshanized)
819
snigdhaos-calamares/modules/packages/main.py
Normal file
819
snigdhaos-calamares/modules/packages/main.py
Normal file
@@ -0,0 +1,819 @@
|
||||
#!/usr/bin/env python3
|
||||
# -*- coding: utf-8 -*-
|
||||
#
|
||||
# === This file is part of Calamares - <https://calamares.io> ===
|
||||
#
|
||||
# SPDX-FileCopyrightText: 2014 Pier Luigi Fiorini <pierluigi.fiorini@gmail.com>
|
||||
# SPDX-FileCopyrightText: 2015-2017 Teo Mrnjavac <teo@kde.org>
|
||||
# SPDX-FileCopyrightText: 2016-2017 Kyle Robbertze <kyle@aims.ac.za>
|
||||
# SPDX-FileCopyrightText: 2017 Alf Gaida <agaida@siduction.org>
|
||||
# SPDX-FileCopyrightText: 2018 Adriaan de Groot <groot@kde.org>
|
||||
# SPDX-FileCopyrightText: 2018 Philip Müller <philm@manjaro.org>
|
||||
# SPDX-License-Identifier: GPL-3.0-or-later
|
||||
#
|
||||
# Calamares is Free Software: see the License-Identifier above.
|
||||
#
|
||||
|
||||
import abc
|
||||
from string import Template
|
||||
import subprocess
|
||||
|
||||
import libcalamares
|
||||
from libcalamares.utils import check_target_env_call, target_env_call
|
||||
from libcalamares.utils import gettext_path, gettext_languages
|
||||
|
||||
import gettext
|
||||
_translation = gettext.translation("calamares-python",
|
||||
localedir=gettext_path(),
|
||||
languages=gettext_languages(),
|
||||
fallback=True)
|
||||
_ = _translation.gettext
|
||||
_n = _translation.ngettext
|
||||
|
||||
|
||||
total_packages = 0 # For the entire job
|
||||
completed_packages = 0 # Done so far for this job
|
||||
group_packages = 0 # One group of packages from an -install or -remove entry
|
||||
|
||||
# A PM object may set this to a string (take care of translations!)
|
||||
# to override the string produced by pretty_status_message()
|
||||
custom_status_message = None
|
||||
|
||||
INSTALL = object()
|
||||
REMOVE = object()
|
||||
mode_packages = None # Changes to INSTALL or REMOVE
|
||||
|
||||
|
||||
def _change_mode(mode):
|
||||
global mode_packages
|
||||
mode_packages = mode
|
||||
libcalamares.job.setprogress(completed_packages * 1.0 / total_packages)
|
||||
|
||||
|
||||
def pretty_name():
|
||||
return _("Install packages.")
|
||||
|
||||
|
||||
def pretty_status_message():
|
||||
if custom_status_message is not None:
|
||||
return custom_status_message
|
||||
if not group_packages:
|
||||
if (total_packages > 0):
|
||||
# Outside the context of an operation
|
||||
s = _("Processing packages (%(count)d / %(total)d)")
|
||||
else:
|
||||
s = _("Install packages.")
|
||||
|
||||
elif mode_packages is INSTALL:
|
||||
s = _n("Installing one package.",
|
||||
"Installing %(num)d packages.", group_packages)
|
||||
elif mode_packages is REMOVE:
|
||||
s = _n("Removing one package.",
|
||||
"Removing %(num)d packages.", group_packages)
|
||||
else:
|
||||
# No mode, generic description
|
||||
s = _("Install packages.")
|
||||
|
||||
return s % {"num": group_packages,
|
||||
"count": completed_packages,
|
||||
"total": total_packages}
|
||||
|
||||
|
||||
class PackageManager(metaclass=abc.ABCMeta):
|
||||
"""
|
||||
Package manager base class. A subclass implements package management
|
||||
for a specific backend, and must have a class property `backend`
|
||||
with the string identifier for that backend.
|
||||
|
||||
Subclasses are collected below to populate the list of possible
|
||||
backends.
|
||||
"""
|
||||
backend = None
|
||||
|
||||
@abc.abstractmethod
|
||||
def install(self, pkgs, from_local=False):
|
||||
"""
|
||||
Install a list of packages (named) into the system.
|
||||
Although this handles lists, in practice it is called
|
||||
with one package at a time.
|
||||
|
||||
@param pkgs: list[str]
|
||||
list of package names
|
||||
@param from_local: bool
|
||||
if True, then these are local packages (on disk) and the
|
||||
pkgs names are paths.
|
||||
"""
|
||||
pass
|
||||
|
||||
@abc.abstractmethod
|
||||
def remove(self, pkgs):
|
||||
"""
|
||||
Removes packages.
|
||||
|
||||
@param pkgs: list[str]
|
||||
list of package names
|
||||
"""
|
||||
pass
|
||||
|
||||
@abc.abstractmethod
|
||||
def update_db(self):
|
||||
pass
|
||||
|
||||
def run(self, script):
|
||||
if script != "":
|
||||
check_target_env_call(script.split(" "))
|
||||
|
||||
def install_package(self, packagedata, from_local=False):
|
||||
"""
|
||||
Install a package from a single entry in the install list.
|
||||
This can be either a single package name, or an object
|
||||
with pre- and post-scripts. If @p packagedata is a dict,
|
||||
it is assumed to follow the documented structure.
|
||||
|
||||
@param packagedata: str|dict
|
||||
@param from_local: bool
|
||||
see install.from_local
|
||||
"""
|
||||
if isinstance(packagedata, str):
|
||||
self.install([packagedata], from_local=from_local)
|
||||
else:
|
||||
self.run(packagedata["pre-script"])
|
||||
self.install([packagedata["package"]], from_local=from_local)
|
||||
self.run(packagedata["post-script"])
|
||||
|
||||
def remove_package(self, packagedata):
|
||||
"""
|
||||
Remove a package from a single entry in the remove list.
|
||||
This can be either a single package name, or an object
|
||||
with pre- and post-scripts. If @p packagedata is a dict,
|
||||
it is assumed to follow the documented structure.
|
||||
|
||||
@param packagedata: str|dict
|
||||
"""
|
||||
if isinstance(packagedata, str):
|
||||
self.remove([packagedata])
|
||||
else:
|
||||
self.run(packagedata["pre-script"])
|
||||
self.remove([packagedata["package"]])
|
||||
self.run(packagedata["post-script"])
|
||||
|
||||
def operation_install(self, package_list, from_local=False):
|
||||
"""
|
||||
Installs the list of packages named in @p package_list .
|
||||
These can be strings -- plain package names -- or
|
||||
structures (with a pre- and post-install step).
|
||||
|
||||
This operation is called for "critical" packages,
|
||||
which are expected to succeed, or fail, all together.
|
||||
However, if there are packages with pre- or post-scripts,
|
||||
then packages are installed one-by-one instead.
|
||||
|
||||
NOTE: package managers may reimplement this method
|
||||
NOTE: exceptions are expected to leave this method, to indicate
|
||||
failure of the installation.
|
||||
"""
|
||||
if all([isinstance(x, str) for x in package_list]):
|
||||
self.install(package_list, from_local=from_local)
|
||||
else:
|
||||
for package in package_list:
|
||||
self.install_package(package, from_local=from_local)
|
||||
|
||||
def operation_try_install(self, package_list):
|
||||
"""
|
||||
Installs the list of packages named in @p package_list .
|
||||
These can be strings -- plain package names -- or
|
||||
structures (with a pre- and post-install step).
|
||||
|
||||
This operation is called for "non-critical" packages,
|
||||
which can succeed or fail without affecting the overall installation.
|
||||
Packages are installed one-by-one to support package managers
|
||||
that do not have a "install as much as you can" mode.
|
||||
|
||||
NOTE: package managers may reimplement this method
|
||||
NOTE: no package-installation exceptions should be raised
|
||||
"""
|
||||
# we make a separate package manager call for each package so a
|
||||
# single failing package won't stop all of them
|
||||
for package in package_list:
|
||||
try:
|
||||
self.install_package(package)
|
||||
except subprocess.CalledProcessError:
|
||||
libcalamares.utils.warning("Could not install package %s" % package)
|
||||
|
||||
def operation_remove(self, package_list):
|
||||
"""
|
||||
Removes the list of packages named in @p package_list .
|
||||
These can be strings -- plain package names -- or
|
||||
structures (with a pre- and post-install step).
|
||||
|
||||
This operation is called for "critical" packages, which are
|
||||
expected to succeed or fail all together.
|
||||
However, if there are packages with pre- or post-scripts,
|
||||
then packages are removed one-by-one instead.
|
||||
|
||||
NOTE: package managers may reimplement this method
|
||||
NOTE: exceptions should be raised to indicate failure
|
||||
"""
|
||||
if all([isinstance(x, str) for x in package_list]):
|
||||
self.remove(package_list)
|
||||
else:
|
||||
for package in package_list:
|
||||
self.remove_package(package)
|
||||
|
||||
def operation_try_remove(self, package_list):
|
||||
"""
|
||||
Same relation as try_install has to install, except it removes
|
||||
packages instead. Packages are removed one-by-one.
|
||||
|
||||
NOTE: package managers may reimplement this method
|
||||
NOTE: no package-installation exceptions should be raised
|
||||
"""
|
||||
for package in package_list:
|
||||
try:
|
||||
self.remove_package(package)
|
||||
except subprocess.CalledProcessError:
|
||||
libcalamares.utils.warning("Could not remove package %s" % package)
|
||||
|
||||
### PACKAGE MANAGER IMPLEMENTATIONS
|
||||
#
|
||||
# Keep these alphabetical (presumably both by class name and backend name),
|
||||
# even the Dummy implementation.
|
||||
#
|
||||
|
||||
class PMApk(PackageManager):
|
||||
backend = "apk"
|
||||
|
||||
def install(self, pkgs, from_local=False):
|
||||
for pkg in pkgs:
|
||||
check_target_env_call(["apk", "add", pkg])
|
||||
|
||||
def remove(self, pkgs):
|
||||
for pkg in pkgs:
|
||||
check_target_env_call(["apk", "del", pkg])
|
||||
|
||||
def update_db(self):
|
||||
check_target_env_call(["apk", "update"])
|
||||
|
||||
def update_system(self):
|
||||
check_target_env_call(["apk", "upgrade", "--available"])
|
||||
|
||||
|
||||
class PMApt(PackageManager):
|
||||
backend = "apt"
|
||||
|
||||
def install(self, pkgs, from_local=False):
|
||||
check_target_env_call(["apt-get", "-q", "-y", "install"] + pkgs)
|
||||
|
||||
def remove(self, pkgs):
|
||||
check_target_env_call(["apt-get", "--purge", "-q", "-y",
|
||||
"remove"] + pkgs)
|
||||
check_target_env_call(["apt-get", "--purge", "-q", "-y",
|
||||
"autoremove"])
|
||||
|
||||
def update_db(self):
|
||||
check_target_env_call(["apt-get", "update"])
|
||||
|
||||
def update_system(self):
|
||||
# Doesn't need to update the system explicitly
|
||||
pass
|
||||
|
||||
|
||||
class PMDnf(PackageManager):
|
||||
"""
|
||||
This is "legacy" DNF, called DNF-4 even though the
|
||||
executable is dnf-3 in modern Fedora. Executable dnf
|
||||
is a symlink to dnf-3 in systems that use it.
|
||||
"""
|
||||
backend = "dnf"
|
||||
|
||||
def install(self, pkgs, from_local=False):
|
||||
check_target_env_call(["dnf-3", "-y", "install"] + pkgs)
|
||||
|
||||
def remove(self, pkgs):
|
||||
# ignore the error code for now because dnf thinks removing a
|
||||
# nonexistent package is an error
|
||||
target_env_call(["dnf-3", "--disablerepo=*", "-C", "-y",
|
||||
"remove"] + pkgs)
|
||||
|
||||
def update_db(self):
|
||||
# Doesn't need updates
|
||||
pass
|
||||
|
||||
def update_system(self):
|
||||
check_target_env_call(["dnf-3", "-y", "upgrade"])
|
||||
|
||||
|
||||
class PMDnf5(PackageManager):
|
||||
"""
|
||||
This is "modern" DNF, DNF-5 which is for Fedora 41 (presumably)
|
||||
and later. Executable dnf is a symlink to dnf5 in systems that use it.
|
||||
"""
|
||||
backend = "dnf5"
|
||||
|
||||
def install(self, pkgs, from_local=False):
|
||||
check_target_env_call(["dnf5", "-y", "install"] + pkgs)
|
||||
|
||||
def remove(self, pkgs):
|
||||
# ignore the error code for now because dnf thinks removing a
|
||||
# nonexistent package is an error
|
||||
target_env_call(["dnf5", "--disablerepo=*", "-C", "-y",
|
||||
"remove"] + pkgs)
|
||||
|
||||
def update_db(self):
|
||||
# Doesn't need updates
|
||||
pass
|
||||
|
||||
def update_system(self):
|
||||
check_target_env_call(["dnf5", "-y", "upgrade"])
|
||||
|
||||
|
||||
class PMDummy(PackageManager):
|
||||
backend = "dummy"
|
||||
|
||||
def install(self, pkgs, from_local=False):
|
||||
from time import sleep
|
||||
libcalamares.utils.debug("Dummy backend: Installing " + str(pkgs))
|
||||
sleep(3)
|
||||
|
||||
def remove(self, pkgs):
|
||||
from time import sleep
|
||||
libcalamares.utils.debug("Dummy backend: Removing " + str(pkgs))
|
||||
sleep(3)
|
||||
|
||||
def update_db(self):
|
||||
libcalamares.utils.debug("Dummy backend: Updating DB")
|
||||
|
||||
def update_system(self):
|
||||
libcalamares.utils.debug("Dummy backend: Updating System")
|
||||
|
||||
def run(self, script):
|
||||
libcalamares.utils.debug("Dummy backend: Running script '" + str(script) + "'")
|
||||
|
||||
|
||||
class PMEntropy(PackageManager):
|
||||
backend = "entropy"
|
||||
|
||||
def install(self, pkgs, from_local=False):
|
||||
check_target_env_call(["equo", "i"] + pkgs)
|
||||
|
||||
def remove(self, pkgs):
|
||||
check_target_env_call(["equo", "rm"] + pkgs)
|
||||
|
||||
def update_db(self):
|
||||
check_target_env_call(["equo", "update"])
|
||||
|
||||
def update_system(self):
|
||||
# Doesn't need to update the system explicitly
|
||||
pass
|
||||
|
||||
class PMFlatpak(PackageManager):
|
||||
backend = "flatpak"
|
||||
|
||||
def install(self, pkgs, from_local=False):
|
||||
check_target_env_call(["flatpak", "install", "--assumeyes"] + pkgs)
|
||||
|
||||
def remove(self, pkgs):
|
||||
check_target_env_call(["flatpak", "uninstall", "--noninteractive"] + pkgs)
|
||||
|
||||
def update_db(self):
|
||||
pass
|
||||
|
||||
def update_system(self):
|
||||
# Doesn't need to update the system explicitly
|
||||
pass
|
||||
|
||||
class PMLuet(PackageManager):
|
||||
backend = "luet"
|
||||
|
||||
def install(self, pkgs, from_local=False):
|
||||
check_target_env_call(["luet", "install", "-y"] + pkgs)
|
||||
|
||||
def remove(self, pkgs):
|
||||
check_target_env_call(["luet", "uninstall", "-y"] + pkgs)
|
||||
|
||||
def update_db(self):
|
||||
# Luet checks for DB update everytime its ran.
|
||||
pass
|
||||
|
||||
def update_system(self):
|
||||
check_target_env_call(["luet", "upgrade", "-y"])
|
||||
|
||||
|
||||
class PMPackageKit(PackageManager):
|
||||
backend = "packagekit"
|
||||
|
||||
def install(self, pkgs, from_local=False):
|
||||
for pkg in pkgs:
|
||||
check_target_env_call(["pkcon", "-py", "install", pkg])
|
||||
|
||||
def remove(self, pkgs):
|
||||
for pkg in pkgs:
|
||||
check_target_env_call(["pkcon", "-py", "remove", pkg])
|
||||
|
||||
def update_db(self):
|
||||
check_target_env_call(["pkcon", "refresh"])
|
||||
|
||||
def update_system(self):
|
||||
check_target_env_call(["pkcon", "-py", "update"])
|
||||
|
||||
|
||||
class PMPacman(PackageManager):
|
||||
backend = "pacman"
|
||||
|
||||
def __init__(self):
|
||||
import re
|
||||
progress_match = re.compile("^\\((\\d+)/(\\d+)\\)")
|
||||
|
||||
def line_cb(line):
|
||||
if line.startswith(":: "):
|
||||
self.in_package_changes = "package" in line or "hooks" in line
|
||||
else:
|
||||
if self.in_package_changes and line.endswith("...\n"):
|
||||
# Update the message, untranslated; do not change the
|
||||
# progress percentage, since there may be more "installing..."
|
||||
# lines in the output for the group, than packages listed
|
||||
# explicitly. We don't know how to calculate proper progress.
|
||||
global custom_status_message
|
||||
custom_status_message = "pacman: " + line.strip()
|
||||
libcalamares.job.setprogress(self.progress_fraction)
|
||||
libcalamares.utils.debug(line)
|
||||
|
||||
self.in_package_changes = False
|
||||
self.line_cb = line_cb
|
||||
|
||||
pacman = libcalamares.job.configuration.get("pacman", None)
|
||||
if pacman is None:
|
||||
pacman = dict()
|
||||
if type(pacman) is not dict:
|
||||
libcalamares.utils.warning("Job configuration *pacman* will be ignored.")
|
||||
pacman = dict()
|
||||
self.pacman_num_retries = pacman.get("num_retries", 0)
|
||||
self.pacman_disable_timeout = pacman.get("disable_download_timeout", False)
|
||||
self.pacman_needed_only = pacman.get("needed_only", False)
|
||||
|
||||
def reset_progress(self):
|
||||
self.in_package_changes = False
|
||||
# These are globals
|
||||
self.progress_fraction = (completed_packages * 1.0 / total_packages)
|
||||
|
||||
def run_pacman(self, command, callback=False):
|
||||
"""
|
||||
Call pacman in a loop until it is successful or the number of retries is exceeded
|
||||
:param command: The pacman command to run
|
||||
:param callback: An optional boolean that indicates if this pacman run should use the callback
|
||||
:return:
|
||||
"""
|
||||
|
||||
pacman_count = 0
|
||||
while pacman_count <= self.pacman_num_retries:
|
||||
pacman_count += 1
|
||||
try:
|
||||
if False: # callback:
|
||||
libcalamares.utils.target_env_process_output(command, self.line_cb)
|
||||
else:
|
||||
libcalamares.utils.target_env_process_output(command)
|
||||
|
||||
return
|
||||
except subprocess.CalledProcessError:
|
||||
if pacman_count <= self.pacman_num_retries:
|
||||
pass
|
||||
else:
|
||||
raise
|
||||
|
||||
def install(self, pkgs, from_local=False):
|
||||
command = ["pacman"]
|
||||
|
||||
if from_local:
|
||||
command.append("-U")
|
||||
else:
|
||||
command.append("-S")
|
||||
|
||||
# Don't ask for user intervention, take the default action
|
||||
command.append("--noconfirm")
|
||||
|
||||
# Don't report download progress for each file
|
||||
command.append("--noprogressbar")
|
||||
|
||||
if self.pacman_needed_only is True:
|
||||
command.append("--needed")
|
||||
command.append("--ask=4")
|
||||
|
||||
if self.pacman_disable_timeout is True:
|
||||
command.append("--disable-download-timeout")
|
||||
|
||||
command += pkgs
|
||||
|
||||
self.reset_progress()
|
||||
self.run_pacman(command, True)
|
||||
|
||||
def remove(self, pkgs):
|
||||
self.reset_progress()
|
||||
self.run_pacman(["pacman", "-Rs", "--noconfirm"] + pkgs, True)
|
||||
|
||||
def update_db(self):
|
||||
self.run_pacman(["pacman", "-Sy"])
|
||||
|
||||
def update_system(self):
|
||||
self.run_pacman(["pacman", "-S", "archlinux-keyring", "--noconfirm"])
|
||||
command = ["pacman", "-Su", "--noconfirm"]
|
||||
if self.pacman_disable_timeout is True:
|
||||
command.append("--disable-download-timeout")
|
||||
|
||||
self.run_pacman(command)
|
||||
|
||||
|
||||
class PMPamac(PackageManager):
|
||||
backend = "pamac"
|
||||
|
||||
def del_db_lock(self, lock="/var/lib/pacman/db.lck"):
|
||||
# In case some error or crash, the database will be locked,
|
||||
# resulting in remaining packages not being installed.
|
||||
check_target_env_call(["rm", "-f", lock])
|
||||
|
||||
def install(self, pkgs, from_local=False):
|
||||
self.del_db_lock()
|
||||
check_target_env_call([self.backend, "install", "--no-confirm"] + pkgs)
|
||||
|
||||
def remove(self, pkgs):
|
||||
self.del_db_lock()
|
||||
check_target_env_call([self.backend, "remove", "--no-confirm"] + pkgs)
|
||||
|
||||
def update_db(self):
|
||||
self.del_db_lock()
|
||||
check_target_env_call([self.backend, "update", "--no-confirm"])
|
||||
|
||||
def update_system(self):
|
||||
self.del_db_lock()
|
||||
check_target_env_call([self.backend, "upgrade", "--no-confirm"])
|
||||
|
||||
|
||||
class PMPisi(PackageManager):
|
||||
backend = "pisi"
|
||||
|
||||
def install(self, pkgs, from_local=False):
|
||||
check_target_env_call(["pisi", "install" "-y"] + pkgs)
|
||||
|
||||
def remove(self, pkgs):
|
||||
check_target_env_call(["pisi", "remove", "-y"] + pkgs)
|
||||
|
||||
def update_db(self):
|
||||
check_target_env_call(["pisi", "update-repo"])
|
||||
|
||||
def update_system(self):
|
||||
# Doesn't need to update the system explicitly
|
||||
pass
|
||||
|
||||
|
||||
class PMPortage(PackageManager):
|
||||
backend = "portage"
|
||||
|
||||
def install(self, pkgs, from_local=False):
|
||||
check_target_env_call(["emerge", "-v"] + pkgs)
|
||||
|
||||
def remove(self, pkgs):
|
||||
check_target_env_call(["emerge", "-C"] + pkgs)
|
||||
check_target_env_call(["emerge", "--depclean", "-q"])
|
||||
|
||||
def update_db(self):
|
||||
check_target_env_call(["emerge", "--sync"])
|
||||
|
||||
def update_system(self):
|
||||
# Doesn't need to update the system explicitly
|
||||
pass
|
||||
|
||||
|
||||
class PMXbps(PackageManager):
|
||||
backend = "xbps"
|
||||
|
||||
def install(self, pkgs, from_local=False):
|
||||
check_target_env_call(["xbps-install", "-Sy"] + pkgs)
|
||||
|
||||
def remove(self, pkgs):
|
||||
check_target_env_call(["xbps-remove", "-Ry", "--noconfirm"] + pkgs)
|
||||
|
||||
def update_db(self):
|
||||
check_target_env_call(["xbps-install", "-S"])
|
||||
|
||||
def update_system(self):
|
||||
check_target_env_call(["xbps", "-Suy"])
|
||||
|
||||
|
||||
class PMYum(PackageManager):
|
||||
backend = "yum"
|
||||
|
||||
def install(self, pkgs, from_local=False):
|
||||
check_target_env_call(["yum", "-y", "install"] + pkgs)
|
||||
|
||||
def remove(self, pkgs):
|
||||
check_target_env_call(["yum", "--disablerepo=*", "-C", "-y",
|
||||
"remove"] + pkgs)
|
||||
|
||||
def update_db(self):
|
||||
# Doesn't need updates
|
||||
pass
|
||||
|
||||
def update_system(self):
|
||||
check_target_env_call(["yum", "-y", "upgrade"])
|
||||
|
||||
|
||||
class PMZypp(PackageManager):
|
||||
backend = "zypp"
|
||||
|
||||
def install(self, pkgs, from_local=False):
|
||||
check_target_env_call(["zypper", "--non-interactive",
|
||||
"--quiet-install", "install",
|
||||
"--auto-agree-with-licenses",
|
||||
"install"] + pkgs)
|
||||
|
||||
def remove(self, pkgs):
|
||||
check_target_env_call(["zypper", "--non-interactive",
|
||||
"remove"] + pkgs)
|
||||
|
||||
def update_db(self):
|
||||
check_target_env_call(["zypper", "--non-interactive", "update"])
|
||||
|
||||
def update_system(self):
|
||||
# Doesn't need to update the system explicitly
|
||||
pass
|
||||
|
||||
|
||||
# Collect all the subclasses of PackageManager defined above,
|
||||
# and index them based on the backend property of each class.
|
||||
backend_managers = [
|
||||
(c.backend, c)
|
||||
for c in globals().values()
|
||||
if type(c) is abc.ABCMeta and issubclass(c, PackageManager) and c.backend]
|
||||
|
||||
|
||||
def subst_locale(plist):
|
||||
"""
|
||||
Returns a locale-aware list of packages, based on @p plist.
|
||||
Package names that contain LOCALE are localized with the
|
||||
BCP47 name of the chosen system locale; if the system
|
||||
locale is 'en' (e.g. English, US) then these localized
|
||||
packages are dropped from the list.
|
||||
|
||||
@param plist: list[str|dict]
|
||||
Candidate packages to install.
|
||||
@return: list[str|dict]
|
||||
"""
|
||||
locale = libcalamares.globalstorage.value("locale")
|
||||
if not locale:
|
||||
# It is possible to skip the locale-setting entirely.
|
||||
# Then pretend it is "en", so that {LOCALE}-decorated
|
||||
# package names are removed from the list.
|
||||
locale = "en"
|
||||
|
||||
ret = []
|
||||
for packagedata in plist:
|
||||
if isinstance(packagedata, str):
|
||||
packagename = packagedata
|
||||
else:
|
||||
packagename = packagedata["package"]
|
||||
|
||||
# Update packagename: substitute LOCALE, and drop packages
|
||||
# if locale is en and LOCALE is in the package name.
|
||||
if locale != "en":
|
||||
packagename = Template(packagename).safe_substitute(LOCALE=locale)
|
||||
elif 'LOCALE' in packagename:
|
||||
packagename = None
|
||||
|
||||
if packagename is not None:
|
||||
# Put it back in packagedata
|
||||
if isinstance(packagedata, str):
|
||||
packagedata = packagename
|
||||
else:
|
||||
packagedata["package"] = packagename
|
||||
|
||||
ret.append(packagedata)
|
||||
|
||||
return ret
|
||||
|
||||
|
||||
def run_operations(pkgman, entry):
|
||||
"""
|
||||
Call package manager with suitable parameters for the given
|
||||
package actions.
|
||||
|
||||
:param pkgman: PackageManager
|
||||
This is the manager that does the actual work.
|
||||
:param entry: dict
|
||||
Keys are the actions -- e.g. "install" -- to take, and the values
|
||||
are the (list of) packages to apply the action to. The actions are
|
||||
not iterated in a specific order, so it is recommended to use only
|
||||
one action per dictionary. The list of packages may be package
|
||||
names (strings) or package information dictionaries with pre-
|
||||
and post-scripts.
|
||||
"""
|
||||
global group_packages, completed_packages, mode_packages
|
||||
|
||||
for key in entry.keys():
|
||||
package_list = subst_locale(entry[key])
|
||||
group_packages = len(package_list)
|
||||
if key == "install":
|
||||
_change_mode(INSTALL)
|
||||
pkgman.operation_install(package_list)
|
||||
elif key == "try_install":
|
||||
_change_mode(INSTALL)
|
||||
pkgman.operation_try_install(package_list)
|
||||
elif key == "remove":
|
||||
_change_mode(REMOVE)
|
||||
pkgman.operation_remove(package_list)
|
||||
elif key == "try_remove":
|
||||
_change_mode(REMOVE)
|
||||
pkgman.operation_try_remove(package_list)
|
||||
elif key == "localInstall":
|
||||
_change_mode(INSTALL)
|
||||
pkgman.operation_install(package_list, from_local=True)
|
||||
elif key == "source":
|
||||
libcalamares.utils.debug("Package-list from {!s}".format(entry[key]))
|
||||
else:
|
||||
libcalamares.utils.warning("Unknown package-operation key {!s}".format(key))
|
||||
completed_packages += len(package_list)
|
||||
libcalamares.job.setprogress(completed_packages * 1.0 / total_packages)
|
||||
libcalamares.utils.debug("Pretty name: {!s}, setting progress..".format(pretty_name()))
|
||||
|
||||
group_packages = 0
|
||||
_change_mode(None)
|
||||
|
||||
|
||||
def run():
|
||||
"""
|
||||
Calls routine with detected package manager to install locale packages
|
||||
or remove drivers not needed on the installed system.
|
||||
|
||||
:return:
|
||||
"""
|
||||
global mode_packages, total_packages, completed_packages, group_packages
|
||||
|
||||
backend = libcalamares.job.configuration.get("backend")
|
||||
|
||||
for identifier, impl in backend_managers:
|
||||
if identifier == backend:
|
||||
pkgman = impl()
|
||||
break
|
||||
else:
|
||||
return "Bad backend", "backend=\"{}\"".format(backend)
|
||||
|
||||
skip_this = libcalamares.job.configuration.get("skip_if_no_internet", False)
|
||||
if skip_this and not libcalamares.globalstorage.value("hasInternet"):
|
||||
libcalamares.utils.warning( "Package installation has been skipped: no internet" )
|
||||
return None
|
||||
|
||||
update_db = libcalamares.job.configuration.get("update_db", False)
|
||||
if update_db and libcalamares.globalstorage.value("hasInternet"):
|
||||
try:
|
||||
pkgman.update_db()
|
||||
except subprocess.CalledProcessError as e:
|
||||
libcalamares.utils.warning(str(e))
|
||||
libcalamares.utils.debug("stdout:" + str(e.stdout))
|
||||
libcalamares.utils.debug("stderr:" + str(e.stderr))
|
||||
return (_("Package Manager error"),
|
||||
_("The package manager could not prepare updates. The command <pre>{!s}</pre> returned error code {!s}.")
|
||||
.format(e.cmd, e.returncode))
|
||||
|
||||
update_system = libcalamares.job.configuration.get("update_system", False)
|
||||
if update_system and libcalamares.globalstorage.value("hasInternet"):
|
||||
try:
|
||||
pkgman.update_system()
|
||||
except subprocess.CalledProcessError as e:
|
||||
libcalamares.utils.warning(str(e))
|
||||
libcalamares.utils.debug("stdout:" + str(e.stdout))
|
||||
libcalamares.utils.debug("stderr:" + str(e.stderr))
|
||||
return (_("Package Manager error"),
|
||||
_("The package manager could not update the system. The command <pre>{!s}</pre> returned error code {!s}.")
|
||||
.format(e.cmd, e.returncode))
|
||||
|
||||
operations = libcalamares.job.configuration.get("operations", [])
|
||||
if libcalamares.globalstorage.contains("packageOperations"):
|
||||
operations += libcalamares.globalstorage.value("packageOperations")
|
||||
|
||||
mode_packages = None
|
||||
total_packages = 0
|
||||
completed_packages = 0
|
||||
for op in operations:
|
||||
for packagelist in op.values():
|
||||
total_packages += len(subst_locale(packagelist))
|
||||
|
||||
if not total_packages:
|
||||
# Avoids potential divide-by-zero in progress reporting
|
||||
return None
|
||||
|
||||
for entry in operations:
|
||||
group_packages = 0
|
||||
libcalamares.utils.debug(pretty_name())
|
||||
try:
|
||||
run_operations(pkgman, entry)
|
||||
except subprocess.CalledProcessError as e:
|
||||
libcalamares.utils.warning(str(e))
|
||||
libcalamares.utils.debug("stdout:" + str(e.stdout))
|
||||
libcalamares.utils.debug("stderr:" + str(e.stderr))
|
||||
return (_("Package Manager error"),
|
||||
_("The package manager could not make changes to the installed system. The command <pre>{!s}</pre> returned error code {!s}.")
|
||||
.format(e.cmd, e.returncode))
|
||||
|
||||
mode_packages = None
|
||||
|
||||
libcalamares.job.setprogress(1.0)
|
||||
|
||||
return None
|
||||
Reference in New Issue
Block a user