¡@
OpenStack Study: extended_snapshot_attributes.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. """The Extended Snapshot Attributes API extension.""" from webob import exc from cinder.api import extensions from cinder.api.openstack import wsgi from cinder.api import xmlutil from cinder import exception from cinder.openstack.common import log as logging from cinder import volume LOG = logging.getLogger(__name__) authorize = extensions.soft_extension_authorizer( 'volume', 'extended_snapshot_attributes')
**** CubicPower OpenStack Study **** class ExtendedSnapshotAttributesController(wsgi.Controller):
**** CubicPower OpenStack Study **** def __init__(self, *args, **kwargs): super(ExtendedSnapshotAttributesController, self).__init__(*args, **kwargs) self.volume_api = volume.API()
**** CubicPower OpenStack Study **** def _get_snapshots(self, context): snapshots = self.volume_api.get_all_snapshots(context) rval = dict((snapshot['id'], snapshot) for snapshot in snapshots) return rval
**** CubicPower OpenStack Study **** def _extend_snapshot(self, snapshot, data): for attr in ['project_id', 'progress']: key = "%s:%s" % (Extended_snapshot_attributes.alias, attr) snapshot[key] = data[attr] @wsgi.extends
**** CubicPower OpenStack Study **** def show(self, req, resp_obj, id): context = req.environ['cinder.context'] if authorize(context): # Attach our slave template to the response object resp_obj.attach(xml=ExtendedSnapshotAttributeTemplate()) try: snapshot = self.volume_api.get_snapshot(context, id) except exception.NotFound: explanation = _("Snapshot not found.") raise exc.HTTPNotFound(explanation=explanation) self._extend_snapshot(snapshot=resp_obj.obj['snapshot'], data=snapshot) @wsgi.extends
**** CubicPower OpenStack Study **** def detail(self, req, resp_obj): context = req.environ['cinder.context'] if authorize(context): # Attach our slave template to the response object resp_obj.attach(xml=ExtendedSnapshotAttributesTemplate()) snapshots = list(resp_obj.obj.get('snapshots', [])) db_snapshots = self._get_snapshots(context) for snapshot_object in snapshots: try: snapshot_data = db_snapshots[snapshot_object['id']] except KeyError: continue self._extend_snapshot(snapshot=snapshot_object, data=snapshot_data)
**** CubicPower OpenStack Study **** class Extended_snapshot_attributes(extensions.ExtensionDescriptor): """Extended SnapshotAttributes support.""" name = "ExtendedSnapshotAttributes" alias = "os-extended-snapshot-attributes" namespace = ("http://docs.openstack.org/volume/ext/" "extended_snapshot_attributes/api/v1") updated = "2012-06-19T00:00:00+00:00"
**** CubicPower OpenStack Study **** def get_controller_extensions(self): controller = ExtendedSnapshotAttributesController() extension = extensions.ControllerExtension(self, 'snapshots', controller) return [extension] def make_snapshot(elem): elem.set('{%s}project_id' % Extended_snapshot_attributes.namespace, '%s:project_id' % Extended_snapshot_attributes.alias) elem.set('{%s}progress' % Extended_snapshot_attributes.namespace, '%s:progress' % Extended_snapshot_attributes.alias)
**** CubicPower OpenStack Study **** def make_snapshot(elem): elem.set('{%s}project_id' % Extended_snapshot_attributes.namespace, '%s:project_id' % Extended_snapshot_attributes.alias) elem.set('{%s}progress' % Extended_snapshot_attributes.namespace, '%s:progress' % Extended_snapshot_attributes.alias)
**** CubicPower OpenStack Study **** class ExtendedSnapshotAttributeTemplate(xmlutil.TemplateBuilder):
**** CubicPower OpenStack Study **** def construct(self): root = xmlutil.TemplateElement('snapshot', selector='snapshot') make_snapshot(root) alias = Extended_snapshot_attributes.alias namespace = Extended_snapshot_attributes.namespace return xmlutil.SlaveTemplate(root, 1, nsmap={alias: namespace})
**** CubicPower OpenStack Study **** class ExtendedSnapshotAttributesTemplate(xmlutil.TemplateBuilder):
**** CubicPower OpenStack Study **** def construct(self): root = xmlutil.TemplateElement('snapshots') elem = xmlutil.SubTemplateElement(root, 'snapshot', selector='snapshots') make_snapshot(elem) alias = Extended_snapshot_attributes.alias namespace = Extended_snapshot_attributes.namespace return xmlutil.SlaveTemplate(root, 1, nsmap={alias: namespace})
|