feat: TT-357 Create SQLAlchemy Dao

Author: ararcos

V2/time_entries/_application/_activities/_delete_activity.py

@@ -1,4 +1,4 @@
-from time_entries._infrastructure import ActivitiesJsonDao
+from time_entries._infrastructure import ActivitiesJsonDao, ActivitiesSQLDao
 from time_entries._domain import ActivityService, _use_cases
 
 import azure.functions as func
@@ -33,4 +33,5 @@ def _delete(activity_id: str) -> str:
 
 def _create_activity_service(path: str):
     activity_json = ActivitiesJsonDao(path)
-    return ActivityService(activity_json)
+    activity_sql = ActivitiesSQLDao()
+    return ActivityService(activity_sql)

V2/time_entries/_application/_activities/_get_activities.py

@@ -1,4 +1,4 @@
-from time_entries._infrastructure import ActivitiesJsonDao
+from time_entries._infrastructure import ActivitiesJsonDao, ActivitiesSQLDao
 from time_entries._domain import ActivityService, _use_cases
 
 import azure.functions as func
@@ -52,4 +52,5 @@ def _get_all() -> str:
 
 def _create_activity_service(path: str):
     activity_json = ActivitiesJsonDao(path)
-    return ActivityService(activity_json)
+    activity_sql = ActivitiesSQLDao()
+    return ActivityService(activity_sql)

V2/time_entries/_infrastructure/__init__.py

@@ -1 +1,3 @@
 from ._data_persistence import ActivitiesJsonDao
+from ._data_persistence import ActivitiesSQLDao
+

V2/time_entries/_infrastructure/_data_persistence/__init__.py

@@ -1 +1,2 @@
 from ._activities_json_dao import ActivitiesJsonDao
+from ._activities_sql_dao import ActivitiesSQLDao

V2/time_entries/_infrastructure/_data_persistence/_activities_sql_dao.py

@@ -0,0 +1,49 @@
+from sqlalchemy.engine.cursor import LegacyCursorResult
+from time_entries._domain import ActivitiesDao, Activity
+from sqlalchemy import create_engine,Table, Column, String, MetaData
+from sqlalchemy.sql import select
+import dataclasses
+import json
+import typing
+
+
+class ActivitiesSQLDao(ActivitiesDao):
+    def __init__(self):
+        self.activity_keys = [
+            field.name for field in dataclasses.fields(Activity)
+        ]
+        self.engine = create_engine('postgresql://postgres:root@localhost/time-tracker')
+        self.conn = self.engine.connect()
+        metadata_obj = MetaData()
+        self.activity = Table('activity', metadata_obj,
+            Column('id', String, primary_key=True),
+            Column('name', String),
+            Column('description', String),
+            Column('deleted', String),
+            Column('status', String),
+            Column('tenant_id', String),
+        )
+   
+   
+
+    def get_by_id(self, activity_id: str) -> Activity:
+        query = select(self.activity).where(self.activity.c.id == activity_id)
+        activity = self.conn.execute(query).one()
+        return self.__create_activity_dto(dict(activity)) if activity else None
+
+    def get_all(self) -> typing.List[Activity]:
+        query = select(self.activity)
+        result = self.conn.execute(query)
+        return [
+            self.__create_activity_dto(dict(activity))
+            for activity in result
+        ]
+
+    def delete(self, activity_id: str) -> Activity:
+        query = self.activity.update().where(self.activity.c.id == activity_id).values(status = 'inactive')
+        self.conn.execute(query)
+        return self.get_by_id(activity_id);
+
+    def __create_activity_dto(self, activity: dict) -> Activity:
+        activity = {key: activity.get(key) for key in self.activity_keys}
+        return Activity(**activity)