mirror of
https://github.com/ansible-collections/community.general.git
synced 2026-02-04 07:51:50 +00:00
301 lines
9.2 KiB
Python
301 lines
9.2 KiB
Python
#!/usr/bin/python
|
|
|
|
# Copyright (c) 2017, Kairo Araujo <kairo@kairo.eti.br>
|
|
# GNU General Public License v3.0+ (see LICENSES/GPL-3.0-or-later.txt or https://www.gnu.org/licenses/gpl-3.0.txt)
|
|
# SPDX-License-Identifier: GPL-3.0-or-later
|
|
|
|
from __future__ import annotations
|
|
|
|
DOCUMENTATION = r"""
|
|
module: installp
|
|
author:
|
|
- Kairo Araujo (@kairoaraujo)
|
|
short_description: Manage packages on AIX
|
|
description:
|
|
- Manage packages using 'installp' on AIX.
|
|
extends_documentation_fragment:
|
|
- community.general.attributes
|
|
attributes:
|
|
check_mode:
|
|
support: full
|
|
diff_mode:
|
|
support: none
|
|
options:
|
|
accept_license:
|
|
description:
|
|
- Whether to accept the license for the package(s).
|
|
type: bool
|
|
default: false
|
|
name:
|
|
description:
|
|
- One or more packages to install or remove.
|
|
- Use V(all) to install all packages available on informed O(repository_path).
|
|
type: list
|
|
elements: str
|
|
required: true
|
|
aliases: [pkg]
|
|
repository_path:
|
|
description:
|
|
- Path with AIX packages (required to install).
|
|
type: path
|
|
state:
|
|
description:
|
|
- Whether the package needs to be present on or absent from the system.
|
|
type: str
|
|
choices: [absent, present]
|
|
default: present
|
|
notes:
|
|
- If the package is already installed, even the package/fileset is new, the module does not install it.
|
|
"""
|
|
|
|
EXAMPLES = r"""
|
|
- name: Install package foo
|
|
community.general.installp:
|
|
name: foo
|
|
repository_path: /repository/AIX71/installp/base
|
|
accept_license: true
|
|
state: present
|
|
|
|
- name: Install bos.sysmgt that includes bos.sysmgt.nim.master, bos.sysmgt.nim.spot
|
|
community.general.installp:
|
|
name: bos.sysmgt
|
|
repository_path: /repository/AIX71/installp/base
|
|
accept_license: true
|
|
state: present
|
|
|
|
- name: Install bos.sysmgt.nim.master only
|
|
community.general.installp:
|
|
name: bos.sysmgt.nim.master
|
|
repository_path: /repository/AIX71/installp/base
|
|
accept_license: true
|
|
state: present
|
|
|
|
- name: Install bos.sysmgt.nim.master and bos.sysmgt.nim.spot
|
|
community.general.installp:
|
|
name: bos.sysmgt.nim.master, bos.sysmgt.nim.spot
|
|
repository_path: /repository/AIX71/installp/base
|
|
accept_license: true
|
|
state: present
|
|
|
|
- name: Remove packages bos.sysmgt.nim.master
|
|
community.general.installp:
|
|
name: bos.sysmgt.nim.master
|
|
state: absent
|
|
"""
|
|
|
|
RETURN = r""" # """
|
|
|
|
import os
|
|
import re
|
|
|
|
from ansible.module_utils.basic import AnsibleModule
|
|
|
|
|
|
def _check_new_pkg(module, package, repository_path):
|
|
"""
|
|
Check if the package of fileset is correct name and repository path.
|
|
|
|
:param module: Ansible module arguments spec.
|
|
:param package: Package/fileset name.
|
|
:param repository_path: Repository package path.
|
|
:return: Bool, package information.
|
|
"""
|
|
|
|
if os.path.isdir(repository_path):
|
|
installp_cmd = module.get_bin_path("installp", True)
|
|
rc, package_result, err = module.run_command([installp_cmd, "-l", "-MR", "-d", repository_path])
|
|
if rc != 0:
|
|
module.fail_json(msg="Failed to run installp.", rc=rc, err=err)
|
|
|
|
if package == "all":
|
|
pkg_info = "All packages on dir"
|
|
return True, pkg_info
|
|
|
|
else:
|
|
pkg_info = {}
|
|
for line in package_result.splitlines():
|
|
if re.findall(package, line):
|
|
pkg_name = line.split()[0].strip()
|
|
pkg_version = line.split()[1].strip()
|
|
pkg_info[pkg_name] = pkg_version
|
|
|
|
return True, pkg_info
|
|
|
|
return False, None
|
|
|
|
else:
|
|
module.fail_json(msg=f"Repository path {repository_path} is not valid.")
|
|
|
|
|
|
def _check_installed_pkg(module, package, repository_path):
|
|
"""
|
|
Check the package on AIX.
|
|
It verifies if the package is installed and information
|
|
|
|
:param module: Ansible module parameters spec.
|
|
:param package: Package/fileset name.
|
|
:param repository_path: Repository package path.
|
|
:return: Bool, package data.
|
|
"""
|
|
|
|
lslpp_cmd = module.get_bin_path("lslpp", True)
|
|
rc, lslpp_result, err = module.run_command([lslpp_cmd, "-lcq", f"{package}*"])
|
|
|
|
if rc == 1:
|
|
package_state = " ".join(err.split()[-2:])
|
|
if package_state == "not installed.":
|
|
return False, None
|
|
else:
|
|
module.fail_json(msg="Failed to run lslpp.", rc=rc, err=err)
|
|
|
|
if rc != 0:
|
|
module.fail_json(msg="Failed to run lslpp.", rc=rc, err=err)
|
|
|
|
pkg_data = {}
|
|
full_pkg_data = lslpp_result.splitlines()
|
|
for line in full_pkg_data:
|
|
pkg_name, fileset, level = line.split(":")[0:3]
|
|
pkg_data[pkg_name] = fileset, level
|
|
|
|
return True, pkg_data
|
|
|
|
|
|
def remove(module, installp_cmd, packages):
|
|
repository_path = None
|
|
remove_count = 0
|
|
removed_pkgs = []
|
|
not_found_pkg = []
|
|
for package in packages:
|
|
pkg_check, dummy = _check_installed_pkg(module, package, repository_path)
|
|
|
|
if pkg_check:
|
|
if not module.check_mode:
|
|
rc, remove_out, err = module.run_command([installp_cmd, "-u", package])
|
|
if rc != 0:
|
|
module.fail_json(msg="Failed to run installp.", rc=rc, err=err)
|
|
remove_count += 1
|
|
removed_pkgs.append(package)
|
|
|
|
else:
|
|
not_found_pkg.append(package)
|
|
|
|
if remove_count > 0:
|
|
if len(not_found_pkg) > 1:
|
|
not_found_pkg.insert(0, "Package(s) not found: ")
|
|
|
|
changed = True
|
|
msg = f"Packages removed: {' '.join(removed_pkgs)}. {' '.join(not_found_pkg)} "
|
|
|
|
else:
|
|
changed = False
|
|
msg = f"No packages removed, all packages not found: {' '.join(not_found_pkg)}"
|
|
|
|
return changed, msg
|
|
|
|
|
|
def install(module, installp_cmd, packages, repository_path, accept_license):
|
|
installed_pkgs = []
|
|
not_found_pkgs = []
|
|
already_installed_pkgs = {}
|
|
|
|
accept_license_param = {
|
|
True: ["-Y"],
|
|
False: [],
|
|
}
|
|
|
|
# Validate if package exists on repository path.
|
|
for package in packages:
|
|
pkg_check, pkg_data = _check_new_pkg(module, package, repository_path)
|
|
|
|
# If package exists on repository path, check if package is installed.
|
|
if pkg_check:
|
|
pkg_check_current, pkg_info = _check_installed_pkg(module, package, repository_path)
|
|
|
|
# If package is already installed.
|
|
if pkg_check_current:
|
|
# Check if package is a package and not a fileset, get version
|
|
# and add the package into already installed list
|
|
if package in pkg_info.keys():
|
|
already_installed_pkgs[package] = pkg_info[package][1]
|
|
|
|
else:
|
|
# If the package is not a package but a fileset, confirm
|
|
# and add the fileset/package into already installed list
|
|
for key in pkg_info.keys():
|
|
if package in pkg_info[key]:
|
|
already_installed_pkgs[package] = pkg_info[key][1]
|
|
|
|
else:
|
|
if not module.check_mode:
|
|
rc, out, err = module.run_command(
|
|
[installp_cmd, "-a"]
|
|
+ accept_license_param[accept_license]
|
|
+ ["-X", "-d", repository_path, package]
|
|
)
|
|
if rc != 0:
|
|
module.fail_json(msg="Failed to run installp", rc=rc, err=err)
|
|
installed_pkgs.append(package)
|
|
|
|
else:
|
|
not_found_pkgs.append(package)
|
|
|
|
if len(installed_pkgs) > 0:
|
|
installed_msg = f" Installed: {' '.join(installed_pkgs)}."
|
|
else:
|
|
installed_msg = ""
|
|
|
|
if len(not_found_pkgs) > 0:
|
|
not_found_msg = f" Not found: {' '.join(not_found_pkgs)}."
|
|
else:
|
|
not_found_msg = ""
|
|
|
|
if len(already_installed_pkgs) > 0:
|
|
already_installed_msg = f" Already installed: {already_installed_pkgs}."
|
|
else:
|
|
already_installed_msg = ""
|
|
|
|
if len(installed_pkgs) > 0:
|
|
changed = True
|
|
msg = f"{installed_msg}{not_found_msg}{already_installed_msg}"
|
|
else:
|
|
changed = False
|
|
msg = f"No packages installed.{installed_msg}{not_found_msg}{already_installed_msg}"
|
|
|
|
return changed, msg
|
|
|
|
|
|
def main():
|
|
module = AnsibleModule(
|
|
argument_spec=dict(
|
|
name=dict(type="list", elements="str", required=True, aliases=["pkg"]),
|
|
repository_path=dict(type="path"),
|
|
accept_license=dict(type="bool", default=False),
|
|
state=dict(type="str", default="present", choices=["absent", "present"]),
|
|
),
|
|
supports_check_mode=True,
|
|
)
|
|
|
|
name = module.params["name"]
|
|
repository_path = module.params["repository_path"]
|
|
accept_license = module.params["accept_license"]
|
|
state = module.params["state"]
|
|
|
|
installp_cmd = module.get_bin_path("installp", True)
|
|
|
|
if state == "present":
|
|
if repository_path is None:
|
|
module.fail_json(msg="repository_path is required to install package")
|
|
|
|
changed, msg = install(module, installp_cmd, name, repository_path, accept_license)
|
|
|
|
elif state == "absent":
|
|
changed, msg = remove(module, installp_cmd, name)
|
|
|
|
else:
|
|
module.fail_json(changed=False, msg="Unexpected state.")
|
|
|
|
module.exit_json(changed=changed, msg=msg)
|
|
|
|
|
|
if __name__ == "__main__":
|
|
main()
|