mirror of
https://github.com/freeipa/ansible-freeipa.git
synced 2026-07-31 20:04:45 +00:00
hostgroup: Use IPAAnsibleModule class
ipaadmin_variables are handled by IPAAnsibleModule, ansible_module.params_get is used to get the parameters and ansible_module.ipa_connect is used to simplify the module.
This commit is contained in:
@@ -32,13 +32,9 @@ DOCUMENTATION = """
|
|||||||
module: ipahostgroup
|
module: ipahostgroup
|
||||||
short description: Manage FreeIPA hostgroups
|
short description: Manage FreeIPA hostgroups
|
||||||
description: Manage FreeIPA hostgroups
|
description: Manage FreeIPA hostgroups
|
||||||
|
extends_documentation_fragment:
|
||||||
|
- ipamodule_base_docs
|
||||||
options:
|
options:
|
||||||
ipaadmin_principal:
|
|
||||||
description: The admin principal
|
|
||||||
default: admin
|
|
||||||
ipaadmin_password:
|
|
||||||
description: The admin password
|
|
||||||
required: false
|
|
||||||
name:
|
name:
|
||||||
description: The hostgroup name
|
description: The hostgroup name
|
||||||
required: false
|
required: false
|
||||||
@@ -138,11 +134,9 @@ EXAMPLES = """
|
|||||||
RETURN = """
|
RETURN = """
|
||||||
"""
|
"""
|
||||||
|
|
||||||
from ansible.module_utils.basic import AnsibleModule
|
from ansible.module_utils.ansible_freeipa_module import \
|
||||||
from ansible.module_utils.ansible_freeipa_module import temp_kinit, \
|
IPAAnsibleModule, compare_args_ipa, gen_add_del_lists, gen_add_list, \
|
||||||
temp_kdestroy, valid_creds, api_connect, api_command, compare_args_ipa, \
|
gen_intersection_list
|
||||||
module_params_get, gen_add_del_lists, api_check_command, api_check_param, \
|
|
||||||
gen_add_list, gen_intersection_list
|
|
||||||
|
|
||||||
|
|
||||||
def find_hostgroup(module, name):
|
def find_hostgroup(module, name):
|
||||||
@@ -151,7 +145,7 @@ def find_hostgroup(module, name):
|
|||||||
"cn": name,
|
"cn": name,
|
||||||
}
|
}
|
||||||
|
|
||||||
_result = api_command(module, "hostgroup_find", name, _args)
|
_result = module.ipa_command("hostgroup_find", name, _args)
|
||||||
|
|
||||||
if len(_result["result"]) > 1:
|
if len(_result["result"]) > 1:
|
||||||
module.fail_json(
|
module.fail_json(
|
||||||
@@ -185,12 +179,9 @@ def gen_member_args(host, hostgroup):
|
|||||||
|
|
||||||
|
|
||||||
def main():
|
def main():
|
||||||
ansible_module = AnsibleModule(
|
ansible_module = IPAAnsibleModule(
|
||||||
argument_spec=dict(
|
argument_spec=dict(
|
||||||
# general
|
# general
|
||||||
ipaadmin_principal=dict(type="str", default="admin"),
|
|
||||||
ipaadmin_password=dict(type="str", required=False, no_log=True),
|
|
||||||
|
|
||||||
name=dict(type="list", aliases=["cn"], default=None,
|
name=dict(type="list", aliases=["cn"], default=None,
|
||||||
required=True),
|
required=True),
|
||||||
# present
|
# present
|
||||||
@@ -217,25 +208,19 @@ def main():
|
|||||||
# Get parameters
|
# Get parameters
|
||||||
|
|
||||||
# general
|
# general
|
||||||
ipaadmin_principal = module_params_get(ansible_module,
|
names = ansible_module.params_get("name")
|
||||||
"ipaadmin_principal")
|
|
||||||
ipaadmin_password = module_params_get(ansible_module,
|
|
||||||
"ipaadmin_password")
|
|
||||||
names = module_params_get(ansible_module, "name")
|
|
||||||
|
|
||||||
# present
|
# present
|
||||||
description = module_params_get(ansible_module, "description")
|
description = ansible_module.params_get("description")
|
||||||
nomembers = module_params_get(ansible_module, "nomembers")
|
nomembers = ansible_module.params_get("nomembers")
|
||||||
host = module_params_get(ansible_module, "host")
|
host = ansible_module.params_get("host")
|
||||||
hostgroup = module_params_get(ansible_module, "hostgroup")
|
hostgroup = ansible_module.params_get("hostgroup")
|
||||||
membermanager_user = module_params_get(ansible_module,
|
membermanager_user = ansible_module.params_get("membermanager_user")
|
||||||
"membermanager_user")
|
membermanager_group = ansible_module.params_get("membermanager_group")
|
||||||
membermanager_group = module_params_get(ansible_module,
|
rename = ansible_module.params_get("rename")
|
||||||
"membermanager_group")
|
action = ansible_module.params_get("action")
|
||||||
rename = module_params_get(ansible_module, "rename")
|
|
||||||
action = module_params_get(ansible_module, "action")
|
|
||||||
# state
|
# state
|
||||||
state = module_params_get(ansible_module, "state")
|
state = ansible_module.params_get("state")
|
||||||
|
|
||||||
# Check parameters
|
# Check parameters
|
||||||
|
|
||||||
@@ -287,15 +272,11 @@ def main():
|
|||||||
|
|
||||||
changed = False
|
changed = False
|
||||||
exit_args = {}
|
exit_args = {}
|
||||||
ccache_dir = None
|
|
||||||
ccache_name = None
|
|
||||||
try:
|
|
||||||
if not valid_creds(ansible_module, ipaadmin_principal):
|
|
||||||
ccache_dir, ccache_name = temp_kinit(ipaadmin_principal,
|
|
||||||
ipaadmin_password)
|
|
||||||
api_connect()
|
|
||||||
|
|
||||||
has_add_membermanager = api_check_command(
|
# Connect to IPA API
|
||||||
|
with ansible_module.ipa_connect():
|
||||||
|
|
||||||
|
has_add_membermanager = ansible_module.ipa_command_exists(
|
||||||
"hostgroup_add_member_manager")
|
"hostgroup_add_member_manager")
|
||||||
if ((membermanager_user is not None or
|
if ((membermanager_user is not None or
|
||||||
membermanager_group is not None) and not has_add_membermanager):
|
membermanager_group is not None) and not has_add_membermanager):
|
||||||
@@ -303,7 +284,8 @@ def main():
|
|||||||
msg="Managing a membermanager user or group is not supported "
|
msg="Managing a membermanager user or group is not supported "
|
||||||
"by your IPA version"
|
"by your IPA version"
|
||||||
)
|
)
|
||||||
has_mod_rename = api_check_param("hostgroup_mod", "rename")
|
has_mod_rename = ansible_module.ipa_command_param_exists(
|
||||||
|
"hostgroup_mod", "rename")
|
||||||
if not has_mod_rename and rename is not None:
|
if not has_mod_rename and rename is not None:
|
||||||
ansible_module.fail_json(
|
ansible_module.fail_json(
|
||||||
msg="Renaming hostgroups is not supported by your IPA version")
|
msg="Renaming hostgroups is not supported by your IPA version")
|
||||||
@@ -515,7 +497,7 @@ def main():
|
|||||||
# Execute commands
|
# Execute commands
|
||||||
for name, command, args in commands:
|
for name, command, args in commands:
|
||||||
try:
|
try:
|
||||||
result = api_command(ansible_module, command, name, args)
|
result = ansible_module.ipa_command(command, name, args)
|
||||||
if "completed" in result:
|
if "completed" in result:
|
||||||
if result["completed"] > 0:
|
if result["completed"] > 0:
|
||||||
changed = True
|
changed = True
|
||||||
@@ -537,12 +519,6 @@ def main():
|
|||||||
if len(errors) > 0:
|
if len(errors) > 0:
|
||||||
ansible_module.fail_json(msg=", ".join(errors))
|
ansible_module.fail_json(msg=", ".join(errors))
|
||||||
|
|
||||||
except Exception as e:
|
|
||||||
ansible_module.fail_json(msg=str(e))
|
|
||||||
|
|
||||||
finally:
|
|
||||||
temp_kdestroy(ccache_dir, ccache_name)
|
|
||||||
|
|
||||||
# Done
|
# Done
|
||||||
|
|
||||||
ansible_module.exit_json(changed=changed, **exit_args)
|
ansible_module.exit_json(changed=changed, **exit_args)
|
||||||
|
|||||||
Reference in New Issue
Block a user