reactor: TT-407 rebase with master - DELETE

Author: mandres2015

V2/serverless.yml

@@ -1,6 +1,6 @@
 service: azure-time-tracker
 
-frameworkVersion: "2"
+frameworkVersion: '2'
 
 provider:
   name: azure
@@ -23,18 +23,18 @@ plugins:
 
 package:
   patterns:
-    - "!env/**"
-    - "!.env/**"
-    - "!local.settings.json"
-    - "!.vscode/**"
-    - "!__pycache__/**"
-    - "!node_modules/**"
-    - "!.python_packages/**"
-    - "!.funcignore"
-    - "!package.json"
-    - "!package-lock.json"
-    - "!.gitignore"
-    - "!.git/**"
+    - '!env/**'
+    - '!.env/**'
+    - '!local.settings.json'
+    - '!.vscode/**'
+    - '!__pycache__/**'
+    - '!node_modules/**'
+    - '!.python_packages/**'
+    - '!.funcignore'
+    - '!package.json'
+    - '!package-lock.json'
+    - '!.gitignore'
+    - '!.git/**'
 
 functions:
   get_activities:
@@ -63,9 +63,9 @@ functions:
       - http: true
         x-azure-settings:
           methods:
-            - PUT   
+            - PUT
           route: activities/{id}
-          authLevel: anonymous    
+          authLevel: anonymous
 
   create_activity:
     handler: time_tracker/activities/interface.create_activity
@@ -96,3 +96,13 @@ functions:
             - DELETE
           route: time-entries/{id}
           authLevel: anonymous
+
+  get_latest_time_entry:
+    handler: time_tracker/time_entries/interface.get_latest_entries
+    events:
+      - http: true
+        x-azure-settings:
+          methods:
+            - GET
+          route: time-entries/latest
+          authLevel: anonymous

V2/tests/api/azure/time_entry_azure_endpoints_test.py

@@ -1,5 +1,7 @@
 import pytest
 import json
+import pytest
+from faker import Faker
 
 import azure.functions as func
 
@@ -76,3 +78,42 @@ def test__delete_time_entries_azure_endpoint__returns_a_status_code_400__when_ti
 
     assert response.status_code == 400
     assert response.get_body() == b'Invalid Format ID'
+
+
+def test__get_latest_entries_azure_endpoint__returns_a_list_of_latest_time_entries__when_an_owner_id_match(
+    test_db, time_entry_factory, insert_time_entry, insert_activity, activity_factory,
+):
+    inserted_activity = insert_activity(activity_factory(), test_db).__dict__
+    time_entry_body = time_entry_factory(activity_id=inserted_activity["id"], technologies="[jira,sql]")
+    inserted_time_entry = insert_time_entry(time_entry_body, test_db)
+
+    req = func.HttpRequest(
+        method='GET',
+        body=None,
+        url=TIME_ENTRY_URL+"latest/",
+        params={"owner_id": inserted_time_entry["owner_id"]},
+    )
+
+    response = azure_time_entries._get_latest_entries.get_latest_entries(req)
+    time_entry_json_data = json.loads(response.get_body().decode("utf-8"))
+
+    assert response.status_code == 200
+    assert time_entry_json_data == [inserted_time_entry]
+
+
+def test__get_latest_entries_azure_endpoint__returns_No_time_entries_found__when_recieve_an_invalid_owner_id(
+    test_db, insert_activity, activity_factory,
+):
+    insert_activity(activity_factory(), test_db)
+
+    req = func.HttpRequest(
+        method='GET',
+        body=None,
+        url=TIME_ENTRY_URL+"latest/",
+        params={"owner_id": Faker().pyint()},
+    )
+
+    response = azure_time_entries._get_latest_entries.get_latest_entries(req)
+
+    assert response.status_code == 404
+    assert response.get_body() == b'No time entries found'

V2/tests/integration/daos/time_entries_dao_test.py

