Coverage for arclith / application / use_cases / read.py: 100%

1from typing import Generic, Optional, TypeVar 

2from uuid6 import UUID 

3 

4from arclith.domain.models.entity import Entity 

5from arclith.domain.ports.logger import Logger 

6from arclith.domain.ports.repository import Repository 

7 

8T = TypeVar("T", bound=Entity) 

9 

10 

11class ReadUseCase(Generic[T]): 

12 def __init__(self, repository: Repository[T], logger: Logger) -> None: 

13 self._repository = repository 

14 self._logger = logger 

15 

16 async def execute(self, uuid: UUID) -> Optional[T]: 

17 self._logger.info("🔍 Reading entity", uuid=str(uuid)) 

18 result = await self._repository.read(uuid) 

19 if result is None or result.is_deleted: 

20 self._logger.warning("⚠️ Entity not found", uuid=str(uuid)) 

21 return None 

22 self._logger.info("✅ Entity found", type=type(result).__name__, uuid=str(uuid)) 

23 return result 

24