ansible/community.general
1
0
Fork 0
mirror of https://github.com/ansible-collections/community.general.git synced 2024-09-14 20:13:21 +02:00
Code Releases Activity

Merge branch 'ericwb-bug/8057' into devel

Browse source
This commit is contained in:
James Cammarata 2014-07-08 14:40:19 -05:00
commit 2c1e58b835
1 changed files with 44 additions and 32 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

44
library/cloud/glance_image
View file

@ -104,6 +104,12 @@ options:
- The path to the file which has to be uploaded, mutually exclusive with copy_from - The path to the file which has to be uploaded, mutually exclusive with copy_from
required: false required: false
default: None default: None
endpoint_type:
description:
- endpoint URL type
choices: [publicURL, internalURL]
required: false
default: publicURL
requirements: ["glanceclient", "keystoneclient"] requirements: ["glanceclient", "keystoneclient"]
''' '''
@ -127,6 +133,7 @@ try:
except ImportError: except ImportError:
print("failed=True msg='glanceclient and keystone client are required'") print("failed=True msg='glanceclient and keystone client are required'")
def _get_ksclient(module, kwargs): def _get_ksclient(module, kwargs):
try: try:
client = ksclient.Client(username=kwargs.get('login_username'), client = ksclient.Client(username=kwargs.get('login_username'),
@ -134,30 +141,32 @@ def _get_ksclient(module, kwargs):
tenant_name=kwargs.get('login_tenant_name'), tenant_name=kwargs.get('login_tenant_name'),
auth_url=kwargs.get('auth_url')) auth_url=kwargs.get('auth_url'))
except Exception, e: except Exception, e:
module.fail_json(msg = "Error authenticating to the keystone: %s " % e.message) module.fail_json(msg="Error authenticating to the keystone: %s " % e.message)
return client return client
def _get_endpoint(module, client): def _get_endpoint(module, client, endpoint_type):
try: try:
endpoint = client.service_catalog.url_for(service_type='image', endpoint_type='publicURL') endpoint = client.service_catalog.url_for(service_type='image', endpoint_type=endpoint_type)
except Exception, e: except Exception, e:
module.fail_json(msg = "Error getting endpoint for glance: %s" % e.message) module.fail_json(msg="Error getting endpoint for glance: %s" % e.message)
return endpoint return endpoint
def _get_glance_client(module, kwargs): def _get_glance_client(module, kwargs):
_ksclient = _get_ksclient(module, kwargs) _ksclient = _get_ksclient(module, kwargs)
token = _ksclient.auth_token token = _ksclient.auth_token
endpoint =_get_endpoint(module, _ksclient) endpoint =_get_endpoint(module, _ksclient, kwargs.get('endpoint_type'))
kwargs = { kwargs = {
'token': token, 'token': token,
} }
try: try:
client = glanceclient.Client('1', endpoint, **kwargs) client = glanceclient.Client('1', endpoint, **kwargs)
except Exception, e: except Exception, e:
module.fail_json(msg = "Error in connecting to glance: %s" %e.message) module.fail_json(msg="Error in connecting to glance: %s" % e.message)
return client return client
def _glance_image_present(module, params, client): def _glance_image_present(module, params, client):
try: try:
for image in client.images.list(): for image in client.images.list():
@ -165,7 +174,8 @@ def _glance_image_present(module, params, client):
return image.id return image.id
return None return None
except Exception, e: except Exception, e:
module.fail_json(msg = "Error in fetching image list: %s" %e.message) module.fail_json(msg="Error in fetching image list: %s" % e.message)
def _glance_image_create(module, params, client): def _glance_image_create(module, params, client):
kwargs = { kwargs = {
@ -188,11 +198,12 @@ def _glance_image_create(module, params, client):
break break
time.sleep(5) time.sleep(5)
except Exception, e: except Exception, e:
module.fail_json(msg = "Error in creating image: %s" %e.message) module.fail_json(msg="Error in creating image: %s" % e.message)
if image.status == 'active': if image.status == 'active':
module.exit_json(changed = True, result = image.status, id=image.id) module.exit_json(changed=True, result=image.status, id=image.id)
else: else:
module.fail_json(msg = " The module timed out, please check manually " + image.status) module.fail_json(msg=" The module timed out, please check manually " + image.status)
def _glance_delete_image(module, params, client): def _glance_delete_image(module, params, client):
try: try:
@ -200,8 +211,9 @@ def _glance_delete_image(module, params, client):
if image.name == params['name']: if image.name == params['name']:
client.images.delete(image) client.images.delete(image)
except Exception, e: except Exception, e:
module.fail_json(msg = "Error in deleting image: %s" %e.message) module.fail_json(msg="Error in deleting image: %s" % e.message)
module.exit_json(changed = True, result = "Deleted") module.exit_json(changed=True, result="Deleted")
def main(): def main():
@ -222,28 +234,28 @@ def main():
copy_from = dict(default= None), copy_from = dict(default= None),
timeout = dict(default=180), timeout = dict(default=180),
file = dict(default=None), file = dict(default=None),
endpoint_type = dict(default='publicURL', choices=['publicURL', 'internalURL']),
state = dict(default='present', choices=['absent', 'present']) state = dict(default='present', choices=['absent', 'present'])
), ),
mutually_exclusive = [['file','copy_from']], mutually_exclusive = [['file','copy_from']],
) )
if module.params['state'] == 'present': if module.params['state'] == 'present':
if not module.params['file'] and not module.params['copy_from']: if not module.params['file'] and not module.params['copy_from']:
module.fail_json(msg = "Either file or copy_from variable should be set to create the image") module.fail_json(msg="Either file or copy_from variable should be set to create the image")
client = _get_glance_client(module, module.params) client = _get_glance_client(module, module.params)
id = _glance_image_present(module, module.params, client) id = _glance_image_present(module, module.params, client)
if not id: if not id:
_glance_image_create(module, module.params, client) _glance_image_create(module, module.params, client)
module.exit_json(changed = False, id = id, result = "success") module.exit_json(changed=False, id=id, result="success")
if module.params['state'] == 'absent': if module.params['state'] == 'absent':
client = _get_glance_client(module, module.params) client = _get_glance_client(module, module.params)
id = _glance_image_present(module, module.params, client) id = _glance_image_present(module, module.params, client)
if not id: if not id:
module.exit_json(changed = False, result = "Success") module.exit_json(changed=False, result="Success")
else: else:
_glance_delete_image(module, module.params, client) _glance_delete_image(module, module.params, client)
# this is magic, see lib/ansible/module.params['common.py # this is magic, see lib/ansible/module.params['common.py
from ansible.module_utils.basic import * from ansible.module_utils.basic import *
main() main()