Add compute.instance.resize.confirm.* event model
* Add compute.instance.resize.confirm.start/end models * Add metatests Change-Id: Ia92b53800bfbdda814aa7f4ae1395af33f5466e2
This commit is contained in:
Levi Blackstone
parent
2578611bf3
commit
1c255d7acc
|
|
@ -0,0 +1,183 @@
|
|||
"""
|
||||
Copyright 2015 Rackspace
|
||||
|
||||
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 cloudcafe.events.models.base import EventBaseModel
|
||||
from cloudcafe.events.models.compute.common import FixedIps
|
||||
|
||||
|
||||
BASE_KWARG_MAP = {
|
||||
'access_ip_v4': 'access_ip_v4',
|
||||
'access_ip_v6': 'access_ip_v6',
|
||||
'architecture': 'architecture',
|
||||
'availability_zone': 'availability_zone',
|
||||
'cell_name': 'cell_name',
|
||||
'created_at': 'created_at',
|
||||
'deleted_at': 'deleted_at',
|
||||
'disk_gb': 'disk_gb',
|
||||
'display_name': 'display_name',
|
||||
'ephemeral_gb': 'ephemeral_gb',
|
||||
'host': 'host',
|
||||
'hostname': 'hostname',
|
||||
'image_meta': 'image_meta',
|
||||
'image_ref_url': 'image_ref_url',
|
||||
'instance_flavor_id': 'instance_flavor_id',
|
||||
'instance_id': 'instance_id',
|
||||
'instance_type': 'instance_type',
|
||||
'instance_type_id': 'instance_type_id',
|
||||
'kernel_id': 'kernel_id',
|
||||
'launched_at': 'launched_at',
|
||||
'memory_mb': 'memory_mb',
|
||||
'metadata': 'metadata',
|
||||
'node': 'node',
|
||||
'os_type': 'os_type',
|
||||
'progress': 'progress',
|
||||
'ramdisk_id': 'ramdisk_id',
|
||||
'reservation_id': 'reservation_id',
|
||||
'root_gb': 'root_gb',
|
||||
'state': 'state',
|
||||
'state_description': 'state_description',
|
||||
'tenant_id': 'tenant_id',
|
||||
'terminated_at': 'terminated_at',
|
||||
'user_id': 'user_id',
|
||||
'vcpus': 'vcpus'}
|
||||
|
||||
|
||||
class InstanceResizeConfirmStart(EventBaseModel):
|
||||
"""Compute Instance Resize Confirm Start Response Model
|
||||
|
||||
@summary: Response model for a compute.instance.resize.confirm.start
|
||||
event notification
|
||||
@note: Represents a single event notification
|
||||
|
||||
JSON Example:
|
||||
{
|
||||
"access_ip_v4": "10.10.0.0",
|
||||
"access_ip_v6": null,
|
||||
"architecture": "x64",
|
||||
"availability_zone": null,
|
||||
"cell_name": "cell name",
|
||||
"created_at": "2015-01-15 18:59:29",
|
||||
"deleted_at": "",
|
||||
"disk_gb": 20,
|
||||
"display_name": "server123456",
|
||||
"ephemeral_gb": 0,
|
||||
"fixed_ips": { <FixedIps> },
|
||||
"host": null,
|
||||
"hostname": "server123456",
|
||||
"image_meta": { <ImageMeta> },
|
||||
"image_ref_url": "http://127.0.0.1/images/my_image",
|
||||
"instance_flavor_id": "instance_flavor_id",
|
||||
"instance_id": "performance1-1",
|
||||
"instance_type": "1 GB Performance",
|
||||
"instance_type_id": "9",
|
||||
"kernel_id": "",
|
||||
"launched_at": "",
|
||||
"memory_mb": 1024,
|
||||
"metadata": {},
|
||||
"node": null,
|
||||
"os_type": "linux",
|
||||
"progress": "",
|
||||
"ramdisk_id": "",
|
||||
"reservation_id": "r-abcdefg",
|
||||
"root_gb": 20,
|
||||
"state": "building",
|
||||
"state_description": "",
|
||||
"tenant_id": "123456",
|
||||
"terminated_at": "",
|
||||
"user_id": "123456789",
|
||||
"vcpus": 1
|
||||
}
|
||||
"""
|
||||
kwarg_map = {}
|
||||
kwarg_map.update(BASE_KWARG_MAP)
|
||||
|
||||
def __init__(self, access_ip_v4, access_ip_v6, architecture,
|
||||
availability_zone, cell_name, created_at, deleted_at,
|
||||
disk_gb, display_name, ephemeral_gb, host, hostname,
|
||||
image_meta, image_ref_url, instance_flavor_id, instance_id,
|
||||
instance_type, instance_type_id, kernel_id, launched_at,
|
||||
memory_mb, metadata, node, os_type, progress, ramdisk_id,
|
||||
reservation_id, root_gb, state, state_description, tenant_id,
|
||||
terminated_at, user_id, vcpus):
|
||||
super(InstanceResizeConfirmStart, self).__init__(locals())
|
||||
|
||||
|
||||
class InstanceResizeConfirmEnd(EventBaseModel):
|
||||
"""Compute Instance Resize Confirm End Response Model
|
||||
|
||||
@summary: Response model for a compute.instance.resize.confirm.end
|
||||
event notification
|
||||
@note: Represents a single event notification
|
||||
|
||||
JSON Example:
|
||||
{
|
||||
"access_ip_v4": "10.10.0.0",
|
||||
"access_ip_v6": null,
|
||||
"architecture": "x64",
|
||||
"availability_zone": null,
|
||||
"cell_name": "cell name",
|
||||
"created_at": "2015-01-15 18:59:29",
|
||||
"deleted_at": "",
|
||||
"disk_gb": 20,
|
||||
"display_name": "server123456",
|
||||
"ephemeral_gb": 0,
|
||||
"fixed_ips": { <FixedIps> },
|
||||
"host": null,
|
||||
"hostname": "server123456",
|
||||
"image_meta": { <ImageMeta> },
|
||||
"image_ref_url": "http://127.0.0.1/images/my_image",
|
||||
"instance_flavor_id": "instance_flavor_id",
|
||||
"instance_id": "performance1-1",
|
||||
"instance_type": "1 GB Performance",
|
||||
"instance_type_id": "9",
|
||||
"kernel_id": "",
|
||||
"launched_at": "",
|
||||
"memory_mb": 1024,
|
||||
"metadata": {},
|
||||
"node": null,
|
||||
"os_type": "linux",
|
||||
"progress": "",
|
||||
"ramdisk_id": "",
|
||||
"reservation_id": "r-abcdefg",
|
||||
"root_gb": 20,
|
||||
"state": "building",
|
||||
"state_description": "",
|
||||
"tenant_id": "123456",
|
||||
"terminated_at": "",
|
||||
"user_id": "123456789",
|
||||
"vcpus": 1
|
||||
}
|
||||
"""
|
||||
kwarg_map = {'fixed_ips': 'fixed_ips'}
|
||||
kwarg_map.update(BASE_KWARG_MAP)
|
||||
|
||||
def __init__(self, access_ip_v4, access_ip_v6, architecture,
|
||||
availability_zone, cell_name, created_at, deleted_at,
|
||||
disk_gb, display_name, ephemeral_gb, fixed_ips, host,
|
||||
hostname, image_meta, image_ref_url, instance_flavor_id,
|
||||
instance_id, instance_type, instance_type_id, kernel_id,
|
||||
launched_at, memory_mb, metadata, node, os_type, progress,
|
||||
ramdisk_id, reservation_id, root_gb, state, state_description,
|
||||
tenant_id, terminated_at, user_id, vcpus):
|
||||
super(InstanceResizeConfirmEnd, self).__init__(locals())
|
||||
|
||||
@classmethod
|
||||
def _dict_to_obj(cls, json_dict):
|
||||
"""Override dict_to_obj implementation"""
|
||||
obj = cls._map_values_to_kwargs(json_dict)
|
||||
obj.fixed_ips = FixedIps._list_to_obj(obj.fixed_ips)
|
||||
|
||||
return obj
|
||||
|
|
@ -0,0 +1,166 @@
|
|||
"""
|
||||
Copyright 2015 Rackspace
|
||||
|
||||
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 json
|
||||
import unittest
|
||||
|
||||
from cloudcafe.events.models.compute.instance_resize_confirm import (
|
||||
InstanceResizeConfirmStart, InstanceResizeConfirmEnd)
|
||||
|
||||
|
||||
class BaseInstanceActionsTest(unittest.TestCase):
|
||||
@classmethod
|
||||
def setUpClass(cls):
|
||||
super(BaseInstanceActionsTest, cls).setUpClass()
|
||||
|
||||
cls.fixed_ip_dict = {
|
||||
"address": "10.10.0.0",
|
||||
"floating_ips": [],
|
||||
"label": "public",
|
||||
"meta": {},
|
||||
"type": "fixed",
|
||||
"version": 4,
|
||||
"vif_mac": "FE:ED:FA:00:1C:D4"
|
||||
}
|
||||
|
||||
cls.image_meta_dict = {
|
||||
"auto_disk_config": "disabled",
|
||||
"base_image_ref": "5e91ad7f-afe4-4a83-bd5f-84673462cae1",
|
||||
"container_format": "ovf",
|
||||
"disk_format": "vhd",
|
||||
"image_type": "base",
|
||||
"min_disk": "20",
|
||||
"min_ram": "512",
|
||||
"org.openstack__1__architecture": "x64",
|
||||
"org.openstack__1__os_distro": "com.ubuntu",
|
||||
"org.openstack__1__os_version": "12.04",
|
||||
"os_type": "linux"
|
||||
}
|
||||
|
||||
cls.base_resize_confirm_dict = {
|
||||
"access_ip_v4": "10.10.0.0",
|
||||
"access_ip_v6": None,
|
||||
"architecture": "x64",
|
||||
"availability_zone": None,
|
||||
"cell_name": "cell name",
|
||||
"created_at": "2015-01-15 18:59:29",
|
||||
"deleted_at": "",
|
||||
"disk_gb": 20,
|
||||
"display_name": "server123456",
|
||||
"ephemeral_gb": 0,
|
||||
"host": None,
|
||||
"hostname": "server123456",
|
||||
"image_meta": cls.image_meta_dict,
|
||||
"image_ref_url": "http://127.0.0.1/images/my_image",
|
||||
"instance_flavor_id": "instance_flavor_id",
|
||||
"instance_id": "performance1-1",
|
||||
"instance_type": "1 GB Performance",
|
||||
"instance_type_id": "9",
|
||||
"kernel_id": "",
|
||||
"launched_at": "",
|
||||
"memory_mb": 1024,
|
||||
"metadata": {},
|
||||
"node": None,
|
||||
"os_type": "linux",
|
||||
"progress": "",
|
||||
"ramdisk_id": "",
|
||||
"reservation_id": "r-abcdefg",
|
||||
"root_gb": 20,
|
||||
"state": "building",
|
||||
"state_description": "",
|
||||
"tenant_id": "123456",
|
||||
"terminated_at": "",
|
||||
"user_id": "123456789",
|
||||
"vcpus": 1
|
||||
}
|
||||
|
||||
cls.resize_confirm_end_dict = {
|
||||
"fixed_ips": [cls.fixed_ip_dict]
|
||||
}
|
||||
cls.resize_confirm_end_dict.update(cls.base_resize_confirm_dict)
|
||||
|
||||
cls.resize_confirm_start_obj = InstanceResizeConfirmStart._dict_to_obj(
|
||||
cls.base_resize_confirm_dict)
|
||||
cls.resize_confirm_end_obj = InstanceResizeConfirmEnd._dict_to_obj(
|
||||
cls.resize_confirm_end_dict)
|
||||
|
||||
|
||||
class InstanceResizeConfirmStartTest(BaseInstanceActionsTest):
|
||||
|
||||
def test_instance_resize_confirm_start_valid_json(self):
|
||||
"""Verify that the valid event deserialized correctly"""
|
||||
expected_obj = self.resize_confirm_start_obj
|
||||
|
||||
actual_json = json.dumps(self.base_resize_confirm_dict)
|
||||
actual_obj = InstanceResizeConfirmStart.deserialize(
|
||||
actual_json, 'json')
|
||||
|
||||
self.assertEqual(expected_obj, actual_obj)
|
||||
self.assertFalse(actual_obj.is_empty())
|
||||
|
||||
def test_instance_resize_confirm_start_missing_attribute_json(self):
|
||||
"""Verify event missing expected attribute does not deserialize"""
|
||||
modified_dict = self.base_resize_confirm_dict.copy()
|
||||
modified_dict.popitem()
|
||||
|
||||
actual_json = json.dumps(modified_dict)
|
||||
actual_obj = InstanceResizeConfirmStart.deserialize(
|
||||
actual_json, 'json')
|
||||
self.assertIsNone(actual_obj)
|
||||
|
||||
def test_instance_resize_confirm_start_extra_attribute_json(self):
|
||||
"""Verify event with unexpected attribute does not deserialize"""
|
||||
modified_dict = self.base_resize_confirm_dict.copy()
|
||||
modified_dict['test_dummy'] = 'test_dummy'
|
||||
|
||||
actual_json = json.dumps(modified_dict)
|
||||
actual_obj = InstanceResizeConfirmStart.deserialize(
|
||||
actual_json, 'json')
|
||||
self.assertIsNone(actual_obj)
|
||||
|
||||
|
||||
class InstanceResizeConfirmEndTest(BaseInstanceActionsTest):
|
||||
|
||||
def test_instance_resize_confirm_end_valid_json(self):
|
||||
"""Verify that the valid event deserialized correctly"""
|
||||
expected_obj = self.resize_confirm_end_obj
|
||||
|
||||
actual_json = json.dumps(self.resize_confirm_end_dict)
|
||||
actual_obj = InstanceResizeConfirmEnd.deserialize(
|
||||
actual_json, 'json')
|
||||
|
||||
self.assertEqual(expected_obj, actual_obj)
|
||||
self.assertFalse(actual_obj.is_empty())
|
||||
|
||||
def test_instance_resize_confirm_end_missing_attribute_json(self):
|
||||
"""Verify event missing expected attribute does not deserialize"""
|
||||
modified_dict = self.resize_confirm_end_dict.copy()
|
||||
modified_dict.popitem()
|
||||
|
||||
actual_json = json.dumps(modified_dict)
|
||||
actual_obj = InstanceResizeConfirmEnd.deserialize(
|
||||
actual_json, 'json')
|
||||
self.assertIsNone(actual_obj)
|
||||
|
||||
def test_instance_resize_confirm_end_extra_attribute_json(self):
|
||||
"""Verify event with unexpected attribute does not deserialize"""
|
||||
modified_dict = self.resize_confirm_end_dict.copy()
|
||||
modified_dict['test_dummy'] = 'test_dummy'
|
||||
|
||||
actual_json = json.dumps(modified_dict)
|
||||
actual_obj = InstanceResizeConfirmEnd.deserialize(
|
||||
actual_json, 'json')
|
||||
self.assertIsNone(actual_obj)
|
||||
Loading…
Reference in New Issue