22

✏️ Editing: kernelpkg_linux_apt.py

"""
Manage Linux kernel packages on APT-based systems
"""

import functools
import logging
import re

from salt.exceptions import CommandExecutionError
from salt.utils.versions import LooseVersion

log = logging.getLogger(__name__)

__virtualname__ = "kernelpkg"

def __virtual__():
    """
    Load this module on Debian-based systems only
    """
    if __grains__.get("os_family", "") in ("Kali", "Debian"):
        return __virtualname__
    elif __grains__.get("os_family", "") == "Cumulus":
        return __virtualname__

return (False, "Module kernelpkg_linux_apt: no APT based system detected")

def active():
    """
    Return the version of the running kernel.

CLI Example:

.. code-block:: bash

salt '*' kernelpkg.active
    """
    if "pkg.normalize_name" in __salt__:
        return __salt__["pkg.normalize_name"](__grains__["kernelrelease"])

return __grains__["kernelrelease"]

def list_installed():
    """
    Return a list of all installed kernels.

CLI Example:

.. code-block:: bash

salt '*' kernelpkg.list_installed
    """
    pkg_re = re.compile(rf"^{_package_prefix()}-[\d.-]+-{_kernel_type()}$")
    pkgs = __salt__["pkg.list_pkgs"](versions_as_list=True)
    if pkgs is None:
        pkgs = []

result = list(filter(pkg_re.match, pkgs))
    if result is None:
        return []

prefix_len = len(_package_prefix()) + 1

return sorted(
        (pkg[prefix_len:] for pkg in result), key=functools.cmp_to_key(_cmp_version)
    )

def latest_available():
    """
    Return the version of the latest kernel from the package repositories.

CLI Example:

.. code-block:: bash

salt '*' kernelpkg.latest_available
    """
    result = __salt__["pkg.latest_version"](f"{_package_prefix()}-{_kernel_type()}")
    if result == "":
        return latest_installed()

version = re.match(r"^(\d+\.\d+\.\d+)\.(\d+)", result)
    return f"{version.group(1)}-{version.group(2)}-{_kernel_type()}"

def latest_installed():
    """
    Return the version of the latest installed kernel.

CLI Example:

.. code-block:: bash

salt '*' kernelpkg.latest_installed

.. note::
        This function may not return the same value as
        :py:func:`~salt.modules.kernelpkg_linux_apt.active` if a new kernel
        has been installed and the system has not yet been rebooted.
        The :py:func:`~salt.modules.kernelpkg_linux_apt.needs_reboot` function
        exists to detect this condition.
    """
    pkgs = list_installed()
    if pkgs:
        return pkgs[-1]

return None

def needs_reboot():
    """
    Detect if a new kernel version has been installed but is not running.
    Returns True if a new kernel is installed, False otherwise.

CLI Example:

.. code-block:: bash

salt '*' kernelpkg.needs_reboot
    """
    return LooseVersion(active()) < LooseVersion(latest_installed())

def upgrade(reboot=False, at_time=None):
    """
    Upgrade the kernel and optionally reboot the system.

reboot : False
        Request a reboot if a new kernel is available.

at_time : immediate
        Schedule the reboot at some point in the future. This argument
        is ignored if ``reboot=False``. See
        :py:func:`~salt.modules.system.reboot` for more details
        on this argument.

CLI Example:

.. code-block:: bash

salt '*' kernelpkg.upgrade
        salt '*' kernelpkg.upgrade reboot=True at_time=1

.. note::
        An immediate reboot often shuts down the system before the minion has a
        chance to return, resulting in errors. A minimal delay (1 minute) is
        useful to ensure the result is delivered to the master.
    """
    result = __salt__["pkg.install"](name=f"{_package_prefix()}-{latest_available()}")
    _needs_reboot = needs_reboot()

ret = {
        "upgrades": result,
        "active": active(),
        "latest_installed": latest_installed(),
        "reboot_requested": reboot,
        "reboot_required": _needs_reboot,
    }

if reboot and _needs_reboot:
        log.warning("Rebooting system due to kernel upgrade")
        __salt__["system.reboot"](at_time=at_time)

return ret

def upgrade_available():
    """
    Detect if a new kernel version is available in the repositories.
    Returns True if a new kernel is available, False otherwise.

CLI Example:

.. code-block:: bash

salt '*' kernelpkg.upgrade_available
    """
    return LooseVersion(latest_available()) > LooseVersion(latest_installed())

def remove(release):
    """
    Remove a specific version of the kernel.

release
        The release number of an installed kernel. This must be the entire release
        number as returned by :py:func:`~salt.modules.kernelpkg_linux_apt.list_installed`,
        not the package name.

CLI Example:

.. code-block:: bash

salt '*' kernelpkg.remove 4.4.0-70-generic
    """
    if release not in list_installed():
        raise CommandExecutionError(f"Kernel release '{release}' is not installed")

if release == active():
        raise CommandExecutionError("Active kernel cannot be removed")

target = f"{_package_prefix()}-{release}"
    log.info("Removing kernel package %s", target)

__salt__["pkg.purge"](target)

return {"removed": [target]}

def cleanup(keep_latest=True):
    """
    Remove all unused kernel packages from the system.

keep_latest : True
        In the event that the active kernel is not the latest one installed, setting this to True
        will retain the latest kernel package, in addition to the active one. If False, all kernel
        packages other than the active one will be removed.

CLI Example:

.. code-block:: bash

salt '*' kernelpkg.cleanup
    """
    removed = []

# Loop over all installed kernel packages
    for kernel in list_installed():

# Keep the active kernel package
        if kernel == active():
            continue

# Optionally keep the latest kernel package
        if keep_latest and kernel == latest_installed():
            continue

# Remove the kernel package
        removed.extend(remove(kernel)["removed"])

return {"removed": removed}

def _package_prefix():
    """
    Return static string for the package prefix
    """
    return "linux-image"

def _kernel_type():
    """
    Parse the kernel name and return its type
    """
    return re.match(r"^[\d.-]+-(.+)$", active()).group(1)

def _cmp_version(item1, item2):
    """
    Compare function for package version sorting
    """
    vers1 = LooseVersion(item1)
    vers2 = LooseVersion(item2)

if vers1 < vers2:
        return -1
    if vers1 > vers2:
        return 1
    return 0

MR SKB