Switch identity_group module to OpenStackModule

Change-Id: I880e425a5b334abfe7b9498d70229427292c2296
This commit is contained in:
Artem Goncharov 2021-05-20 16:21:23 +02:00
parent 6b3bf3bba0
commit ad70a20af5

View File

@ -86,13 +86,22 @@ group:
sample: "default" sample: "default"
''' '''
from ansible.module_utils.basic import AnsibleModule from ansible_collections.openstack.cloud.plugins.module_utils.openstack import OpenStackModule
from ansible_collections.openstack.cloud.plugins.module_utils.openstack import (openstack_full_argument_spec,
openstack_module_kwargs,
openstack_cloud_from_module)
def _system_state_change(state, description, group): class IdentityGroupModule(OpenStackModule):
argument_spec = dict(
name=dict(required=True),
description=dict(required=False, default=None),
domain_id=dict(required=False, default=None),
state=dict(default='present', choices=['absent', 'present']),
)
module_kwargs = dict(
supports_check_mode=True
)
def _system_state_change(self, state, description, group):
if state == 'present' and not group: if state == 'present' and not group:
return True return True
if state == 'present' and description is not None and group.description != description: if state == 'present' and description is not None and group.description != description:
@ -101,60 +110,47 @@ def _system_state_change(state, description, group):
return True return True
return False return False
def run(self):
name = self.params.get('name')
description = self.params.get('description')
state = self.params.get('state')
def main(): domain_id = self.params.pop('domain_id')
argument_spec = openstack_full_argument_spec(
name=dict(required=True),
description=dict(required=False, default=None),
domain_id=dict(required=False, default=None),
state=dict(default='present', choices=['absent', 'present']),
)
module_kwargs = openstack_module_kwargs()
module = AnsibleModule(argument_spec,
supports_check_mode=True,
**module_kwargs)
name = module.params.get('name')
description = module.params.get('description')
state = module.params.get('state')
domain_id = module.params.pop('domain_id')
sdk, cloud = openstack_cloud_from_module(module)
try:
if domain_id: if domain_id:
group = cloud.get_group(name, filters={'domain_id': domain_id}) group = self.conn.get_group(name, filters={'domain_id': domain_id})
else: else:
group = cloud.get_group(name) group = self.conn.get_group(name)
if module.check_mode: if self.ansible.check_mode:
module.exit_json(changed=_system_state_change(state, description, group)) self.exit_json(changed=self._system_state_change(state, description, group))
if state == 'present': if state == 'present':
if group is None: if group is None:
group = cloud.create_group( group = self.conn.create_group(
name=name, description=description, domain=domain_id) name=name, description=description, domain=domain_id)
changed = True changed = True
else: else:
if description is not None and group.description != description: if description is not None and group.description != description:
group = cloud.update_group( group = self.conn.update_group(
group.id, description=description) group.id, description=description)
changed = True changed = True
else: else:
changed = False changed = False
module.exit_json(changed=changed, group=group) self.exit_json(changed=changed, group=group)
elif state == 'absent': elif state == 'absent':
if group is None: if group is None:
changed = False changed = False
else: else:
cloud.delete_group(group.id) self.conn.delete_group(group.id)
changed = True changed = True
module.exit_json(changed=changed) self.exit_json(changed=changed)
except sdk.exceptions.OpenStackCloudException as e:
module.fail_json(msg=str(e)) def main():
module = IdentityGroupModule()
module()
if __name__ == '__main__': if __name__ == '__main__':