Atualização lambda API

Author: andersoncontreira

examples/lambda_api/.coveragerc

@@ -3,7 +3,7 @@
 source =
     ./chalicelib/
     ./flask_app/
-    ./lambda_app/
+    ./flambda_app/
     ./app.py
 
 [run]

examples/lambda_api/.github/workflows/pylint.yml

@@ -68,6 +68,6 @@ jobs:
           pip install pylint
       - name: Execute pylint
         run: |
-          # pylint ./app.py ./lambda_app ./tests/unit ./tests/integration ./tests/component
-          # pylint ./app.py ./boot.py ./flambda_app
+          # pylint ./app.py ./flambda_app ./tests/unit ./tests/integration ./tests/component
+          # pylint ./app.py ./boot.py ./fflambda_app
           ./scripts/pylint.sh

examples/lambda_api/.gitignore

@@ -27,9 +27,9 @@ venv
 /.coverage
 
 # mantem a vendor
-!/vendor
+!vendor
 # ignora os demais arquivos
-/vendor/*
+vendor/*
 # mantem essa pasta
 !/vendor/public
 # mantem essa pasta
@@ -65,3 +65,11 @@ config/integration.en
 output/response.json
 /output/
 /include/
+/life-cycle-service-manager-recovery.zip
+/env/integration.env
+/env/production.env
+/env/staging.env
+/env/_staging.env
+/env/_integration.env
+/env/_production.env
+

examples/lambda_api/app.py

@@ -2,49 +2,56 @@
 
 This module contains the handler method
 """
-import boot
-import os
 import base64
-from lambda_app.services.v1.healthcheck import HealthCheckSchema, HealthCheckResult
-from lambda_app.services.v1.healthcheck.resources import \
-    MysqlConnectionHealthCheck, RedisConnectionHealthCheck, \
-    SQSConnectionHealthCheck, SelfConnectionHealthCheck
-from lambda_app.services.v1.healthcheck_service import HealthCheckService
-from lambda_app.config import get_config
-from lambda_app.enums.events import EventType
-from lambda_app.enums.messages import MessagesEnum
-from lambda_app.events.tracker import EventTracker
-from lambda_app.exceptions import ApiException
-from lambda_app.http_resources.request import ApiRequest
-from lambda_app.http_resources.response import ApiResponse
-from lambda_app.services.v1.ocoren_event_service import OcorenEventService as OcorenEventServiceV1
-from lambda_app.vos.events import EventVO
-from lambda_app.logging import get_logger
-from lambda_app import APP_NAME, APP_VERSION, http_helper
-from lambda_app.helper import open_vendor_file, print_routes
-from lambda_app.http_helper import CUSTOM_DEFAULT_HEADERS
-from lambda_app.lambda_flask import LambdaFlask
-from lambda_app.openapi import spec, get_doc, generate_openapi_yml
-from lambda_app.openapi import api_schemas
-from lambda_app.services.event_manager import EventManager
-from lambda_app import helper
-
-# load env
-ENV = helper.get_environment()
-boot.load_dot_env(ENV)
+import os
+
+import boot
+from flambda_app import APP_NAME, APP_VERSION, http_helper
+from flambda_app import helper
+from flambda_app.config import get_config
+from flambda_app.enums.events import EventType
+from flambda_app.enums.messages import MessagesEnum
+from flambda_app.events.tracker import EventTracker
+from flambda_app.exceptions import ApiException
+from flambda_app.flambda import Flambda
+from flambda_app.helper import open_vendor_file, print_routes
+from flambda_app.http_helper import CUSTOM_DEFAULT_HEADERS
+from flambda_app.http_resources.request import ApiRequest
+from flambda_app.http_resources.response import ApiResponse
+from flambda_app.logging import get_logger, set_debug_mode
+from flambda_app.openapi import api_schemas
+from flambda_app.openapi import spec, get_doc, generate_openapi_yml
+from flambda_app.services.event_manager import EventManager
+from flambda_app.services.healthcheck_manager import HealthCheckManager
+from flambda_app.services.v1.ocoren_event_service import OcorenEventService as OcorenEventServiceV1
+from flambda_app.vos.events import EventVO
+
+# load directly by boot
+ENV = boot.get_environment()
+# boot.load_dot_env(ENV)
 
 
 # config
 CONFIG = get_config()
 # debug
 DEBUG = helper.debug_mode()
-# logger
-LOGGER = get_logger()
 
-APP = LambdaFlask(__name__)
+# keep in this order, the app generic stream handler will be removed
+APP = Flambda(APP_NAME)
+# Logger
+LOGGER = get_logger(force=True)
+# override the APP logger
+APP.logger = LOGGER
+# override the log configs
+if DEBUG:
+    # override to the level desired
+    set_debug_mode(LOGGER)
+
+API_ROOT = os.environ['API_ROOT'] if 'API_ROOT' in os.environ else None
+API_ROOT_ENDPOINT = API_ROOT if API_ROOT != "" else '/'
 
 
-@APP.route('/')
+@APP.route(API_ROOT_ENDPOINT)
 def index():
     """
     API Root path
@@ -55,11 +62,7 @@ def index():
     return http_helper.create_response(body=body, status_code=200)
 
 
-# general vars
-APP_QUEUE = CONFIG.APP_QUEUE
-
-
-@APP.route('/alive')
+@APP.route(API_ROOT + '/alive')
 def alive():
     """
     Health check path
@@ -76,41 +79,79 @@ def alive():
                     content:
                         application/json:
                             schema: HealthCheckSchema
+                424:
+                    description: Failed dependency response
+                    content:
+                        application/json:
+                            schema: HealthCheckSchema
+                503:
+                    description: Service unavailable response
+                    content:
+                        application/json:
+                            schema: HealthCheckSchema
         """
-    service = HealthCheckService()
-    service.add_check("self", SelfConnectionHealthCheck(LOGGER, CONFIG), [])
-    service.add_check(
-        "mysql", MysqlConnectionHealthCheck(LOGGER, CONFIG), ["db"])
-    service.add_check("redis", RedisConnectionHealthCheck(
-        LOGGER, CONFIG), ["redis"])
-    service.add_check("queue", SQSConnectionHealthCheck(
-        LOGGER, CONFIG), ["queue"])
-    service.add_check("internal", lambda:  HealthCheckResult.unhealthy("connect"), ["example"])
+    service = HealthCheckManager()
+    return service.check()
 
-    return service.get_response()
 
-
-@APP.route('/favicon-32x32.png')
+@APP.route(API_ROOT + '/favicon-32x32.png')
 def favicon():
     headers = CUSTOM_DEFAULT_HEADERS.copy()
     headers['Content-Type'] = "image/png"
-    data = base64.b64decode(
-        'iVBORw0KGgoAAAANSUhEUgAAACAAAAAgCAMAAABEpIrGAAAAkFBMVEUAAAAQM0QWNUYWNkYXNkYALjo'
-        'WNUYYOEUXN0YaPEUPMUAUM0QVNUYWNkYWNUYWNUUWNUYVNEYWNkYWNUYWM0eF6i0XNkchR0OB5SwzZj'
-        '9wyTEvXkA3az5apTZ+4C5DgDt31C9frjU5bz5uxTI/eDxzzjAmT0IsWUEeQkVltzR62S6D6CxIhzpKi'
-        'jpJiDpOkDl4b43lAAAAFXRSTlMAFc304QeZ/vj+ECB3xKlGilPXvS2Ka/h0AAABfklEQVR42oVT2XaC'
-        'MBAdJRAi7pYJa2QHxbb//3ctSSAUPfa+THLmzj4DBvZpvyauS9b7kw3PWDkWsrD6fFQhQ9dZLfVbC5M'
-        '88CWCPERr+8fLZodJ5M8QJbjbGL1H2M1fIGfEm+wJN+bGCSc6EXtNS/8FSrq2VX6YDv++XLpJ8SgDWM'
-        'nwqznGo6alcTbIxB2CHKn8VFikk2mMV2lEnV+CJd9+jJlxXmMr5dW14YCqwgbFpO8FNvJxwwM4TPWPo'
-        '5QalEsRMAcusXpi58/QUEWPL0AK1ThM5oQCUyXPoPINkdd922VBw4XgTV9zDGWWFrgjIQs4vwvOg6xr'
-        '+6gbCTqE+DYhlMGX0CF2OknK5gQ2JrkDh/W6TOEbYDeVecKbJtyNXiCfGmW7V93J2hDus1bDfhxWbIZ'
-        'VYDXITA7Lo6E0Ktgg9eB4KWuR44aj7ppBVPazhQH7/M/KgWe9X1qAg8XypT6nxIMJH+T94QCsLvj29I'
-        'YwZxyO9/F8vCbO9tX5/wDGjEZ7vrgFZwAAAABJRU5ErkJggg==')
-    return http_helper.create_response(
-        body=data, status_code=200, headers=headers)
-
-
-@APP.route('/docs')
+    data = 'iVBORw0KGgoAAAANSUhEUgAAACAAAAAgCAMAAABEpIrGAAAAkFBMVEUAAAAQM0QWNUYWNkYXNkYALjoWNUYYOEUXN0YaPEUPMUAUM0QVN' \
+           'UYWNkYWNUYWNUUWNUYVNEYWNkYWNUYWM0eF6i0XNkchR0OB5SwzZj9wyTEvXkA3az5apTZ+4C5DgDt31C9frjU5bz5uxTI/eDxzzjAmT0' \
+           'IsWUEeQkVltzR62S6D6CxIhzpKijpJiDpOkDl4b43lAAAAFXRSTlMAFc304QeZ/vj+ECB3xKlGilPXvS2Ka/h0AAABfklEQVR42oVT2Xa' \
+           'CMBAdJRAi7pYJa2QHxbb//3ctSSAUPfa+THLmzj4DBvZpvyauS9b7kw3PWDkWsrD6fFQhQ9dZLfVbC5M88CWCPERr+8fLZodJ5M8QJbjb' \
+           'GL1H2M1fIGfEm+wJN+bGCSc6EXtNS/8FSrq2VX6YDv++XLpJ8SgDWMnwqznGo6alcTbIxB2CHKn8VFikk2mMV2lEnV+CJd9+jJlxXmMr5' \
+           'dW14YCqwgbFpO8FNvJxwwM4TPWPo5QalEsRMAcusXpi58/QUEWPL0AK1ThM5oQCUyXPoPINkdd922VBw4XgTV9zDGWWFrgjIQs4vwvOg6' \
+           'xr+6gbCTqE+DYhlMGX0CF2OknK5gQ2JrkDh/W6TOEbYDeVecKbJtyNXiCfGmW7V93J2hDus1bDfhxWbIZVYDXITA7Lo6E0Ktgg9eB4KWu' \
+           'R44aj7ppBVPazhQH7/M/KgWe9X1qAg8XypT6nxIMJH+T94QCsLvj29IYwZxyO9/F8vCbO9tX5/wDGjEZ7vrgFZwAAAABJRU5ErkJggg=='
+
+    if helper.is_running_on_lambda():
+        data_b64 = {
+            'headers': headers,
+            'statusCode': 200,
+            'body': data,
+            'isBase64Encoded': True
+        }
+        data = helper.to_json(data_b64)
+        headers = {"Content-Type": "application/json"}
+    else:
+        data = base64.b64decode(data)
+
+    return http_helper.create_response(body=data, status_code=200, headers=headers)
+
+
+@APP.route(API_ROOT + '/favicon-16x16.png')
+def favicon16():
+    headers = CUSTOM_DEFAULT_HEADERS.copy()
+    headers['Content-Type'] = "image/png"
+    data = 'iVBORw0KGgoAAAANSUhEUgAAABAAAAAQCAMAAAAoLQ9TAAABNVBMVEVisTRhsTReqzVbpTVXoDdVnTdSlzh' \
+           'RljgvXkAuXUAtWkErV0EzZj40Zj85bz0lTkMkTUMkT0MmTUIkS0IjTEIhSUMkS0IkTEIkTUIlTUIkTkMlTkMcQUQcP0UfQ0QdQ0QfREQg' \
+           'RUMiSUMiSUMjSkInU0EkTEMmUEEiR0IiSEMpVkErWT8kTUElTUIUNkYVNEQVMkcRM0QSNUYQMUIMMUkVK0AAJEkAM00AMzMAAAAAAACF6' \
+           'i2E6SyD6CyC5i2B5Sx/4i6A4S593S583S520jB00DByyjFxyTFwyDFvxjJtxTFtxDFswzJrwDJqvzJpvjNouzNoujNnuDNLjTlKijpKiT' \
+           'pEfztDfzxAeT0+dz05bj44bT44bj82aj81aD8zZT8bPUUbPkUcP0UcPUUeQ0UfREQgRkRgJREvAAAAO3RSTlP09PX19vX39u7u7/Dq6uf' \
+           'h4eDg4+Pf3Nvb2tnY2NvPv7y6rKupqaGZlpSOiYWETDEkHh0fFQwHCgUBAAcHrskAAADYSURBVHjaPc/ZLkNRGIbhz26KjVJpqSKGtjHP' \
+           'c9a7W7OEEhtBjDWUO3XghqQSwVrNTp+j///OXhlrLpdJdg9MLblbxqwPd5RLUDpOjK66YWMwTqRpaM0OhZbo3dskljea9+HyAevxHtoWV' \
+           'AjhfQtr5w3CSfUE8BrgvEDQpxRc3eyfH5wenlQuIO39Sb9x/8uv+bXvmPSjbABPRZznIkGvxkOo7mJtV+FsQsutcFvBuruG9kWZMY+G5p' \
+           'zxlMp/KPKZSUs2cLrzyMWVEyP1OGtlNpvs6p+p5/8DzUo5hMDku9EAAAAASUVORK5CYII='
+
+    if helper.is_running_on_lambda():
+        data_b64 = {
+            'headers': headers,
+            'statusCode': 200,
+            'body': data,
+            'isBase64Encoded': True
+        }
+        data = helper.to_json(data_b64)
+        headers = {"Content-Type": "application/json"}
+    else:
+        data = base64.b64decode(data)
+
+    return http_helper.create_response(body=data, status_code=200, headers=headers)
+
+
+@APP.route(API_ROOT + '/docs')
 def docs():
     headers = CUSTOM_DEFAULT_HEADERS.copy()
     headers['Content-Type'] = "text/html"
@@ -120,7 +161,7 @@ def docs():
         body=html, status_code=200, headers=headers)
 
 
-@APP.route('/openapi.yml')
+@APP.route(API_ROOT + '/openapi.yml')
 def openapi():
     headers = CUSTOM_DEFAULT_HEADERS.copy()
     headers['Content-Type'] = "text/yaml"
@@ -130,7 +171,7 @@ def openapi():
         body=html, status_code=200, headers=headers)
 
 
-@APP.route('/v1/event/<event_type>', methods=['POST'])
+@APP.route(API_ROOT+ '/v1/event/<event_type>', methods=['POST'])
 def event_create(event_type):
     """
     :param event_type:
@@ -274,15 +315,22 @@ def event_list(event_type):
     return response.get_response(status_code)
 
 
+# *************
 # doc
-spec.path(view=alive, path="/alive", operations=get_doc(alive))
+# *************
+spec.path(view=alive, path=API_ROOT + "/alive", operations=get_doc(alive))
+# *************
+# event
+# *************
 spec.path(view=event_list,
-          path="/v1/event/{event_type}", operations=get_doc(event_list))
+          path=API_ROOT + "/v1/event/{event_type}", operations=get_doc(event_list))
 spec.path(view=event_create,
-          path="/v1/event/{event_type}", operations=get_doc(event_create))
+          path=API_ROOT + "/v1/event/{event_type}", operations=get_doc(event_create))
 
 print_routes(APP, LOGGER)
-LOGGER.info('Running at {}'.format(os.environ['APP_ENV']))
+LOGGER.info('Running at {}'.format(ENV))
 
 # generate de openapi.yml
 generate_openapi_yml(spec, LOGGER, force=True)
+
+api_schemas.register()