¡@
OpenStack Study: controllers.py**** CubicPower OpenStack Study ****
# Copyright 2012 OpenStack Foundation # # Licensed under the Apache License, Version 2.0 (the "License"); you may # not use this file except in compliance with the License. You may obtain # a copy of the License at # # http://www.apache.org/licenses/LICENSE-2.0 # # Unless required by applicable law or agreed to in writing, software # distributed under the License is distributed on an "AS IS" BASIS, WITHOUT # WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the # License for the specific language governing permissions and limitations # under the License. from keystone.common import extension from keystone.common import wsgi from keystone import config from keystone import exception from keystone.openstack.common import log LOG = log.getLogger(__name__) CONF = config.CONF MEDIA_TYPE_JSON = 'application/vnd.openstack.identity-%s+json' MEDIA_TYPE_XML = 'application/vnd.openstack.identity-%s+xml' _VERSIONS = []
**** CubicPower OpenStack Study **** class Extensions(wsgi.Application): """Base extensions controller to be extended by public and admin API's.""" #extend in subclass to specify the set of extensions @property
**** CubicPower OpenStack Study **** def extensions(self): return None
**** CubicPower OpenStack Study **** def get_extensions_info(self, context): return {'extensions': {'values': self.extensions.values()}}
**** CubicPower OpenStack Study **** def get_extension_info(self, context, extension_alias): try: return {'extension': self.extensions[extension_alias]} except KeyError: raise exception.NotFound(target=extension_alias)
**** CubicPower OpenStack Study **** class AdminExtensions(Extensions): @property
**** CubicPower OpenStack Study **** def extensions(self): return extension.ADMIN_EXTENSIONS
**** CubicPower OpenStack Study **** class PublicExtensions(Extensions): @property
**** CubicPower OpenStack Study **** def extensions(self): return extension.PUBLIC_EXTENSIONS def register_version(version): _VERSIONS.append(version)
**** CubicPower OpenStack Study **** def register_version(version): _VERSIONS.append(version)
**** CubicPower OpenStack Study **** class Version(wsgi.Application):
**** CubicPower OpenStack Study **** def __init__(self, version_type): self.endpoint_url_type = version_type super(Version, self).__init__()
**** CubicPower OpenStack Study **** def _get_identity_url(self, context, version): """Returns a URL to keystone's own endpoint.""" url = self.base_url(context, self.endpoint_url_type) return '%s/%s/' % (url, version)
**** CubicPower OpenStack Study **** def _get_versions_list(self, context): """The list of versions is dependent on the context.""" versions = {} if 'v2.0' in _VERSIONS: versions['v2.0'] = { 'id': 'v2.0', 'status': 'stable', 'updated': '2014-04-17T00:00:00Z', 'links': [ { 'rel': 'self', 'href': self._get_identity_url(context, 'v2.0'), }, { 'rel': 'describedby', 'type': 'text/html', 'href': 'http://docs.openstack.org/api/openstack-' 'identity-service/2.0/content/' }, { 'rel': 'describedby', 'type': 'application/pdf', 'href': 'http://docs.openstack.org/api/openstack-' 'identity-service/2.0/identity-dev-guide-' '2.0.pdf' } ], 'media-types': [ { 'base': 'application/json', 'type': MEDIA_TYPE_JSON % 'v2.0' }, { 'base': 'application/xml', 'type': MEDIA_TYPE_XML % 'v2.0' } ] } if 'v3' in _VERSIONS: versions['v3'] = { 'id': 'v3.0', 'status': 'stable', 'updated': '2013-03-06T00:00:00Z', 'links': [ { 'rel': 'self', 'href': self._get_identity_url(context, 'v3'), } ], 'media-types': [ { 'base': 'application/json', 'type': MEDIA_TYPE_JSON % 'v3' }, { 'base': 'application/xml', 'type': MEDIA_TYPE_XML % 'v3' } ] } return versions
**** CubicPower OpenStack Study **** def get_versions(self, context): versions = self._get_versions_list(context) return wsgi.render_response(status=(300, 'Multiple Choices'), body={ 'versions': { 'values': versions.values() } })
**** CubicPower OpenStack Study **** def get_version_v2(self, context): versions = self._get_versions_list(context) if 'v2.0' in _VERSIONS: return wsgi.render_response(body={ 'version': versions['v2.0'] }) else: raise exception.VersionNotFound(version='v2.0')
**** CubicPower OpenStack Study **** def get_version_v3(self, context): versions = self._get_versions_list(context) if 'v3' in _VERSIONS: return wsgi.render_response(body={ 'version': versions['v3'] }) else: raise exception.VersionNotFound(version='v3')
|