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
|
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 V2Openrc(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')
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')
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)
|
