Correções gerais, versionamento de repositórios e serviços, implementação de restful para produts (rota de listagem)

Author: andersoncontreira

examples/lambda_api/app.py

@@ -2,9 +2,11 @@
 
 This module contains the handler method
 """
-import boot
+import inspect
 import os
 import base64
+import boot
+from lambda_app.services.product_manager import ProductManager
 from lambda_app.services.v1.healthcheck import HealthCheckSchema
 from lambda_app.services.v1.healthcheck.resources import \
     MysqlConnectionHealthCheck, RedisConnectionHealthCheck, \
@@ -17,7 +19,8 @@
 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
+from lambda_app.services.v1.ocoren_event_service import OcorenEventService as OcorenEventServiceV1
+from lambda_app.services.v1.product_service import ProductService as ProductServiceV1
 from lambda_app.vos.events import EventVO
 from lambda_app.logging import get_logger
 from lambda_app import APP_NAME, APP_VERSION, http_helper
@@ -33,7 +36,6 @@
 ENV = helper.get_environment()
 boot.load_dot_env(ENV)
 
-
 # config
 CONFIG = get_config()
 # debug
@@ -129,6 +131,101 @@ def openapi():
         body=html, status_code=200, headers=headers)
 
 
+@APP.route('/v1/product', methods=['GET'])
+def product_list():
+    """
+    ---
+    get:
+        summary: Product List
+        parameters:
+            - name: limit
+              in: query
+              description: "List limit"
+              required: false
+              schema:
+                type: int
+                example: 20
+            - name: offset
+              in: query
+              description: "List offset"
+              required: false
+              schema:
+                type: int
+                example: 0
+            - name: fields
+              in: query
+              description: "Filter fields with comma"
+              required: false
+              schema:
+                type: string
+                example:
+            - name: order_by
+              in: query
+              description: "Ordination of list"
+              required: false
+              schema:
+                type: string
+                enum:
+                 - "asc"
+                 - "desc"
+            - name: sort_by
+              in: query
+              description: "Sorting of the list"
+              required: false
+              schema:
+                type: string
+                example: id
+        responses:
+            200:
+                description: Success response
+                content:
+                    application/json:
+                        schema: ProductListResponseSchema
+    """
+    request = ApiRequest().parse_request(APP)
+    LOGGER.info('request: {}'.format(request))
+
+    status_code = 200
+    response = ApiResponse(request)
+    response.set_hateos(False)
+
+    manager = ProductManager(logger=LOGGER, product_service=ProductServiceV1(logger=LOGGER))
+    manager.debug(DEBUG)
+    try:
+        response.set_data(manager.list(request))
+        response.set_total(manager.count(request))
+    except Exception as err:
+        LOGGER.error(err)
+        LOGGER.info('aq')
+        error = ApiException(MessagesEnum.LIST_ERROR)
+        status_code = 400
+        if manager.exception:
+            error = manager.exception
+        response.set_exception(error)
+
+    return response.get_response(status_code)
+
+
+@APP.route('/v1/product/<uuid>', methods=['GET'])
+def product_get(uuid):
+    pass
+
+
+@APP.route('/v1/product/<uuid>', methods=['POST'])
+def product_create():
+    pass
+
+
+@APP.route('/v1/product/<uuid>', methods=['PUT'])
+def product_update():
+    pass
+
+
+@APP.route('/v1/product/<uuid>', methods=['DELETE'])
+def product_delete():
+    pass
+
+
 @APP.route('/v1/event/<event_type>', methods=['POST'])
 def event_create(event_type):
     """
@@ -183,7 +280,7 @@ def event_create(event_type):
         #     event_service = OcorenEventService()
         # else:
         #     event_service = ProductEventService()
-        event_service = OcorenEventService()
+        event_service = OcorenEventServiceV1()
         service = EventManager(logger=LOGGER, event_service=event_service)
         result = service.process(event_vo)
         event_hash = event_vo.hash
@@ -329,8 +426,26 @@ def event_list(event_type):
     return response.get_response(status_code)
 
 
+# *************
 # doc
+# *************
 spec.path(view=alive, path="/alive", operations=get_doc(alive))
