Merge "Add unit test for config file validation"

[functest-kubernetes.git] / functest_kubernetes / k8stest.py

diff --git a/functest_kubernetes/k8stest.py b/functest_kubernetes/k8stest.py
index 65c8acf..7d9400e 100644 (file)
--- a/functest_kubernetes/k8stest.py
+++ b/functest_kubernetes/k8stest.py
@@ -30,6 +30,7 @@ class K8sTesting(testcase.TestCase):
 
     def __init__(self, **kwargs):
         super(K8sTesting, self).__init__(**kwargs)
+        self.config = '/root/.kube/config'
         self.cmd = []
         self.result = 0
         self.start_time = 0
@@ -51,24 +52,24 @@ class K8sTesting(testcase.TestCase):
         i = 0
         while i < len(lines):
             if '[k8s.io]' in lines[i]:
-                if i != 0 and 'seconds' in lines[i-1]:
-                    self.__logger.debug(lines[i-1])
-                while lines[i] != '-'*len(lines[i]):
+                if i != 0 and 'seconds' in lines[i - 1]:
+                    self.__logger.debug(lines[i - 1])
+                while lines[i] != '-' * len(lines[i]):
                     if lines[i].startswith('STEP:') or ('INFO:' in lines[i]):
                         break
                     self.__logger.debug(lines[i])
-                    i = i+1
+                    i = i + 1
 
             success = 'SUCCESS!' in lines[i]
             failure = 'FAIL!' in lines[i]
             if success or failure:
-                if i != 0 and 'seconds' in lines[i-1]:
-                    remarks.append(lines[i-1])
+                if i != 0 and 'seconds' in lines[i - 1]:
+                    remarks.append(lines[i - 1])
                 remarks = remarks + lines[i].replace('--', '|').split('|')
                 break
-            i = i+1
+            i = i + 1
 
-        self.__logger.debug('-'*10)
+        self.__logger.debug('-' * 10)
         self.__logger.info("Remarks:")
         for remark in remarks:
             if 'seconds' in remark:
@@ -87,9 +88,9 @@ class K8sTesting(testcase.TestCase):
 
     def run(self, **kwargs):
 
-        if not os.path.isfile(os.getenv('KUBECONFIG')):
+        if not os.path.isfile(self.config):
             self.__logger.error(
-                "Cannot run k8s testcases. Config file not found ")
+                "Cannot run k8s testcases. Config file not found")
             return self.EX_RUN_ERROR
 
         self.start_time = time.time()
@@ -107,7 +108,6 @@ class K8sTesting(testcase.TestCase):
         """Check if required environment variables are set"""
         try:
             assert 'DEPLOY_SCENARIO' in os.environ
-            assert 'KUBECONFIG' in os.environ
             assert 'KUBE_MASTER_IP' in os.environ
             assert 'KUBERNETES_PROVIDER' in os.environ
             assert 'KUBE_MASTER_URL' in os.environ
@@ -135,4 +135,5 @@ class K8sConformanceTest(K8sTesting):
         super(K8sConformanceTest, self).__init__(**kwargs)
         self.check_envs()
         self.cmd = ['/src/k8s.io/kubernetes/_output/bin/e2e.test',
-                    '--ginkgo.focus', 'Conformance']
+                    '-ginkgo.focus', 'Conformance',
+                    '-kubeconfig', self.config]