feat: TT-418 create get_all, get_by_id and delete methods

gcobena-dev · gcobena-dev · commit c4fbb0f36e0c · 2021-11-23T12:17:43.000-05:00
diff --git a/V2/serverless.yml b/V2/serverless.yml
@@ -2,6 +2,8 @@ service: azure-time-tracker
 
 frameworkVersion: "2"
 
+#region Config
+
 provider:
   name: azure
   region: westus2
@@ -36,7 +38,14 @@ package:
     - "!.gitignore"
     - "!.git/**"
 
+#endregion Fin Config
+
+#region Functions
+
 functions:
+
+#region Activities
+
   get_activities:
     handler: time_tracker/activities/interface.get_activities
     events:
@@ -77,6 +86,10 @@ functions:
           route: activities/
           authLevel: anonymous
 
+#endregion fin Activities
+
+#region Time-Entries
+
   create_time_entry:
     handler: time_tracker/time_entries/interface.create_time_entry
     events:
@@ -97,6 +110,10 @@ functions:
           route: time-entries/{id}
           authLevel: anonymous
 
+#endregion Fin TimeEntries
+
+#region Customer
+
   create_customer:
     handler: time_tracker/customers/interface.create_customer
     events:
@@ -106,3 +123,27 @@ functions:
             - POST
           route: customer/
           authLevel: anonymous
+
+  get_customers:
+    handler: time_tracker/customers/interface.get_customers
+    events:
+      - http: true
+        x-azure-settings:
+          methods:
+            - GET
+          route: customers/{id:?}
+          authLevel: anonymous
+
+  delete_customer:
+    handler: time_tracker/customers/interface.delete_customer
+    events:
+      - http: true
+        x-azure-settings:
+          methods:
+            - DELETE
+          route: customers/{id}
+          authLevel: anonymous
+
+#endregion Fin Customer
+
+#endregion Fin Funciones
diff --git a/V2/time_tracker/customers/_application/__init__.py b/V2/time_tracker/customers/_application/__init__.py
@@ -1,2 +1,4 @@
 # flake8: noqa
-from ._time_entries import create_customer
+from ._customers import create_customer
+from ._customers import get_customers
+from ._customers import delete_customer
diff --git a/V2/time_tracker/customers/_application/_customers/__init__.py b/V2/time_tracker/customers/_application/_customers/__init__.py
@@ -0,0 +1,4 @@
+# flake8: noqa
+from ._create_customer import create_customer
+from ._get_customers import get_customers
+from ._delete_customer import delete_customer
diff --git a/V2/time_tracker/customers/_application/_customers/_create_customer.py b/V2/time_tracker/customers/_application/_customers/_create_customer.py
diff --git a/V2/time_tracker/customers/_application/_customers/_delete_customer.py b/V2/time_tracker/customers/_application/_customers/_delete_customer.py
@@ -0,0 +1,37 @@
+import json
+
+import azure.functions as func
+
+from ... import _domain
+from ... import _infrastructure
+from time_tracker._infrastructure import DB
+
+DATATYPE="application/json"
+
+def delete_customer(req: func.HttpRequest) -> func.HttpResponse:
+    customer_dao = _infrastructure.CustomersSQLDao(DB())
+    customer_service = _domain.CustomerService(customer_dao)
+    use_case = _domain._use_cases.DeleteCustomerUseCase(customer_service)
+
+    try:
+        customer_id = int(req.route_params.get("id"))
+        deleted_customer = use_case.delete_customer(customer_id)
+        if not deleted_customer:
+            return func.HttpResponse(
+                body="Not found",
+                status_code=404,
+                mimetype=DATATYPE
+            )
+
+        return func.HttpResponse(
+            body=json.dumps(deleted_customer.__dict__, default=str),
+            status_code=200,
+            mimetype=DATATYPE,
+        )
+
+    except ValueError:
+        return func.HttpResponse(
+            body=b"Invalid Format ID",
+            status_code=400,
+            mimetype=DATATYPE
+        )
diff --git a/V2/time_tracker/customers/_application/_customers/_get_customers.py b/V2/time_tracker/customers/_application/_customers/_get_customers.py
@@ -0,0 +1,60 @@
+import json
+import logging
+
+import azure.functions as func
+
+from ... import _domain
+from ... import _infrastructure
+from time_tracker._infrastructure import DB
+
+DATABASE = DB()
+
+
+def get_customers(req: func.HttpRequest) -> func.HttpResponse:
+    logging.info(
+        'Python HTTP trigger function processed a request to get an activity.'
+    )
+    customer_id = req.route_params.get('id')
+    status_code = 200
+
+    try:
+        if customer_id:
+            response = _get_by_id(int(customer_id))
+            if response == b'This customer does not exist':
+                status_code = 404
+        else:
+            response = _get_all()
+
+        return func.HttpResponse(
+            body=response, status_code=status_code, mimetype="application/json"
+        )
+    except ValueError:
+        return func.HttpResponse(
+            body=b"The id has an invalid format", status_code=400, mimetype="application/json"
+        )
+
+
+def _get_by_id(customer_id: int) -> str:
+    customer_use_case = _domain._use_cases.GetByIdCustomerUseCase(
+        _create_customer_service(DATABASE)
+    )
+    customer = customer_use_case.get_customer_by_id(customer_id)
+
+    return json.dumps(customer.__dict__) if customer else b'This customer does not exist'
+
+
+def _get_all() -> str:
+    customer_sql = _domain._use_cases.GetAllCustomerUseCase(
+        _create_customer_service(DATABASE)
+    )
+    return json.dumps(
+        [
+            customer.__dict__
+            for customer in customer_sql.get_all_customer()
+        ]
+    )
+
+
+def _create_customer_service(db: DB) -> _domain.CustomerService:
+    customer_sql = _infrastructure.CustomersSQLDao(db)
+    return _domain.CustomerService(customer_sql)
diff --git a/V2/time_tracker/customers/_application/_time_entries/__init__.py b/V2/time_tracker/customers/_application/_time_entries/__init__.py
diff --git a/V2/time_tracker/customers/_application/_time_entries/_delete_time_entry.py b/V2/time_tracker/customers/_application/_time_entries/_delete_time_entry.py
diff --git a/V2/time_tracker/customers/_domain/_persistence_contracts/_customers_dao.py b/V2/time_tracker/customers/_domain/_persistence_contracts/_customers_dao.py
@@ -13,14 +13,14 @@ def create(self, data: Customer) -> Customer:
     # def update(self, data: Customer) -> Customer:
     #     pass
 
