feat: TT-401 Implemented service, end-point, dao, test- time entries

Author: ararcos

V2/serverless.yml

@@ -76,3 +76,13 @@ functions:
             - POST
           route: activities/
           authLevel: anonymous
+
+  create_time_entry:
+    handler: time_tracker/time_entries/interface.create_time_entry
+    events:
+      - http: true
+        x-azure-settings:
+          methods:
+            - POST
+          route: time-entries/
+          authLevel: anonymous

V2/tests/api/azure/time_entry_azure_endpoints_test.py

@@ -0,0 +1,40 @@
+from time_tracker.time_entries._application import _time_entries as time_entries
+from faker import Faker
+
+import azure.functions as func
+import json
+
+
+ACTIVITY_URL = "/api/time-entries/"
+
+
+def test__time_entry_azure_endpoint__creates_an_time_entry__when_time_entry_has_all_attributes(
+    create_temp_time_entries,
+):
+    time_entries_json, tmp_directory = create_temp_time_entries
+    time_entries._create_time_entry._JSON_PATH = tmp_directory
+
+    time_entry_body = {
+        "id" : None,
+        "start_date" : Faker().date(),
+        "owner_id" : Faker().random_int(),
+        "description": Faker().sentence(),
+        "activity_id" : Faker().random_int(),
+        "uri": "http://timetracker.com",
+        "technologies" : ["jira","git"],
+        "end_date": Faker().date(),
+        "deleted": Faker().random_int(),
+        "timezone_offset": "300",
+        "project_id": Faker().random_int(),
+    }
+    body = json.dumps(time_entry_body).encode("utf-8")
+    req = func.HttpRequest(
+        method="POST",
+        body=body,
+        url=ACTIVITY_URL,
+    )
+
+    response = time_entries.create_time_entry(req)
+    time_entry_json_data = response.get_body()
+    assert response.status_code == 201
+    assert time_entry_json_data == body

V2/tests/conftest.py

@@ -1,2 +1,2 @@
 # flake8: noqa
-from fixtures import _activity_factory, _create_fake_dao, _create_fake_database
+from fixtures import _activity_factory, _create_fake_dao, _create_fake_database

V2/tests/integration/daos/time_entries_dao.test.py

@@ -0,0 +1,45 @@
+import json
+import pytest
+import typing
+
+from faker import Faker
+
+from time_tracker.time_entries._infrastructure import TimeEntriesJsonDao
+from time_tracker.time_entries._domain import TimeEntry
+
+
+@pytest.fixture(name="create_fake_time_entries")
+def _create_fake_time_entries(mocker) -> typing.List[TimeEntry]:
+    def _creator(time_entries):
+        read_data = json.dumps(time_entries)
+        mocker.patch("builtins.open", mocker.mock_open(read_data=read_data))
+        return [TimeEntry(**time_entry) for time_entry in time_entries]
+
+    return _creator
+
+
+def test_create_time_entry__returns_an_time_entry_dto__when_create_an_time_entry_that_matches_attributes(
+    create_fake_time_entries,
+):
+    create_fake_time_entries([])
+
+    time_entries_json_dao = TimeEntriesJsonDao(Faker().file_path())
+    time_entry_data = {
+        "id" : None,
+        "start_date" : Faker().date(),
+        "owner_id" : Faker().random_int(),
+        "description": Faker().sentence(),
+        "activity_id" : Faker().random_int(),
+        "uri": "http://hola.com",
+        "technologies" : ["jira","git"],
+        "end_date": Faker().date(),
+        "deleted": Faker().random_int(),
+        "timezone_offset": "UTC-5",
+        "project_id": Faker().random_int(),
+    }
+    result = time_entries_json_dao.create(time_entry_data)
+    assert result == TimeEntry(**time_entry_data)
+
+
+
+

V2/tests/unit/services/time_entry_service_test.py

@@ -0,0 +1,15 @@
+from faker import Faker
+
+from time_tracker.time_entries._domain import TimeEntryService
+
+def test__create_time_entries__uses_the_time_entry_dao__to_create_an_time_entry(mocker):
+    expected_time_entry = mocker.Mock()
+    time_entry_dao = mocker.Mock(
+        create=mocker.Mock(return_value=expected_time_entry)
+    )
+    time_entry_service = TimeEntryService(time_entry_dao)
+
+    actual_time_entry = time_entry_service.create(Faker().pydict())
+
+    assert time_entry_dao.create.called
+    assert expected_time_entry == actual_time_entry

V2/tests/unit/use_cases/time_entries_use_case_test.py

@@ -0,0 +1,20 @@
+from faker import Faker
+
+from pytest_mock import MockFixture
+
+from time_tracker.time_entries._domain import _use_cases
+
+def test__create_time_entry_function__uses_the_time_entries_service__to_create_time_entry(
+    mocker: MockFixture,
+):
+    expected_time_entry = mocker.Mock()
+    time_entry_service = mocker.Mock(
+        create=mocker.Mock(return_value=expected_time_entry)
+    )
+
+    time_entry_use_case = _use_cases.CreateTimeEntryUseCase(time_entry_service)
+    actual_time_entry = time_entry_use_case.create_time_entry(Faker().pydict())
+
+    assert time_entry_service.create.called
+    assert expected_time_entry == actual_time_entry
+

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/_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,
+)