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

1from datetime import datetime, timezone 

2from typing import Generic, TypeVar 

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 CreateUseCase(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, entity: T) -> T: 

17 now = datetime.now(timezone.utc) 

18 entity = entity.model_copy(update={"created_at": now, "updated_at": now}) 

19 self._logger.info("➕ Creating entity", type=type(entity).__name__, uuid=str(entity.uuid)) 

20 result = await self._repository.create(entity) 

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

22 return result 

23