from fastapi import HTTPException
from sqlalchemy.ext.asyncio import AsyncSession

from repositories import ProjectRepository
from schemas.project import (
    GetProjectsResponse,
    ProjectSchema,
    CreateProjectRequest,
    CreateProjectResponse,
    UpdateProjectRequest,
    UpdateProjectResponse,
    DeleteProjectResponse,
)


class ProjectService:
    def __init__(self, session: AsyncSession):
        self.repository = ProjectRepository(session)

    async def get_projects(self) -> GetProjectsResponse:
        projects = await self.repository.get_all()
        return GetProjectsResponse(
            projects=[ProjectSchema.model_validate(project) for project in projects]
        )

    async def create_project(
        self, request: CreateProjectRequest
    ) -> CreateProjectResponse:
        project = await self.repository.create(request.project)
        return CreateProjectResponse(
            project=ProjectSchema.model_validate(project),
            message="Проект успешно создан",
        )

    async def update_project(
        self, project_id: int, request: UpdateProjectRequest
    ) -> UpdateProjectResponse:
        project = await self.repository.get_by_id(project_id)
        if not project:
            raise HTTPException(status_code=404, detail="Проект не найден")

        await self.repository.update(project, request.project)
        return UpdateProjectResponse(message="Проект успешно обновлен")

    async def delete_project(self, project_id: int) -> DeleteProjectResponse:
        project = await self.repository.get_by_id(project_id)
        if not project:
            raise HTTPException(status_code=404, detail="Проект не найден")

        is_soft_needed: bool = len(project.boards) > 0
        await self.repository.delete(project, is_soft_needed)
        return DeleteProjectResponse(message="Проект успешно удален")