Service test

.gitignore

@@ -0,0 +1,4 @@
+**/*.pyc
+**/__pycache__/
+**/private/*
+**/.vscode

scripts/install-dependencies.properities.py

@@ -5,39 +5,38 @@
 import re
 
 if len(sys.argv) == 1:
-    print "No argument passed"
+    print("No argument passed")
     exit(1)
 
 if len(sys.argv) > 2:
-    print "More than 1 parameter given"
+    print("More than 1 parameter given")
     exit(-1)
 
 with open(sys.argv[1]) as f:
     content = f.readlines()
 
-
 for line in content:
 
     os.chdir('..')
-    
+
     dependency, target = line.split('=')
 
     if target == None or target == '':
         target = 'develop'
-    
+
     project = dependency.split("/")[-1].split(".")[0]
     repository = re.search("[^/]+(?=\.git)", dependency).group(0)
-    
-    print "> git clone \"%s\" into \"%s\"" % (dependency, project)
+
+    print("> git clone \"%s\" into \"%s\"" % (dependency, project))
     os.system("git clone " + dependency)
 
-    print "> cd %s" % repository
+    print("> cd %s" % repository)
     os.chdir(repository)
 
-    print "> git checkout " + target
+    print("> git checkout " + target)
     os.system("git checkout " + target)
 
-    print os.getcwd()
+    print(os.getcwd())
 
-    print "> mvn install"
+    print("> mvn install")
     os.system("mvn install")

service_test/authentication_service/__init__.py

@@ -1,8 +1,7 @@
 # -*- coding: utf-8 -*-
 
 from .service_tests import *
-from .general_configuration_test import *
 
-modules = [service_tests, general_configuration_test]
+modules = [service_tests]
 
 __all__ = [prop for module in modules for prop in module.__all__]

service_test/authentication_service/service_tests.py

@@ -1,55 +1,46 @@
 # -*- coding: utf-8 -*-
-import requests
-import shutil
 
-from common import TestSuite, TestEngine
+from common import FogbowHttpUtil, VersionandPublicKeyCheck
 
 __all__ = ['AuthTest']
 
-class AuthTest(TestSuite):
+class AuthTest(VersionandPublicKeyCheck):
 
     def __init__(self, service, configuration, resources):
-        TestSuite.__init__(self, service)
-        self.conf = configuration
-        self.pid = None
-        self.resources = resources
-        self.port = self.conf['application']['port']
-        self.origin = 'http://localhost:' + str(self.port)
+        super().__init__(service, configuration, resources)
 
-    def setup(self):
-        repo_url = self.conf['application']['repo_url']
-        branch = self.conf['application']['branch_under_test']
-
-        self.clonerepo(repo_url, branch)
-
-        command = self.conf['commands']['run_application']
-        port = self.port
-
-        pid = self.run_in_background(command, port)
+    def run(self):
+        try:
+            super().run()
+            self.createtoken()
+            self.failcreatetoken()
+        except Exception as e:
+            self.fail()
+            print("Interruped execution due to runtime error")
+            raise e
+        finally:
+            self.logresults()
 
-        print("pid for proccess is %s" % pid)
-        self.setpid(pid)
+    def createtoken(self):
+        self.__createtokentest__('Creating token', \
+            self.resources['auth_credentials'], \
+            self.assertlt)
 
-    def teardown(self):
-        print('tasketeeee')
-        # self.kill_background_process(self.pid)
-        # shutil.rmtree(self.workdir)
+    def failcreatetoken(self):
+        self.__createtokentest__('Fail attemp to create token', \
+            self.resources['invalid_auth_credentials'], \
+            self.assertge)
 
-    def run(self):
-        self.createtoken()
+    def __createtokentest__ (self, message, credentials, assertion):
+        self.starttest(message)
 
-    def createtoken(self):
-        self.logTest('Creating token')
-        test = TestEngine(self.origin)
-        credentials = self.resources['auth_credentials']
+        test = FogbowHttpUtil(self.origin)
         res = test.create('token', body=credentials)
-        token = res['token']
-        print('Token %s was obtained' % token)
-        # body = json.lao
-
-    def setpid(self, pid):
-        self.pid = pid
+
+        assertion(res.status_code, 400)
+
+        self.endtest()
 
     @classmethod
     def required_resources(self):
-        return ['auth_credentials']
+        return ['auth_credentials', 'invalid_auth_credentials']

service_test/common/__init__.py

@@ -2,10 +2,13 @@
 from .constants import *
 from .http_methods import *
 from .instance_states import *
-from .test_factory import *
-from .test_suite import *
+from .service_test_instance import *
+from .fogbow_http_util import *
 from .utils import *
+from .check_version import *
+from .check_version_and_public_key import *
 
-modules = [constants, http_methods, instance_states, test_suite, test_factory, utils]
+modules = [constants, http_methods, instance_states, service_test_instance, 
+    fogbow_http_util, utils, check_version, check_version_and_public_key]
 
 __all__ = [prop for module in modules for prop in module.__all__]

service_test/common/assertion.py

@@ -0,0 +1,23 @@
+# -*- coding: utf-8 -*-
+
+""" Util class for ServiceTestInstance """
+class Assertion(object):
+
+    def __init__(self, suite, compare):
+        self.compare = compare
+        self.suite = suite
+
+    def __call__(self, obtained, expected=None):
+        if expected != None:
+            assertpassed = self.compare(obtained,expected)
+        else:
+            assertpassed = self.compare(obtained)
+
+        if assertpassed:
+            self.suite.__assertion_ok__()
+        else:
+            print("Assertion failed: given: {}, expected {}".format(obtained, expected))
+            self.suite.__assertion_fail__()
+
+        return assertpassed
+

service_test/common/check_version.py

@@ -0,0 +1,22 @@
+# -*- coding: utf-8 -*-
+
+from .service_test_instance import ServiceTestInstance
+from .fogbow_http_util import FogbowHttpUtil
+
+__all__ = ['VersionCheck']
+
+class VersionCheck(ServiceTestInstance):
+
+    def run(self):
+        self.version()
+
+    def version(self):
+        self.starttest('Requesting version')
+
+        test = FogbowHttpUtil(self.origin)
+        res = test.get('version').json()
+        version = res['version']
+
+        self.assertgt(len(version), 0)
+
+        self.endtest()

service_test/common/check_version_and_public_key.py

@@ -0,0 +1,24 @@
+# -*- coding: utf-8 -*-
+
+from .service_test_instance import ServiceTestInstance
+from .fogbow_http_util import FogbowHttpUtil
+from .check_version import VersionCheck
+
+__all__ = ['VersionandPublicKeyCheck']
+
+class VersionandPublicKeyCheck(VersionCheck):
+
+    def run(self):
+        super().run()
+        self.publickey()
+
+    def publickey(self):
+        self.starttest('Requesting public key')
+
+        test = FogbowHttpUtil(self.origin)
+        res = test.get('public-key').json()
+        publickey = res['publicKey']
+
+        self.assertgt(len(publickey), 0)
+
+        self.endtest()

service_test/common/constants.py

@@ -3,3 +3,5 @@
 class CommonConstants:
     resource_path = 'src/main/resources/'
     private = 'private'
+    dependencies_properties = 'dependencies.properties'
+    install_dependencies_script = 'python2 {}/../../scripts/install-dependencies.properities.py'