from http import HTTPStatus from typing import Any, Dict, List, Optional, Union, cast import httpx from ... import errors from ...client import AuthenticatedClient, Client from ...models.http_validation_error import HTTPValidationError from ...types import UNSET, Response, Unset def _get_kwargs( *, client: Client, campaign_ids: Union[Unset, None, List[str]] = UNSET, vendor_ids: Union[Unset, None, List[int]] = UNSET, subaccount_ids: Union[Unset, None, List[int]] = UNSET, global_participant_ids: Union[Unset, None, List[str]] = UNSET, identity_ids: Union[Unset, None, List[str]] = UNSET, ) -> Dict[str, Any]: url = "{}/_test/meta/campaigns".format(client.base_url) headers: Dict[str, str] = client.get_headers() cookies: Dict[str, Any] = client.get_cookies() params: Dict[str, Any] = {} json_campaign_ids: Union[Unset, None, List[str]] = UNSET if not isinstance(campaign_ids, Unset): if campaign_ids is None: json_campaign_ids = None else: json_campaign_ids = campaign_ids params["campaignIds"] = json_campaign_ids json_vendor_ids: Union[Unset, None, List[int]] = UNSET if not isinstance(vendor_ids, Unset): if vendor_ids is None: json_vendor_ids = None else: json_vendor_ids = vendor_ids params["vendorIds"] = json_vendor_ids json_subaccount_ids: Union[Unset, None, List[int]] = UNSET if not isinstance(subaccount_ids, Unset): if subaccount_ids is None: json_subaccount_ids = None else: json_subaccount_ids = subaccount_ids params["subaccountIds"] = json_subaccount_ids json_global_participant_ids: Union[Unset, None, List[str]] = UNSET if not isinstance(global_participant_ids, Unset): if global_participant_ids is None: json_global_participant_ids = None else: json_global_participant_ids = global_participant_ids params["globalParticipantIds"] = json_global_participant_ids json_identity_ids: Union[Unset, None, List[str]] = UNSET if not isinstance(identity_ids, Unset): if identity_ids is None: json_identity_ids = None else: json_identity_ids = identity_ids params["identityIds"] = json_identity_ids params = {k: v for k, v in params.items() if v is not UNSET and v is not None} return { "method": "delete", "url": url, "headers": headers, "cookies": cookies, "timeout": client.get_timeout(), "follow_redirects": client.follow_redirects, "params": params, } def _parse_response( *, client: Client, response: httpx.Response ) -> Optional[Union[Any, HTTPValidationError]]: if response.status_code == HTTPStatus.NO_CONTENT: response_204 = cast(Any, None) return response_204 if response.status_code == HTTPStatus.UNPROCESSABLE_ENTITY: response_422 = HTTPValidationError.from_dict(response.json()) return response_422 if client.raise_on_unexpected_status: raise errors.UnexpectedStatus(response.status_code, response.content) else: return None def _build_response( *, client: Client, response: httpx.Response ) -> Response[Union[Any, HTTPValidationError]]: return Response( status_code=HTTPStatus(response.status_code), content=response.content, headers=response.headers, parsed=_parse_response(client=client, response=response), ) def sync_detailed( *, client: Client, campaign_ids: Union[Unset, None, List[str]] = UNSET, vendor_ids: Union[Unset, None, List[int]] = UNSET, subaccount_ids: Union[Unset, None, List[int]] = UNSET, global_participant_ids: Union[Unset, None, List[str]] = UNSET, identity_ids: Union[Unset, None, List[str]] = UNSET, ) -> Response[Union[Any, HTTPValidationError]]: """Delete Meta Campaigns Args: campaign_ids (Union[Unset, None, List[str]]): vendor_ids (Union[Unset, None, List[int]]): subaccount_ids (Union[Unset, None, List[int]]): global_participant_ids (Union[Unset, None, List[str]]): identity_ids (Union[Unset, None, List[str]]): Raises: errors.UnexpectedStatus: If the server returns an undocumented status code and Client.raise_on_unexpected_status is True. httpx.TimeoutException: If the request takes longer than Client.timeout. Returns: Response[Union[Any, HTTPValidationError]] """ kwargs = _get_kwargs( client=client, campaign_ids=campaign_ids, vendor_ids=vendor_ids, subaccount_ids=subaccount_ids, global_participant_ids=global_participant_ids, identity_ids=identity_ids, ) response = httpx.request( verify=client.verify_ssl, **kwargs, ) return _build_response(client=client, response=response) def sync( *, client: Client, campaign_ids: Union[Unset, None, List[str]] = UNSET, vendor_ids: Union[Unset, None, List[int]] = UNSET, subaccount_ids: Union[Unset, None, List[int]] = UNSET, global_participant_ids: Union[Unset, None, List[str]] = UNSET, identity_ids: Union[Unset, None, List[str]] = UNSET, ) -> Optional[Union[Any, HTTPValidationError]]: """Delete Meta Campaigns Args: campaign_ids (Union[Unset, None, List[str]]): vendor_ids (Union[Unset, None, List[int]]): subaccount_ids (Union[Unset, None, List[int]]): global_participant_ids (Union[Unset, None, List[str]]): identity_ids (Union[Unset, None, List[str]]): Raises: errors.UnexpectedStatus: If the server returns an undocumented status code and Client.raise_on_unexpected_status is True. httpx.TimeoutException: If the request takes longer than Client.timeout. Returns: Union[Any, HTTPValidationError] """ return sync_detailed( client=client, campaign_ids=campaign_ids, vendor_ids=vendor_ids, subaccount_ids=subaccount_ids, global_participant_ids=global_participant_ids, identity_ids=identity_ids, ).parsed async def asyncio_detailed( *, client: Client, campaign_ids: Union[Unset, None, List[str]] = UNSET, vendor_ids: Union[Unset, None, List[int]] = UNSET, subaccount_ids: Union[Unset, None, List[int]] = UNSET, global_participant_ids: Union[Unset, None, List[str]] = UNSET, identity_ids: Union[Unset, None, List[str]] = UNSET, ) -> Response[Union[Any, HTTPValidationError]]: """Delete Meta Campaigns Args: campaign_ids (Union[Unset, None, List[str]]): vendor_ids (Union[Unset, None, List[int]]): subaccount_ids (Union[Unset, None, List[int]]): global_participant_ids (Union[Unset, None, List[str]]): identity_ids (Union[Unset, None, List[str]]): Raises: errors.UnexpectedStatus: If the server returns an undocumented status code and Client.raise_on_unexpected_status is True. httpx.TimeoutException: If the request takes longer than Client.timeout. Returns: Response[Union[Any, HTTPValidationError]] """ kwargs = _get_kwargs( client=client, campaign_ids=campaign_ids, vendor_ids=vendor_ids, subaccount_ids=subaccount_ids, global_participant_ids=global_participant_ids, identity_ids=identity_ids, ) async with httpx.AsyncClient(verify=client.verify_ssl) as _client: response = await _client.request(**kwargs) return _build_response(client=client, response=response) async def asyncio( *, client: Client, campaign_ids: Union[Unset, None, List[str]] = UNSET, vendor_ids: Union[Unset, None, List[int]] = UNSET, subaccount_ids: Union[Unset, None, List[int]] = UNSET, global_participant_ids: Union[Unset, None, List[str]] = UNSET, identity_ids: Union[Unset, None, List[str]] = UNSET, ) -> Optional[Union[Any, HTTPValidationError]]: """Delete Meta Campaigns Args: campaign_ids (Union[Unset, None, List[str]]): vendor_ids (Union[Unset, None, List[int]]): subaccount_ids (Union[Unset, None, List[int]]): global_participant_ids (Union[Unset, None, List[str]]): identity_ids (Union[Unset, None, List[str]]): Raises: errors.UnexpectedStatus: If the server returns an undocumented status code and Client.raise_on_unexpected_status is True. httpx.TimeoutException: If the request takes longer than Client.timeout. Returns: Union[Any, HTTPValidationError] """ return ( await asyncio_detailed( client=client, campaign_ids=campaign_ids, vendor_ids=vendor_ids, subaccount_ids=subaccount_ids, global_participant_ids=global_participant_ids, identity_ids=identity_ids, ) ).parsed