import os
import httpx

from typing import Dict

from ..auth import auth_headers

async def save_subcategory_redirects(mapping: Dict[str, str]) -> None:
    sync_url = os.getenv("SAVE_REDIRECTS", "http://localhost:8000/market/api/products/redirects/")

    async with httpx.AsyncClient(timeout=httpx.Timeout(20.0, connect=10.0)) as client:
        resp = await client.post(sync_url, json=mapping, headers=auth_headers())
    # Raise for non-2xx
    resp.raise_for_status()
    data = resp.json() if resp.content else {}
    return data
    