¡@

Home 

OpenStack Study: server_metadata.py

OpenStack Index

**** CubicPower OpenStack Study ****

# Copyright 2011 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.

from webob import exc

from nova.api.openstack import common

from nova.api.openstack import wsgi

from nova import compute

from nova import exception

from nova.openstack.common.gettextutils import _

**** CubicPower OpenStack Study ****

class Controller(object):

"""The server metadata API controller for the OpenStack API."""

**** CubicPower OpenStack Study ****

    def __init__(self):

        self.compute_api = compute.API()

        super(Controller, self).__init__()

**** CubicPower OpenStack Study ****

    def _get_metadata(self, context, server_id):

        try:

            server = self.compute_api.get(context, server_id)

            meta = self.compute_api.get_instance_metadata(context, server)

        except exception.InstanceNotFound:

            msg = _('Server does not exist')

            raise exc.HTTPNotFound(explanation=msg)

        meta_dict = {}

        for key, value in meta.iteritems():

            meta_dict[key] = value

        return meta_dict

    @wsgi.serializers(xml=common.MetadataTemplate)

**** CubicPower OpenStack Study ****

    def index(self, req, server_id):

        """Returns the list of metadata for a given instance."""

        context = req.environ['nova.context']

        return {'metadata': self._get_metadata(context, server_id)}

    @wsgi.serializers(xml=common.MetadataTemplate)

    @wsgi.deserializers(xml=common.MetadataDeserializer)

**** CubicPower OpenStack Study ****

    def create(self, req, server_id, body):

        try:

            metadata = body['metadata']

        except (KeyError, TypeError):

            msg = _("Malformed request body")

            raise exc.HTTPBadRequest(explanation=msg)

        context = req.environ['nova.context']

        new_metadata = self._update_instance_metadata(context,

                                                      server_id,

                                                      metadata,

                                                      delete=False)

        return {'metadata': new_metadata}

    @wsgi.serializers(xml=common.MetaItemTemplate)

    @wsgi.deserializers(xml=common.MetaItemDeserializer)

**** CubicPower OpenStack Study ****

    def update(self, req, server_id, id, body):

        try:

            meta_item = body['meta']

        except (TypeError, KeyError):

            expl = _('Malformed request body')

            raise exc.HTTPBadRequest(explanation=expl)

        if id not in meta_item:

            expl = _('Request body and URI mismatch')

            raise exc.HTTPBadRequest(explanation=expl)

        if len(meta_item) > 1:

            expl = _('Request body contains too many items')

            raise exc.HTTPBadRequest(explanation=expl)

        context = req.environ['nova.context']

        self._update_instance_metadata(context,

                                       server_id,

                                       meta_item,

                                       delete=False)

        return {'meta': meta_item}

    @wsgi.serializers(xml=common.MetadataTemplate)

    @wsgi.deserializers(xml=common.MetadataDeserializer)

**** CubicPower OpenStack Study ****

    def update_all(self, req, server_id, body):

        try:

            metadata = body['metadata']

        except (TypeError, KeyError):

            expl = _('Malformed request body')

            raise exc.HTTPBadRequest(explanation=expl)

        context = req.environ['nova.context']

        new_metadata = self._update_instance_metadata(context,

                                                      server_id,

                                                      metadata,

                                                      delete=True)

        return {'metadata': new_metadata}

**** CubicPower OpenStack Study ****

    def _update_instance_metadata(self, context, server_id, metadata,

                                  delete=False):

        try:

            server = self.compute_api.get(context, server_id,

                                          want_objects=True)

            return self.compute_api.update_instance_metadata(context,

                                                             server,

                                                             metadata,

                                                             delete)

        except exception.InstanceNotFound:

            msg = _('Server does not exist')

            raise exc.HTTPNotFound(explanation=msg)

        except (ValueError, AttributeError):

            msg = _("Malformed request body")

            raise exc.HTTPBadRequest(explanation=msg)

        except exception.InvalidMetadata as error:

            raise exc.HTTPBadRequest(explanation=error.format_message())

        except exception.InvalidMetadataSize as error:

            raise exc.HTTPRequestEntityTooLarge(

                explanation=error.format_message())

        except exception.QuotaError as error:

            raise exc.HTTPRequestEntityTooLarge(

                explanation=error.format_message(),

                headers={'Retry-After': 0})

        except exception.InstanceInvalidState as state_error:

            common.raise_http_conflict_for_instance_invalid_state(state_error,

                    'update metadata')

    @wsgi.serializers(xml=common.MetaItemTemplate)

**** CubicPower OpenStack Study ****

    def show(self, req, server_id, id):

        """Return a single metadata item."""

        context = req.environ['nova.context']

        data = self._get_metadata(context, server_id)

        try:

            return {'meta': {id: data[id]}}

        except KeyError:

            msg = _("Metadata item was not found")

            raise exc.HTTPNotFound(explanation=msg)

    @wsgi.response(204)

**** CubicPower OpenStack Study ****

    def delete(self, req, server_id, id):

        """Deletes an existing metadata."""

        context = req.environ['nova.context']

        metadata = self._get_metadata(context, server_id)

        if id not in metadata:

            msg = _("Metadata item was not found")

            raise exc.HTTPNotFound(explanation=msg)

        try:

            server = self.compute_api.get(context, server_id,

                                          want_objects=True)

            self.compute_api.delete_instance_metadata(context, server, id)

        except exception.InstanceNotFound:

            msg = _('Server does not exist')

            raise exc.HTTPNotFound(explanation=msg)

        except exception.InstanceInvalidState as state_error:

            common.raise_http_conflict_for_instance_invalid_state(state_error,

                    'delete metadata')

def create_resource():

    return wsgi.Resource(Controller())

**** CubicPower OpenStack Study ****

def create_resource():

    return wsgi.Resource(Controller())