"""Integration tests for POST /infra/connectivity/ows-account/."""

import requests

from tests.integration import config


async def test_connectivity_ows_account(
    bearer_token_pdptest_user: str,
) -> None:
    """Test endpoint for connectivity of ows-account."""
    url = f"{config.QA_BASE_URL}/infra/connectivity/ows-account/"
    headers = {"Authorization": f"Bearer {bearer_token_pdptest_user}"}
    body = {
        "uuids": [
            "902b8778-e09a-11ee-a7c1-12b0989b795f",
        ],
        "fetch_flags": ["TENANT_HIERARCHY"],
    }

    response = requests.post(url, json=body, headers=headers)
    assert response.status_code == 200, f"Response: {response.text}"
    assert response.json() == {
        "vendors": [
            {
                "parent_company_uuid": "955a1bbd-b623-4ea1-ab5f-8d6620c442fb",
                "company_brand_uuid": "7c8b382c-fc37-4179-9115-2165b1a93bed",
                "uuid": "902b8778-e09a-11ee-a7c1-12b0989b795f",
                "vendor_id": 778603,
            }
        ]
    }