Merge "bugfix for finding tempest failed testcase"
[functest.git] / functest / opnfv_tests / openstack / tempest / conf_utils.py
index 67b5279..91a5bb4 100644 (file)
@@ -11,10 +11,12 @@ import ConfigParser
 import os
 import re
 import shutil
+import subprocess
 
 import opnfv.utils.constants as releng_constants
 
 from functest.utils.constants import CONST
+import functest.utils.functest_logger as ft_logger
 import functest.utils.functest_utils as ft_utils
 import functest.utils.openstack_utils as os_utils
 
@@ -39,8 +41,74 @@ TEMPEST_LIST = os.path.join(TEMPEST_RESULTS_DIR, 'test_list.txt')
 CI_INSTALLER_TYPE = CONST.INSTALLER_TYPE
 CI_INSTALLER_IP = CONST.INSTALLER_IP
 
+""" logging configuration """
+logger = ft_logger.Logger("Tempest").getLogger()
 
-def configure_tempest(logger, deployment_dir, IMAGE_ID=None, FLAVOR_ID=None):
+
+def get_verifier_id():
+    """
+    Returns verifer id for current Tempest
+    """
+    cmd = ("rally verify list-verifiers | awk '/" +
+           CONST.tempest_deployment_name +
+           "/ {print $2}'")
+    p = subprocess.Popen(cmd, shell=True,
+                         stdout=subprocess.PIPE,
+                         stderr=subprocess.STDOUT)
+    deployment_uuid = p.stdout.readline().rstrip()
+    if deployment_uuid == "":
+        logger.error("Tempest verifier not found.")
+        raise Exception('Error with command:%s' % cmd)
+    return deployment_uuid
+
+
+def get_verifier_deployment_id():
+    """
+    Returns deployment id for active Rally deployment
+    """
+    cmd = ("rally deployment list | awk '/" +
+           CONST.rally_deployment_name +
+           "/ {print $2}'")
+    p = subprocess.Popen(cmd, shell=True,
+                         stdout=subprocess.PIPE,
+                         stderr=subprocess.STDOUT)
+    deployment_uuid = p.stdout.readline().rstrip()
+    if deployment_uuid == "":
+        logger.error("Rally deployment not found.")
+        raise Exception('Error with command:%s' % cmd)
+    return deployment_uuid
+
+
+def get_verifier_repo_dir(verifier_id):
+    """
+    Returns installed verfier repo directory for Tempest
+    """
+    if not verifier_id:
+        verifier_id = get_verifier_id()
+
+    return os.path.join(CONST.dir_rally_inst,
+                        'verification',
+                        'verifier-{}'.format(verifier_id),
+                        'repo')
+
+
+def get_verifier_deployment_dir(verifier_id, deployment_id):
+    """
+    Returns Rally deployment directory for current verifier
+    """
+    if not verifier_id:
+        verifier_id = get_verifier_id()
+
+    if not deployment_id:
+        deployment_id = get_verifier_deployment_id()
+
+    return os.path.join(CONST.dir_rally_inst,
+                        'verification',
+                        'verifier-{}'.format(verifier_id),
+                        'for-deployment-{}'.format(deployment_id))
+
+
+def configure_tempest(deployment_dir, IMAGE_ID=None, FLAVOR_ID=None):
     """
     Add/update needed parameters into tempest.conf file generated by Rally
     """
@@ -82,6 +150,8 @@ def configure_tempest(logger, deployment_dir, IMAGE_ID=None, FLAVOR_ID=None):
     config.set('identity', 'password', CONST.tempest_identity_user_password)
     config.set(
         'validation', 'ssh_timeout', CONST.tempest_validation_ssh_timeout)
+    config.set('object-storage', 'operator_role',
+               CONST.tempest_object_storage_operator_role)
 
     if CONST.OS_ENDPOINT_TYPE is not None:
         services_list = ['compute',
@@ -102,18 +172,21 @@ def configure_tempest(logger, deployment_dir, IMAGE_ID=None, FLAVOR_ID=None):
         config.write(config_file)
 
     # Copy tempest.conf to /home/opnfv/functest/results/tempest/
+    if not os.path.exists(TEMPEST_RESULTS_DIR):
+        os.makedirs(TEMPEST_RESULTS_DIR)
+
     shutil.copyfile(tempest_conf_file,
                     os.path.join(TEMPEST_RESULTS_DIR, 'tempest.conf'))
 
     return releng_constants.EXIT_OK
 
 
-def configure_tempest_multisite(logger, deployment_dir):
+def configure_tempest_multisite(deployment_dir):
     """
     Add/update needed parameters into tempest.conf file generated by Rally
     """
     logger.debug("configure the tempest")
-    configure_tempest(logger, deployment_dir)
+    configure_tempest(deployment_dir)
 
     logger.debug("Finding tempest.conf file...")
     tempest_conf_old = os.path.join(deployment_dir, 'tempest.conf')
@@ -135,7 +208,7 @@ def configure_tempest_multisite(logger, deployment_dir):
     # cmd = ("openstack endpoint show kingbird | grep publicurl |"
     #       "awk '{print $4}' | awk -F '/' '{print $4}'")
     # kingbird_api_version = os.popen(cmd).read()
-    kingbird_api_version = os_utils.get_endpoint(service_type='kingbird')
+    kingbird_api_version = os_utils.get_endpoint(service_type='multisite')
 
     if CI_INSTALLER_TYPE == 'fuel':
         # For MOS based setup, the service is accessible