fix: Close #102 Tweak config of trigger handlers

Author: EliuX

.gitignore

@@ -33,3 +33,6 @@ swagger.json
 
 # Local migration files
 migration_status.csv
+
+# Mac
+.DS_Store

commons/data_access_layer/events_model.py

@@ -3,4 +3,4 @@
 container_definition = {
     'id': 'event',
     'partition_key': PartitionKey(path='/tenant_id')
-}
+}

commons/data_access_layer/sql.py

@@ -1,9 +1,7 @@
-from datetime import datetime
-
 from flask import Flask
 from flask_sqlalchemy import SQLAlchemy
 
-from commons.data_access_layer.database import CRUDDao, ID_MAX_LENGTH
+from commons.data_access_layer.database import CRUDDao
 
 db: SQLAlchemy = None
 

commons/git_hooks/enforce_semantic_commit_msg.py

@@ -15,12 +15,10 @@
 
 COMMIT_MSG_REGEX = r'(build|ci|docs|feat|fix|perf|refactor|style|test|chore|revert)(\([\w\-]+\))?:\s.*'
 
-
 # Get the commit message file
 commit_msg_file = open(sys.argv[1])  # The first argument is the file
 commit_msg = commit_msg_file.read()
 
-
 if re.match(COMMIT_MSG_REGEX, commit_msg) is None:
     print(ERROR_MSG)
     sys.exit(1)

setup.py

@@ -1,6 +1,7 @@
-from setuptools import setup, find_packages
 import sys
 
+from setuptools import setup, find_packages
+
 
 def get_version() -> str:
     version = {}

tests/conftest.py

@@ -7,9 +7,9 @@
 from flask.testing import FlaskClient
 
 from commons.data_access_layer.cosmos_db import CosmosDBRepository, CosmosDBDao
-from time_tracker_api.database import init_sql
 from commons.data_access_layer.database import EventContext
 from time_tracker_api import create_app
+from time_tracker_api.database import init_sql
 from time_tracker_api.security import get_or_generate_dev_secret_key
 from time_tracker_api.time_entries.time_entries_model import TimeEntryCosmosDBRepository
 

tests/time_tracker_api/time_entries/time_entries_namespace_test.py

@@ -8,6 +8,7 @@
 from pytest_mock import MockFixture, pytest
 
 from commons.data_access_layer.cosmos_db import current_datetime, current_datetime_str
+from time_tracker_api.time_entries.time_entries_model import TimeEntriesCosmosDBDao
 
 fake = Faker()
 
@@ -289,8 +290,8 @@ def test_stop_time_entry_with_valid_id(client: FlaskClient, mocker: MockFixture,
                            follow_redirects=True)
 
     assert HTTPStatus.OK == response.status_code
-    repository_update_mock.assert_called_once_with(str(valid_id), {"end_date": mocker.ANY},
-                                                   ANY, peeker=ANY)
+    repository_update_mock.assert_called_once_with(str(valid_id), {"end_date": mocker.ANY}, ANY,
+                                                   peeker=TimeEntriesCosmosDBDao.checks_owner_and_is_not_stopped)
 
 
 def test_stop_time_entry_with_id_with_invalid_format(client: FlaskClient,
@@ -308,8 +309,8 @@ def test_stop_time_entry_with_id_with_invalid_format(client: FlaskClient,
                            follow_redirects=True)
 
     assert HTTPStatus.UNPROCESSABLE_ENTITY == response.status_code
-    repository_update_mock.assert_called_once_with(invalid_id, {"end_date": ANY},
-                                                   ANY, peeker=ANY)
+    repository_update_mock.assert_called_once_with(invalid_id, {"end_date": ANY}, ANY,
+                                                   peeker=TimeEntriesCosmosDBDao.checks_owner_and_is_not_stopped)
 
 
 def test_restart_time_entry_with_valid_id(client: FlaskClient,

time_tracker_events/handle_activity_events_trigger/__init__.py

@@ -0,0 +1,3 @@
+from ..handle_events_trigger import main as handler
+
+main = handler

time_tracker_events/handle_events_trigger/function.json renamed to time_tracker_events/handle_activity_events_trigger/function.json

@@ -9,7 +9,8 @@
       "connectionStringSetting": "COSMOS_DATABASE_URI",
       "databaseName": "time-tracker-db",
       "collectionName": "activity",
-      "createLeaseCollectionIfNotExists": "true"
+      "createLeaseCollectionIfNotExists": "true",
+      "leaseCollectionPrefix": "activity_"
     },
     {
       "direction": "out",

time_tracker_events/handle_customer_trigger/__init__.py

@@ -0,0 +1,3 @@
+from ..handle_events_trigger import main as handler
+
+main = handler