Config reload endpoint

pyms/flask/app/__init__.py

@@ -1,5 +1,5 @@
-from .create_app import Microservice
+from .create_app import Microservice, microservice
 from .create_config import config
 
 
-__all__ = ['Microservice', 'config']
+__all__ = ['Microservice', 'config', 'microservice']

pyms/flask/app/create_app.py

@@ -10,6 +10,7 @@
 from pyms.crypt.driver import CryptResource
 from pyms.flask.app.utils import SingletonMeta, ReverseProxied
 from pyms.flask.healthcheck import healthcheck_blueprint
+from pyms.flask.configreload import configreload_blueprint
 from pyms.flask.services.driver import ServicesResource, DriverService
 from pyms.logger import CustomJsonFormatter
 from pyms.utils import check_package_exists, import_from
@@ -218,6 +219,7 @@ def create_app(self):
 
         # Initialize Blueprints
         self.application.register_blueprint(healthcheck_blueprint)
+        self.application.register_blueprint(configreload_blueprint)
 
         self.init_libs()
         self.add_error_handlers()
@@ -245,3 +247,11 @@ def add_error_handler(self, code_or_exception, handler):
         :param handler: callback for error handler
         """
         self.application.connexion_app.add_error_handler(code_or_exception, handler)
+
+
+def microservice():
+    """The behavior of this function is to access to the microservice outer the scope of flask context, to prevent to
+     raise a `'working outside of application context`
+    :return:
+    """
+    return Microservice()

pyms/flask/configreload/__init__.py

@@ -0,0 +1,4 @@
+from .configreload import configreload_blueprint
+
+
+__all__ = ['configreload_blueprint']

pyms/flask/configreload/configreload.py

@@ -0,0 +1,16 @@
+from __future__ import unicode_literals, print_function, absolute_import, division
+from flask import Blueprint
+
+configreload_blueprint = Blueprint('configreload', __name__, static_url_path='/static')
+
+
+@configreload_blueprint.route('/reload_config', methods=['GET'])
+def reloadconfig():
+    """
+    Reread configuration from file.
+    :return:
+    """
+    # pylint: disable=import-outside-toplevel
+    from pyms.flask.app import microservice
+    microservice().reload_conf()
+    return "OK"

pyms/flask/healthcheck/healthcheck.py

@@ -7,7 +7,7 @@
 
 @healthcheck_blueprint.route('/healthcheck', methods=['GET'])
 def healthcheck():
-    """Set a healtcheck to help other service to discover this microservice, like Kubernetes, AWS ELB, etc.
+    """Set a healthcheck to help other service to discover this microservice, like Kubernetes, AWS ELB, etc.
     :return:
     """
     return "OK"

tests/config-tests-reload1.yml

@@ -0,0 +1,5 @@
+pyms:
+  config:
+    DEBUG: true
+    TESTING: true
+    APP_NAME: "reload1"

tests/config-tests-reload2.yml

@@ -0,0 +1,5 @@
+pyms:
+  config:
+    DEBUG: true
+    TESTING: true
+    APP_NAME: "reload2"

tests/test_flask.py

@@ -81,6 +81,31 @@ def test_reverse_proxy_zuul(self):
         self.assertEqual(200, response.status_code)
 
 
+class ReloadTests(unittest.TestCase):
+    """
+    Tests for configreload endpoints
+    """
+
+    file1 = "config-tests-reload1.yml"
+    file2 = "config-tests-reload2.yml"
+
+    def setUp(self):
+        os.environ[CONFIGMAP_FILE_ENVIRONMENT] = os.path.join(os.path.dirname(os.path.abspath(__file__)),
+                                                              self.file1)
+        ms = MyMicroservice(path=__file__)
+        self.app = ms.create_app()
+        self.client = self.app.test_client()
+        self.assertEqual("reload1", self.app.config["APP_NAME"])
+
+    def test_configreload(self):
+        os.environ[CONFIGMAP_FILE_ENVIRONMENT] = os.path.join(os.path.dirname(os.path.abspath(__file__)),
+                                                              self.file2)
+        response = self.client.get('/reload_config')
+        self.assertEqual(b"OK", response.data)
+        self.assertEqual(200, response.status_code)
+        self.assertEqual("reload2", config()["APP_NAME"])
+
+
 class MicroserviceTest(unittest.TestCase):
     """
     Tests for Singleton