upd

Author: ProFastCode

app/__init__.py

@@ -22,6 +22,11 @@
 
 app.include_router(api.api_router)
 
+class CustomException(Exception):
+    def __init__(self, message: str, status_code: int = 500):
+        super().__init__(message)
+        self.message = message
+        self.status_code = status_code
 
 @app.exception_handler(exps.CustomException)
 async def exception_handler(request, exc: exps.CustomException):

poetry.lock

@@ -14,6 +14,7 @@ pydantic-settings = "^2.5.2"
 pyjwt = "^2.10.1"
 pytest = "^8.3.4"
 bcrypt = "^4.2.1"
+uvicorn = "^0.34.0"
 
 
 [build-system]

pyproject.toml

@@ -0,0 +1,20 @@
+from fastapi import FastAPI
+from fastapi.responses import JSONResponse
+
+from presentation.api.user_controller import router as user_router
+from domain.base.exception import DomainError
+
+app = FastAPI()
+
+app.include_router(user_router)
+
+@app.exception_handler(Exception)
+async def exception_handler(request, exc: DomainError):
+    return JSONResponse(
+        status_code=exc.status,
+        content={"detail": exc.message},
+    )
+
+if __name__ == "__main__":
+    import uvicorn
+    uvicorn.run(app, host="0.0.0.0", port=8000)

src/__main__.py

@@ -0,0 +1,22 @@
+from typing import Optional
+from uuid import UUID
+
+from domain.user.entities.user import User
+from domain.user.repositories.user import UserRepository
+
+
+class UserService:
+    def __init__(self, user_repository: UserRepository):
+        self.user_repository = user_repository
+
+    def create_user(self, username: str, password: str) -> User:
+        if not (user := self.user_repository.find_by_username(username)):
+            user = User.create(username, password)
+            self.user_repository.save(user)
+        return user
+
+    def get_user_by_username(self, username: str) -> Optional[User]:
+        return self.user_repository.find_by_username(username)
+
+    def get_user_by_id(self, user_id: UUID) -> Optional[User]:
+        return self.user_repository.find_by_id(user_id)

src/application/__init__.py

@@ -1,3 +1,4 @@
+from abc import abstractmethod
 from dataclasses import dataclass
 from typing import ClassVar
 
@@ -15,3 +16,7 @@ class DomainError(AppError):
     @property
     def detail(self) -> str:
         return "A domain error occurred"
+
+    @property
+    @abstractmethod
+    def message(self) -> str: ...

src/application/services/__init__.py

@@ -0,0 +1,32 @@
+from abc import ABC, abstractmethod
+from typing import Optional
+from uuid import UUID
+
+from domain.user.entities.user import User
+
+
+class UserRepository(ABC):
+    """
+    Абстрактный класс репозитория для работы с пользователями.
+    """
+
+    @abstractmethod
+    def save(self, user: User) -> None:
+        """
+        Сохраняет пользователя в репозитории.
+        """
+        pass
+
+    @abstractmethod
+    def find_by_username(self, username: str) -> Optional[User]:
+        """
+        Находит пользователя по имени пользователя.
+        """
+        pass
+
+    @abstractmethod
+    def find_by_id(self, user_id: UUID) -> Optional[User]:
+        """
+        Находит пользователя по идентификатору.
+        """
+        pass