Add API schema for v2.1 block_device_mapping extension
By defining the API schema, it is possible to separate the validation code from the API method. The API method can be more simple. In addition, a response of API validation error can be consistent for the whole Nova API. Partially implements blueprint v2-on-v3-api Change-Id: I6d53ef2e3dad5a4ac9b67a5838f6e07606a8372b
This commit is contained in:
parent
0fef477e3b
commit
5316aeabfe
|
@ -17,6 +17,8 @@
|
|||
|
||||
from webob import exc
|
||||
|
||||
from nova.api.openstack.compute.schemas.v3 import block_device_mapping as \
|
||||
schema_block_device_mapping
|
||||
from nova.api.openstack import extensions
|
||||
from nova import block_device
|
||||
from nova import exception
|
||||
|
@ -53,19 +55,17 @@ class BlockDeviceMapping(extensions.V3APIExtensionBase):
|
|||
'is not allowed in the same request.')
|
||||
raise exc.HTTPBadRequest(explanation=expl)
|
||||
|
||||
if not isinstance(bdm, list):
|
||||
msg = _('block_device_mapping_v2 must be a list')
|
||||
raise exc.HTTPBadRequest(explanation=msg)
|
||||
|
||||
try:
|
||||
block_device_mapping = [
|
||||
block_device.BlockDeviceDict.from_api(bdm_dict)
|
||||
for bdm_dict in bdm]
|
||||
except (exception.InvalidBDMFormat,
|
||||
exception.InvalidBDMVolumeNotBootable) as e:
|
||||
except exception.InvalidBDMFormat as e:
|
||||
raise exc.HTTPBadRequest(explanation=e.format_message())
|
||||
|
||||
if block_device_mapping:
|
||||
create_kwargs['block_device_mapping'] = block_device_mapping
|
||||
# Unset the legacy_bdm flag if we got a block device mapping.
|
||||
create_kwargs['legacy_bdm'] = False
|
||||
|
||||
def get_server_create_schema(self):
|
||||
return schema_block_device_mapping.server_create
|
||||
|
|
|
@ -0,0 +1,86 @@
|
|||
# Copyright 2014 NEC Corporation. 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 nova.api.validation import parameter_types
|
||||
|
||||
server_create = {
|
||||
'block_device_mapping_v2': {
|
||||
'type': 'array',
|
||||
'items': [{
|
||||
'type': 'object',
|
||||
'properties': {
|
||||
'virtual_name': {
|
||||
'type': 'string', 'maxLength': 255,
|
||||
},
|
||||
# defined in nova/block_device.py:from_api()
|
||||
# NOTE: Client can specify the Id with the combination of
|
||||
# source_type and uuid, or a single attribute like volume_id/
|
||||
# image_id/snapshot_id.
|
||||
'source_type': {
|
||||
'type': 'string',
|
||||
'enum': ['volume', 'image', 'snapshot', 'blank'],
|
||||
},
|
||||
'uuid': {
|
||||
'type': 'string', 'minLength': 1, 'maxLength': 255,
|
||||
'pattern': '^[a-zA-Z0-9._-]*$',
|
||||
},
|
||||
'volume_id': parameter_types.volume_id,
|
||||
'image_id': parameter_types.image_id,
|
||||
'snapshot_id': parameter_types.image_id,
|
||||
|
||||
'volume_size': parameter_types.non_negative_integer,
|
||||
# Defined as varchar(255) in column "destination_type" in table
|
||||
# "block_device_mapping"
|
||||
'destination_type': {
|
||||
'type': 'string', 'maxLength': 255,
|
||||
},
|
||||
# Defined as varchar(255) in column "guest_format" in table
|
||||
# "block_device_mapping"
|
||||
'guest_format': {
|
||||
'type': 'string', 'maxLength': 255,
|
||||
},
|
||||
# Defined as varchar(255) in column "device_type" in table
|
||||
# "block_device_mapping"
|
||||
'device_type': {
|
||||
'type': 'string', 'maxLength': 255,
|
||||
},
|
||||
# Defined as varchar(255) in column "disk_bus" in table
|
||||
# "block_device_mapping"
|
||||
'disk_bus': {
|
||||
'type': 'string', 'maxLength': 255,
|
||||
},
|
||||
# Defined as integer in nova/block_device.py:from_api()
|
||||
'boot_index': {
|
||||
'type': ['integer', 'string'],
|
||||
'pattern': '^-?[0-9]+$',
|
||||
},
|
||||
# Do not allow empty device names and number values and
|
||||
# containing spaces(defined in nova/block_device.py:from_api())
|
||||
'device_name': {
|
||||
'type': 'string', 'minLength': 1, 'maxLength': 255,
|
||||
'pattern': '^[a-zA-Z0-9._-r/]*$',
|
||||
},
|
||||
# Defined as boolean in nova/block_device.py:from_api()
|
||||
'delete_on_termination': parameter_types.boolean,
|
||||
'no_device': {},
|
||||
# Defined as mediumtext in column "connection_info" in table
|
||||
# "block_device_mapping"
|
||||
'connection_info': {
|
||||
'type': 'string', 'maxLength': 16777215
|
||||
},
|
||||
},
|
||||
'additionalProperties': False
|
||||
}]
|
||||
}
|
||||
}
|
|
@ -94,6 +94,11 @@ server_id = {
|
|||
}
|
||||
|
||||
|
||||
image_id = {
|
||||
'type': 'string', 'format': 'uuid'
|
||||
}
|
||||
|
||||
|
||||
volume_id = {
|
||||
'type': 'string', 'format': 'uuid'
|
||||
}
|
||||
|
|
|
@ -384,6 +384,9 @@ def validate_and_default_volume_size(bdm):
|
|||
bdm['volume_size'] = utils.validate_integer(
|
||||
bdm['volume_size'], 'volume_size', min_value=0)
|
||||
except exception.InvalidInput:
|
||||
# NOTE: We can remove this validation code after removing
|
||||
# Nova v2.0 API code because v2.1 API validates this case
|
||||
# already at its REST API layer.
|
||||
raise exception.InvalidBDMFormat(
|
||||
details=_("Invalid volume_size."))
|
||||
|
||||
|
|
|
@ -37,6 +37,7 @@ CONF = cfg.CONF
|
|||
|
||||
|
||||
class BlockDeviceMappingTestV21(test.TestCase):
|
||||
validation_error = exception.ValidationError
|
||||
|
||||
def _setup_controller(self):
|
||||
ext_info = plugins.LoadedExtensionInfo()
|
||||
|
@ -158,7 +159,7 @@ class BlockDeviceMappingTestV21(test.TestCase):
|
|||
self.stubs.Set(compute_api.API, 'create', create)
|
||||
|
||||
params = {block_device_mapping.ATTRIBUTE_NAME: self.bdm}
|
||||
self.assertRaises(exc.HTTPBadRequest,
|
||||
self.assertRaises(self.validation_error,
|
||||
self._test_create, params, no_image=True)
|
||||
|
||||
@mock.patch.object(compute_api.API, 'create')
|
||||
|
@ -179,7 +180,7 @@ class BlockDeviceMappingTestV21(test.TestCase):
|
|||
self.stubs.Set(compute_api.API, 'create', create)
|
||||
|
||||
params = {block_device_mapping.ATTRIBUTE_NAME: self.bdm}
|
||||
self.assertRaises(exc.HTTPBadRequest,
|
||||
self.assertRaises(self.validation_error,
|
||||
self._test_create, params, no_image=True)
|
||||
|
||||
def test_create_instance_with_device_name_too_long(self):
|
||||
|
@ -194,7 +195,7 @@ class BlockDeviceMappingTestV21(test.TestCase):
|
|||
self.stubs.Set(compute_api.API, 'create', create)
|
||||
|
||||
params = {block_device_mapping.ATTRIBUTE_NAME: self.bdm}
|
||||
self.assertRaises(exc.HTTPBadRequest,
|
||||
self.assertRaises(self.validation_error,
|
||||
self._test_create, params, no_image=True)
|
||||
|
||||
def test_create_instance_with_space_in_device_name(self):
|
||||
|
@ -210,7 +211,7 @@ class BlockDeviceMappingTestV21(test.TestCase):
|
|||
self.stubs.Set(compute_api.API, 'create', create)
|
||||
|
||||
params = {block_device_mapping.ATTRIBUTE_NAME: self.bdm}
|
||||
self.assertRaises(exc.HTTPBadRequest,
|
||||
self.assertRaises(self.validation_error,
|
||||
self._test_create, params, no_image=True)
|
||||
|
||||
def test_create_instance_with_invalid_size(self):
|
||||
|
@ -225,7 +226,7 @@ class BlockDeviceMappingTestV21(test.TestCase):
|
|||
self.stubs.Set(compute_api.API, 'create', create)
|
||||
|
||||
params = {block_device_mapping.ATTRIBUTE_NAME: self.bdm}
|
||||
self.assertRaises(exc.HTTPBadRequest,
|
||||
self.assertRaises(self.validation_error,
|
||||
self._test_create, params, no_image=True)
|
||||
|
||||
def test_create_instance_bdm(self):
|
||||
|
@ -332,6 +333,7 @@ class BlockDeviceMappingTestV21(test.TestCase):
|
|||
|
||||
|
||||
class BlockDeviceMappingTestV2(BlockDeviceMappingTestV21):
|
||||
validation_error = exc.HTTPBadRequest
|
||||
|
||||
def _setup_controller(self):
|
||||
self.ext_mgr = extensions.ExtensionManager()
|
||||
|
|
Loading…
Reference in New Issue