Modify ONOS CI running

Change-Id: I4b662b494c6c488d8643ec459a949b781ba3374a
Signed-off-by: lanqinglong <lanqinglong@huawei.com>

diff --git a/testcases/Controllers/ONOS/Teston/CI/onosfunctest.py b/testcases/Controllers/ONOS/Teston/CI/onosfunctest.py
index 696e868..ccd49b7 100644 (file)
--- a/testcases/Controllers/ONOS/Teston/CI/onosfunctest.py
+++ b/testcases/Controllers/ONOS/Teston/CI/onosfunctest.py
@@ -6,7 +6,6 @@ CASE1 - Northbound NBI test network/subnet/ports
 CASE2 - Ovsdb test&Default configuration&Vm go online
 
 lanqinglong@huawei.com
-
 #
 # All rights reserved. This program and the accompanying materials
 # are made available under the terms of the Apache License, Version 2.0
@@ -14,18 +13,126 @@ lanqinglong@huawei.com
 # http://www.apache.org/licenses/LICENSE-2.0
 #
 """
-from adapters.client import client
 
-if __name__=="__main__":
+import os
+import time
+import sys
+import logging
+import yaml
+import datetime
+import re
+
+""" logging configuration """
+
+logger = logging.getLogger('onos')
+logger.setLevel(logging.DEBUG)
+
+ch = logging.StreamHandler()
+
+
+formatter = logging.Formatter('%(asctime)s - %(name)s'
+                              '- %(levelname)s - %(message)s')
+
+ch.setFormatter(formatter)
+logger.addHandler(ch)
+
+with open("/home/opnfv/functest/conf/config_functest.yaml") as f:
+    functest_yaml = yaml.safe_load(f)
+f.close()
+
+# onos parameters
+TEST_DB = functest_yaml.get("results").get("test_db_url")
+ONOS_REPO_PATH = functest_yaml.get("general").get("directories").get("dir_repos")
+ONOS_CONF_DIR = functest_yaml.get("general").get("directories").get("dir_functest_conf")
+REPO_PATH = ONOS_REPO_PATH + '/functest/'
+if not os.path.exists(REPO_PATH):
+    logger.error("Functest repository directory not found '%s'" % REPO_PATH)
+    exit(-1)
+sys.path.append(REPO_PATH + "testcases/")
+import functest_utils
+
+ONOSCI_PATH= REPO_PATH+'testcases/Controllers/ONOS/Teston/CI/'
+starttime = datetime.datetime.now()
+
+HOME = os.environ['HOME'] + "/"
+
+def RunScript(testname):
+    """
+    Run ONOS Test Script
+    Parameters:
+    testname: ONOS Testcase Name
+    """
+    runtest = ONOSCI_PATH + "OnosSystemTest/TestON/bin/cli.py run " + testname
+    logger.debug( "Run script " + testname )
+    os.system(runtest)
+
+def DownloadCodes(url="https://github.com/sunyulin/OnosSystemTest.git"):
+    """
+    Download Onos Teston codes
+    Parameters:
+    url: github url
+    """
+    downloadcode = "git clone " + url + " " + ONOSCI_PATH + "OnosSystemTest"
+    logger.debug( "Download Onos Teston codes " + url)
+    os.system(downloadcode)
+
+def GetResult():
+    LOGPATH = ONOSCI_PATH + "OnosSystemTest/TestON/logs"
+    cmd = "grep -rnh " + "Fail" + " " + LOGPATH
+    Resultbuffer = os.popen(cmd).read()
+    duration = datetime.datetime.now() - starttime
+    time.sleep(2)
+
+    if re.search("\s+[1-9]+\s+", Resultbuffer):
+        logger.debug("Testcase Fails\n" + Resultbuffer)
+        Result = "Failed"
+    else:
+        logger.debug("Testcases Success")
+        Result = "Success"
+    payload={'timestart': str(starttime),
+              'duration': str(duration),
+                'status': Result}
+    return payload
+
+def SetOnosIp():
+    onoscreds = ONOS_CONF_DIR + "/openstack.creds"
+    cmd = "cat " + onoscreds + " | grep OS_AUTH_URL"
+    cmd_output = os.popen(cmd).read()
+    print cmd_output
+    OC1=re.search(r"\d+\.\d+\.\d+\.\d+",cmd_output).group()
+    os.environ['OC1'] = OC1
+    time.sleep(2)
+    logger.debug( "ONOS IP is " + OC1)
+
+def CleanOnosTest():
+    TESTONPATH = ONOSCI_PATH + "OnosSystemTest/"
+    cmd = "rm -rf " + TESTONPATH
+    os.system(cmd)
+    time.sleep(2)
+    logger.debug( "Clean ONOS Teston" )
+
+def main():
+
+    DownloadCodes()
+    SetOnosIp()
+    RunScript("FUNCvirNetNB")
+    RunScript("FUNCvirNetNBL3")
+
+    try:
+        logger.debug("Push result into DB")
+        # TODO check path result for the file
+        git_version = functest_utils.get_git_branch(REPO_PATH)
+        pod_name = functest_utils.get_pod_name(logger)
+        result = GetResult()
+        functest_utils.push_results_to_db(TEST_DB,
+                                          "ONOS",
+                                          logger, pod_name, git_version,
+                                          payload=result)
+    except:
+        logger.error("Error pushing results into Database")
+
+    CleanOnosTest()
 
-    main = client()
-    main.getdefaultpara()
 
-    #scripts to run
-    runhandle = main.onosstart()
-    main.RunScript(runhandle, "FUNCvirNetNB")
-#    main.RunScript(runhandle, "FUNCovsdbtest")
-    main.RunScript(runhandle, "FUNCvirNetNBL3")
-#    main.RunScript(runhandle, "FUNCovsdbtestL3")
-    main.onosclean( runhandle )
-    main.push_results_to_db(main.GetResult())
+if __name__ == '__main__':
+    main()
\ No newline at end of file