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
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
|
import uuid
import logging
import re
import os
import yaml
from oslo_serialization import jsonutils
from api import ApiResource
from api.database.v2.handlers import V2OpenrcHandler
from api.database.v2.handlers import V2EnvironmentHandler
from yardstick.common import constants as consts
from yardstick.common.utils import result_handler
from yardstick.common.utils import makedirs
from yardstick.common.utils import source_env
LOG = logging.getLogger(__name__)
LOG.setLevel(logging.DEBUG)
class V2Openrcs(ApiResource):
def post(self):
return self._dispatch_post()
def upload_openrc(self, args):
try:
upload_file = args['file']
except KeyError:
return result_handler(consts.API_ERROR, 'file must be provided')
try:
environment_id = args['environment_id']
except KeyError:
return result_handler(consts.API_ERROR, 'environment_id must be provided')
try:
uuid.UUID(environment_id)
except ValueError:
return result_handler(consts.API_ERROR, 'invalid environment id')
LOG.info('writing openrc: %s', consts.OPENRC)
makedirs(consts.CONF_DIR)
upload_file.save(consts.OPENRC)
source_env(consts.OPENRC)
LOG.info('parsing openrc')
try:
openrc_data = self._get_openrc_dict()
except Exception:
LOG.exception('parse openrc failed')
return result_handler(consts.API_ERROR, 'parse openrc failed')
openrc_id = str(uuid.uuid4())
self._write_into_database(environment_id, openrc_id, openrc_data)
LOG.info('writing ansible cloud conf')
try:
self._generate_ansible_conf_file(openrc_data)
except Exception:
LOG.exception('write cloud conf failed')
return result_handler(consts.API_ERROR, 'genarate ansible conf failed')
LOG.info('finish writing ansible cloud conf')
return result_handler(consts.API_SUCCESS, {'openrc': openrc_data, 'uuid': openrc_id})
def update_openrc(self, args):
try:
openrc_vars = args['openrc']
except KeyError:
return result_handler(consts.API_ERROR, 'openrc must be provided')
try:
environment_id = args['environment_id']
except KeyError:
return result_handler(consts.API_ERROR, 'environment_id must be provided')
try:
uuid.UUID(environment_id)
except ValueError:
return result_handler(consts.API_ERROR, 'invalid environment id')
LOG.info('writing openrc: %s', consts.OPENRC)
makedirs(consts.CONF_DIR)
lines = ['export {}={}\n'.format(k, v) for k, v in openrc_vars.items()]
LOG.debug('writing: %s', ''.join(lines))
with open(consts.OPENRC, 'w') as f:
f.writelines(lines)
LOG.info('writing openrc: Done')
LOG.info('source openrc: %s', consts.OPENRC)
try:
source_env(consts.OPENRC)
except Exception:
LOG.exception('source openrc failed')
return result_handler(consts.API_ERROR, 'source openrc failed')
LOG.info('source openrc: Done')
openrc_id = str(uuid.uuid4())
self._write_into_database(environment_id, openrc_id, openrc_vars)
LOG.info('writing ansible cloud conf')
try:
self._generate_ansible_conf_file(openrc_vars)
except Exception:
LOG.exception('write cloud conf failed')
return result_handler(consts.API_ERROR, 'genarate ansible conf failed')
LOG.info('finish writing ansible cloud conf')
return result_handler(consts.API_SUCCESS, {'openrc': openrc_vars, 'uuid': openrc_id})
def _write_into_database(self, environment_id, openrc_id, openrc_data):
LOG.info('writing openrc to database')
openrc_handler = V2OpenrcHandler()
openrc_init_data = {
'uuid': openrc_id,
'environment_id': environment_id,
'content': jsonutils.dumps(openrc_data)
}
openrc_handler.insert(openrc_init_data)
LOG.info('binding openrc to environment: %s', environment_id)
environment_handler = V2EnvironmentHandler()
environment_handler.update_attr(environment_id, {'openrc_id': openrc_id})
def _get_openrc_dict(self):
with open(consts.OPENRC) as f:
content = f.readlines()
result = {}
for line in content:
m = re.search(r'(\ .*)=(.*)', line)
if m:
try:
value = os.environ[m.group(1).strip()]
except KeyError:
pass
else:
result.update({m.group(1).strip(): value})
return result
def _generate_ansible_conf_file(self, openrc_data):
ansible_conf = {
'clouds': {
'opnfv': {
'auth': {
}
}
}
}
black_list = ['OS_IDENTITY_API_VERSION', 'OS_IMAGE_API_VERSION']
for k, v in openrc_data.items():
if k.startswith('OS') and k not in black_list:
key = k[3:].lower()
ansible_conf['clouds']['opnfv']['auth'][key] = v
try:
value = openrc_data['OS_IDENTITY_API_VERSION']
except KeyError:
pass
else:
ansible_conf['clouds']['opnfv']['identity_api_version'] = value
makedirs(consts.OPENSTACK_CONF_DIR)
with open(consts.CLOUDS_CONF, 'w') as f:
yaml.dump(ansible_conf, f, default_flow_style=False)
class V2Openrc(ApiResource):
def get(self, openrc_id):
try:
uuid.UUID(openrc_id)
except ValueError:
return result_handler(consts.API_ERROR, 'invalid openrc id')
LOG.info('Geting openrc: %s', openrc_id)
openrc_handler = V2OpenrcHandler()
try:
openrc = openrc_handler.get_by_uuid(openrc_id)
except ValueError:
return result_handler(consts.API_ERROR, 'no such openrc id')
LOG.info('load openrc content')
content = jsonutils.loads(openrc.content)
return result_handler(consts.API_ERROR, {'openrc': content})
def delete(self, openrc_id):
try:
uuid.UUID(openrc_id)
except ValueError:
return result_handler(consts.API_ERROR, 'invalid openrc id')
LOG.info('Geting openrc: %s', openrc_id)
openrc_handler = V2OpenrcHandler()
try:
openrc = openrc_handler.get_by_uuid(openrc_id)
except ValueError:
return result_handler(consts.API_ERROR, 'no such openrc id')
LOG.info('update openrc in environment')
environment_handler = V2EnvironmentHandler()
environment_handler.update_attr(openrc.environment_id, {'openrc_id': None})
openrc_handler.delete_by_uuid(openrc_id)
return result_handler(consts.API_SUCCESS, {'openrc': openrc_id})
|
