feat: TT-407 get latest entries added without params

mandres2015 · mandres2015 · commit 65505f09c71f · 2021-11-16T17:41:24.000-05:00
diff --git a/V2/create_activity/function.json b/V2/create_activity/function.json
@@ -0,0 +1,22 @@
+{
+  "disabled": false,
+  "bindings": [
+    {
+      "type": "httpTrigger",
+      "direction": "in",
+      "name": "req",
+      "route": "activities/",
+      "authLevel": "anonymous",
+      "methods": [
+        "POST"
+      ]
+    },
+    {
+      "type": "http",
+      "direction": "out",
+      "name": "$return"
+    }
+  ],
+  "entryPoint": "create_activity",
+  "scriptFile": "../time_tracker/activities/interface.py"
+}
diff --git a/V2/delete_activity/function.json b/V2/delete_activity/function.json
@@ -0,0 +1,22 @@
+{
+  "disabled": false,
+  "bindings": [
+    {
+      "type": "httpTrigger",
+      "direction": "in",
+      "name": "req",
+      "route": "activities/{id}",
+      "authLevel": "anonymous",
+      "methods": [
+        "DELETE"
+      ]
+    },
+    {
+      "type": "http",
+      "direction": "out",
+      "name": "$return"
+    }
+  ],
+  "entryPoint": "delete_activity",
+  "scriptFile": "../time_tracker/activities/interface.py"
+}
diff --git a/V2/delete_time_entry/function.json b/V2/delete_time_entry/function.json
@@ -0,0 +1,22 @@
+{
+  "disabled": false,
+  "bindings": [
+    {
+      "type": "httpTrigger",
+      "direction": "in",
+      "name": "req",
+      "route": "time-entries/{id}",
+      "authLevel": "anonymous",
+      "methods": [
+        "DELETE"
+      ]
+    },
+    {
+      "type": "http",
+      "direction": "out",
+      "name": "$return"
+    }
+  ],
+  "entryPoint": "delete_time_entry",
+  "scriptFile": "../time_tracker/time_entries/interface.py"
+}
diff --git a/V2/get_activities/function.json b/V2/get_activities/function.json
@@ -0,0 +1,22 @@
+{
+  "disabled": false,
+  "bindings": [
+    {
+      "type": "httpTrigger",
+      "direction": "in",
+      "name": "req",
+      "route": "activities/{id:?}",
+      "authLevel": "anonymous",
+      "methods": [
+        "GET"
+      ]
+    },
+    {
+      "type": "http",
+      "direction": "out",
+      "name": "$return"
+    }
+  ],
+  "entryPoint": "get_activities",
+  "scriptFile": "../time_tracker/activities/interface.py"
+}
diff --git a/V2/get_lastest_time_entries/function.json b/V2/get_lastest_time_entries/function.json
@@ -0,0 +1,22 @@
+{
+  "disabled": false,
+  "bindings": [
+    {
+      "type": "httpTrigger",
+      "direction": "in",
+      "name": "req",
+      "route": "time-entries/latest",
+      "authLevel": "anonymous",
+      "methods": [
+        "GET"
+      ]
+    },
+    {
+      "type": "http",
+      "direction": "out",
+      "name": "$return"
+    }
+  ],
+  "entryPoint": "get_latest_entries",
+  "scriptFile": "../time_tracker/time_entries/interface.py"
+}
diff --git a/V2/serverless.yml b/V2/serverless.yml
@@ -86,3 +86,13 @@ functions:
             - DELETE
           route: time-entries/{id}
           authLevel: anonymous
+
+  get_latest_time_entries:
+    handler: time_tracker/time_entries/interface.get_latest_entries
+    events:
+      - http: true
+        x-azure-settings:
+          methods:
+            - GET
+          route: time-entries/latest
+          authLevel: anonymous
diff --git a/V2/time_tracker/time_entries/_application/__init__.py b/V2/time_tracker/time_entries/_application/__init__.py
@@ -1,2 +1,2 @@
 # flake8: noqa
-from ._time_entries import delete_time_entry
+from ._time_entries import delete_time_entry, get_latest_entries
diff --git a/V2/time_tracker/time_entries/_application/_time_entries/__init__.py b/V2/time_tracker/time_entries/_application/_time_entries/__init__.py
@@ -1,2 +1,3 @@
 # flake8: noqa
-from ._delete_time_entry import delete_time_entry
+from ._delete_time_entry import delete_time_entry
+from ._get_latest_entries import get_latest_entries
diff --git a/V2/time_tracker/time_entries/_application/_time_entries/_get_latest_entries.py b/V2/time_tracker/time_entries/_application/_time_entries/_get_latest_entries.py
@@ -0,0 +1,38 @@
+import json
+
+import azure.functions as func
+
+from ... import _domain
+from ... import _infrastructure
+from time_tracker._infrastructure import DB
+
+DATABASE = DB()
+
+
+def get_latest_entries(req: func.HttpRequest) -> func.HttpResponse:
+    time_entry_dao = _infrastructure.TimeEntriesSQLDao(DATABASE)
+    time_entry_service = _domain.TimeEntryService(time_entry_dao)
+    use_case = _domain._use_cases.GetLastTimeEntryUseCase(time_entry_service)
+
+    try:
+        time_entries = use_case.get_latest_entries()
+
+        if not time_entries or len(time_entries) == 0:
+            return func.HttpResponse(
+                body="Not found",
+                status_code=404,
+                mimetype="application/json"
+            )
+
+        return func.HttpResponse(
+            body=json.dumps(time_entries, default=str),
+            status_code=200,
+            mimetype="application/json",
+        )
+
+    except ValueError:
+        return func.HttpResponse(
+            body=b"Invalid Format ID",
+            status_code=400,
+            mimetype="application/json"
+        )
diff --git a/V2/time_tracker/time_entries/_domain/__init__.py b/V2/time_tracker/time_entries/_domain/__init__.py
@@ -3,5 +3,6 @@
 from ._persistence_contracts import TimeEntriesDao
 from ._services import TimeEntryService
 from ._use_cases import (
-    DeleteTimeEntryUseCase
+    DeleteTimeEntryUseCase,
+    GetLastTimeEntryUseCase
 )
