33756ac899
Include: - util modules. such as table_parser, ssh/localhost clients, cli module, exception, logger, etc. Util modules are mostly used by keywords. - keywords modules. These are helper functions that are used directly by test functions. - platform (with platform or platform_sanity marker) and stx-openstack (with sanity, sx_sanity, cpe_sanity, or storage_sanity marker) sanity testcases - pytest config conftest, and test fixture modules - test config file template/example Required packages: - python3.4 or python3.5 - pytest >=3.10,<4.0 - pexpect - requests - pyyaml - selenium (firefox, ffmpeg, pyvirtualdisplay, Xvfb or Xephyr or Xvnc) Limitations: - Anything that requires copying from Test File Server will not work until a public share is configured to shared test files. Tests skipped for now. Co-Authored-By: Maria Yousaf <maria.yousaf@windriver.com> Co-Authored-By: Marvin Huang <marvin.huang@windriver.com> Co-Authored-By: Yosief Gebremariam <yosief.gebremariam@windriver.com> Co-Authored-By: Paul Warner <paul.warner@windriver.com> Co-Authored-By: Xueguang Ma <Xueguang.Ma@windriver.com> Co-Authored-By: Charles Chen <charles.chen@windriver.com> Co-Authored-By: Daniel Graziano <Daniel.Graziano@windriver.com> Co-Authored-By: Jordan Li <jordan.li@windriver.com> Co-Authored-By: Nimalini Rasa <nimalini.rasa@windriver.com> Co-Authored-By: Senthil Mukundakumar <senthil.mukundakumar@windriver.com> Co-Authored-By: Anuejyan Manokeran <anujeyan.manokeran@windriver.com> Co-Authored-By: Peng Peng <peng.peng@windriver.com> Co-Authored-By: Chris Winnicki <chris.winnicki@windriver.com> Co-Authored-By: Joe Vimar <Joe.Vimar@windriver.com> Co-Authored-By: Alex Kozyrev <alex.kozyrev@windriver.com> Co-Authored-By: Jack Ding <jack.ding@windriver.com> Co-Authored-By: Ming Lei <ming.lei@windriver.com> Co-Authored-By: Ankit Jain <ankit.jain@windriver.com> Co-Authored-By: Eric Barrett <eric.barrett@windriver.com> Co-Authored-By: William Jia <william.jia@windriver.com> Co-Authored-By: Joseph Richard <Joseph.Richard@windriver.com> Co-Authored-By: Aldo Mcfarlane <aldo.mcfarlane@windriver.com> Story: 2005892 Task: 33750 Signed-off-by: Yang Liu <yang.liu@windriver.com> Change-Id: I7a88a47e09733d39f024144530f5abb9aee8cad2
199 lines
5.6 KiB
Python
199 lines
5.6 KiB
Python
#
|
|
# Copyright (c) 2019 Wind River Systems, Inc.
|
|
#
|
|
# SPDX-License-Identifier: Apache-2.0
|
|
#
|
|
|
|
|
|
import json
|
|
import requests
|
|
|
|
from consts.auth import Tenant
|
|
from utils import table_parser, cli
|
|
from utils.tis_log import LOG
|
|
from consts.proj_vars import ProjVar
|
|
from keywords import keystone_helper
|
|
|
|
|
|
def get_ip_addr():
|
|
return ProjVar.get_var('lab')['floating ip']
|
|
|
|
|
|
def create_url(ip=None, port=None, version=None, extension=None):
|
|
"""
|
|
Creates a url with the given parameters inn the form:
|
|
http(s)://<ip address>:<port>/<version>/<extension>
|
|
Args:
|
|
ip (str): the main ip address. If set to None will be set to the lab's
|
|
ip address by default.
|
|
port (int): the port number to connect to.
|
|
version (str): for REST API. version number, e.g. "v1", "v2.0"
|
|
extension (str): extensions to add to the url
|
|
|
|
Returns (str): a url created with the given parameters
|
|
|
|
"""
|
|
if keystone_helper.is_https_enabled() is True:
|
|
url = 'https://'
|
|
else:
|
|
url = 'http://'
|
|
if ip:
|
|
url += ip
|
|
else:
|
|
url += get_ip_addr()
|
|
|
|
if port:
|
|
url += ':{}'.format(port)
|
|
|
|
if version:
|
|
url += '/{}'.format(version)
|
|
|
|
if extension:
|
|
url += '/{}'.format(extension)
|
|
|
|
return url
|
|
|
|
|
|
def get_user_token(field='id', con_ssh=None, auth_info=Tenant.get('admin')):
|
|
"""
|
|
Return an authentication token for the admin.
|
|
|
|
Args:
|
|
field (str):
|
|
con_ssh (SSHClient):
|
|
auth_info
|
|
Returns (list): a list containing at most one authentication token
|
|
|
|
"""
|
|
table_ = table_parser.table(cli.openstack('token issue', ssh_client=con_ssh,
|
|
auth_info=auth_info)[1])
|
|
token = table_parser.get_value_two_col_table(table_, field)
|
|
return token
|
|
|
|
|
|
def get_request(url, headers, verify=True):
|
|
"""
|
|
Sends a GET request to the url
|
|
Args:
|
|
url (str): url to send request to
|
|
headers (dict): header to add to the request
|
|
verify: Verify SSL certificate
|
|
|
|
Returns (dict): The response for the request
|
|
|
|
"""
|
|
LOG.info("Sending GET request to {}. Headers: {}".format(url, headers))
|
|
resp = requests.get(url, headers=headers, verify=verify)
|
|
|
|
if resp.status_code == requests.codes.ok:
|
|
data = json.loads(resp.text)
|
|
LOG.info("The returned data is: {}".format(data))
|
|
return data
|
|
|
|
LOG.info("Error {}".format(resp.status_code))
|
|
return None
|
|
|
|
|
|
def post_request(url, data, headers, verify=True):
|
|
"""
|
|
Sends a POST request to the url
|
|
Args:
|
|
url (str): url to send request to
|
|
data (dict): data to be sent in the request body
|
|
headers (dict): header to add to the request
|
|
verify: Verify SSL certificate
|
|
|
|
Returns (dict): The response for the request
|
|
|
|
"""
|
|
if not isinstance(data, str):
|
|
data = json.dumps(data)
|
|
LOG.info("Sending POST request to {}. Headers: {}. Data: "
|
|
"{}".format(url, headers, data))
|
|
resp = requests.post(url, headers=headers, data=data, verify=verify)
|
|
|
|
if resp.status_code == requests.codes.ok:
|
|
data = json.loads(resp.text)
|
|
LOG.info("The returned data is: {}".format(data))
|
|
return data
|
|
|
|
LOG.info("Error {}".format(resp.status_code))
|
|
return None
|
|
|
|
|
|
def put_request(url, data, headers, verify=True):
|
|
"""
|
|
Sends a GET request to the url
|
|
Args:
|
|
url (str): url to send request to
|
|
data (dict): data to be sent in the request body
|
|
headers (dict): header to add to the request
|
|
verify: Verify SSL certificate
|
|
|
|
Returns (dict): The response for the request
|
|
|
|
"""
|
|
if not isinstance(data, str):
|
|
data = json.dumps(data)
|
|
LOG.info("Sending PUT request to {}. Headers: {}. Data: "
|
|
"{}".format(url, headers, data))
|
|
resp = requests.put(url, headers=headers, data=data, verify=verify)
|
|
|
|
if resp.status_code == requests.codes.ok:
|
|
data = json.loads(resp.text)
|
|
LOG.info("The returned data is: {}".format(data))
|
|
return data
|
|
|
|
LOG.info("Error {}".format(resp.status_code))
|
|
return None
|
|
|
|
|
|
def delete_request(url, headers, verify=True):
|
|
"""
|
|
Sends a GET request to the url
|
|
Args:
|
|
url (str): url to send request to
|
|
headers (dict): header to add to the request
|
|
verify: Verify SSL certificate
|
|
|
|
Returns (dict): The response for the request
|
|
|
|
"""
|
|
LOG.info("Sending DELETE request to {}. Headers: {}".format(url, headers))
|
|
resp = requests.delete(url, headers=headers, verify=verify)
|
|
|
|
if resp.status_code == requests.codes.ok:
|
|
data = json.loads(resp.text)
|
|
LOG.info("The returned data is: {}".format(data))
|
|
return data
|
|
|
|
LOG.info("Error {}".format(resp.status_code))
|
|
return None
|
|
|
|
|
|
def patch_request(url, data, headers, verify=True):
|
|
"""
|
|
Sends a PATCH request to the url
|
|
Args:
|
|
url (str): url to send request to
|
|
data (dict|str|list): data to be sent in the request body
|
|
headers (dict): header to add to the request
|
|
verify: Verify SSL certificate
|
|
|
|
Returns (dict): The response for the request
|
|
|
|
"""
|
|
if not isinstance(data, str):
|
|
data = json.dumps(data)
|
|
LOG.info("Sending PATCH request to {}. Headers: {}. Data: "
|
|
"{}".format(url, headers, data))
|
|
resp = requests.patch(url, headers=headers, data=data, verify=verify)
|
|
|
|
if resp.status_code == requests.codes.ok:
|
|
data = json.loads(resp.text)
|
|
LOG.info("The returned data is: {}".format(data))
|
|
return data
|
|
|
|
LOG.info("Error {}".format(resp.status_code))
|
|
return None
|