from delivery_metadata.api.app import app
from delivery_metadata.models.schemas import TerritoryCodeA2


async def get_product_territory_rights(
    upc: int, store_id: int
) -> list[TerritoryCodeA2]:
    response = await app.state.ows_connector.get(
        service_name="ows-carveouts", path=f"/carveout/projection/{upc}/dms/{store_id}"
    )

    response.raise_for_status()
    return [TerritoryCodeA2(country_code=x) for x in response.json()["territories"]]