7 from oslo_serialization import jsonutils
9 from api import ApiResource
10 from api.database.v2.handlers import V2OpenrcHandler
11 from api.database.v2.handlers import V2EnvironmentHandler
12 from yardstick.common import constants as consts
13 from yardstick.common.utils import result_handler
14 from yardstick.common.utils import makedirs
15 from yardstick.common.utils import source_env
17 LOG = logging.getLogger(__name__)
18 LOG.setLevel(logging.DEBUG)
21 class V2Openrcs(ApiResource):
24 return self._dispatch_post()
26 def upload_openrc(self, args):
28 upload_file = args['file']
30 return result_handler(consts.API_ERROR, 'file must be provided')
33 environment_id = args['environment_id']
35 return result_handler(consts.API_ERROR, 'environment_id must be provided')
38 uuid.UUID(environment_id)
40 return result_handler(consts.API_ERROR, 'invalid environment id')
42 LOG.info('writing openrc: %s', consts.OPENRC)
43 makedirs(consts.CONF_DIR)
44 upload_file.save(consts.OPENRC)
45 source_env(consts.OPENRC)
47 LOG.info('parsing openrc')
49 openrc_data = self._get_openrc_dict()
51 LOG.exception('parse openrc failed')
52 return result_handler(consts.API_ERROR, 'parse openrc failed')
54 openrc_id = str(uuid.uuid4())
55 self._write_into_database(environment_id, openrc_id, openrc_data)
57 LOG.info('writing ansible cloud conf')
59 self._generate_ansible_conf_file(openrc_data)
61 LOG.exception('write cloud conf failed')
62 return result_handler(consts.API_ERROR, 'genarate ansible conf failed')
63 LOG.info('finish writing ansible cloud conf')
65 return result_handler(consts.API_SUCCESS, {'openrc': openrc_data, 'uuid': openrc_id})
67 def update_openrc(self, args):
69 openrc_vars = args['openrc']
71 return result_handler(consts.API_ERROR, 'openrc must be provided')
74 environment_id = args['environment_id']
76 return result_handler(consts.API_ERROR, 'environment_id must be provided')
79 uuid.UUID(environment_id)
81 return result_handler(consts.API_ERROR, 'invalid environment id')
83 LOG.info('writing openrc: %s', consts.OPENRC)
84 makedirs(consts.CONF_DIR)
86 lines = ['export {}={}\n'.format(k, v) for k, v in openrc_vars.items()]
87 LOG.debug('writing: %s', ''.join(lines))
88 with open(consts.OPENRC, 'w') as f:
90 LOG.info('writing openrc: Done')
92 LOG.info('source openrc: %s', consts.OPENRC)
94 source_env(consts.OPENRC)
96 LOG.exception('source openrc failed')
97 return result_handler(consts.API_ERROR, 'source openrc failed')
98 LOG.info('source openrc: Done')
100 openrc_id = str(uuid.uuid4())
101 self._write_into_database(environment_id, openrc_id, openrc_vars)
103 LOG.info('writing ansible cloud conf')
105 self._generate_ansible_conf_file(openrc_vars)
107 LOG.exception('write cloud conf failed')
108 return result_handler(consts.API_ERROR, 'genarate ansible conf failed')
109 LOG.info('finish writing ansible cloud conf')
111 return result_handler(consts.API_SUCCESS, {'openrc': openrc_vars, 'uuid': openrc_id})
113 def _write_into_database(self, environment_id, openrc_id, openrc_data):
114 LOG.info('writing openrc to database')
115 openrc_handler = V2OpenrcHandler()
118 'environment_id': environment_id,
119 'content': jsonutils.dumps(openrc_data)
121 openrc_handler.insert(openrc_init_data)
123 LOG.info('binding openrc to environment: %s', environment_id)
124 environment_handler = V2EnvironmentHandler()
125 environment_handler.update_attr(environment_id, {'openrc_id': openrc_id})
127 def _get_openrc_dict(self):
128 with open(consts.OPENRC) as f:
129 content = f.readlines()
133 m = re.search(r'(\ .*)=(.*)', line)
136 value = os.environ[m.group(1).strip()]
140 result.update({m.group(1).strip(): value})
144 def _generate_ansible_conf_file(self, openrc_data):
153 black_list = ['OS_IDENTITY_API_VERSION', 'OS_IMAGE_API_VERSION']
155 for k, v in openrc_data.items():
156 if k.startswith('OS') and k not in black_list:
158 ansible_conf['clouds']['opnfv']['auth'][key] = v
161 value = openrc_data['OS_IDENTITY_API_VERSION']
165 ansible_conf['clouds']['opnfv']['identity_api_version'] = value
167 makedirs(consts.OPENSTACK_CONF_DIR)
168 with open(consts.CLOUDS_CONF, 'w') as f:
169 yaml.dump(ansible_conf, f, default_flow_style=False)
172 class V2Openrc(ApiResource):
174 def get(self, openrc_id):
178 return result_handler(consts.API_ERROR, 'invalid openrc id')
180 LOG.info('Geting openrc: %s', openrc_id)
181 openrc_handler = V2OpenrcHandler()
183 openrc = openrc_handler.get_by_uuid(openrc_id)
185 return result_handler(consts.API_ERROR, 'no such openrc id')
187 LOG.info('load openrc content')
188 content = jsonutils.loads(openrc.content)
190 return result_handler(consts.API_ERROR, {'openrc': content})
192 def delete(self, openrc_id):
196 return result_handler(consts.API_ERROR, 'invalid openrc id')
198 LOG.info('Geting openrc: %s', openrc_id)
199 openrc_handler = V2OpenrcHandler()
201 openrc = openrc_handler.get_by_uuid(openrc_id)
203 return result_handler(consts.API_ERROR, 'no such openrc id')
205 LOG.info('update openrc in environment')
206 environment_handler = V2EnvironmentHandler()
207 environment_handler.update_attr(openrc.environment_id, {'openrc_id': None})
209 openrc_handler.delete_by_uuid(openrc_id)
211 return result_handler(consts.API_SUCCESS, {'openrc': openrc_id})