Move orchestration_client from tempest to murano tempest plugin.
orchestration_client in Tempest is planned to be removed and heat
client present in heat_tempest_plugin is supposed to be used
- ba43685c13/heat_tempest_plugin/services/clients.py (L103)
Meanwhile murano_tempest_plugin is the only user of tempest orchestration_client
so moving that here and it can be removed once murano switch to use
client from heat_tempest_plugin.
Change-Id: I8f160c6b9b59d6915d6fb346be7816b4b8084939
This commit is contained in:
Ghanshyam Mann
parent
cf5b003783
commit
a96aab9567
|
|
@ -0,0 +1,412 @@
|
|||
# Copyright 2013 IBM Corp.
|
||||
# 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.
|
||||
|
||||
import re
|
||||
import time
|
||||
from urllib import parse as urllib
|
||||
|
||||
from oslo_serialization import jsonutils as json
|
||||
from tempest import exceptions
|
||||
from tempest.lib.common import rest_client
|
||||
from tempest.lib import exceptions as lib_exc
|
||||
|
||||
|
||||
class OrchestrationClient(rest_client.RestClient):
|
||||
|
||||
def list_stacks(self, params=None):
|
||||
"""Lists all stacks for a user."""
|
||||
|
||||
uri = 'stacks'
|
||||
if params:
|
||||
uri += '?%s' % urllib.urlencode(params)
|
||||
|
||||
resp, body = self.get(uri)
|
||||
self.expected_success(200, resp.status)
|
||||
body = json.loads(body)
|
||||
return rest_client.ResponseBody(resp, body)
|
||||
|
||||
def create_stack(self, name, disable_rollback=True, parameters=None,
|
||||
timeout_mins=60, template=None, template_url=None,
|
||||
environment=None, files=None):
|
||||
if parameters is None:
|
||||
parameters = {}
|
||||
headers, body = self._prepare_update_create(
|
||||
name,
|
||||
disable_rollback,
|
||||
parameters,
|
||||
timeout_mins,
|
||||
template,
|
||||
template_url,
|
||||
environment,
|
||||
files)
|
||||
uri = 'stacks'
|
||||
resp, body = self.post(uri, headers=headers, body=body)
|
||||
self.expected_success(201, resp.status)
|
||||
body = json.loads(body)
|
||||
return rest_client.ResponseBody(resp, body)
|
||||
|
||||
def update_stack(self, stack_identifier, name, disable_rollback=True,
|
||||
parameters=None, timeout_mins=60, template=None,
|
||||
template_url=None, environment=None, files=None):
|
||||
if parameters is None:
|
||||
parameters = {}
|
||||
headers, body = self._prepare_update_create(
|
||||
name,
|
||||
disable_rollback,
|
||||
parameters,
|
||||
timeout_mins,
|
||||
template,
|
||||
template_url,
|
||||
environment)
|
||||
|
||||
uri = "stacks/%s" % stack_identifier
|
||||
resp, body = self.put(uri, headers=headers, body=body)
|
||||
self.expected_success(202, resp.status)
|
||||
return rest_client.ResponseBody(resp, body)
|
||||
|
||||
def _prepare_update_create(self, name, disable_rollback=True,
|
||||
parameters=None, timeout_mins=60,
|
||||
template=None, template_url=None,
|
||||
environment=None, files=None):
|
||||
if parameters is None:
|
||||
parameters = {}
|
||||
post_body = {
|
||||
"stack_name": name,
|
||||
"disable_rollback": disable_rollback,
|
||||
"parameters": parameters,
|
||||
"timeout_mins": timeout_mins,
|
||||
"template": "HeatTemplateFormatVersion: '2012-12-12'\n",
|
||||
"environment": environment,
|
||||
"files": files
|
||||
}
|
||||
if template:
|
||||
post_body['template'] = template
|
||||
if template_url:
|
||||
post_body['template_url'] = template_url
|
||||
body = json.dumps(post_body)
|
||||
|
||||
# Password must be provided on stack create so that heat
|
||||
# can perform future operations on behalf of the user
|
||||
headers = self.get_headers()
|
||||
headers['X-Auth-Key'] = self.password
|
||||
headers['X-Auth-User'] = self.user
|
||||
return headers, body
|
||||
|
||||
def show_stack(self, stack_identifier):
|
||||
"""Returns the details of a single stack."""
|
||||
url = "stacks/%s" % stack_identifier
|
||||
resp, body = self.get(url)
|
||||
self.expected_success(200, resp.status)
|
||||
body = json.loads(body)
|
||||
return rest_client.ResponseBody(resp, body)
|
||||
|
||||
def suspend_stack(self, stack_identifier):
|
||||
"""Suspend a stack."""
|
||||
url = 'stacks/%s/actions' % stack_identifier
|
||||
body = {'suspend': None}
|
||||
resp, body = self.post(url, json.dumps(body))
|
||||
self.expected_success(200, resp.status)
|
||||
return rest_client.ResponseBody(resp)
|
||||
|
||||
def resume_stack(self, stack_identifier):
|
||||
"""Resume a stack."""
|
||||
url = 'stacks/%s/actions' % stack_identifier
|
||||
body = {'resume': None}
|
||||
resp, body = self.post(url, json.dumps(body))
|
||||
self.expected_success(200, resp.status)
|
||||
return rest_client.ResponseBody(resp)
|
||||
|
||||
def list_resources(self, stack_identifier):
|
||||
"""Returns the details of a single resource."""
|
||||
url = "stacks/%s/resources" % stack_identifier
|
||||
resp, body = self.get(url)
|
||||
self.expected_success(200, resp.status)
|
||||
body = json.loads(body)
|
||||
return rest_client.ResponseBody(resp, body)
|
||||
|
||||
def show_resource(self, stack_identifier, resource_name):
|
||||
"""Returns the details of a single resource."""
|
||||
url = "stacks/%s/resources/%s" % (stack_identifier, resource_name)
|
||||
resp, body = self.get(url)
|
||||
self.expected_success(200, resp.status)
|
||||
body = json.loads(body)
|
||||
return rest_client.ResponseBody(resp, body)
|
||||
|
||||
def delete_stack(self, stack_identifier):
|
||||
"""Deletes the specified Stack."""
|
||||
resp, _ = self.delete("stacks/%s" % str(stack_identifier))
|
||||
self.expected_success(204, resp.status)
|
||||
return rest_client.ResponseBody(resp)
|
||||
|
||||
def wait_for_stack_status(self, stack_identifier, status,
|
||||
failure_pattern='^.*_FAILED$'):
|
||||
"""Waits for a Stack to reach a given status."""
|
||||
start = int(time.time())
|
||||
fail_regexp = re.compile(failure_pattern)
|
||||
|
||||
while True:
|
||||
try:
|
||||
body = self.show_stack(stack_identifier)['stack']
|
||||
except lib_exc.NotFound:
|
||||
if status == 'DELETE_COMPLETE':
|
||||
return
|
||||
stack_name = body['stack_name']
|
||||
stack_status = body['stack_status']
|
||||
if stack_status == status:
|
||||
return body
|
||||
if fail_regexp.search(stack_status):
|
||||
raise exceptions.StackBuildErrorException(
|
||||
stack_identifier=stack_identifier,
|
||||
stack_status=stack_status,
|
||||
stack_status_reason=body['stack_status_reason'])
|
||||
|
||||
if int(time.time()) - start >= self.build_timeout:
|
||||
message = ('Stack %s failed to reach %s status (current: %s) '
|
||||
'within the required time (%s s).' %
|
||||
(stack_name, status, stack_status,
|
||||
self.build_timeout))
|
||||
raise lib_exc.TimeoutException(message)
|
||||
time.sleep(self.build_interval)
|
||||
|
||||
def show_resource_metadata(self, stack_identifier, resource_name):
|
||||
"""Returns the resource's metadata."""
|
||||
url = ('stacks/{stack_identifier}/resources/{resource_name}'
|
||||
'/metadata'.format(**locals()))
|
||||
resp, body = self.get(url)
|
||||
self.expected_success(200, resp.status)
|
||||
body = json.loads(body)
|
||||
return rest_client.ResponseBody(resp, body)
|
||||
|
||||
def list_events(self, stack_identifier):
|
||||
"""Returns list of all events for a stack."""
|
||||
url = 'stacks/{stack_identifier}/events'.format(**locals())
|
||||
resp, body = self.get(url)
|
||||
self.expected_success(200, resp.status)
|
||||
body = json.loads(body)
|
||||
return rest_client.ResponseBody(resp, body)
|
||||
|
||||
def list_resource_events(self, stack_identifier, resource_name):
|
||||
"""Returns list of all events for a resource from stack."""
|
||||
url = ('stacks/{stack_identifier}/resources/{resource_name}'
|
||||
'/events'.format(**locals()))
|
||||
resp, body = self.get(url)
|
||||
self.expected_success(200, resp.status)
|
||||
body = json.loads(body)
|
||||
return rest_client.ResponseBody(resp, body)
|
||||
|
||||
def show_event(self, stack_identifier, resource_name, event_id):
|
||||
"""Returns the details of a single stack's event."""
|
||||
url = ('stacks/{stack_identifier}/resources/{resource_name}/events'
|
||||
'/{event_id}'.format(**locals()))
|
||||
resp, body = self.get(url)
|
||||
self.expected_success(200, resp.status)
|
||||
body = json.loads(body)
|
||||
return rest_client.ResponseBody(resp, body)
|
||||
|
||||
def show_template(self, stack_identifier):
|
||||
"""Returns the template for the stack."""
|
||||
url = ('stacks/{stack_identifier}/template'.format(**locals()))
|
||||
resp, body = self.get(url)
|
||||
self.expected_success(200, resp.status)
|
||||
body = json.loads(body)
|
||||
return rest_client.ResponseBody(resp, body)
|
||||
|
||||
def _validate_template(self, post_body):
|
||||
"""Returns the validation request result."""
|
||||
post_body = json.dumps(post_body)
|
||||
resp, body = self.post('validate', post_body)
|
||||
self.expected_success(200, resp.status)
|
||||
body = json.loads(body)
|
||||
return rest_client.ResponseBody(resp, body)
|
||||
|
||||
def validate_template(self, template, parameters=None):
|
||||
"""Returns the validation result for a template with parameters."""
|
||||
if parameters is None:
|
||||
parameters = {}
|
||||
post_body = {
|
||||
'template': template,
|
||||
'parameters': parameters,
|
||||
}
|
||||
return self._validate_template(post_body)
|
||||
|
||||
def validate_template_url(self, template_url, parameters=None):
|
||||
"""Returns the validation result for a template with parameters."""
|
||||
if parameters is None:
|
||||
parameters = {}
|
||||
post_body = {
|
||||
'template_url': template_url,
|
||||
'parameters': parameters,
|
||||
}
|
||||
return self._validate_template(post_body)
|
||||
|
||||
def list_resource_types(self):
|
||||
"""List resource types."""
|
||||
resp, body = self.get('resource_types')
|
||||
self.expected_success(200, resp.status)
|
||||
body = json.loads(body)
|
||||
return rest_client.ResponseBody(resp, body)
|
||||
|
||||
def show_resource_type(self, resource_type_name):
|
||||
"""Return the schema of a resource type."""
|
||||
url = 'resource_types/%s' % resource_type_name
|
||||
resp, body = self.get(url)
|
||||
self.expected_success(200, resp.status)
|
||||
return rest_client.ResponseBody(resp, json.loads(body))
|
||||
|
||||
def show_resource_type_template(self, resource_type_name):
|
||||
"""Return the template of a resource type."""
|
||||
url = 'resource_types/%s/template' % resource_type_name
|
||||
resp, body = self.get(url)
|
||||
self.expected_success(200, resp.status)
|
||||
return rest_client.ResponseBody(resp, json.loads(body))
|
||||
|
||||
def create_software_config(self, name=None, config=None, group=None,
|
||||
inputs=None, outputs=None, options=None):
|
||||
headers, body = self._prep_software_config_create(
|
||||
name, config, group, inputs, outputs, options)
|
||||
|
||||
url = 'software_configs'
|
||||
resp, body = self.post(url, headers=headers, body=body)
|
||||
self.expected_success(200, resp.status)
|
||||
body = json.loads(body)
|
||||
return rest_client.ResponseBody(resp, body)
|
||||
|
||||
def show_software_config(self, conf_id):
|
||||
"""Returns a software configuration resource."""
|
||||
url = 'software_configs/%s' % str(conf_id)
|
||||
resp, body = self.get(url)
|
||||
self.expected_success(200, resp.status)
|
||||
body = json.loads(body)
|
||||
return rest_client.ResponseBody(resp, body)
|
||||
|
||||
def delete_software_config(self, conf_id):
|
||||
"""Deletes a specific software configuration."""
|
||||
url = 'software_configs/%s' % str(conf_id)
|
||||
resp, _ = self.delete(url)
|
||||
self.expected_success(204, resp.status)
|
||||
return rest_client.ResponseBody(resp)
|
||||
|
||||
def create_software_deploy(self, server_id=None, config_id=None,
|
||||
action=None, status=None,
|
||||
input_values=None, output_values=None,
|
||||
status_reason=None, signal_transport=None):
|
||||
"""Creates or updates a software deployment."""
|
||||
headers, body = self._prep_software_deploy_update(
|
||||
None, server_id, config_id, action, status, input_values,
|
||||
output_values, status_reason, signal_transport)
|
||||
|
||||
url = 'software_deployments'
|
||||
resp, body = self.post(url, headers=headers, body=body)
|
||||
self.expected_success(200, resp.status)
|
||||
body = json.loads(body)
|
||||
return rest_client.ResponseBody(resp, body)
|
||||
|
||||
def update_software_deploy(self, deploy_id=None, server_id=None,
|
||||
config_id=None, action=None, status=None,
|
||||
input_values=None, output_values=None,
|
||||
status_reason=None, signal_transport=None):
|
||||
"""Creates or updates a software deployment."""
|
||||
headers, body = self._prep_software_deploy_update(
|
||||
deploy_id, server_id, config_id, action, status, input_values,
|
||||
output_values, status_reason, signal_transport)
|
||||
|
||||
url = 'software_deployments/%s' % str(deploy_id)
|
||||
resp, body = self.put(url, headers=headers, body=body)
|
||||
self.expected_success(200, resp.status)
|
||||
body = json.loads(body)
|
||||
return rest_client.ResponseBody(resp, body)
|
||||
|
||||
def list_software_deployments(self):
|
||||
"""Returns a list of all deployments."""
|
||||
url = 'software_deployments'
|
||||
resp, body = self.get(url)
|
||||
self.expected_success(200, resp.status)
|
||||
body = json.loads(body)
|
||||
return rest_client.ResponseBody(resp, body)
|
||||
|
||||
def show_software_deployment(self, deploy_id):
|
||||
"""Returns a specific software deployment."""
|
||||
url = 'software_deployments/%s' % str(deploy_id)
|
||||
resp, body = self.get(url)
|
||||
self.expected_success(200, resp.status)
|
||||
body = json.loads(body)
|
||||
return rest_client.ResponseBody(resp, body)
|
||||
|
||||
def show_software_deployment_metadata(self, server_id):
|
||||
"""Return a config metadata for a specific server."""
|
||||
url = 'software_deployments/metadata/%s' % server_id
|
||||
resp, body = self.get(url)
|
||||
self.expected_success(200, resp.status)
|
||||
body = json.loads(body)
|
||||
return rest_client.ResponseBody(resp, body)
|
||||
|
||||
def delete_software_deploy(self, deploy_id):
|
||||
"""Deletes a specific software deployment."""
|
||||
url = 'software_deployments/%s' % str(deploy_id)
|
||||
resp, _ = self.delete(url)
|
||||
self.expected_success(204, resp.status)
|
||||
return rest_client.ResponseBody(resp)
|
||||
|
||||
def _prep_software_config_create(self, name=None, conf=None, group=None,
|
||||
inputs=None, outputs=None, options=None):
|
||||
"""Prepares a software configuration body."""
|
||||
post_body = {}
|
||||
if name is not None:
|
||||
post_body["name"] = name
|
||||
if conf is not None:
|
||||
post_body["config"] = conf
|
||||
if group is not None:
|
||||
post_body["group"] = group
|
||||
if inputs is not None:
|
||||
post_body["inputs"] = inputs
|
||||
if outputs is not None:
|
||||
post_body["outputs"] = outputs
|
||||
if options is not None:
|
||||
post_body["options"] = options
|
||||
body = json.dumps(post_body)
|
||||
|
||||
headers = self.get_headers()
|
||||
return headers, body
|
||||
|
||||
def _prep_software_deploy_update(self, deploy_id=None, server_id=None,
|
||||
config_id=None, action=None, status=None,
|
||||
input_values=None, output_values=None,
|
||||
status_reason=None,
|
||||
signal_transport=None):
|
||||
"""Prepares a deployment create or update (if an id was given)."""
|
||||
post_body = {}
|
||||
|
||||
if deploy_id is not None:
|
||||
post_body["id"] = deploy_id
|
||||
if server_id is not None:
|
||||
post_body["server_id"] = server_id
|
||||
if config_id is not None:
|
||||
post_body["config_id"] = config_id
|
||||
if action is not None:
|
||||
post_body["action"] = action
|
||||
if status is not None:
|
||||
post_body["status"] = status
|
||||
if input_values is not None:
|
||||
post_body["input_values"] = input_values
|
||||
if output_values is not None:
|
||||
post_body["output_values"] = output_values
|
||||
if status_reason is not None:
|
||||
post_body["status_reason"] = status_reason
|
||||
if signal_transport is not None:
|
||||
post_body["signal_transport"] = signal_transport
|
||||
body = json.dumps(post_body)
|
||||
|
||||
headers = self.get_headers()
|
||||
return headers, body
|
||||
|
|
@ -22,10 +22,10 @@ from tempest.common import credentials_factory as common_creds
|
|||
from tempest.common import waiters
|
||||
from tempest import config
|
||||
from tempest.lib import exceptions
|
||||
from tempest.services import orchestration
|
||||
from tempest import test
|
||||
|
||||
from murano_tempest_tests import clients
|
||||
from murano_tempest_tests.services import orchestration
|
||||
from murano_tempest_tests import utils
|
||||
|
||||
CONF = config.CONF
|
||||
|
|
|
|||
Loading…
Reference in New Issue