¡@
OpenStack Study: flavors.py**** CubicPower OpenStack Study ****
# Copyright 2010 OpenStack Foundation # All Rights Reserved. # # 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. import webob from nova.api.openstack.compute.views import flavors as flavors_view from nova.api.openstack import extensions from nova.api.openstack import wsgi from nova.compute import flavors from nova import exception from nova.openstack.common.gettextutils import _ from nova.openstack.common import strutils from nova import utils
**** CubicPower OpenStack Study **** class FlavorsController(wsgi.Controller): """Flavor controller for the OpenStack API.""" _view_builder_class = flavors_view.V3ViewBuilder @extensions.expected_errors(400)
**** CubicPower OpenStack Study **** def index(self, req): """Return all flavors in brief.""" limited_flavors = self._get_flavors(req) return self._view_builder.index(req, limited_flavors) @extensions.expected_errors(400)
**** CubicPower OpenStack Study **** def detail(self, req): """Return all flavors in detail.""" limited_flavors = self._get_flavors(req) req.cache_db_flavors(limited_flavors) return self._view_builder.detail(req, limited_flavors) @extensions.expected_errors(404)
**** CubicPower OpenStack Study **** def show(self, req, id): """Return data about the given flavor id.""" context = req.environ['nova.context'] try: flavor = flavors.get_flavor_by_flavor_id(id, ctxt=context) req.cache_db_flavor(flavor) except exception.FlavorNotFound as e: raise webob.exc.HTTPNotFound(explanation=e.format_message()) return self._view_builder.show(req, flavor)
**** CubicPower OpenStack Study **** def _parse_is_public(self, is_public): """Parse is_public into something usable.""" if is_public is None: # preserve default value of showing only public flavors return True elif utils.is_none_string(is_public): return None else: try: return strutils.bool_from_string(is_public, strict=True) except ValueError: msg = _('Invalid is_public filter [%s]') % is_public raise webob.exc.HTTPBadRequest(explanation=msg)
**** CubicPower OpenStack Study **** def _get_flavors(self, req): """Helper function that returns a list of flavor dicts.""" filters = {} sort_key = req.params.get('sort_key') or 'flavorid' sort_dir = req.params.get('sort_dir') or 'asc' limit = req.params.get('limit') or None marker = req.params.get('marker') or None context = req.environ['nova.context'] if context.is_admin: # Only admin has query access to all flavor types filters['is_public'] = self._parse_is_public( req.params.get('is_public', None)) else: filters['is_public'] = True filters['disabled'] = False if 'min_ram' in req.params: try: filters['min_memory_mb'] = int(req.params['min_ram']) except ValueError: msg = _('Invalid min_ram filter [%s]') % req.params['min_ram'] raise webob.exc.HTTPBadRequest(explanation=msg) if 'min_disk' in req.params: try: filters['min_root_gb'] = int(req.params['min_disk']) except ValueError: msg = (_('Invalid min_disk filter [%s]') % req.params['min_disk']) raise webob.exc.HTTPBadRequest(explanation=msg) try: limited_flavors = flavors.get_all_flavors_sorted_list(context, filters=filters, sort_key=sort_key, sort_dir=sort_dir, limit=limit, marker=marker) except exception.MarkerNotFound: msg = _('marker [%s] not found') % marker raise webob.exc.HTTPBadRequest(explanation=msg) return limited_flavors
**** CubicPower OpenStack Study **** class Flavors(extensions.V3APIExtensionBase): """Flavors Extension.""" name = "flavors" alias = "flavors" version = 1
**** CubicPower OpenStack Study **** def get_resources(self): collection_actions = {'detail': 'GET'} member_actions = {'action': 'POST'} resources = [ extensions.ResourceExtension('flavors', FlavorsController(), member_name='flavor', collection_actions=collection_actions, member_actions=member_actions) ] return resources
**** CubicPower OpenStack Study **** def get_controller_extensions(self): return []
|