@@ -69,3 +69,29 @@ def test_delete__returns_none__when_no_time_entry_matching_its_id_is_found(
     result = dao.delete(Faker().pyint())
 
     assert result is None
+
+
+def test_get_latest_entries__returns_a_list_of_latest_time_entries__when_an_owner_id_match(
+    create_fake_dao, time_entry_factory, insert_activity, activity_factory, test_db
+):
+    dao = create_fake_dao(test_db)
+    inserted_activity = insert_activity(activity_factory(), dao.db)
+    time_entry_to_insert = time_entry_factory(
+        activity_id=inserted_activity.id,
+        technologies="[jira,sql]")
+    inserted_time_entry = dao.create(time_entry_to_insert)
+
+    result = dao.get_latest_entries(int(inserted_time_entry.owner_id))
+
+    assert result == [inserted_time_entry.__dict__]
+
+
+def test_get_latest_entries__returns_None__when_an_owner_id_is_not_found(
+    create_fake_dao, test_db, insert_activity, activity_factory
+):
+    dao = create_fake_dao(test_db)
+    insert_activity(activity_factory(), dao.db)
+
+    result = dao.get_latest_entries(Faker().pyint())
+
+    assert result is None

V2/tests/unit/services/time_entry_service_test.py

@@ -1,6 +1,7 @@
 from faker import Faker
 
 from time_tracker.time_entries._domain import TimeEntryService
+from faker import Faker
 
 
 def test__create_time_entries__uses_the_time_entry_dao__to_create_an_time_entry(mocker, time_entry_factory):
@@ -29,3 +30,18 @@ def test__delete_time_entry__uses_the_time_entry_dao__to_delete_time_entry_selec
 
     assert time_entry_dao.delete.called
     assert expected_time_entry == deleted_time_entry
+
+
+def test__get_latest_entries__uses_the_time_entry_dao__to_get_last_entries(
+    mocker,
+):
+    expected_latest_time_entries = mocker.Mock()
+    time_entry_dao = mocker.Mock(
+        get_latest_entries=mocker.Mock(return_value=expected_latest_time_entries)
+    )
+
+    time_entry_service = TimeEntryService(time_entry_dao)
+    latest_time_entries = time_entry_service.get_latest_entries(Faker().pyint(), Faker().pyint())
+
+    assert expected_latest_time_entries == latest_time_entries
+    assert time_entry_dao.get_latest_entries.called

V2/tests/unit/use_cases/time_entries_use_case_test.py

@@ -30,3 +30,16 @@ def test__delete_time_entry_function__uses_the_time_entry_service__to_delete_tim
 
     assert time_entry_service.delete.called
     assert expected_time_entry == deleted_time_entry
+
+
+def test__get_latest_entries_function__uses_the_time_entry_service__to_get_last_entries(
+    mocker: MockFixture,
+):
+    expected_latest_time_entries = mocker.Mock()
+    time_entry_service = mocker.Mock(get_latest_entries=mocker.Mock(return_value=expected_latest_time_entries))
+
+    time_entry_use_case = _use_cases.GetLastestTimeEntryUseCase(time_entry_service)
+    latest_time_entries = time_entry_use_case.get_latest_entries(Faker().pyint(), Faker().pyint())
+
+    assert time_entry_service.get_latest_entries.called
+    assert expected_latest_time_entries == latest_time_entries

V2/time_tracker/time_entries/_application/__init__.py

@@ -1,2 +1,2 @@
 # flake8: noqa
-from ._time_entries import create_time_entry, delete_time_entry
+from ._time_entries import create_time_entry, delete_time_entry, get_latest_entries

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

@@ -1,3 +1,4 @@
 # flake8: noqa
 from ._create_time_entry import create_time_entry
-from ._delete_time_entry import delete_time_entry
+from ._delete_time_entry import delete_time_entry
+from ._get_latest_entries import get_latest_entries

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

@@ -0,0 +1,47 @@
+import json
+
+import azure.functions as func
+
+from ... import _domain
+from ... import _infrastructure
+from time_tracker._infrastructure import DB
+
+
+def get_latest_entries(req: func.HttpRequest) -> func.HttpResponse:
+    database = DB()
+    time_entry_dao = _infrastructure.TimeEntriesSQLDao(database)
+    time_entry_service = _domain.TimeEntryService(time_entry_dao)
+    use_case = _domain._use_cases.GetLastestTimeEntryUseCase(time_entry_service)
+
+    try:
+        owner_id = req.params.get("owner_id")
+        limit = req.params.get("limit")
+
+        if not owner_id:
+            return func.HttpResponse(
+                body="No owner id found",
+                status_code=404,
+                mimetype="application/json"
+            )
+
+        time_entries = use_case.get_latest_entries(int(owner_id), int(limit) if limit and int(limit) > 0 else None)
+
+        if not time_entries or len(time_entries) == 0:
+            return func.HttpResponse(
+                body="No time entries 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"
+        )

V2/time_tracker/time_entries/_domain/__init__.py

@@ -4,5 +4,6 @@
 from ._services import TimeEntryService
 from ._use_cases import (
     CreateTimeEntryUseCase,
-    DeleteTimeEntryUseCase
+    DeleteTimeEntryUseCase,
+    GetLastestTimeEntryUseCase,
 )

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

@@ -1,4 +1,5 @@
 import abc
+import typing
 
 from time_tracker.time_entries._domain import TimeEntry
 
@@ -11,3 +12,7 @@ def create(self, time_entry_data: TimeEntry) -> TimeEntry:
     @abc.abstractmethod
     def delete(self, id: int) -> TimeEntry:
         pass
+
+    @abc.abstractmethod
+    def get_latest_entries(self, owner_id: int, limit: int) -> typing.List[TimeEntry]:
+        pass