from sqlalchemy import select

from models import Deal
from repositories.base import BaseRepository


class DealRepository(BaseRepository):
    async def get_all(self, board_id: int) -> list[Deal]:
        stmt = select(Deal).where(Deal.is_deleted.is_(False), Deal.board_id == board_id)
        result = await self.session.execute(stmt)
        return list(result.scalars().all())