diff options
Diffstat (limited to 'nova/api/openstack/compute/legacy_v2/contrib/keypairs.py')
| -rw-r--r-- | nova/api/openstack/compute/legacy_v2/contrib/keypairs.py | 181 |
1 files changed, 0 insertions, 181 deletions
diff --git a/nova/api/openstack/compute/legacy_v2/contrib/keypairs.py b/nova/api/openstack/compute/legacy_v2/contrib/keypairs.py deleted file mode 100644 index d4a34d035e..0000000000 --- a/nova/api/openstack/compute/legacy_v2/contrib/keypairs.py +++ /dev/null @@ -1,181 +0,0 @@ -# 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. - -"""Keypair management extension.""" - -import webob -import webob.exc - -from nova.api.openstack.compute.legacy_v2 import servers -from nova.api.openstack import extensions -from nova.api.openstack import wsgi -from nova.compute import api as compute_api -from nova import exception -from nova.i18n import _ - - -authorize = extensions.extension_authorizer('compute', 'keypairs') -soft_authorize = extensions.soft_extension_authorizer('compute', 'keypairs') - - -class KeypairController(object): - - """Keypair API controller for the OpenStack API.""" - def __init__(self): - self.api = compute_api.KeypairAPI() - - def _filter_keypair(self, keypair, **attrs): - clean = { - 'name': keypair.name, - 'public_key': keypair.public_key, - 'fingerprint': keypair.fingerprint, - } - for attr in attrs: - clean[attr] = keypair[attr] - return clean - - def create(self, req, body): - """Create or import keypair. - - Sending name will generate a key and return private_key - and fingerprint. - - You can send a public_key to add an existing ssh key - - params: keypair object with: - name (required) - string - public_key (optional) - string - """ - - context = req.environ['nova.context'] - authorize(context, action='create') - - try: - params = body['keypair'] - name = params['name'] - except KeyError: - msg = _("Invalid request body") - raise webob.exc.HTTPBadRequest(explanation=msg) - - try: - if 'public_key' in params: - keypair = self.api.import_key_pair(context, - context.user_id, name, - params['public_key']) - keypair = self._filter_keypair(keypair, user_id=True) - else: - keypair, private_key = self.api.create_key_pair( - context, context.user_id, name) - keypair = self._filter_keypair(keypair, user_id=True) - keypair['private_key'] = private_key - - return {'keypair': keypair} - - except exception.KeypairLimitExceeded: - msg = _("Quota exceeded, too many key pairs.") - raise webob.exc.HTTPForbidden(explanation=msg) - except exception.InvalidKeypair as exc: - raise webob.exc.HTTPBadRequest(explanation=exc.format_message()) - except exception.KeyPairExists as exc: - raise webob.exc.HTTPConflict(explanation=exc.format_message()) - - def delete(self, req, id): - """Delete a keypair with a given name.""" - context = req.environ['nova.context'] - authorize(context, action='delete') - try: - self.api.delete_key_pair(context, context.user_id, id) - except exception.KeypairNotFound as exc: - raise webob.exc.HTTPNotFound(explanation=exc.format_message()) - return webob.Response(status_int=202) - - def show(self, req, id): - """Return data for the given key name.""" - context = req.environ['nova.context'] - authorize(context, action='show') - - try: - # The return object needs to be a dict in order to pop the 'type' - # field, since it is incompatible with API version <= 2.1. - keypair = self.api.get_key_pair(context, context.user_id, id) - keypair = self._filter_keypair(keypair, created_at=True, - deleted=True, deleted_at=True, - id=True, user_id=True, - updated_at=True) - except exception.KeypairNotFound as exc: - raise webob.exc.HTTPNotFound(explanation=exc.format_message()) - return {'keypair': keypair} - - def index(self, req): - """List of keypairs for a user.""" - context = req.environ['nova.context'] - authorize(context, action='index') - key_pairs = self.api.get_key_pairs(context, context.user_id) - rval = [] - for key_pair in key_pairs: - rval.append({'keypair': self._filter_keypair(key_pair)}) - - return {'keypairs': rval} - - -class Controller(servers.Controller): - - def _add_key_name(self, req, servers): - for server in servers: - db_server = req.get_db_instance(server['id']) - # server['id'] is guaranteed to be in the cache due to - # the core API adding it in its 'show'/'detail' methods. - server['key_name'] = db_server['key_name'] - - def _show(self, req, resp_obj): - if 'server' in resp_obj.obj: - server = resp_obj.obj['server'] - self._add_key_name(req, [server]) - - @wsgi.extends - def show(self, req, resp_obj, id): - context = req.environ['nova.context'] - if soft_authorize(context): - self._show(req, resp_obj) - - @wsgi.extends - def detail(self, req, resp_obj): - context = req.environ['nova.context'] - if 'servers' in resp_obj.obj and soft_authorize(context): - servers = resp_obj.obj['servers'] - self._add_key_name(req, servers) - - -class Keypairs(extensions.ExtensionDescriptor): - """Keypair Support.""" - - name = "Keypairs" - alias = "os-keypairs" - namespace = "http://docs.openstack.org/compute/ext/keypairs/api/v1.1" - updated = "2011-08-08T00:00:00Z" - - def get_resources(self): - resources = [] - - res = extensions.ResourceExtension( - 'os-keypairs', - KeypairController()) - resources.append(res) - return resources - - def get_controller_extensions(self): - controller = Controller(self.ext_mgr) - extension = extensions.ControllerExtension(self, 'servers', controller) - return [extension] |