Add the injector and configurations.

This commit is contained in:
2025-01-11 17:38:35 +02:00
parent eb01a26713
commit a0846b93a1
6 changed files with 79 additions and 7 deletions
@@ -0,0 +1,31 @@
from injector import singleton, inject, Injector, Module, provider
from tui_rsync.core.components.backup_plan.application.repository import BackupPlanRepositoryPort
from tui_rsync.core.components.backup_plan.application.repository.backup_plan_repository import BackupPlanRepository
from tui_rsync.core.components.backup_plan.application.services.backup_plan_service import BackupPlanService
from tui_rsync.core.ports.configuration import UserDataPathsPort
from tui_rsync.core.ports.orm import DatabaseManagerPort
from tui_rsync.infrastructure.configuration import UserDataPaths
from tui_rsync.infrastructure.orm import SqliteDatabaseManager
class Configuration(Module):
@provider
@singleton
def provide_user_data_paths(self) -> UserDataPathsPort:
return UserDataPaths()
@provider
@singleton
def provide_database_manager(self, user_data_paths: UserDataPathsPort) -> DatabaseManagerPort:
return SqliteDatabaseManager(user_data_paths)
@provider
@singleton
def provide_backup_plan_repository(self, database_manager: DatabaseManagerPort) -> BackupPlanRepositoryPort:
return BackupPlanRepository(database_manager)
@provider
@singleton
def provide_backup_plan_service(self, backup_plan_repository: BackupPlanRepositoryPort) -> BackupPlanService:
return BackupPlanService(backup_plan_repository)
@@ -0,0 +1,23 @@
from injector import Injector
class CurrentConfiguration:
"""
Manages global state for the configuration using injector.
"""
_injector: Injector | None = None
@staticmethod
def get_injector() -> Injector:
if CurrentConfiguration._injector is None:
raise RuntimeError("Injector not initialized")
return CurrentConfiguration._injector
@staticmethod
def get(instance):
return CurrentConfiguration.get_injector().get(instance)
@staticmethod
def set_injector(new_injector):
CurrentConfiguration._injector = new_injector
+6
View File
@@ -1,8 +1,14 @@
from injector import Injector
from tui_rsync.infrastructure.configuration import UserDataPaths
from tui_rsync.infrastructure.configuration.configuration import Configuration
from tui_rsync.infrastructure.configuration.current_configuration import CurrentConfiguration
from tui_rsync.user_interface.cli.cli import cli_app
def main():
injector = Injector([Configuration()])
CurrentConfiguration.set_injector(injector)
UserDataPaths().safe_create_user_data_dir()
cli_app()
@@ -21,12 +21,10 @@ from rich.console import Console
from typing import List, Optional
import typer
from tui_rsync.core.components.backup_plan.application.repository.backup_plan_repository import BackupPlanRepository
from tui_rsync.core.components.backup_plan.application.services.backup_plan_service import BackupPlanService
from tui_rsync.core.components.backup_plan.domain import BackupPlan, Source, Destination
from tui_rsync.core.shared_kernel.components.common import Label
from tui_rsync.infrastructure.configuration import UserDataPaths
from tui_rsync.infrastructure.orm import SqliteDatabaseManager
from tui_rsync.infrastructure.configuration.current_configuration import CurrentConfiguration
console = Console()
@@ -58,9 +56,7 @@ def add(
if source is None:
source = console.input("What is the [yellow b]path to the source[/]? ")
db = SqliteDatabaseManager(UserDataPaths())
repository = BackupPlanRepository(db)
service = BackupPlanService(repository)
service: BackupPlanService = CurrentConfiguration.get(BackupPlanService)
plan = BackupPlan(label=Label(label), source=Source(source), destinations=[Destination(path) for path in destinations])
service.add(plan)