1fb557bf05
The main methods create/update/delete in HeatIntegrationTest class already contains _wait_for_stack_status, so we can remove duplicate checks in tests. Also was added paramter enable_cleanup for stack_create method, which allows to disable CleanUp method in tests, where we delete stack manually. Change-Id: I41b546d648656676ec9bc3b38940eac68f9a848d
110 lines
4.3 KiB
Python
110 lines
4.3 KiB
Python
# 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
|
|
|
|
from heat_integrationtests.common import exceptions
|
|
from heat_integrationtests.scenario import scenario_base
|
|
|
|
|
|
class CfnInitIntegrationTest(scenario_base.ScenarioTestsBase):
|
|
"""
|
|
The class is responsible for testing cfn-init and cfn-signal workability
|
|
"""
|
|
|
|
def setUp(self):
|
|
super(CfnInitIntegrationTest, self).setUp()
|
|
|
|
def check_stack(self, sid):
|
|
# Check status of all resources
|
|
for res in ('WaitHandle', 'SmokeSecurityGroup', 'SmokeKeys',
|
|
'CfnUser', 'SmokeServer', 'IPAddress'):
|
|
self._wait_for_resource_status(
|
|
sid, res, 'CREATE_COMPLETE')
|
|
|
|
server_resource = self.client.resources.get(sid, 'SmokeServer')
|
|
server_id = server_resource.physical_resource_id
|
|
server = self.compute_client.servers.get(server_id)
|
|
|
|
try:
|
|
self._wait_for_resource_status(
|
|
sid, 'WaitCondition', 'CREATE_COMPLETE')
|
|
except (exceptions.StackResourceBuildErrorException,
|
|
exceptions.TimeoutException) as e:
|
|
raise e
|
|
finally:
|
|
# attempt to log the server console regardless of WaitCondition
|
|
# going to complete. This allows successful and failed cloud-init
|
|
# logs to be compared
|
|
self._log_console_output(servers=[server])
|
|
|
|
stack = self.client.stacks.get(sid)
|
|
|
|
# This is an assert of great significance, as it means the following
|
|
# has happened:
|
|
# - cfn-init read the provided metadata and wrote out a file
|
|
# - a user was created and credentials written to the server
|
|
# - a cfn-signal was built which was signed with provided credentials
|
|
# - the wait condition was fulfilled and the stack has changed state
|
|
wait_status = json.loads(
|
|
self._stack_output(stack, 'WaitConditionStatus'))
|
|
self.assertEqual('smoke test complete', wait_status['smoke_status'])
|
|
|
|
server_ip = self._stack_output(stack, 'SmokeServerIp')
|
|
|
|
# Check that created server is reachable
|
|
if not self._ping_ip_address(server_ip):
|
|
self._log_console_output(servers=[server])
|
|
self.fail(
|
|
"Timed out waiting for %s to become reachable" % server_ip)
|
|
|
|
# Check that the user can authenticate with the generated keypair
|
|
if self.keypair:
|
|
try:
|
|
linux_client = self.get_remote_client(
|
|
server_ip, username='ec2-user')
|
|
linux_client.validate_authentication()
|
|
except (exceptions.ServerUnreachable,
|
|
exceptions.SSHTimeout) as e:
|
|
self._log_console_output(servers=[server])
|
|
raise e
|
|
|
|
def test_server_cfn_init(self):
|
|
"""
|
|
Check cfn-init and cfn-signal availability on the created server.
|
|
|
|
The alternative scenario is the following:
|
|
1. Create a stack with a server and configured security group.
|
|
2. Check that all stack resources were created.
|
|
3. Check that created server is reachable.
|
|
4. Check that stack was created successfully.
|
|
5. Check that is it possible to connect to server
|
|
via generated keypair.
|
|
"""
|
|
parameters = {
|
|
"key_name": self.keypair_name,
|
|
"flavor": self.conf.instance_type,
|
|
"image": self.conf.image_ref,
|
|
"timeout": self.conf.build_timeout,
|
|
"subnet": self.net["subnets"][0],
|
|
}
|
|
|
|
# Launch stack
|
|
stack_id = self.launch_stack(
|
|
template_name="test_server_cfn_init.yaml",
|
|
parameters=parameters,
|
|
expected_status=None
|
|
)
|
|
|
|
# Check stack
|
|
self.check_stack(stack_id)
|