51 lines
1.8 KiB
Python
51 lines
1.8 KiB
Python
from fastapi import HTTPException
|
|
from sqlalchemy.ext.asyncio import AsyncSession
|
|
|
|
from repositories import BoardRepository
|
|
from schemas.board import (
|
|
GetBoardsResponse,
|
|
BoardSchema,
|
|
UpdateBoardRequest,
|
|
UpdateBoardResponse,
|
|
CreateBoardRequest,
|
|
CreateBoardResponse,
|
|
DeleteBoardResponse,
|
|
)
|
|
|
|
|
|
class BoardService:
|
|
def __init__(self, session: AsyncSession):
|
|
self.repository = BoardRepository(session)
|
|
|
|
async def get_boards(self, project_id: int) -> GetBoardsResponse:
|
|
boards = await self.repository.get_all(project_id)
|
|
return GetBoardsResponse(
|
|
boards=[BoardSchema.model_validate(board) for board in boards]
|
|
)
|
|
|
|
async def create_board(self, request: CreateBoardRequest) -> CreateBoardResponse:
|
|
board = await self.repository.create(request.entity)
|
|
return CreateBoardResponse(
|
|
entity=BoardSchema.model_validate(board),
|
|
message="Доска успешно создана",
|
|
)
|
|
|
|
async def update_board(
|
|
self, board_id: int, request: UpdateBoardRequest
|
|
) -> UpdateBoardResponse:
|
|
board = await self.repository.get_by_id(board_id)
|
|
if not board:
|
|
raise HTTPException(status_code=404, detail="Доска не найдена")
|
|
|
|
await self.repository.update(board, request.entity)
|
|
return UpdateBoardResponse(message="Доска успешно обновлена")
|
|
|
|
async def delete_board(self, board_id: int) -> DeleteBoardResponse:
|
|
board = await self.repository.get_by_id(board_id)
|
|
if not board:
|
|
raise HTTPException(status_code=404, detail="Доска не найдена")
|
|
|
|
is_soft_needed: bool = len(board.deals) > 0
|
|
await self.repository.delete(board, is_soft_needed)
|
|
return DeleteBoardResponse(message="Доска успешно удалена")
|