-    # @abc.abstractmethod
-    # def get_by_id(self, id: int) -> Customer:
-    #     pass
+    @abc.abstractmethod
+    def get_by_id(self, id: int) -> Customer:
+        pass
 
-    # @abc.abstractmethod
-    # def get_all(self) -> typing.List[Customer]:
-    #     pass
+    @abc.abstractmethod
+    def get_all(self) -> typing.List[Customer]:
+        pass
 
-    # @abc.abstractmethod
-    # def delete(self, id: int) -> Customer:
-    #     pass
+    @abc.abstractmethod
+    def delete(self, id: int) -> Customer:
+        pass
diff --git a/V2/time_tracker/customers/_domain/_services/_customer.py b/V2/time_tracker/customers/_domain/_services/_customer.py
@@ -14,11 +14,11 @@ def create(self, data: Customer) -> Customer:
     # def update(self, data: Customer) -> Customer:
     #     return self.customer_dao.update(data)
 
-    # def get_by_id(self, id: int) -> Customer:
-    #     return self.customer_dao.get_by_id(id)
+    def get_by_id(self, id: int) -> Customer:
+        return self.customer_dao.get_by_id(id)
 
-    # def get_all(self) -> typing.List[Customer]:
-    #     return self.customer_dao.get_all()
+    def get_all(self) -> typing.List[Customer]:
+        return self.customer_dao.get_all()
 
-    # def delete(self, id: int) -> Customer:
-    #     return self.customer_dao.delete(id)
+    def delete(self, id: int) -> Customer:
+        return self.customer_dao.delete(id)
diff --git a/V2/time_tracker/customers/_infrastructure/_data_persistence/_customer_dao.py b/V2/time_tracker/customers/_infrastructure/_data_persistence/_customer_dao.py
@@ -1,6 +1,7 @@
 import dataclasses
 import sqlalchemy as sq
 import sqlalchemy.sql as sql
+import typing
 
 import time_tracker.customers._domain as domain
 from time_tracker._infrastructure import _db
@@ -21,6 +22,19 @@ def __init__(self, database: _db.DB):
             sq.Column('status', sq.Integer),
             extend_existing=True,
         )
+        
+    def get_by_id(self, customer_id: int) -> domain.Customer:
+        query = sql.select(self.customer).where(self.customer.c.id == customer_id)
+        customer = self.db.get_session().execute(query).one_or_none()
+        return self.__create_customer_dto(dict(customer)) if customer else None
+
+    def get_all(self) -> typing.List[domain.Customer]:
+        query = sql.select(self.customer)
+        result = self.db.get_session().execute(query)
+        return [
+            self.__create_customer_dto(dict(customer))
+            for customer in result
+        ]
 
     def create(self, data: domain.Customer) -> domain.Customer:
         try:
@@ -48,13 +62,13 @@ def __create_customer_dto(self, customer: dict) -> domain.Customer:
         customer = {key: customer.get(key) for key in self.customer_key}
         return domain.Customer(**customer)
 
-    # def delete(self, customer_id: int) -> domain.Customer:
-    #     query = (
-    #         self.customer.update()
-    #         .where(self.customer.c.id == customer_id)
-    #         .values({"deleted": True})
-    #     )
-    #     self.db.get_session().execute(query)
-    #     query_deleted_customer = sq.sql.select(self.customer).where(self.customer.c.id == customer_id)
-    #     customer = self.db.get_session().execute(query_deleted_customer).one_or_none()
-    #     return self.__create_customer_dto(dict(customer)) if customer else None
+    def delete(self, customer_id: int) -> domain.Customer:
+        query = (
+            self.customer.update()
+            .where(self.customer.c.id == customer_id)
+            .values({"deleted": True})
+        )
+        self.db.get_session().execute(query)
+        query_deleted_customer = sq.sql.select(self.customer).where(self.customer.c.id == customer_id)
+        customer = self.db.get_session().execute(query_deleted_customer).one_or_none()
+        return self.__create_customer_dto(dict(customer)) if customer else None
diff --git a/V2/time_tracker/customers/interface.py b/V2/time_tracker/customers/interface.py
@@ -1,2 +1,4 @@
 # flake8: noqa
-from ._application import create_customer
+from ._application import create_customer
+from ._application import get_customers
+from ._application import delete_customer
