summaryrefslogtreecommitdiff
path: root/cinder_volume_types
blob: ea990b43e869e634bb7a00ecfbbfb2b2aa3b8dda (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
#!/bin/python

from ansible.module_utils.basic import *
try:
    from cinderclient.v2 import client
except ImportError:
    print("failed=True msg='cinder client is required'")


DOCUMENTATION = '''
---
module: cinder_configure
short_description: Configure Openstack Block Storage (Cinder)
description: Create Volume Types needed for deploying Cinder
options:
  action:
    description:
      - Currently only supported option is create
    required: true
    choices: [create]
  username:
    description:
      - username used to authenticate with keystone.
    required: true
  password:
    description:
      - password used to authenticate with keystone.
    required: true
  url_auth:
    description:
      - keystone url for authentication.
    required: true
  tenant_name:
    description:
      - tenant name or project name of the login user
    required: true
  region_name:
    description:
      - region to connect to
    required: true
  name:
    description:
      - Name to be given to the volume type.
    required: true
  extra_specs:
    description:
      - A dictionary of extra specs to add to the volume type.
    required: false
requirements: [ cinder ]
author: Rodrigo Soto
'''

EXAMPLES = '''
cinder_volume_types:
    action: create
    username: admin
    password: "{{keystone_admin_password}}"
    tenant_name: admin
    region_name: RegionOne
    url_auth: "{{keystone_admin_url}}"
    name: some-name
    extra_specs: "volume_backend_name=some-name"
'''


def _get_cinderclient(module):
    try:
        cinder_client = client.Client(
            module.params.get('username'),
            module.params.get('password'),
            module.params.get('tenant_name'),
            module.params.get('url_auth'),
            region_name=module.params.get('region_name')
        )
    except Exception as e:
        module.fail_json(msg="Error authenticating to cinder: %s" % e.message)
    return cinder_client


def _get_volume_type(module, cinderclient):
    name = module.params.get('name')
    try:
        volume_type = cinderclient.volume_types.find(name=name)
        if volume_type is not None:
            return volume_type
    except Exception:
        return None
    return None


def _create_volume_type(module, cinderclient):
    name = module.params.get('name')
    try:
        volume_type_result = cinderclient.volume_types.create(name)
    except Exception as e:
        module.fail_json(msg="Error in creating volume type: %s" % e.message)
    return volume_type_result


def _delete_volume_type(module, cinderclient):
    name = module.params.get('name')
    try:
        volume_type = cinderclient.volume_types.find(name=name)
    except Exception as e:
        module.fail_json(
                msg="Error finding volume type to delete: %s" % e.message
            )
    try:
        cinderclient.volume_types.delete(volume_type.id)
    except Exception as e:
        module.fail_json(
                msg="Error in deleting the volume type: %s" % e.message
            )
    return True


def _volume_type_set_keys(volume_type, extra_specs):
    if extra_specs is not None:
        extra_specs_dict = {}
        extra_specs = extra_specs.split(',')
        for extra_spec in extra_specs:
            key, value = extra_spec.split('=')
            extra_specs_dict[key] = value
        try:
            volume_type.set_keys(extra_specs_dict)
        except Exception as e:
            raise e


def _get_volume_type_id(module, cinderclient):
    name = module.params.get('name')
    try:
        volume_type = cinderclient.volume_types.find(name=name)
    except Exception as e:
        module.fail_json(
                msg="Error finding volume type %s: %s" % (name, e.message)
            )
    return volume_type.id


def main():
    module = AnsibleModule(
        argument_spec={
            'action': {'default': 'create'},
            'username': {'required': True},
            'password': {'required': True},
            'url_auth': {'required': True},
            'tenant_name': {'required': True},
            'region_name': {'required': True},
            'name': {'required': True},
            'extra_specs': {'required': False},
        },
    )

    cinderclient = _get_cinderclient(module)

    if module.params.get('action') == 'create':
        volume_type = _get_volume_type(module, cinderclient)
        if volume_type is None:
            volume_type = _create_volume_type(module, cinderclient)
            _volume_type_set_keys(
                    volume_type, module.params.get('extra_specs')
                )
            module.exit_json(
                    changed=True,
                    result="Created",
                    msg=volume_type.id
                )
        else:
            _volume_type_set_keys(
                    volume_type, module.params.get('extra_specs')
                )
            module.exit_json(
                    changed=False,
                    result="Success",
                    msg=_get_volume_type_id(module, cinderclient)
                )

main()