diff --git a/V2/time_tracker/time_entries/_domain/_persistence_contracts/_time_entries_dao.py b/V2/time_tracker/time_entries/_domain/_persistence_contracts/_time_entries_dao.py
@@ -7,3 +7,7 @@ class TimeEntriesDao(abc.ABC):
     @abc.abstractmethod
     def delete(self, id: int) -> TimeEntry:
         pass
+    
+    @abc.abstractmethod
+    def get_latest_entries(self) -> TimeEntry:
+        pass
diff --git a/V2/time_tracker/time_entries/_domain/_services/_time_entry.py b/V2/time_tracker/time_entries/_domain/_services/_time_entry.py
@@ -8,3 +8,6 @@ def __init__(self, time_entry_dao: TimeEntriesDao):
 
     def delete(self, time_entry_id: int) -> TimeEntry:
         return self.time_entry_dao.delete(time_entry_id)
+
+    def get_latest_entries(self) -> TimeEntry:
+        return self.time_entry_dao.get_latest_entries()
diff --git a/V2/time_tracker/time_entries/_domain/_use_cases/__init__.py b/V2/time_tracker/time_entries/_domain/_use_cases/__init__.py
@@ -1,2 +1,3 @@
 # flake8: noqa
 from ._delete_time_entry_use_case import DeleteTimeEntryUseCase
+from ._get_latest_entries_use_case import GetLastTimeEntryUseCase 
diff --git a/V2/time_tracker/time_entries/_domain/_use_cases/_get_latest_entries_use_case.py b/V2/time_tracker/time_entries/_domain/_use_cases/_get_latest_entries_use_case.py
@@ -0,0 +1,10 @@
+from time_tracker.time_entries._domain import TimeEntry, TimeEntryService
+
+
+class GetLastTimeEntryUseCase:
+
+    def __init__(self, time_entry_service: TimeEntryService):
+        self.time_entry_service = time_entry_service
+
+    def get_latest_entries(self) -> TimeEntry:
+        return self.time_entry_service.get_latest_entries()
diff --git a/V2/time_tracker/time_entries/_infrastructure/_data_persistence/_time_entries_dao.py b/V2/time_tracker/time_entries/_infrastructure/_data_persistence/_time_entries_dao.py
@@ -1,6 +1,7 @@
 import dataclasses
 import sqlalchemy
 import sqlalchemy.sql as sql
+from typing import List
 
 from time_tracker.time_entries._domain import TimeEntriesDao, TimeEntry
 import time_tracker.time_entries._domain as domain
@@ -48,6 +49,11 @@ def create(self, time_entry_data: domain.TimeEntry) -> domain.TimeEntry:
         except sqlalchemy.exc.SQLAlchemyError:
             return None
 
+    def get_latest_entries(self) -> List[TimeEntry]:
+        query = sql.select(self.time_entry)
+        time_entry = self.db.get_session().execute(query)
+        return [dict(entry) for entry in time_entry]
+
     def delete(self, time_entry_id: int) -> TimeEntry:
         query = (
             self.time_entry.update()
diff --git a/V2/time_tracker/time_entries/interface.py b/V2/time_tracker/time_entries/interface.py
@@ -1,2 +1,3 @@
 # flake8: noqa
-from ._application import delete_time_entry
+from ._application import delete_time_entry
+from ._application import get_latest_entries
diff --git a/V2/update_activity/function.json b/V2/update_activity/function.json
@@ -0,0 +1,22 @@
+{
+  "disabled": false,
+  "bindings": [
+    {
+      "type": "httpTrigger",
+      "direction": "in",
+      "name": "req",
+      "route": "activities/{id}",
+      "authLevel": "anonymous",
+      "methods": [
+        "PUT"
+      ]
+    },
+    {
+      "type": "http",
+      "direction": "out",
+      "name": "$return"
+    }
+  ],
+  "entryPoint": "update_activity",
+  "scriptFile": "../time_tracker/activities/interface.py"
+}

Original file line number	Diff line number	Diff line change
`@@ -1,2 +1,2 @@`
`1`	`1`	`# flake8: noqa`
`2`		`-from ._time_entries import delete_time_entry`
	`2`	`+from ._time_entries import delete_time_entry, get_latest_entries`
Original file line number	Diff line number	Diff line change
`@@ -3,5 +3,6 @@`
`3`	`3`	`from ._persistence_contracts import TimeEntriesDao`
`4`	`4`	`from ._services import TimeEntryService`
`5`	`5`	`from ._use_cases import (`
`6`		`- DeleteTimeEntryUseCase`
	`6`	`+ DeleteTimeEntryUseCase,`
	`7`	`+ GetLastTimeEntryUseCase`
`7`	`8`	`)`