Merge pull request #26 from getmarkus/cm-branch-24

refactor: replace in-memory repository with collection repository

Author: getmarkus

app/interface_adapters/containers.py

@@ -1,7 +1,9 @@
 from dependency_injector import containers, providers
 from sqlmodel import Session
 
-from app.resource_adapters.persistence.in_memory.issues import InMemoryIssueRepository
+from app.resource_adapters.persistence.collections.issues import (
+    CollectionIssueRepository,
+)
 from app.resource_adapters.persistence.sqlmodel.database import get_engine
 from app.resource_adapters.persistence.sqlmodel.issues import SQLModelIssueRepository
 from config import settings
@@ -17,13 +19,13 @@ class Container(containers.DeclarativeContainer):
     # Repositories
     sqlmodel_repository = providers.Factory(SQLModelIssueRepository, session=db_session)
 
-    in_memory_repository = providers.Factory(InMemoryIssueRepository)
+    collection_repository = providers.Factory(CollectionIssueRepository)
 
     def get_model_config():
         return settings.model_config
 
     issue_repository = providers.Selector(
         get_model_config,
         sqlmodel=sqlmodel_repository,
-        **{"in-memory": in_memory_repository},
+        **{"collection": collection_repository},
     )

…apters/persistence/in_memory/__init__.py …ters/persistence/collections/__init__.pyapp/resource_adapters/persistence/in_memory/__init__.py renamed to app/resource_adapters/persistence/collections/__init__.py app/resource_adapters/persistence/in_memory/__init__.py renamed to app/resource_adapters/persistence/collections/__init__.py

@@ -4,10 +4,12 @@
 
 from app.core.ports.repositories.issues import IssueRepository
 from app.domain.issue import Issue
-from app.resource_adapters.persistence.in_memory.unit_of_work import InMemoryUnitOfWork
+from app.resource_adapters.persistence.collections.unit_of_work import (
+    CollectionUnitOfWork,
+)
 
 
-class InMemoryIssueRepository(InMemoryUnitOfWork, IssueRepository):
+class CollectionIssueRepository(CollectionUnitOfWork, IssueRepository):
     def __init__(self) -> None:
         self.issues: List[Issue] = []
         # self.issues: dict[int, Issue] = {}

…adapters/persistence/in_memory/issues.py …apters/persistence/collections/issues.pyapp/resource_adapters/persistence/in_memory/issues.py renamed to app/resource_adapters/persistence/collections/issues.py app/resource_adapters/persistence/in_memory/issues.py renamed to app/resource_adapters/persistence/collections/issues.py

@@ -5,7 +5,7 @@
 from app.core.repository import UnitOfWork
 
 
-class InMemoryUnitOfWork(UnitOfWork):
+class CollectionUnitOfWork(UnitOfWork):
     def __init__(self) -> None:
         self.committed = False
 
@@ -15,7 +15,7 @@ def commit(self) -> None:
     def rollback(self) -> None:
         self.committed = False
 
-    def __enter__(self) -> "InMemoryUnitOfWork":
+    def __enter__(self) -> "CollectionUnitOfWork":
         logger.info("enter uow")
         return self
 

…adapters/persistence/in_memory/readme.md …apters/persistence/collections/readme.mdapp/resource_adapters/persistence/in_memory/readme.md renamed to app/resource_adapters/persistence/collections/readme.md app/resource_adapters/persistence/in_memory/readme.md renamed to app/resource_adapters/persistence/collections/readme.md

@@ -1,11 +1,12 @@
 [default]
 project_name = "python-template"
 # dialect+driver://username:password@host:port/database
+# sqlite:// sqlite:///./issues.db
 database_url = "sqlite:///./issues.db"
 database_schema = ""
 migrate_database = false
 sqlite_wal_mode = false
-# in-memory, sqlmodel
+# collection, sqlmodel
 model_config = "sqlmodel"
 
 # CORS Settings
@@ -38,7 +39,7 @@ cors_allow_methods = [
 # sqlite:///./test.db sqlite://
 database_url = "sqlite://"
 database_schema = ""
-# in-memory, sqlmodel
+# collection, sqlmodel
 model_config = "sqlmodel"
 migrate_database = false
 sqlite_wal_mode = false