+# *************
+# product
+# *************
+spec.path(view=product_list,
+          path="/v1/product", operations=get_doc(product_list))
+spec.path(view=product_get,
+          path="/v1/product/{uuid}", operations=get_doc(product_get))
+spec.path(view=product_create,
+          path="/v1/product/{uuid}", operations=get_doc(product_create))
+spec.path(view=product_update,
+          path="/v1/product/{uuid}", operations=get_doc(product_update))
+spec.path(view=product_delete,
+          path="/v1/product/{uuid}", operations=get_doc(product_delete))
+# *************
+# event
+# *************
 spec.path(view=event_list,
           path="/v1/event/{event_type}", operations=get_doc(event_list))
 spec.path(view=event_create,
@@ -339,5 +454,7 @@ def event_list(event_type):
 print_routes(APP, LOGGER)
 LOGGER.info('Running at {}'.format(os.environ['APP_ENV']))
 
+# *************
 # generate de openapi.yml
+# *************
 generate_openapi_yml(spec, LOGGER, force=True)

examples/lambda_api/lambda_app/helper.py

@@ -77,7 +77,7 @@ def to_dict(obj, force_str=False):
 
 
 def to_json(obj):
-    return json.dumps(obj)
+    return json.dumps(obj, default=str)
 
 
 def debug_mode():

examples/lambda_api/lambda_app/http_resources/request.py

@@ -52,9 +52,6 @@ def __getitem__(self, item):
     def __str__(self):
         return self.to_json()
 
-    def __repr__(self):
-        return str(self.to_json())
-
     def to_dict(self, force_str=False):
         data = helper.to_dict(self, force_str)
         data['_request'] = None
@@ -101,6 +98,12 @@ def parse_request(self, app):
         self.server_type = parsed_request.server_type
         self._request = request
 
-        # logger = helper.get_logger()
-        # logger.info('Request: {}'.format(self.to_dict()))
-        return self
+        return self
+
+    @staticmethod
+    def factory(method, host, path):
+        api_request = ApiRequest()
+        api_request.method = method
+        api_request.host = host
+        api_request.path = path
+        return api_request

examples/lambda_api/lambda_app/http_resources/response.py

@@ -27,13 +27,13 @@ def __init__(self, api_request=None):
         self.next = {}
         self.last = {}
         self.limit = api_request.limit if api_request is not None else Pagination.LIMIT
-        self.offset = api_request.offset if api_request is not None else  Pagination.OFFSET
+        self.offset = api_request.offset if api_request is not None else Pagination.OFFSET
         self.total = 0
         self.count = 0
 
         self.api_request = api_request
 
-    def set_hateos(self, flag:bool):
+    def set_hateos(self, flag: bool):
         self.hateos = flag
 
     def set_data(self, data):
@@ -58,12 +58,18 @@ def get_response(self, status_code=None):
 
         headers = self.headers
         status_code = self.status_code
+        success = status_code == 200
+        message = MessagesEnum.OK.message
+        code = MessagesEnum.OK.code
+        label = MessagesEnum.OK.label
+        params = []
 
         if self.exception is not None:
             if isinstance(self.exception, ApiException):
                 code = self.exception.code
                 label = self.exception.label
                 message = self.exception.message
+                params = self.exception.params
             else:
                 message = self.data if not None else MessagesEnum.UNKNOWN_ERROR
                 code = MessagesEnum.NOK.code
@@ -74,7 +80,8 @@ def get_response(self, status_code=None):
                 "error": {
                     "code": code,
                     "label": label,
-                    "message": message
+                    "message": message,
+                    "params": params
                 }
             }
 
@@ -108,27 +115,31 @@ def get_response(self, status_code=None):
                 "last": ""
             }
 
-            if self.hateos:
-                body = {
-                    # data
-                    "data": self.data,
-                    # navigation
-                    "control": {
-                        "offset": self.offset,
-                        "limit": self.limit,
-                        "total": self.total,
-                        "count": self.count,
-                    },
-                    # hypermedia info
-                    "meta": self.meta,
-                    # hypermedia links
-                    "links": self.links
-                }
-            else:
-                body = {
-                    # data
-                    "data": self.data
-                }
+            body = {
+                # success
+                "success": success,
+                "label": label,
+                "code": code,
+                "message": message,
+                "params": [],
+                # data
+                "data": self.data,
+                # navigation
+                "control": {
+                    "offset": self.offset,
+                    "limit": self.limit,
+                    "total": self.total,
+                    "count": self.count,
+                },
+                # hypermedia info
+                "meta": self.meta,
+                # hypermedia links
+                "links": self.links
+            }
+
+            if not self.hateos:
+                del body["meta"]
+                del body["links"]
 
         if 'Content-Type' in headers and headers['Content-Type'] == 'application/json':
             body = helper.to_json(body)
@@ -143,11 +154,8 @@ def keys(self):
     def __str__(self):
         return self.to_json()
 
-    def __repr__(self):
-        return self.to_json()
-
     def to_dict(self, force_str=False):
         return helper.to_dict(self, force_str)
 
     def to_json(self):
-        return json.dumps(self.to_dict(force_str=False))
+        return json.dumps(self.to_dict(force_str=False))

examples/lambda_api/lambda_app/openapi/api_schemas.py

@@ -5,6 +5,26 @@
 from lambda_app.openapi.schemas import DeletionSchema, RequestControlSchema, MetaSchema, LinkSchema
 
 
+# ***************************
+# Product
+# ***************************
+class ProductSchema(Schema):
+    sku = fields.Int(example=657705)
+    quantity = fields.Int(example=1)
+    uuid = fields.UUID(example="3d9f2fdb-f71a-4e6d-8fbf-72b12cc0c381")
+
+
+class ProductListResponseSchema(Schema):
+    data = fields.List(fields.Nested(ProductSchema))
+    control = fields.Nested(RequestControlSchema)
+    meta = fields.Nested(MetaSchema)
+    links = fields.List(fields.Nested(LinkSchema))
+
+
+# ***************************
+# Event
+# ***************************
+
 class EventSchema(Schema):
     type = fields.Str()
     data = fields.Dict()
@@ -19,14 +39,10 @@ class OcorenSchema(Schema):
     pedido = fields.Str(example="Z1223321")
 
 
-class ProductSchema(Schema):
-    sku = fields.Int(example=657705)
-    quantity = fields.Int(example=1)
-
-
 class EventCreateRequest(OcorenSchema):
     pass
 
+
 class EventUpdateRequest(EventCreateRequest):
     pass