from sqlalchemy import text

from delivery_metadata.api.app import app
from delivery_metadata.models import Model


class ArtRelationsProductProvidedStoreArtists(Model):
    spotify: str | None


async def get_product_provided_store_artists(
    release_id: int,
) -> ArtRelationsProductProvidedStoreArtists:
    async with app.state.art_relations_connector.db_session() as session:
        result = await session.execute(
            text(
                """
                SELECT ppsa.spotify
                FROM product_provided_store_artists ppsa
                WHERE ppsa.release_id = :release_id
                """
            ),
            {
                "release_id": release_id,
            },
        )
        row = result.first()
    return ArtRelationsProductProvidedStoreArtists(spotify=row.spotify if row else None)