feat: TT-402 add put time entries

Author: Jobzi

V2/serverless.yml

@@ -89,14 +89,25 @@ functions:
 
   delete_time_entry:
     handler: time_tracker/time_entries/interface.delete_time_entry
-    events:
+     events:
       - http: true
         x-azure-settings:
           methods:
             - DELETE
           route: time-entries/{id}
           authLevel: anonymous
 
+    
+  update_time_entry:
+    handler: time_tracker/time_entries/interface.update_time_entry
+    events:
+      - http: true
+        x-azure-settings:
+          methods:
+            - PUT   
+          route: time-entries/{id}
+          authLevel: anonymous   
+
   create_customer:
     handler: time_tracker/customers/interface.create_customer
     events:
@@ -106,3 +117,4 @@ functions:
             - POST
           route: customers/
           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,43 @@ 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__update_activity_azure_endpoint__returns_an_activity__when_found_an_activity_to_update(
+    test_db, time_entry_factory, insert_time_entry, activity_factory, insert_activity
+):
+    inserted_activity = insert_activity(activity_factory(), test_db)
+    existent_time_entries = time_entry_factory(activity_id=inserted_activity.id, technologies="[jira,sql]")
+    inserted_time_entries = insert_time_entry(existent_time_entries, test_db).__dict__
+
+    time_entry_body = {"description": Faker().sentence()}
+
+    req = func.HttpRequest(
+        method='PUT',
+        body=json.dumps(time_entry_body).encode("utf-8"),
+        url=TIME_ENTRY_URL,
+        route_params={"id": inserted_time_entries["id"]},
+    )
+
+    response = azure_time_entries._update_time_entry.update_time_entry(req)
+    activitiy_json_data = response.get_body().decode("utf-8")
+    inserted_time_entries.update(time_entry_body)
+
+    assert response.status_code == 200
+    assert activitiy_json_data == json.dumps(inserted_time_entries)
+
+
+def test__update_time_entries_azure_endpoint__returns_a_status_code_400__when_time_entry_recive_invalid_id():
+    time_entry_body = {"description": Faker().sentence()}
+
+    req = func.HttpRequest(
+        method="PUT",
+        body=json.dumps(time_entry_body).encode("utf-8"),
+        url=TIME_ENTRY_URL,
+        route_params={"id": "invalid id"},
+    )
+
+    response = azure_time_entries._update_time_entry.update_time_entry(req)
+
+    assert response.status_code == 400
+    assert response.get_body() == b'Invalid ID'

V2/tests/integration/daos/time_entries_sql_dao_test.py

@@ -0,0 +1,41 @@
+import pytest
+
+from time_tracker.time_entries._infrastructure import TimeEntriesSQLDao
+
+from time_tracker._infrastructure import DB
+
+
+@pytest.fixture(name='create_time_entry_fake_dao')
+def _create_fake_dao() -> TimeEntriesSQLDao:
+    db_fake = DB('sqlite:///:memory:')
+    dao = TimeEntriesSQLDao(db_fake)
+    return dao
+
+
+def test_update__returns_an_time_entry_dto__when_found_one_time_entry_to_update(
+    create_time_entry_fake_dao, time_entry_factory, insert_activity, activity_factory
+):
+    dao = create_time_entry_fake_dao
+    inserted_activity = insert_activity(activity_factory(), dao.db)
+    existent_time_entries = time_entry_factory(activity_id=inserted_activity.id, technologies="[jira,sql]")
+    inserted_time_entries = dao.create(existent_time_entries).__dict__
+    time_entry_id = inserted_time_entries["id"]
+    inserted_time_entries.update({"description": "description updated"})
+
+    time_entry = dao.update(time_entry_id=time_entry_id, time_entry_data=inserted_time_entries)
+
+    assert time_entry.id == time_entry_id
+    assert time_entry.description == "description updated"
+
+
+def test_update__returns_none__when_doesnt_found_one_time_entry_to_update(
+     create_time_entry_fake_dao, time_entry_factory, insert_activity, activity_factory
+):
+    dao = create_time_entry_fake_dao
+    inserted_activity = insert_activity(activity_factory(), dao.db)
+    existent_time_entries = time_entry_factory(activity_id=inserted_activity.id, technologies="[jira,sql]")
+    inserted_time_entries = dao.create(existent_time_entries).__dict__
+
+    time_entry = dao.update(0, inserted_time_entries)
+
+    assert time_entry is None

