feat: TT-404 get time entries

Author: scastillo-jp

V2/time_tracker/time_entries/_application/__init__.py

@@ -0,0 +1 @@
+from ._time_entries import create_time_entry

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

@@ -0,0 +1 @@
+from ._create_time_entry import create_time_entry

V2/time_tracker/time_entries/_application/_time_entries/_create_time_entry.py

@@ -0,0 +1,49 @@
+import dataclasses
+import json
+import typing
+
+import azure.functions as func
+
+from ... import _domain
+from ... import _infrastructure
+
+_JSON_PATH = (
+    'time_entries/_infrastructure/_data_persistence/time_entries_data.json'
+)
+
+def create_time_entry(req: func.HttpRequest) -> func.HttpResponse:
+
+  time_entry_dao = _infrastructure.TimeEntriesJsonDao(_JSON_PATH)
+  time_entry_service = _domain.TimeEntryService(time_entry_dao)
+  use_case = _domain._use_cases.CreateTimeEntryUseCase(time_entry_service)
+
+  time_entry_data = req.get_json()
+
+  time_entry_to_create = _domain.TimeEntry(
+    id=None,
+    start_date=time_entry_data["start_date"],
+    owner_id=time_entry_data["owner_id"],
+    description=time_entry_data["description"],
+    activity_id=time_entry_data["activity_id"],
+    uri=time_entry_data["uri"],
+    technologies=time_entry_data["technologies"],
+    end_date=time_entry_data["end_date"],
+    deleted=time_entry_data["deleted"],
+    timezone_offset=time_entry_data["timezone_offset"],
+    project_id=time_entry_data["project_id"]
+  )
+
+  created_time_entry = use_case.create_time_entry(time_entry_to_create.__dict__)
+  
+  if not created_time_entry:
+    return func.HttpResponse(
+      body=json.dumps({'error': 'time_entry could not be created'}),
+      status_code=500,
+      mimetype="application/json"
+    )
+
+  return func.HttpResponse(
+    body=json.dumps(created_time_entry.__dict__),
+    status_code=201,
+    mimetype="application/json"
+  )

V2/time_tracker/time_entries/_application/_time_entries/_get_time_entries.py

@@ -0,0 +1,55 @@
+from time_entries._infrastructure import TimeEntriesJsonDao
+from time_entries._domain import TimeEntryService, _use_cases
+
+import azure.functions as func
+import json
+import logging
+
+JSON_PATH = (
+    'time_entries/_infrastructure/_data_persistence/time_entries_data.json'
+)
+
+def get_time_entries(req: func.HttpRequest) -> func.HttpResponse:
+    logging.info(
+        'Python HTTP trigger function processed a request to get an activity.'
+    )
+    #  WIP
+    time_entry_id = req.route_params.get('id')
+    status_code = 200
+
+    if activity_id:
+        response = _get_by_id(activity_id)
+        if response == b'Not Found':
+            status_code = 404
+    else:
+        response = _get_all()
+
+    return func.HttpResponse(
+        body=response, status_code=status_code, mimetype="application/json"
+    )
+
+
+def _get_by_id(activity_id: str) -> str:
+    activity_use_case = _use_cases.GetActivityUseCase(
+        _create_activity_service(JSON_PATH)
+    )
+    activity = activity_use_case.get_activity_by_id(activity_id)
+
+    return json.dumps(activity.__dict__) if activity else b'Not Found'
+
+
+def _get_all() -> str:
+    activities_use_case = _use_cases.GetActivitiesUseCase(
+        _create_activity_service(JSON_PATH)
+    )
+    return json.dumps(
+        [
+            activity.__dict__
+            for activity in activities_use_case.get_activities()
+        ]
+    )
+
+
+def _create_activity_service(path: str):
+    activity_json = ActivitiesJsonDao(path)
+    return ActivityService(activity_json)

V2/time_tracker/time_entries/_domain/__init__.py

@@ -0,0 +1,6 @@
+from ._entities import TimeEntry
+from ._persistence_contracts import TimeEntriesDao
+from ._services import TimeEntryService
+from ._use_cases import (
+    CreateTimeEntryUseCase,
+)

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

@@ -0,0 +1 @@
+from ._time_entry import TimeEntry

V2/time_tracker/time_entries/_domain/_entities/_time_entry.py

@@ -0,0 +1,16 @@
+from dataclasses import dataclass
+from typing import List
+
+@dataclass(frozen=True)
+class TimeEntry:
+    id: int
+    start_date: str
+    owner_id: int
+    description: str
+    activity_id: int
+    uri: str
+    technologies: List[str]
+    end_date: str
+    deleted: str
+    timezone_offset: str
+    project_id: int

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

@@ -0,0 +1 @@
+from ._time_entries_dao import TimeEntriesDao

V2/time_tracker/time_entries/_domain/_persistence_contracts/_time_entries_dao.py

@@ -0,0 +1,16 @@
+import abc
+import typing
+
+from time_entries._domain import TimeEntry
+
+class TimeEntriesDao(abc.ABC):
+    @abc.abstractmethod
+    def get_by_id(self, id: str) -> TimeEntry:
+      pass
+
+    @abc.abstractmethod
+    def get_all(self) -> typing.List[TimeEntry]:
+        pass
+
+    def create(self, time_entry_data: dict) -> TimeEntry:
+        pass

V2/time_tracker/time_entries/_domain/_services/__init__.py

@@ -0,0 +1 @@
+from ._time_entry import TimeEntryService