Refactored identity_domain_info

Switch to SDK's cloud layer function search_domains which allows
us to reduce our code. Added integration test for this module.

Change-Id: Ic7915fd3334266783ea5e9d442ef304fa734ca00
This commit is contained in:
Rafael Castillo 2022-04-26 16:08:33 -07:00 committed by Jakob Meng
parent fd1b9fc0d2
commit b31fdf8320
5 changed files with 97 additions and 15 deletions

View File

@ -70,6 +70,7 @@
dns_zone_info
floating_ip_info
group
identity_domain_info
identity_user
identity_user_info
identity_role

View File

@ -0,0 +1,9 @@
domain_name: domain_info_test_domain
unexistent_domain_name: domain_info_unexistent_domain
disabled_domain_name: test_domain_disabled
domain_info_fields:
- description
- id
- is_enabled
- name
- links

View File

@ -0,0 +1,72 @@
---
- block:
- name: Ensure domain does not exist
openstack.cloud.identity_domain:
cloud: "{{ cloud }}"
state: absent
name: "{{ unexistent_domain_name }}"
- name: Get unexistent domain
openstack.cloud.identity_domain_info:
cloud: "{{ cloud }}"
name: "{{ unexistent_domain_name }}"
register: domain_info
- name: Assert no results returned
assert:
that: not domain_info.openstack_domains
- block:
- name: Ensure domain exists
openstack.cloud.identity_domain:
cloud: "{{ cloud }}"
state: present
name: "{{ domain_name }}"
description: "test description"
register: domain
- name: Get domain
openstack.cloud.identity_domain_info:
cloud: "{{ cloud }}"
name: "{{ domain_name }}"
register: domain_info
- name: Assert one result exists
assert:
that: domain_info.openstack_domains | length == 1
- name: Assert fields are present
assert:
that: item in domain_info.openstack_domains[0]
loop: "{{ domain_info_fields }}"
- name: Assert returned value
assert:
that:
- domain_info.openstack_domains[0].description == domain.domain.description
- block:
- name: Get all domains
openstack.cloud.identity_domain_info:
cloud: "{{ cloud }}"
register: domain_info
- block:
- name: Ensure disabled domain exists
openstack.cloud.identity_domain:
cloud: "{{ cloud }}"
state: present
name: "{{ disabled_domain_name }}"
enabled: false
description: "test description"
register: domain
- name: Get filtered domains
openstack.cloud.identity_domain_info:
cloud: "{{ cloud }}"
filters:
enabled: true
register: domain_info
- name: Assert at least one result
assert:
that: domain_info.openstack_domains | length >= 1
- name: Assert returned value
assert:
that: item.is_enabled == true
loop: "{{ domain_info.openstack_domains }}"

View File

@ -16,6 +16,7 @@
tags: dns
when: sdk_version is version(0.28, '>=')
- { role: floating_ip_info, tags: floating_ip_info }
- { role: identity_domain_info, tags: identity_domain_info }
- { role: identity_user, tags: identity_user }
- { role: identity_user_info, tags: identity_user_info }
- { role: identity_role, tags: identity_role }

View File

@ -18,7 +18,7 @@ options:
type: str
filters:
description:
- A dictionary of meta data to use for further filtering. Elements of
- A dictionary of meta data to use for filtering. Elements of
this dictionary may be additional dictionaries.
type: dict
requirements:
@ -61,7 +61,8 @@ RETURN = '''
openstack_domains:
description: has all the OpenStack information about domains
returned: always, but can be null
type: complex
type: list
elements: dict
contains:
id:
description: Unique UUID.
@ -75,10 +76,14 @@ openstack_domains:
description: Description of the domain.
returned: success
type: str
enabled:
is_enabled:
description: Flag to indicate if the domain is enabled.
returned: success
type: bool
links:
type: list
returned: success
description: The links related to the domain resource
'''
from ansible_collections.openstack.cloud.plugins.module_utils.openstack import OpenStackModule
@ -89,10 +94,8 @@ class IdentityDomainInfoModule(OpenStackModule):
name=dict(required=False, default=None),
filters=dict(required=False, type='dict', default=None),
)
module_kwargs = dict(
mutually_exclusive=[
['name', 'filters'],
],
supports_check_mode=True
)
@ -100,18 +103,14 @@ class IdentityDomainInfoModule(OpenStackModule):
def run(self):
name = self.params['name']
filters = self.params['filters']
filters = self.params['filters'] or {}
args = {}
if name:
# Let's suppose user is passing domain ID
try:
domains = self.conn.get_domain(name)
except Exception:
domains = self.conn.search_domains(filters={'name': name})
else:
domains = self.conn.search_domains(filters)
args['name_or_id'] = name
args['filters'] = filters
domains = [d.to_dict(computed=False) for d in self.conn.search_domains(**args)]
self.exit_json(changed=False, openstack_domains=domains)