V2/tests/unit/services/time_entry_service_test.py

@@ -29,3 +29,20 @@ 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__update_time_entry__uses_the_time_entry_dao__to_update_one_time_entry(
+    mocker,
+):
+    expected_time_entry = mocker.Mock()
+    time_entry_dao = mocker.Mock(
+        update=mocker.Mock(return_value=expected_time_entry)
+    )
+    time_entry_service = TimeEntryService(time_entry_dao)
+
+    updated_time_entry = time_entry_service.update(
+        Faker().pyint(), Faker().pydict()
+    )
+
+    assert time_entry_dao.update.called
+    assert expected_time_entry == updated_time_entry

V2/tests/unit/use_cases/time_entries_use_case_test.py

@@ -1,3 +1,4 @@
+from faker import Faker
 from pytest_mock import MockFixture
 from faker import Faker
 
@@ -30,3 +31,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__update_time_entries_function__uses_the_time_entry_service__to_update_an_time_entry(
+    mocker: MockFixture,
+):
+    expected_time_entry = mocker.Mock()
+    time_entry_service = mocker.Mock(update=mocker.Mock(return_value=expected_time_entry))
+
+    time_entry_use_case = _use_cases.UpdateTimeEntryUseCase(time_entry_service)
+    updated_time_entry = time_entry_use_case.update_time_entry(Faker().uuid4(), Faker().pydict())
+
+    assert time_entry_service.update.called
+    assert expected_time_entry == updated_time_entry

V2/time_tracker/_infrastructure/_db.py

@@ -2,6 +2,8 @@
 
 from . import _config
 
+_TEST_DIALECT = "sqlite"
+
 
 class DB():
     config = _config.load_config()
@@ -17,4 +19,6 @@ def get_session(self):
         self.metadata.create_all(self.engine)
         if self.connection is None:
             self.connection = self.engine.connect()
+            if self.engine.dialect.name == _TEST_DIALECT:
+                self.connection.execute("pragma foreign_keys=ON")
         return self.connection

V2/time_tracker/time_entries/_application/__init__.py

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

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 ._update_time_entry import update_time_entry

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

@@ -0,0 +1,48 @@
+import dataclasses
+import json
+import logging
+
+import azure.functions as func
+
+from time_tracker.time_entries._infrastructure import TimeEntriesSQLDao
+from time_tracker.time_entries._domain import TimeEntryService, TimeEntry, _use_cases
+from time_tracker._infrastructure import DB
+
+
+
+def update_time_entry(req: func.HttpRequest) -> func.HttpResponse:
+    logging.info(
+        'Python HTTP trigger function processed a request to update an time entry.'
+    )
+    time_entry_id = req.route_params.get('id')
+    time_entry_data = req.get_json() if req.get_body() else {}
+    time_entry_keys = [field.name for field in dataclasses.fields(TimeEntry)]
+
+    if all(key in time_entry_keys for key in time_entry_data.keys()):
+        try:
+            response = _update(int(time_entry_id), time_entry_data)
+            status_code = 200
+        except ValueError:
+            response = b'Invalid ID'
+            status_code = 400
+    else:
+        response = b'Incorrect time entry body'
+        status_code = 400
+
+    return func.HttpResponse(
+        body=response, status_code=status_code, mimetype="application/json"
+    )
+
+
+def _update(time_entry_id: int, time_entry_data: dict) -> str:
+    database = DB()
+    time_entry_use_case = _use_cases.UpdateTimeEntryUseCase(
+        _create_time_entry_service(database)
+    )
+    time_entry = time_entry_use_case.update_time_entry(time_entry_id, time_entry_data)
+    return json.dumps(time_entry.__dict__) if time_entry else b'Not Found'
+
+
+def _create_time_entry_service(db: DB):
+    time_entry_sql = TimeEntriesSQLDao(db)
+    return TimeEntryService(time_entry_sql)

V2/time_tracker/time_entries/_domain/__init__.py

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