feat: TT-418 create added

Author: mandres2015

V2/serverless.yml

@@ -96,3 +96,13 @@ functions:
             - DELETE
           route: time-entries/{id}
           authLevel: anonymous
+
+  create_customer:
+    handler: time_tracker/customers/interface.create_customer
+    events:
+      - http: true
+        x-azure-settings:
+          methods:
+            - POST
+          route: customer/
+          authLevel: anonymous

V2/time_tracker/customers/_application/__init__.py

@@ -0,0 +1,2 @@
+# flake8: noqa
+from ._time_entries import create_customer

V2/time_tracker/customers/_application/_time_entries/__init__.py

@@ -0,0 +1,2 @@
+# flake8: noqa
+from ._create_customer import create_customer

V2/time_tracker/customers/_application/_time_entries/_create_customer.py

@@ -0,0 +1,56 @@
+import dataclasses
+import json
+import typing
+
+import azure.functions as func
+
+from ... import _domain
+from ... import _infrastructure
+from time_tracker._infrastructure import DB
+
+DEFAULT_FIELDS = ["id", "deleted", "status"]
+
+
+def create_customer(req: func.HttpRequest) -> func.HttpResponse:
+    database = DB()
+    customer_dao = _infrastructure.CustomersSQLDao(database)
+    customer_service = _domain.CustomerService(customer_dao)
+    use_case = _domain._use_cases.CreateCustomerUseCase(customer_service)
+
+    customer_data = req.get_json()
+    validation_errors = _validate_customer(customer_data)
+    if validation_errors:
+        return func.HttpResponse(
+            body=validation_errors, status_code=400, mimetype="application/json"
+        )
+
+    customer_to_create = _domain.Customer(
+        id=None,
+        name=customer_data["name"],
+        description=customer_data["description"],
+        deleted=False,
+        status=-1
+    )
+
+    created_customer = use_case.create_customer(customer_to_create)
+
+    if not created_customer:
+        return func.HttpResponse(
+            body=json.dumps({'error': 'customer could not be created'}),
+            status_code=500,
+            mimetype="application/json"
+        )
+
+    return func.HttpResponse(
+        body=json.dumps(created_customer.__dict__),
+        status_code=201,
+        mimetype="application/json"
+    )
+
+
+def _validate_customer(customer_data: dict) -> typing.List[str]:
+    customer_fields = [field.name for field in dataclasses.fields(_domain.Customer) 
+                        if field.name not in DEFAULT_FIELDS]
+    if [field for field in customer_fields if field not in customer_data]:
+        return b'Invalid format or structure of the attributes of the customer'
+    return []

V2/time_tracker/customers/_application/_time_entries/_delete_time_entry.py

@@ -0,0 +1,36 @@
+import json
+
+import azure.functions as func
+
+from ... import _domain
+from ... import _infrastructure
+from time_tracker._infrastructure import DB
+
+
+def delete_time_entry(req: func.HttpRequest) -> func.HttpResponse:
+    time_entry_dao = _infrastructure.TimeEntriesSQLDao(DB())
+    time_entry_service = _domain.TimeEntryService(time_entry_dao)
+    use_case = _domain._use_cases.DeleteTimeEntryUseCase(time_entry_service)
+
+    try:
+        time_entry_id = int(req.route_params.get("id"))
+        deleted_time_entry = use_case.delete_time_entry(time_entry_id)
+        if not deleted_time_entry:
+            return func.HttpResponse(
+                body="Not found",
+                status_code=404,
+                mimetype="application/json"
+            )
+
+        return func.HttpResponse(
+            body=json.dumps(deleted_time_entry.__dict__, default=str),
+            status_code=200,
+            mimetype="application/json",
+        )
+
+    except ValueError:
+        return func.HttpResponse(
+            body=b"Invalid Format ID",
+            status_code=400,
+            mimetype="application/json"
+        )

V2/time_tracker/customers/_domain/__init__.py

@@ -0,0 +1,11 @@
+# flake8: noqa
+from ._entities import Customer
+from ._persistence_contracts import CustomersDao
+from ._services import CustomerService
+from ._use_cases import (
+    CreateCustomerUseCase,
+    UpdateCustomerUseCase,
+    GetAllCustomerUseCase,
+    GetByIdCustomerUseCase,
+    DeleteCustomerUseCase
+)

V2/time_tracker/customers/_domain/_entities/__init__.py

@@ -0,0 +1,2 @@
+# flake8: noqa
+from ._customer import Customer

V2/time_tracker/customers/_domain/_entities/_customer.py

@@ -0,0 +1,10 @@
+from dataclasses import dataclass
+
+
+@dataclass(frozen=True)
+class Customer:
+    id: int
+    name: str
+    description: str
+    deleted: bool
+    status: int

V2/time_tracker/customers/_domain/_persistence_contracts/__init__.py

@@ -0,0 +1,2 @@
+# flake8: noqa
+from ._customers_dao import CustomersDao

V2/time_tracker/customers/_domain/_persistence_contracts/_customers_dao.py

@@ -0,0 +1,26 @@
+import abc
+import typing
+
+from time_tracker.customers._domain import Customer
+
+
+class CustomersDao(abc.ABC):
+    @abc.abstractmethod
+    def create(self, data: Customer) -> Customer:
+        pass
+
+    # @abc.abstractmethod
+    # def update(self, data: Customer) -> 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 delete(self, id: int) -> Customer:
+    #     pass