diff options
Diffstat (limited to 'heat/tests/test_instance_network.py')
| -rw-r--r-- | heat/tests/test_instance_network.py | 272 |
1 files changed, 272 insertions, 0 deletions
diff --git a/heat/tests/test_instance_network.py b/heat/tests/test_instance_network.py new file mode 100644 index 000000000..4f0ffabf3 --- /dev/null +++ b/heat/tests/test_instance_network.py @@ -0,0 +1,272 @@ +# vim: tabstop=4 shiftwidth=4 softtabstop=4 + +# 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 unittest +import mox + +from nose.plugins.attrib import attr + +from heat.tests.v1_1 import fakes +from heat.engine.resources import instance as instances +from heat.engine.resources import network_interface as network_interfaces +from heat.common import template_format +from heat.engine import parser +from heat.openstack.common import uuidutils + +wp_template = ''' +{ + "AWSTemplateFormatVersion" : "2010-09-09", + "Description" : "WordPress", + "Parameters" : { + "KeyName" : { + "Description" : "KeyName", + "Type" : "String", + "Default" : "test" + }, + "InstanceType": { + "Type": "String", + "Description": "EC2 instance type", + "Default": "m1.small", + "AllowedValues": [ "m1.small", "m1.large" ] + }, + "SubnetId": { + "Type" : "String", + "Description" : "SubnetId of an existing subnet in your VPC" + }, + }, + "Resources" : { + "WebServer": { + "Type": "AWS::EC2::Instance", + "Properties": { + "ImageId" : "F17-x86_64-gold", + "InstanceType" : { "Ref" : "InstanceType" }, + "SubnetId" : { "Ref" : "SubnetId" }, + "KeyName" : { "Ref" : "KeyName" }, + "UserData" : "wordpress" + } + } + } +} +''' + +wp_template_with_nic = ''' +{ + "AWSTemplateFormatVersion" : "2010-09-09", + "Description" : "WordPress", + "Parameters" : { + "KeyName" : { + "Description" : "KeyName", + "Type" : "String", + "Default" : "test" + }, + "InstanceType": { + "Type": "String", + "Description": "EC2 instance type", + "Default": "m1.small", + "AllowedValues": [ "m1.small", "m1.large" ] + }, + "SubnetId": { + "Type" : "String", + "Description" : "SubnetId of an existing subnet in your VPC" + }, + }, + "Resources" : { + + "nic1": { + "Type": "AWS::EC2::NetworkInterface", + "Properties": { + "SubnetId": { "Ref": "SubnetId" } + } + }, + + "WebServer": { + "Type": "AWS::EC2::Instance", + "Properties": { + "ImageId" : "F17-x86_64-gold", + "InstanceType" : { "Ref" : "InstanceType" }, + "NetworkInterfaces": [ { "NetworkInterfaceId" : {"Ref": "nic1"}, + "DeviceIndex" : "0" } ], + "KeyName" : { "Ref" : "KeyName" }, + "UserData" : "wordpress" + } + } + } +} +''' + + +class FakeQuantum(object): + + def show_subnet(self, subnet, **_params): + return { + 'subnet': { + 'name': 'name', + 'network_id': 'fc68ea2c-b60b-4b4f-bd82-94ec81110766', + 'tenant_id': 'c1210485b2424d48804aad5d39c61b8f', + 'allocation_pools': [{'start': '10.10.0.2', + 'end': '10.10.0.254'}], + 'gateway_ip': '10.10.0.1', + 'ip_version': 4, + 'cidr': '10.10.0.0/24', + 'id': '4156c7a5-e8c4-4aff-a6e1-8f3c7bc83861', + 'enable_dhcp': False, + + }} + + def create_port(self, body=None): + return { + 'port': { + 'admin_state_up': True, + 'device_id': '', + 'device_owner': '', + 'fixed_ips': [{ + 'ip_address': '10.0.3.3', + 'subnet_id': '4156c7a5-e8c4-4aff-a6e1-8f3c7bc83861'}], + 'id': '64d913c1-bcb1-42d2-8f0a-9593dbcaf251', + 'mac_address': 'fa:16:3e:25:32:5d', + 'name': '', + 'network_id': 'fc68ea2c-b60b-4b4f-bd82-94ec81110766', + 'status': 'ACTIVE', + 'tenant_id': 'c1210485b2424d48804aad5d39c61b8f' + }} + + +@attr(tag=['unit', 'resource', 'instance']) +@attr(speed='fast') +class instancesTest(unittest.TestCase): + def setUp(self): + self.m = mox.Mox() + self.fc = fakes.FakeClient() + + def _create_test_instance(self, return_server, name): + stack_name = '%s_stack' % name + t = template_format.parse(wp_template) + template = parser.Template(t) + kwargs = {'KeyName': 'test', + 'InstanceType': 'm1.large', + 'SubnetId': '4156c7a5-e8c4-4aff-a6e1-8f3c7bc83861'} + params = parser.Parameters(stack_name, template, kwargs) + stack = parser.Stack(None, stack_name, template, params, + stack_id=uuidutils.generate_uuid()) + + t['Resources']['WebServer']['Properties']['ImageId'] = 'CentOS 5.2' + instance = instances.Instance('%s_name' % name, + t['Resources']['WebServer'], stack) + + self.m.StubOutWithMock(instance, 'nova') + instance.nova().MultipleTimes().AndReturn(self.fc) + + self.m.StubOutWithMock(instance, 'quantum') + instance.quantum().MultipleTimes().AndReturn(FakeQuantum()) + + instance.t = instance.stack.resolve_runtime_data(instance.t) + + # need to resolve the template functions + server_userdata = instance._build_userdata( + instance.t['Properties']['UserData']) + + self.m.StubOutWithMock(self.fc.servers, 'create') + self.fc.servers.create( + image=1, flavor=3, key_name='test', + name='%s.%s' % (stack_name, instance.name), + security_groups=None, + userdata=server_userdata, scheduler_hints=None, meta=None, + nics=[{'port-id': '64d913c1-bcb1-42d2-8f0a-9593dbcaf251'}], + availability_zone=None).AndReturn( + return_server) + self.m.ReplayAll() + + self.assertEqual(instance.create(), None) + return instance + + def _create_test_instance_with_nic(self, return_server, name): + stack_name = '%s_stack' % name + t = template_format.parse(wp_template_with_nic) + template = parser.Template(t) + kwargs = {'KeyName': 'test', + 'InstanceType': 'm1.large', + 'SubnetId': '4156c7a5-e8c4-4aff-a6e1-8f3c7bc83861'} + params = parser.Parameters(stack_name, template, kwargs) + stack = parser.Stack(None, stack_name, template, params, + stack_id=uuidutils.generate_uuid()) + + t['Resources']['WebServer']['Properties']['ImageId'] = 'CentOS 5.2' + + nic = network_interfaces.NetworkInterface('%s_nic' % name, + t['Resources']['nic1'], + stack) + + instance = instances.Instance('%s_name' % name, + t['Resources']['WebServer'], stack) + + self.m.StubOutWithMock(nic, 'quantum') + nic.quantum().MultipleTimes().AndReturn(FakeQuantum()) + + self.m.StubOutWithMock(instance, 'nova') + instance.nova().MultipleTimes().AndReturn(self.fc) + + nic.t = nic.stack.resolve_runtime_data(nic.t) + instance.t = instance.stack.resolve_runtime_data(instance.t) + + # need to resolve the template functions + server_userdata = instance._build_userdata( + instance.t['Properties']['UserData']) + self.m.StubOutWithMock(self.fc.servers, 'create') + self.fc.servers.create( + image=1, flavor=3, key_name='test', + name='%s.%s' % (stack_name, instance.name), + security_groups=None, + userdata=server_userdata, scheduler_hints=None, meta=None, + nics=[{'port-id': '64d913c1-bcb1-42d2-8f0a-9593dbcaf251'}], + availability_zone=None).AndReturn( + return_server) + self.m.ReplayAll() + + # create network interface + self.assertEqual(nic.create(), None) + stack.resources["nic1"] = nic + + self.assertEqual(instance.create(), None) + return instance + + def test_instance_create(self): + return_server = self.fc.servers.list()[1] + instance = self._create_test_instance(return_server, + 'test_instance_create') + # this makes sure the auto increment worked on instance creation + self.assertTrue(instance.id > 0) + + expected_ip = return_server.networks['public'][0] + self.assertEqual(instance.FnGetAtt('PublicIp'), expected_ip) + self.assertEqual(instance.FnGetAtt('PrivateIp'), expected_ip) + self.assertEqual(instance.FnGetAtt('PrivateDnsName'), expected_ip) + self.assertEqual(instance.FnGetAtt('PrivateDnsName'), expected_ip) + + self.m.VerifyAll() + + def test_instance_create_with_nic(self): + return_server = self.fc.servers.list()[1] + instance = self._create_test_instance_with_nic( + return_server, 'test_instance_create_with_network_interface') + + # this makes sure the auto increment worked on instance creation + self.assertTrue(instance.id > 0) + + expected_ip = return_server.networks['public'][0] + self.assertEqual(instance.FnGetAtt('PublicIp'), expected_ip) + self.assertEqual(instance.FnGetAtt('PrivateIp'), expected_ip) + self.assertEqual(instance.FnGetAtt('PrivateDnsName'), expected_ip) + self.assertEqual(instance.FnGetAtt('PrivateDnsName'), expected_ip) + + self.m.VerifyAll() |