ansible-collections/community.general
1
0
Fork 0
mirror of https://github.com/ansible-collections/community.general.git synced 2025-07-03 15:10:21 -07:00
Code Issues Projects Releases Packages Wiki Activity Actions 4

ovirt: Support to search entity with additional parameters (#35285)

Browse source
This commit is contained in:
Ondra Machacek 2018-01-25 20:19:25 +01:00 • committed by Ryan Brown
parent 7abdab6c9e
commit 88c48d1437
2 changed files with 15 additions and 10 deletions
Download patch file Download diff file Expand all files Collapse all files

21
lib/ansible/module_utils/ovirt.py
View file

@ -218,20 +218,22 @@ def equal(param1, param2, ignore_case=False):
return True return True
def search_by_attributes(service, **kwargs): def search_by_attributes(service, list_params=None, **kwargs):
""" """
Search for the entity by attributes. Nested entities don't support search Search for the entity by attributes. Nested entities don't support search
via REST, so in case using search for nested entity we return all entities via REST, so in case using search for nested entity we return all entities
and filter them by specified attributes. and filter them by specified attributes.
""" """
list_params = list_params or {}
# Check if 'list' method support search(look for search parameter): # Check if 'list' method support search(look for search parameter):
if 'search' in inspect.getargspec(service.list)[0]: if 'search' in inspect.getargspec(service.list)[0]:
res = service.list( res = service.list(
search=' and '.join('{0}={1}'.format(k, v) for k, v in kwargs.items()) search=' and '.join('{0}={1}'.format(k, v) for k, v in kwargs.items()),
**list_params
) )
else: else:
res = [ res = [
e for e in service.list() if len([ e for e in service.list(**list_params) if len([
k for k, v in kwargs.items() if getattr(e, k, None) == v k for k, v in kwargs.items() if getattr(e, k, None) == v
]) == len(kwargs) ]) == len(kwargs)
] ]
@ -269,12 +271,15 @@ def search_by_name(service, name, **kwargs):
return res[0] return res[0]
def get_entity(service): def get_entity(service, get_params=None):
""" """
Ignore SDK Error in case of getting an entity from service. Ignore SDK Error in case of getting an entity from service.
""" """
entity = None entity = None
try: try:
if get_params is not None:
entity = service.get(**get_params)
else:
entity = service.get() entity = service.get()
except sdk.Error: except sdk.Error:
# We can get here 404, we should ignore it, in case # We can get here 404, we should ignore it, in case
@ -757,7 +762,7 @@ class BaseModule(object):
return entity return entity
time.sleep(poll_interval) time.sleep(poll_interval)
def search_entity(self, search_params=None): def search_entity(self, search_params=None, list_params=None):
""" """
Always first try to search by `ID`, if ID isn't specified, Always first try to search by `ID`, if ID isn't specified,
check if user constructed special search in `search_params`, check if user constructed special search in `search_params`,
@ -766,10 +771,10 @@ class BaseModule(object):
entity = None entity = None
if 'id' in self._module.params and self._module.params['id'] is not None: if 'id' in self._module.params and self._module.params['id'] is not None:
entity = get_entity(self._service.service(self._module.params['id'])) entity = get_entity(self._service.service(self._module.params['id']), get_params=list_params)
elif search_params is not None: elif search_params is not None:
entity = search_by_attributes(self._service, **search_params) entity = search_by_attributes(self._service, list_params=list_params, **search_params)
elif self._module.params.get('name') is not None: elif self._module.params.get('name') is not None:
entity = search_by_attributes(self._service, name=self._module.params['name']) entity = search_by_attributes(self._service, list_params=list_params, name=self._module.params['name'])
return entity return entity

2
lib/ansible/modules/cloud/ovirt/ovirt_vms.py
View file

@ -1500,7 +1500,7 @@ def main():
module=module, module=module,
service=vms_service, service=vms_service,
) )
vm = vms_module.search_entity() vm = vms_module.search_entity(list_params={'all_content': True})
control_state(vm, vms_service, module) control_state(vm, vms_service, module)
if state in ('present', 'running', 'next_run'): if state in ('present', 'running', 'next_run'):