"""SQL-backed MarketService implementation.

Queries ``shared.models.market.*`` and ``shared.models.market_place.*`` —
only this module may read market-domain tables on behalf of other domains.
"""
from __future__ import annotations

from sqlalchemy import select
from sqlalchemy.ext.asyncio import AsyncSession

from shared.models.market import Product
from shared.models.market_place import MarketPlace
from shared.contracts.dtos import MarketPlaceDTO, ProductDTO


def _mp_to_dto(mp: MarketPlace) -> MarketPlaceDTO:
    return MarketPlaceDTO(
        id=mp.id,
        container_type=mp.container_type,
        container_id=mp.container_id,
        name=mp.name,
        slug=mp.slug,
        description=mp.description,
    )


def _product_to_dto(p: Product) -> ProductDTO:
    return ProductDTO(
        id=p.id,
        slug=p.slug,
        title=p.title,
        image=p.image,
        description_short=p.description_short,
        rrp=p.rrp,
        regular_price=p.regular_price,
        special_price=p.special_price,
    )


class SqlMarketService:
    async def marketplaces_for_container(
        self, session: AsyncSession, container_type: str, container_id: int,
    ) -> list[MarketPlaceDTO]:
        result = await session.execute(
            select(MarketPlace).where(
                MarketPlace.container_type == container_type,
                MarketPlace.container_id == container_id,
                MarketPlace.deleted_at.is_(None),
            ).order_by(MarketPlace.name.asc())
        )
        return [_mp_to_dto(mp) for mp in result.scalars().all()]

    async def product_by_id(self, session: AsyncSession, product_id: int) -> ProductDTO | None:
        product = (
            await session.execute(select(Product).where(Product.id == product_id))
        ).scalar_one_or_none()
        return _product_to_dto(product) if product else None