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.board)
        return CreateBoardResponse(
            board=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.board)
        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="Доска успешно удалена")