kgess-mirror/cloudflare-python
1
0
Fork 0
mirror of https://github.com/cloudflare/cloudflare-python.git synced 2026-01-16 23:01:03 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 2

feat: OpenAPI spec update via Stainless API (#81)

Browse source
This commit is contained in:
stainless-app[bot] 2024-03-04 15:09:43 +00:00
parent 5f69b969c2
commit 3eafc8724b
377 changed files with 2542 additions and 1081 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
src/cloudflare/_files.py
View file

@ -13,12 +13,17 @@ from ._types import (
FileContent,
RequestFiles,
HttpxFileTypes,
Base64FileInput,
HttpxFileContent,
HttpxRequestFiles,
)
from ._utils import is_tuple_t, is_mapping_t, is_sequence_t
def is_base64_file_input(obj: object) -> TypeGuard[Base64FileInput]:
return isinstance(obj, io.IOBase) or isinstance(obj, os.PathLike)
def is_file_content(obj: object) -> TypeGuard[FileContent]:
return (
isinstance(obj, bytes) or isinstance(obj, tuple) or isinstance(obj, io.IOBase) or isinstance(obj, os.PathLike)

2
src/cloudflare/_types.py
View file

@ -40,8 +40,10 @@ _T = TypeVar("_T")
ProxiesDict = Dict["str | URL", Union[None, str, URL, Proxy]]
ProxiesTypes = Union[str, Proxy, ProxiesDict]
if TYPE_CHECKING:
Base64FileInput = Union[IO[bytes], PathLike[str]]
FileContent = Union[IO[bytes], bytes, PathLike[str]]
else:
Base64FileInput = Union[IO[bytes], PathLike]
FileContent = Union[IO[bytes], bytes, PathLike] # PathLike is not subscriptable in Python 3.8.
FileTypes = Union[
# file (or bytes)

2
src/cloudflare/_utils/__init__.py
View file

@ -44,5 +44,7 @@ from ._streams import consume_sync_iterator as consume_sync_iterator, consume_as
from ._transform import (
PropertyInfo as PropertyInfo,
transform as transform,
async_transform as async_transform,
maybe_transform as maybe_transform,
async_maybe_transform as async_maybe_transform,
)

167
src/cloudflare/_utils/_transform.py
View file

@ -1,9 +1,13 @@
from __future__ import annotations
import io
import base64
import pathlib
from typing import Any, Mapping, TypeVar, cast
from datetime import date, datetime
from typing_extensions import Literal, get_args, override, get_type_hints
import anyio
import pydantic
from ._utils import (
@ -11,6 +15,7 @@ from ._utils import (
is_mapping,
is_iterable,
)
from .._files import is_base64_file_input
from ._typing import (
is_list_type,
is_union_type,
@ -29,7 +34,7 @@ _T = TypeVar("_T")
# TODO: ensure works correctly with forward references in all cases
PropertyFormat = Literal["iso8601", "custom"]
PropertyFormat = Literal["iso8601", "base64", "custom"]
class PropertyInfo:
@ -180,11 +185,7 @@ def _transform_recursive(
if isinstance(data, pydantic.BaseModel):
return model_dump(data, exclude_unset=True)
return _transform_value(data, annotation)
def _transform_value(data: object, type_: type) -> object:
annotated_type = _get_annotated_type(type_)
annotated_type = _get_annotated_type(annotation)
if annotated_type is None:
return data
@ -205,6 +206,22 @@ def _format_data(data: object, format_: PropertyFormat, format_template: str | N
if format_ == "custom" and format_template is not None:
return data.strftime(format_template)
if format_ == "base64" and is_base64_file_input(data):
binary: str | bytes | None = None
if isinstance(data, pathlib.Path):
binary = data.read_bytes()
elif isinstance(data, io.IOBase):
binary = data.read()
if isinstance(binary, str): # type: ignore[unreachable]
binary = binary.encode()
if not isinstance(binary, bytes):
raise RuntimeError(f"Could not read bytes from {data}; Received {type(binary)}")
return base64.b64encode(binary).decode("ascii")
return data
@ -222,3 +239,141 @@ def _transform_typeddict(
else:
result[_maybe_transform_key(key, type_)] = _transform_recursive(value, annotation=type_)
return result
async def async_maybe_transform(
data: object,
expected_type: object,
) -> Any | None:
"""Wrapper over `async_transform()` that allows `None` to be passed.
See `async_transform()` for more details.
"""
if data is None:
return None
return await async_transform(data, expected_type)
async def async_transform(
data: _T,
expected_type: object,
) -> _T:
"""Transform dictionaries based off of type information from the given type, for example:
```py
class Params(TypedDict, total=False):
card_id: Required[Annotated[str, PropertyInfo(alias="cardID")]]
transformed = transform({"card_id": "<my card ID>"}, Params)
# {'cardID': '<my card ID>'}
```
Any keys / data that does not have type information given will be included as is.
It should be noted that the transformations that this function does are not represented in the type system.
"""
transformed = await _async_transform_recursive(data, annotation=cast(type, expected_type))
return cast(_T, transformed)
async def _async_transform_recursive(
data: object,
*,
annotation: type,
inner_type: type | None = None,
) -> object:
"""Transform the given data against the expected type.
Args:
annotation: The direct type annotation given to the particular piece of data.
This may or may not be wrapped in metadata types, e.g. `Required[T]`, `Annotated[T, ...]` etc
inner_type: If applicable, this is the "inside" type. This is useful in certain cases where the outside type
is a container type such as `List[T]`. In that case `inner_type` should be set to `T` so that each entry in
the list can be transformed using the metadata from the container type.
Defaults to the same value as the `annotation` argument.
"""
if inner_type is None:
inner_type = annotation
stripped_type = strip_annotated_type(inner_type)
if is_typeddict(stripped_type) and is_mapping(data):
return await _async_transform_typeddict(data, stripped_type)
if (
# List[T]
(is_list_type(stripped_type) and is_list(data))
# Iterable[T]
or (is_iterable_type(stripped_type) and is_iterable(data) and not isinstance(data, str))
):
inner_type = extract_type_arg(stripped_type, 0)
return [await _async_transform_recursive(d, annotation=annotation, inner_type=inner_type) for d in data]
if is_union_type(stripped_type):
# For union types we run the transformation against all subtypes to ensure that everything is transformed.
#
# TODO: there may be edge cases where the same normalized field name will transform to two different names
# in different subtypes.
for subtype in get_args(stripped_type):
data = await _async_transform_recursive(data, annotation=annotation, inner_type=subtype)
return data
if isinstance(data, pydantic.BaseModel):
return model_dump(data, exclude_unset=True)
annotated_type = _get_annotated_type(annotation)
if annotated_type is None:
return data
# ignore the first argument as it is the actual type
annotations = get_args(annotated_type)[1:]
for annotation in annotations:
if isinstance(annotation, PropertyInfo) and annotation.format is not None:
return await _async_format_data(data, annotation.format, annotation.format_template)
return data
async def _async_format_data(data: object, format_: PropertyFormat, format_template: str | None) -> object:
if isinstance(data, (date, datetime)):
if format_ == "iso8601":
return data.isoformat()
if format_ == "custom" and format_template is not None:
return data.strftime(format_template)
if format_ == "base64" and is_base64_file_input(data):
binary: str | bytes | None = None
if isinstance(data, pathlib.Path):
binary = await anyio.Path(data).read_bytes()
elif isinstance(data, io.IOBase):
binary = data.read()
if isinstance(binary, str): # type: ignore[unreachable]
binary = binary.encode()
if not isinstance(binary, bytes):
raise RuntimeError(f"Could not read bytes from {data}; Received {type(binary)}")
return base64.b64encode(binary).decode("ascii")
return data
async def _async_transform_typeddict(
data: Mapping[str, object],
expected_type: type,
) -> Mapping[str, object]:
result: dict[str, object] = {}
annotations = get_type_hints(expected_type, include_extras=True)
for key, value in data.items():
type_ = annotations.get(key)
if type_ is None:
# we do not have a type annotation for this field, leave it as is
result[key] = value
else:
result[_maybe_transform_key(key, type_)] = await _async_transform_recursive(value, annotation=type_)
return result

7
src/cloudflare/resources/accounts/accounts.py
View file

@ -30,7 +30,10 @@ from .members import (
AsyncMembersWithStreamingResponse,
)
from ..._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ..._utils import maybe_transform
from ..._utils import (
maybe_transform,
async_maybe_transform,
)
from ..._compat import cached_property
from ..._resource import SyncAPIResource, AsyncAPIResource
from ..._response import (
@ -261,7 +264,7 @@ class AsyncAccounts(AsyncAPIResource):
AccountUpdateResponse,
await self._put(
f"/accounts/{account_id}",
body=maybe_transform(
body=await async_maybe_transform(
{
"name": name,
"settings": settings,

9
src/cloudflare/resources/accounts/members.py
View file

@ -8,7 +8,10 @@ from typing_extensions import Literal
import httpx
from ..._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ..._utils import maybe_transform
from ..._utils import (
maybe_transform,
async_maybe_transform,
)
from ..._compat import cached_property
from ..._resource import SyncAPIResource, AsyncAPIResource
from ..._response import (
@ -322,7 +325,7 @@ class AsyncMembers(AsyncAPIResource):
"""
return await self._post(
f"/accounts/{account_id}/members",
body=maybe_transform(
body=await async_maybe_transform(
{
"email": email,
"roles": roles,
@ -373,7 +376,7 @@ class AsyncMembers(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `member_id` but received {member_id!r}")
return await self._put(
f"/accounts/{account_id}/members/{member_id}",
body=maybe_transform({"roles": roles}, member_update_params.MemberUpdateParams),
body=await async_maybe_transform({"roles": roles}, member_update_params.MemberUpdateParams),
options=make_request_options(
extra_headers=extra_headers,
extra_query=extra_query,

7
src/cloudflare/resources/acm/total_tls.py
View file

@ -8,7 +8,10 @@ from typing_extensions import Literal
import httpx
from ..._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ..._utils import maybe_transform
from ..._utils import (
maybe_transform,
async_maybe_transform,
)
from ..._compat import cached_property
from ..._resource import SyncAPIResource, AsyncAPIResource
from ..._response import (
@ -173,7 +176,7 @@ class AsyncTotalTLS(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `zone_id` but received {zone_id!r}")
return await self._post(
f"/zones/{zone_id}/acm/total_tls",
body=maybe_transform(
body=await async_maybe_transform(
{
"enabled": enabled,
"certificate_authority": certificate_authority,

9
src/cloudflare/resources/addressing/address_maps/address_maps.py
View file

@ -31,7 +31,10 @@ from .accounts import (
AsyncAccountsWithStreamingResponse,
)
from ...._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ...._utils import maybe_transform
from ...._utils import (
maybe_transform,
async_maybe_transform,
)
from ...._compat import cached_property
from ...._resource import SyncAPIResource, AsyncAPIResource
from ...._response import (
@ -392,7 +395,7 @@ class AsyncAddressMaps(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `account_id` but received {account_id!r}")
return await self._post(
f"/accounts/{account_id}/addressing/address_maps",
body=maybe_transform(
body=await async_maybe_transform(
{
"description": description,
"enabled": enabled,
@ -548,7 +551,7 @@ class AsyncAddressMaps(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `address_map_id` but received {address_map_id!r}")
return await self._patch(
f"/accounts/{account_id}/addressing/address_maps/{address_map_id}",
body=maybe_transform(
body=await async_maybe_transform(
{
"default_sni": default_sni,
"description": description,

9
src/cloudflare/resources/addressing/loa_documents/loa_documents.py
View file

@ -7,7 +7,10 @@ from typing import Type, cast
import httpx
from ...._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ...._utils import maybe_transform
from ...._utils import (
maybe_transform,
async_maybe_transform,
)
from .downloads import (
Downloads,
AsyncDownloads,
@ -135,7 +138,9 @@ class AsyncLOADocuments(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `account_id` but received {account_id!r}")
return await self._post(
f"/accounts/{account_id}/addressing/loa_documents",
body=maybe_transform({"loa_document": loa_document}, loa_document_create_params.LOADocumentCreateParams),
body=await async_maybe_transform(
{"loa_document": loa_document}, loa_document_create_params.LOADocumentCreateParams
),
options=make_request_options(
extra_headers=extra_headers,
extra_query=extra_query,

7
src/cloudflare/resources/addressing/prefixes/bgp/bindings.py
View file

@ -7,7 +7,10 @@ from typing import Any, Type, cast
import httpx
from ....._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ....._utils import maybe_transform
from ....._utils import (
maybe_transform,
async_maybe_transform,
)
from ....._compat import cached_property
from ....._resource import SyncAPIResource, AsyncAPIResource
from ....._response import (
@ -306,7 +309,7 @@ class AsyncBindings(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `prefix_id` but received {prefix_id!r}")
return await self._post(
f"/accounts/{account_id}/addressing/prefixes/{prefix_id}/bindings",
body=maybe_transform(
body=await async_maybe_transform(
{
"cidr": cidr,
"service_id": service_id,

7
src/cloudflare/resources/addressing/prefixes/bgp/prefixes.py
View file

@ -7,7 +7,10 @@ from typing import Type, Optional, cast
import httpx
from ....._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ....._utils import maybe_transform
from ....._utils import (
maybe_transform,
async_maybe_transform,
)
from ....._compat import cached_property
from ....._resource import SyncAPIResource, AsyncAPIResource
from ....._response import (
@ -287,7 +290,7 @@ class AsyncPrefixes(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `bgp_prefix_id` but received {bgp_prefix_id!r}")
return await self._patch(
f"/accounts/{account_id}/addressing/prefixes/{prefix_id}/bgp/prefixes/{bgp_prefix_id}",
body=maybe_transform({"on_demand": on_demand}, prefix_edit_params.PrefixEditParams),
body=await async_maybe_transform({"on_demand": on_demand}, prefix_edit_params.PrefixEditParams),
options=make_request_options(
extra_headers=extra_headers,
extra_query=extra_query,

7
src/cloudflare/resources/addressing/prefixes/bgp/statuses.py
View file

@ -7,7 +7,10 @@ from typing import Type, cast
import httpx
from ....._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ....._utils import maybe_transform
from ....._utils import (
maybe_transform,
async_maybe_transform,
)
from ....._compat import cached_property
from ....._resource import SyncAPIResource, AsyncAPIResource
from ....._response import (
@ -173,7 +176,7 @@ class AsyncStatuses(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `prefix_id` but received {prefix_id!r}")
return await self._patch(
f"/accounts/{account_id}/addressing/prefixes/{prefix_id}/bgp/status",
body=maybe_transform({"advertised": advertised}, status_edit_params.StatusEditParams),
body=await async_maybe_transform({"advertised": advertised}, status_edit_params.StatusEditParams),
options=make_request_options(
extra_headers=extra_headers,
extra_query=extra_query,

7
src/cloudflare/resources/addressing/prefixes/delegations.py
View file

@ -7,7 +7,10 @@ from typing import Type, Optional, cast
import httpx
from ...._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ...._utils import maybe_transform
from ...._utils import (
maybe_transform,
async_maybe_transform,
)
from ...._compat import cached_property
from ...._resource import SyncAPIResource, AsyncAPIResource
from ...._response import (
@ -239,7 +242,7 @@ class AsyncDelegations(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `prefix_id` but received {prefix_id!r}")
return await self._post(
f"/accounts/{account_id}/addressing/prefixes/{prefix_id}/delegations",
body=maybe_transform(
body=await async_maybe_transform(
{
"cidr": cidr,
"delegated_account_id": delegated_account_id,

9
src/cloudflare/resources/addressing/prefixes/prefixes.py
View file

@ -16,7 +16,10 @@ from .bgp import (
)
from .bgp.bgp import BGP, AsyncBGP
from ...._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ...._utils import maybe_transform
from ...._utils import (
maybe_transform,
async_maybe_transform,
)
from ...._compat import cached_property
from .delegations import (
Delegations,
@ -359,7 +362,7 @@ class AsyncPrefixes(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `account_id` but received {account_id!r}")
return await self._post(
f"/accounts/{account_id}/addressing/prefixes",
body=maybe_transform(
body=await async_maybe_transform(
{
"asn": asn,
"cidr": cidr,
@ -502,7 +505,7 @@ class AsyncPrefixes(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `prefix_id` but received {prefix_id!r}")
return await self._patch(
f"/accounts/{account_id}/addressing/prefixes/{prefix_id}",
body=maybe_transform({"description": description}, prefix_edit_params.PrefixEditParams),
body=await async_maybe_transform({"description": description}, prefix_edit_params.PrefixEditParams),
options=make_request_options(
extra_headers=extra_headers,
extra_query=extra_query,

9
src/cloudflare/resources/alerting/v3/destinations/webhooks.py
View file

@ -7,7 +7,10 @@ from typing import Any, Type, Optional, cast
import httpx
from ....._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ....._utils import maybe_transform
from ....._utils import (
maybe_transform,
async_maybe_transform,
)
from ....._compat import cached_property
from ....._resource import SyncAPIResource, AsyncAPIResource
from ....._response import (
@ -348,7 +351,7 @@ class AsyncWebhooks(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `account_id` but received {account_id!r}")
return await self._post(
f"/accounts/{account_id}/alerting/v3/destinations/webhooks",
body=maybe_transform(
body=await async_maybe_transform(
{
"name": name,
"url": url,
@ -412,7 +415,7 @@ class AsyncWebhooks(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `webhook_id` but received {webhook_id!r}")
return await self._put(
f"/accounts/{account_id}/alerting/v3/destinations/webhooks/{webhook_id}",
body=maybe_transform(
body=await async_maybe_transform(
{
"name": name,
"url": url,

9
src/cloudflare/resources/alerting/v3/policies.py
View file

@ -8,7 +8,10 @@ from typing_extensions import Literal
import httpx
from ...._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ...._utils import maybe_transform
from ...._utils import (
maybe_transform,
async_maybe_transform,
)
from ...._compat import cached_property
from ...._resource import SyncAPIResource, AsyncAPIResource
from ...._response import (
@ -554,7 +557,7 @@ class AsyncPolicies(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `account_id` but received {account_id!r}")
return await self._post(
f"/accounts/{account_id}/alerting/v3/policies",
body=maybe_transform(
body=await async_maybe_transform(
{
"alert_type": alert_type,
"enabled": enabled,
@ -688,7 +691,7 @@ class AsyncPolicies(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `policy_id` but received {policy_id!r}")
return await self._put(
f"/accounts/{account_id}/alerting/v3/policies/{policy_id}",
body=maybe_transform(
body=await async_maybe_transform(
{
"alert_type": alert_type,
"description": description,

7
src/cloudflare/resources/argo/smart_routing.py
View file

@ -8,7 +8,10 @@ from typing_extensions import Literal
import httpx
from ..._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ..._utils import maybe_transform
from ..._utils import (
maybe_transform,
async_maybe_transform,
)
from ..._compat import cached_property
from ..._resource import SyncAPIResource, AsyncAPIResource
from ..._response import (
@ -171,7 +174,7 @@ class AsyncSmartRouting(AsyncAPIResource):
SmartRoutingEditResponse,
await self._patch(
f"/zones/{zone_id}/argo/smart_routing",
body=maybe_transform({"value": value}, smart_routing_edit_params.SmartRoutingEditParams),
body=await async_maybe_transform({"value": value}, smart_routing_edit_params.SmartRoutingEditParams),
options=make_request_options(
extra_headers=extra_headers,
extra_query=extra_query,

7
src/cloudflare/resources/argo/tiered_caching.py
View file

@ -8,7 +8,10 @@ from typing_extensions import Literal
import httpx
from ..._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ..._utils import maybe_transform
from ..._utils import (
maybe_transform,
async_maybe_transform,
)
from ..._compat import cached_property
from ..._resource import SyncAPIResource, AsyncAPIResource
from ..._response import (
@ -171,7 +174,7 @@ class AsyncTieredCaching(AsyncAPIResource):
TieredCachingEditResponse,
await self._patch(
f"/zones/{zone_id}/argo/tiered_caching",
body=maybe_transform({"value": value}, tiered_caching_edit_params.TieredCachingEditParams),
body=await async_maybe_transform({"value": value}, tiered_caching_edit_params.TieredCachingEditParams),
options=make_request_options(
extra_headers=extra_headers,
extra_query=extra_query,

7
src/cloudflare/resources/bot_management.py
View file

@ -9,7 +9,10 @@ import httpx
from ..types import BotManagementGetResponse, BotManagementUpdateResponse, bot_management_update_params
from .._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from .._utils import maybe_transform
from .._utils import (
maybe_transform,
async_maybe_transform,
)
from .._compat import cached_property
from .._resource import SyncAPIResource, AsyncAPIResource
from .._response import (
@ -262,7 +265,7 @@ class AsyncBotManagement(AsyncAPIResource):
BotManagementUpdateResponse,
await self._put(
f"/zones/{zone_id}/bot_management",
body=maybe_transform(
body=await async_maybe_transform(
{
"auto_update_model": auto_update_model,
"enable_js": enable_js,

9
src/cloudflare/resources/brand_protection.py
View file

@ -13,7 +13,10 @@ from ..types import (
brand_protection_url_info_params,
)
from .._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from .._utils import maybe_transform
from .._utils import (
maybe_transform,
async_maybe_transform,
)
from .._compat import cached_property
from .._resource import SyncAPIResource, AsyncAPIResource
from .._response import (
@ -172,7 +175,7 @@ class AsyncBrandProtection(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `account_id` but received {account_id!r}")
return await self._post(
f"/accounts/{account_id}/brand-protection/submit",
body=maybe_transform({"url": url}, brand_protection_submit_params.BrandProtectionSubmitParams),
body=await async_maybe_transform({"url": url}, brand_protection_submit_params.BrandProtectionSubmitParams),
options=make_request_options(
extra_headers=extra_headers,
extra_query=extra_query,
@ -219,7 +222,7 @@ class AsyncBrandProtection(AsyncAPIResource):
extra_query=extra_query,
extra_body=extra_body,
timeout=timeout,
query=maybe_transform(
query=await async_maybe_transform(
{
"url": url,
"url_id_param": url_id_param,

7
src/cloudflare/resources/cache/cache.py vendored
View file

@ -8,7 +8,10 @@ import httpx
from ...types import CachePurgeResponse, cache_purge_params
from ..._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ..._utils import maybe_transform
from ..._utils import (
maybe_transform,
async_maybe_transform,
)
from .variants import (
Variants,
AsyncVariants,
@ -248,7 +251,7 @@ class AsyncCache(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `zone_id` but received {zone_id!r}")
return await self._post(
f"/zones/{zone_id}/purge_cache",
body=maybe_transform(
body=await async_maybe_transform(
{
"files": files,
"hosts": hosts,

7
src/cloudflare/resources/cache/cache_reserve.py vendored
View file

@ -8,7 +8,10 @@ from typing_extensions import Literal
import httpx
from ..._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ..._utils import maybe_transform
from ..._utils import (
maybe_transform,
async_maybe_transform,
)
from ..._compat import cached_property
from ..._resource import SyncAPIResource, AsyncAPIResource
from ..._response import (
@ -350,7 +353,7 @@ class AsyncCacheReserve(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `zone_id` but received {zone_id!r}")
return await self._patch(
f"/zones/{zone_id}/cache/cache_reserve",
body=maybe_transform({"value": value}, cache_reserve_edit_params.CacheReserveEditParams),
body=await async_maybe_transform({"value": value}, cache_reserve_edit_params.CacheReserveEditParams),
options=make_request_options(
extra_headers=extra_headers,
extra_query=extra_query,

9
src/cloudflare/resources/cache/regional_tiered_cache.py vendored
View file

@ -8,7 +8,10 @@ from typing_extensions import Literal
import httpx
from ..._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ..._utils import maybe_transform
from ..._utils import (
maybe_transform,
async_maybe_transform,
)
from ..._compat import cached_property
from ..._resource import SyncAPIResource, AsyncAPIResource
from ..._response import (
@ -169,7 +172,9 @@ class AsyncRegionalTieredCache(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `zone_id` but received {zone_id!r}")
return await self._patch(
f"/zones/{zone_id}/cache/regional_tiered_cache",
body=maybe_transform({"value": value}, regional_tiered_cache_edit_params.RegionalTieredCacheEditParams),
body=await async_maybe_transform(
{"value": value}, regional_tiered_cache_edit_params.RegionalTieredCacheEditParams
),
options=make_request_options(
extra_headers=extra_headers,
extra_query=extra_query,

7
src/cloudflare/resources/cache/tiered_cache_smart_topology.py vendored
View file

@ -8,7 +8,10 @@ from typing_extensions import Literal
import httpx
from ..._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ..._utils import maybe_transform
from ..._utils import (
maybe_transform,
async_maybe_transform,
)
from ..._compat import cached_property
from ..._resource import SyncAPIResource, AsyncAPIResource
from ..._response import (
@ -266,7 +269,7 @@ class AsyncTieredCacheSmartTopology(AsyncAPIResource):
TieredCacheSmartTopologyEditResponse,
await self._patch(
f"/zones/{zone_id}/cache/tiered_cache_smart_topology_enable",
body=maybe_transform(
body=await async_maybe_transform(
{"value": value}, tiered_cache_smart_topology_edit_params.TieredCacheSmartTopologyEditParams
),
options=make_request_options(

7
src/cloudflare/resources/cache/variants.py vendored
View file

@ -7,7 +7,10 @@ from typing import Type, cast
import httpx
from ..._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ..._utils import maybe_transform
from ..._utils import (
maybe_transform,
async_maybe_transform,
)
from ..._compat import cached_property
from ..._resource import SyncAPIResource, AsyncAPIResource
from ..._response import (
@ -299,7 +302,7 @@ class AsyncVariants(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `zone_id` but received {zone_id!r}")
return await self._patch(
f"/zones/{zone_id}/cache/variants",
body=maybe_transform({"value": value}, variant_edit_params.VariantEditParams),
body=await async_maybe_transform({"value": value}, variant_edit_params.VariantEditParams),
options=make_request_options(
extra_headers=extra_headers,
extra_query=extra_query,

9
src/cloudflare/resources/calls.py
View file

@ -16,7 +16,10 @@ from ..types import (
call_update_params,
)
from .._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from .._utils import maybe_transform
from .._utils import (
maybe_transform,
async_maybe_transform,
)
from .._compat import cached_property
from .._resource import SyncAPIResource, AsyncAPIResource
from .._response import (
@ -306,7 +309,7 @@ class AsyncCalls(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `account_id` but received {account_id!r}")
return await self._post(
f"/accounts/{account_id}/calls/apps",
body=maybe_transform({"name": name}, call_create_params.CallCreateParams),
body=await async_maybe_transform({"name": name}, call_create_params.CallCreateParams),
options=make_request_options(
extra_headers=extra_headers,
extra_query=extra_query,
@ -354,7 +357,7 @@ class AsyncCalls(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `app_id` but received {app_id!r}")
return await self._put(
f"/accounts/{account_id}/calls/apps/{app_id}",
body=maybe_transform({"name": name}, call_update_params.CallUpdateParams),
body=await async_maybe_transform({"name": name}, call_update_params.CallUpdateParams),
options=make_request_options(
extra_headers=extra_headers,
extra_query=extra_query,

9
src/cloudflare/resources/certificate_authorities/hostname_associations.py
View file

@ -7,7 +7,10 @@ from typing import List, Type, cast
import httpx
from ..._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ..._utils import maybe_transform
from ..._utils import (
maybe_transform,
async_maybe_transform,
)
from ..._compat import cached_property
from ..._resource import SyncAPIResource, AsyncAPIResource
from ..._response import (
@ -184,7 +187,7 @@ class AsyncHostnameAssociations(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `zone_id` but received {zone_id!r}")
return await self._put(
f"/zones/{zone_id}/certificate_authorities/hostname_associations",
body=maybe_transform(
body=await async_maybe_transform(
{
"hostnames": hostnames,
"mtls_certificate_id": mtls_certificate_id,
@ -240,7 +243,7 @@ class AsyncHostnameAssociations(AsyncAPIResource):
extra_query=extra_query,
extra_body=extra_body,
timeout=timeout,
query=maybe_transform(
query=await async_maybe_transform(
{"mtls_certificate_id": mtls_certificate_id},
hostname_association_list_params.HostnameAssociationListParams,
),

7
src/cloudflare/resources/certificates.py
View file

@ -15,7 +15,10 @@ from ..types import (
certificate_create_params,
)
from .._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from .._utils import maybe_transform
from .._utils import (
maybe_transform,
async_maybe_transform,
)
from .._compat import cached_property
from .._resource import SyncAPIResource, AsyncAPIResource
from .._response import (
@ -274,7 +277,7 @@ class AsyncCertificates(AsyncAPIResource):
CertificateCreateResponse,
await self._post(
"/certificates",
body=maybe_transform(
body=await async_maybe_transform(
{
"csr": csr,
"hostnames": hostnames,

13
src/cloudflare/resources/challenges/widgets.py
View file

@ -8,7 +8,10 @@ from typing_extensions import Literal
import httpx
from ..._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ..._utils import maybe_transform
from ..._utils import (
maybe_transform,
async_maybe_transform,
)
from ..._compat import cached_property
from ..._resource import SyncAPIResource, AsyncAPIResource
from ..._response import (
@ -496,7 +499,7 @@ class AsyncWidgets(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `account_identifier` but received {account_identifier!r}")
return await self._post(
f"/accounts/{account_identifier}/challenges/widgets",
body=maybe_transform(
body=await async_maybe_transform(
{
"domains": domains,
"mode": mode,
@ -513,7 +516,7 @@ class AsyncWidgets(AsyncAPIResource):
extra_query=extra_query,
extra_body=extra_body,
timeout=timeout,
query=maybe_transform(
query=await async_maybe_transform(
{
"direction": direction,
"order": order,
@ -581,7 +584,7 @@ class AsyncWidgets(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `sitekey` but received {sitekey!r}")
return await self._put(
f"/accounts/{account_identifier}/challenges/widgets/{sitekey}",
body=maybe_transform(
body=await async_maybe_transform(
{
"domains": domains,
"mode": mode,
@ -793,7 +796,7 @@ class AsyncWidgets(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `sitekey` but received {sitekey!r}")
return await self._post(
f"/accounts/{account_identifier}/challenges/widgets/{sitekey}/rotate_secret",
body=maybe_transform(
body=await async_maybe_transform(
{"invalidate_immediately": invalidate_immediately}, widget_rotate_secret_params.WidgetRotateSecretParams
),
options=make_request_options(

7
src/cloudflare/resources/client_certificates.py
View file

@ -17,7 +17,10 @@ from ..types import (
client_certificate_create_params,
)
from .._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from .._utils import maybe_transform
from .._utils import (
maybe_transform,
async_maybe_transform,
)
from .._compat import cached_property
from .._resource import SyncAPIResource, AsyncAPIResource
from .._response import (
@ -348,7 +351,7 @@ class AsyncClientCertificates(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `zone_id` but received {zone_id!r}")
return await self._post(
f"/zones/{zone_id}/client_certificates",
body=maybe_transform(
body=await async_maybe_transform(
{
"csr": csr,
"validity_days": validity_days,

11
src/cloudflare/resources/cloudforce_one/requests/message.py
View file

@ -9,7 +9,10 @@ from typing_extensions import Literal
import httpx
from ...._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ...._utils import maybe_transform
from ...._utils import (
maybe_transform,
async_maybe_transform,
)
from ...._compat import cached_property
from ...._resource import SyncAPIResource, AsyncAPIResource
from ...._response import (
@ -336,7 +339,7 @@ class AsyncMessage(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `request_identifier` but received {request_identifier!r}")
return await self._post(
f"/accounts/{account_identifier}/cloudforce-one/requests/{request_identifier}/message/new",
body=maybe_transform({"content": content}, message_create_params.MessageCreateParams),
body=await async_maybe_transform({"content": content}, message_create_params.MessageCreateParams),
options=make_request_options(
extra_headers=extra_headers,
extra_query=extra_query,
@ -397,7 +400,7 @@ class AsyncMessage(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `request_identifier` but received {request_identifier!r}")
return await self._put(
f"/accounts/{account_identifier}/cloudforce-one/requests/{request_identifier}/message/{message_identifer}",
body=maybe_transform(
body=await async_maybe_transform(
{
"content": content,
"priority": priority,
@ -519,7 +522,7 @@ class AsyncMessage(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `request_identifier` but received {request_identifier!r}")
return await self._post(
f"/accounts/{account_identifier}/cloudforce-one/requests/{request_identifier}/message",
body=maybe_transform(
body=await async_maybe_transform(
{
"page": page,
"per_page": per_page,

11
src/cloudflare/resources/cloudforce_one/requests/priority.py
View file

@ -8,7 +8,10 @@ from typing_extensions import Literal
import httpx
from ...._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ...._utils import maybe_transform
from ...._utils import (
maybe_transform,
async_maybe_transform,
)
from ...._compat import cached_property
from ...._resource import SyncAPIResource, AsyncAPIResource
from ...._response import (
@ -405,7 +408,7 @@ class AsyncPriority(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `account_identifier` but received {account_identifier!r}")
return await self._post(
f"/accounts/{account_identifier}/cloudforce-one/requests/priority/new",
body=maybe_transform(
body=await async_maybe_transform(
{
"labels": labels,
"priority": priority,
@ -470,7 +473,7 @@ class AsyncPriority(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `priority_identifer` but received {priority_identifer!r}")
return await self._put(
f"/accounts/{account_identifier}/cloudforce-one/requests/priority/{priority_identifer}",
body=maybe_transform(
body=await async_maybe_transform(
{
"labels": labels,
"priority": priority,
@ -573,7 +576,7 @@ class AsyncPriority(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `account_identifier` but received {account_identifier!r}")
return await self._post(
f"/accounts/{account_identifier}/cloudforce-one/requests/priority",
body=maybe_transform(
body=await async_maybe_transform(
{
"page": page,
"per_page": per_page,

9
src/cloudflare/resources/cloudforce_one/requests/requests.py
View file

@ -25,7 +25,10 @@ from .priority import (
AsyncPriorityWithStreamingResponse,
)
from ...._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ...._utils import maybe_transform
from ...._utils import (
maybe_transform,
async_maybe_transform,
)
from ...._compat import cached_property
from ...._resource import SyncAPIResource, AsyncAPIResource
from ...._response import (
@ -568,7 +571,7 @@ class AsyncRequests(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `account_identifier` but received {account_identifier!r}")
return await self._post(
f"/accounts/{account_identifier}/cloudforce-one/requests/new",
body=maybe_transform(
body=await async_maybe_transform(
{
"content": content,
"priority": priority,
@ -640,7 +643,7 @@ class AsyncRequests(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `request_identifier` but received {request_identifier!r}")
return await self._put(
f"/accounts/{account_identifier}/cloudforce-one/requests/{request_identifier}",
body=maybe_transform(
body=await async_maybe_transform(
{
"content": content,
"priority": priority,

9
src/cloudflare/resources/custom_certificates/custom_certificates.py
View file

@ -18,7 +18,10 @@ from ...types import (
custom_certificate_create_params,
)
from ..._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ..._utils import maybe_transform
from ..._utils import (
maybe_transform,
async_maybe_transform,
)
from ..._compat import cached_property
from .prioritize import (
Prioritize,
@ -482,7 +485,7 @@ class AsyncCustomCertificates(AsyncAPIResource):
CustomCertificateCreateResponse,
await self._post(
f"/zones/{zone_id}/custom_certificates",
body=maybe_transform(
body=await async_maybe_transform(
{
"certificate": certificate,
"private_key": private_key,
@ -684,7 +687,7 @@ class AsyncCustomCertificates(AsyncAPIResource):
CustomCertificateEditResponse,
await self._patch(
f"/zones/{zone_id}/custom_certificates/{custom_certificate_id}",
body=maybe_transform(
body=await async_maybe_transform(
{
"bundle_method": bundle_method,
"certificate": certificate,

9
src/cloudflare/resources/custom_certificates/prioritize.py
View file

@ -7,7 +7,10 @@ from typing import Type, Iterable, Optional, cast
import httpx
from ..._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ..._utils import maybe_transform
from ..._utils import (
maybe_transform,
async_maybe_transform,
)
from ..._compat import cached_property
from ..._resource import SyncAPIResource, AsyncAPIResource
from ..._response import (
@ -123,7 +126,9 @@ class AsyncPrioritize(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `zone_id` but received {zone_id!r}")
return await self._put(
f"/zones/{zone_id}/custom_certificates/prioritize",
body=maybe_transform({"certificates": certificates}, prioritize_update_params.PrioritizeUpdateParams),
body=await async_maybe_transform(
{"certificates": certificates}, prioritize_update_params.PrioritizeUpdateParams
),
options=make_request_options(
extra_headers=extra_headers,
extra_query=extra_query,

9
src/cloudflare/resources/custom_hostnames/custom_hostnames.py
View file

@ -18,7 +18,10 @@ from ...types import (
custom_hostname_create_params,
)
from ..._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ..._utils import maybe_transform
from ..._utils import (
maybe_transform,
async_maybe_transform,
)
from ..._compat import cached_property
from ..._resource import SyncAPIResource, AsyncAPIResource
from ..._response import (
@ -411,7 +414,7 @@ class AsyncCustomHostnames(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `zone_id` but received {zone_id!r}")
return await self._post(
f"/zones/{zone_id}/custom_hostnames",
body=maybe_transform(
body=await async_maybe_transform(
{
"hostname": hostname,
"ssl": ssl,
@ -599,7 +602,7 @@ class AsyncCustomHostnames(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `custom_hostname_id` but received {custom_hostname_id!r}")
return await self._patch(
f"/zones/{zone_id}/custom_hostnames/{custom_hostname_id}",
body=maybe_transform(
body=await async_maybe_transform(
{
"custom_metadata": custom_metadata,
"custom_origin_server": custom_origin_server,

9
src/cloudflare/resources/custom_hostnames/fallback_origin.py
View file

@ -7,7 +7,10 @@ from typing import Any, cast
import httpx
from ..._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ..._utils import maybe_transform
from ..._utils import (
maybe_transform,
async_maybe_transform,
)
from ..._compat import cached_property
from ..._resource import SyncAPIResource, AsyncAPIResource
from ..._response import (
@ -219,7 +222,9 @@ class AsyncFallbackOrigin(AsyncAPIResource):
FallbackOriginUpdateResponse,
await self._put(
f"/zones/{zone_id}/custom_hostnames/fallback_origin",
body=maybe_transform({"origin": origin}, fallback_origin_update_params.FallbackOriginUpdateParams),
body=await async_maybe_transform(
{"origin": origin}, fallback_origin_update_params.FallbackOriginUpdateParams
),
options=make_request_options(
extra_headers=extra_headers,
extra_query=extra_query,

7
src/cloudflare/resources/custom_nameservers.py
View file

@ -15,7 +15,10 @@ from ..types import (
custom_nameserver_create_params,
)
from .._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from .._utils import maybe_transform
from .._utils import (
maybe_transform,
async_maybe_transform,
)
from .._compat import cached_property
from .._resource import SyncAPIResource, AsyncAPIResource
from .._response import (
@ -306,7 +309,7 @@ class AsyncCustomNameservers(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `account_id` but received {account_id!r}")
return await self._post(
f"/accounts/{account_id}/custom_ns",
body=maybe_transform(
body=await async_maybe_transform(
{
"ns_name": ns_name,
"ns_set": ns_set,

9
src/cloudflare/resources/d1/database.py
View file

@ -7,7 +7,10 @@ from typing import Any, List, Type, Optional, cast
import httpx
from ..._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ..._utils import maybe_transform
from ..._utils import (
maybe_transform,
async_maybe_transform,
)
from ..._compat import cached_property
from ...types.d1 import (
DatabaseGetResponse,
@ -328,7 +331,7 @@ class AsyncDatabase(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `account_id` but received {account_id!r}")
return await self._post(
f"/accounts/{account_id}/d1/database",
body=maybe_transform({"name": name}, database_create_params.DatabaseCreateParams),
body=await async_maybe_transform({"name": name}, database_create_params.DatabaseCreateParams),
options=make_request_options(
extra_headers=extra_headers,
extra_query=extra_query,
@ -524,7 +527,7 @@ class AsyncDatabase(AsyncAPIResource):
)
return await self._post(
f"/accounts/{account_identifier}/d1/database/{database_identifier}/query",
body=maybe_transform(
body=await async_maybe_transform(
{
"sql": sql,
"params": params,

9
src/cloudflare/resources/devices/dex_tests.py
View file

@ -7,7 +7,10 @@ from typing import Type, Optional, cast
import httpx
from ..._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ..._utils import maybe_transform
from ..._utils import (
maybe_transform,
async_maybe_transform,
)
from ..._compat import cached_property
from ..._resource import SyncAPIResource, AsyncAPIResource
from ..._response import (
@ -337,7 +340,7 @@ class AsyncDEXTests(AsyncAPIResource):
"""
return await self._post(
f"/accounts/{account_id}/devices/dex_tests",
body=maybe_transform(
body=await async_maybe_transform(
{
"data": data,
"enabled": enabled,
@ -403,7 +406,7 @@ class AsyncDEXTests(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `dex_test_id` but received {dex_test_id!r}")
return await self._put(
f"/accounts/{account_id}/devices/dex_tests/{dex_test_id}",
body=maybe_transform(
body=await async_maybe_transform(
{
"data": data,
"enabled": enabled,

9
src/cloudflare/resources/devices/networks.py
View file

@ -8,7 +8,10 @@ from typing_extensions import Literal
import httpx
from ..._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ..._utils import maybe_transform
from ..._utils import (
maybe_transform,
async_maybe_transform,
)
from ..._compat import cached_property
from ..._resource import SyncAPIResource, AsyncAPIResource
from ..._response import (
@ -315,7 +318,7 @@ class AsyncNetworks(AsyncAPIResource):
"""
return await self._post(
f"/accounts/{account_id}/devices/networks",
body=maybe_transform(
body=await async_maybe_transform(
{
"config": config,
"name": name,
@ -373,7 +376,7 @@ class AsyncNetworks(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `network_id` but received {network_id!r}")
return await self._put(
f"/accounts/{account_id}/devices/networks/{network_id}",
body=maybe_transform(
body=await async_maybe_transform(
{
"config": config,
"name": name,

7
src/cloudflare/resources/devices/policies/excludes.py
View file

@ -7,7 +7,10 @@ from typing import Type, Iterable, Optional, cast
import httpx
from ...._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ...._utils import maybe_transform
from ...._utils import (
maybe_transform,
async_maybe_transform,
)
from ...._compat import cached_property
from ...._resource import SyncAPIResource, AsyncAPIResource
from ...._response import (
@ -188,7 +191,7 @@ class AsyncExcludes(AsyncAPIResource):
"""
return await self._put(
f"/accounts/{account_id}/devices/policy/exclude",
body=maybe_transform(body, exclude_update_params.ExcludeUpdateParams),
body=await async_maybe_transform(body, exclude_update_params.ExcludeUpdateParams),
options=make_request_options(
extra_headers=extra_headers,
extra_query=extra_query,

7
src/cloudflare/resources/devices/policies/fallback_domains.py
View file

@ -7,7 +7,10 @@ from typing import Type, Iterable, Optional, cast
import httpx
from ...._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ...._utils import maybe_transform
from ...._utils import (
maybe_transform,
async_maybe_transform,
)
from ...._compat import cached_property
from ...._resource import SyncAPIResource, AsyncAPIResource
from ...._response import (
@ -207,7 +210,7 @@ class AsyncFallbackDomains(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `policy_id` but received {policy_id!r}")
return await self._put(
f"/accounts/{account_id}/devices/policy/{policy_id}/fallback_domains",
body=maybe_transform(body, fallback_domain_update_params.FallbackDomainUpdateParams),
body=await async_maybe_transform(body, fallback_domain_update_params.FallbackDomainUpdateParams),
options=make_request_options(
extra_headers=extra_headers,
extra_query=extra_query,

7
src/cloudflare/resources/devices/policies/includes.py
View file

@ -7,7 +7,10 @@ from typing import Type, Iterable, Optional, cast
import httpx
from ...._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ...._utils import maybe_transform
from ...._utils import (
maybe_transform,
async_maybe_transform,
)
from ...._compat import cached_property
from ...._resource import SyncAPIResource, AsyncAPIResource
from ...._response import (
@ -188,7 +191,7 @@ class AsyncIncludes(AsyncAPIResource):
"""
return await self._put(
f"/accounts/{account_id}/devices/policy/include",
body=maybe_transform(body, include_update_params.IncludeUpdateParams),
body=await async_maybe_transform(body, include_update_params.IncludeUpdateParams),
options=make_request_options(
extra_headers=extra_headers,
extra_query=extra_query,

9
src/cloudflare/resources/devices/policies/policies.py
View file

@ -23,7 +23,10 @@ from .includes import (
AsyncIncludesWithStreamingResponse,
)
from ...._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ...._utils import maybe_transform
from ...._utils import (
maybe_transform,
async_maybe_transform,
)
from ...._compat import cached_property
from ...._resource import SyncAPIResource, AsyncAPIResource
from ...._response import (
@ -537,7 +540,7 @@ class AsyncPolicies(AsyncAPIResource):
"""
return await self._post(
f"/accounts/{account_id}/devices/policy",
body=maybe_transform(
body=await async_maybe_transform(
{
"match": match,
"name": name,
@ -722,7 +725,7 @@ class AsyncPolicies(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `policy_id` but received {policy_id!r}")
return await self._patch(
f"/accounts/{account_id}/devices/policy/{policy_id}",
body=maybe_transform(
body=await async_maybe_transform(
{
"allow_mode_switch": allow_mode_switch,
"allow_updates": allow_updates,

9
src/cloudflare/resources/devices/postures/integrations.py
View file

@ -8,7 +8,10 @@ from typing_extensions import Literal
import httpx
from ...._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ...._utils import maybe_transform
from ...._utils import (
maybe_transform,
async_maybe_transform,
)
from ...._compat import cached_property
from ...._resource import SyncAPIResource, AsyncAPIResource
from ...._response import (
@ -331,7 +334,7 @@ class AsyncIntegrations(AsyncAPIResource):
"""
return await self._post(
f"/accounts/{account_id}/devices/posture/integration",
body=maybe_transform(
body=await async_maybe_transform(
{
"config": config,
"interval": interval,
@ -474,7 +477,7 @@ class AsyncIntegrations(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `integration_id` but received {integration_id!r}")
return await self._patch(
f"/accounts/{account_id}/devices/posture/integration/{integration_id}",
body=maybe_transform(
body=await async_maybe_transform(
{
"config": config,
"interval": interval,

9
src/cloudflare/resources/devices/postures/postures.py
View file

@ -8,7 +8,10 @@ from typing_extensions import Literal
import httpx
from ...._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ...._utils import maybe_transform
from ...._utils import (
maybe_transform,
async_maybe_transform,
)
from ...._compat import cached_property
from ...._resource import SyncAPIResource, AsyncAPIResource
from ...._response import (
@ -437,7 +440,7 @@ class AsyncPostures(AsyncAPIResource):
"""
return await self._post(
f"/accounts/{account_id}/devices/posture",
body=maybe_transform(
body=await async_maybe_transform(
{
"name": name,
"type": type,
@ -532,7 +535,7 @@ class AsyncPostures(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `rule_id` but received {rule_id!r}")
return await self._put(
f"/accounts/{account_id}/devices/posture/{rule_id}",
body=maybe_transform(
body=await async_maybe_transform(
{
"name": name,
"type": type,

7
src/cloudflare/resources/devices/revokes.py
View file

@ -7,7 +7,10 @@ from typing import Any, List, Optional, cast
import httpx
from ..._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ..._utils import maybe_transform
from ..._utils import (
maybe_transform,
async_maybe_transform,
)
from ..._compat import cached_property
from ..._resource import SyncAPIResource, AsyncAPIResource
from ..._response import (
@ -118,7 +121,7 @@ class AsyncRevokes(AsyncAPIResource):
Optional[RevokeCreateResponse],
await self._post(
f"/accounts/{account_id}/devices/revoke",
body=maybe_transform(body, revoke_create_params.RevokeCreateParams),
body=await async_maybe_transform(body, revoke_create_params.RevokeCreateParams),
options=make_request_options(
extra_headers=extra_headers,
extra_query=extra_query,

7
src/cloudflare/resources/devices/settings.py
View file

@ -7,7 +7,10 @@ from typing import Type, Optional, cast
import httpx
from ..._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ..._utils import maybe_transform
from ..._utils import (
maybe_transform,
async_maybe_transform,
)
from ..._compat import cached_property
from ..._resource import SyncAPIResource, AsyncAPIResource
from ..._response import (
@ -172,7 +175,7 @@ class AsyncSettings(AsyncAPIResource):
"""
return await self._put(
f"/accounts/{account_id}/devices/settings",
body=maybe_transform(
body=await async_maybe_transform(
{
"gateway_proxy_enabled": gateway_proxy_enabled,
"gateway_udp_proxy_enabled": gateway_udp_proxy_enabled,

7
src/cloudflare/resources/devices/unrevokes.py
View file

@ -7,7 +7,10 @@ from typing import Any, List, Optional, cast
import httpx
from ..._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ..._utils import maybe_transform
from ..._utils import (
maybe_transform,
async_maybe_transform,
)
from ..._compat import cached_property
from ..._resource import SyncAPIResource, AsyncAPIResource
from ..._response import (
@ -118,7 +121,7 @@ class AsyncUnrevokes(AsyncAPIResource):
Optional[UnrevokeCreateResponse],
await self._post(
f"/accounts/{account_id}/devices/unrevoke",
body=maybe_transform(body, unrevoke_create_params.UnrevokeCreateParams),
body=await async_maybe_transform(body, unrevoke_create_params.UnrevokeCreateParams),
options=make_request_options(
extra_headers=extra_headers,
extra_query=extra_query,

7
src/cloudflare/resources/diagnostics/traceroutes.py
View file

@ -7,7 +7,10 @@ from typing import List, Type, Optional, cast
import httpx
from ..._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ..._utils import maybe_transform
from ..._utils import (
maybe_transform,
async_maybe_transform,
)
from ..._compat import cached_property
from ..._resource import SyncAPIResource, AsyncAPIResource
from ..._response import (
@ -132,7 +135,7 @@ class AsyncTraceroutes(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `account_id` but received {account_id!r}")
return await self._post(
f"/accounts/{account_id}/diagnostics/traceroute",
body=maybe_transform(
body=await async_maybe_transform(
{
"targets": targets,
"colos": colos,

7
src/cloudflare/resources/dns/analytics/reports/bytimes.py
View file

@ -9,7 +9,10 @@ from typing_extensions import Literal
import httpx
from ....._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ....._utils import maybe_transform
from ....._utils import (
maybe_transform,
async_maybe_transform,
)
from ....._compat import cached_property
from ....._resource import SyncAPIResource, AsyncAPIResource
from ....._response import (
@ -192,7 +195,7 @@ class AsyncBytimes(AsyncAPIResource):
extra_query=extra_query,
extra_body=extra_body,
timeout=timeout,
query=maybe_transform(
query=await async_maybe_transform(
{
"dimensions": dimensions,
"filters": filters,

7
src/cloudflare/resources/dns/analytics/reports/reports.py
View file

@ -16,7 +16,10 @@ from .bytimes import (
AsyncBytimesWithStreamingResponse,
)
from ....._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ....._utils import maybe_transform
from ....._utils import (
maybe_transform,
async_maybe_transform,
)
from ....._compat import cached_property
from ....._resource import SyncAPIResource, AsyncAPIResource
from ....._response import (
@ -198,7 +201,7 @@ class AsyncReports(AsyncAPIResource):
extra_query=extra_query,
extra_body=extra_body,
timeout=timeout,
query=maybe_transform(
query=await async_maybe_transform(
{
"dimensions": dimensions,
"filters": filters,

7
src/cloudflare/resources/dns/firewall/analytics/reports/bytimes.py
View file

@ -9,7 +9,10 @@ from typing_extensions import Literal
import httpx
from ......_types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ......_utils import maybe_transform
from ......_utils import (
maybe_transform,
async_maybe_transform,
)
from ......_compat import cached_property
from ......_resource import SyncAPIResource, AsyncAPIResource
from ......_response import (
@ -202,7 +205,7 @@ class AsyncBytimes(AsyncAPIResource):
extra_query=extra_query,
extra_body=extra_body,
timeout=timeout,
query=maybe_transform(
query=await async_maybe_transform(
{
"dimensions": dimensions,
"filters": filters,

7
src/cloudflare/resources/dns/firewall/analytics/reports/reports.py
View file

@ -16,7 +16,10 @@ from .bytimes import (
AsyncBytimesWithStreamingResponse,
)
from ......_types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ......_utils import maybe_transform
from ......_utils import (
maybe_transform,
async_maybe_transform,
)
from ......_compat import cached_property
from ......_resource import SyncAPIResource, AsyncAPIResource
from ......_response import (
@ -208,7 +211,7 @@ class AsyncReports(AsyncAPIResource):
extra_query=extra_query,
extra_body=extra_body,
timeout=timeout,
query=maybe_transform(
query=await async_maybe_transform(
{
"dimensions": dimensions,
"filters": filters,

9
src/cloudflare/resources/dns/firewall/firewall.py
View file

@ -7,7 +7,10 @@ from typing import List, Type, Union, Optional, cast
import httpx
from ...._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ...._utils import maybe_transform
from ...._utils import (
maybe_transform,
async_maybe_transform,
)
from .analytics import (
Analytics,
AsyncAnalytics,
@ -457,7 +460,7 @@ class AsyncFirewall(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `account_id` but received {account_id!r}")
return await self._post(
f"/accounts/{account_id}/dns_firewall",
body=maybe_transform(
body=await async_maybe_transform(
{
"name": name,
"upstream_ips": upstream_ips,
@ -647,7 +650,7 @@ class AsyncFirewall(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `dns_firewall_id` but received {dns_firewall_id!r}")
return await self._patch(
f"/accounts/{account_id}/dns_firewall/{dns_firewall_id}",
body=maybe_transform(
body=await async_maybe_transform(
{
"deprecate_any_requests": deprecate_any_requests,
"dns_firewall_ips": dns_firewall_ips,

13
src/cloudflare/resources/dns/records.py
View file

@ -8,7 +8,10 @@ from typing_extensions import Literal
import httpx
from ..._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ..._utils import maybe_transform
from ..._utils import (
maybe_transform,
async_maybe_transform,
)
from ..._compat import cached_property
from ..._resource import SyncAPIResource, AsyncAPIResource
from ..._response import (
@ -779,7 +782,7 @@ class AsyncRecords(AsyncAPIResource):
RecordCreateResponse,
await self._post(
f"/zones/{zone_id}/dns_records",
body=maybe_transform(
body=await async_maybe_transform(
{
"name": name,
"type": type,
@ -876,7 +879,7 @@ class AsyncRecords(AsyncAPIResource):
RecordUpdateResponse,
await self._put(
f"/zones/{zone_id}/dns_records/{dns_record_id}",
body=maybe_transform(
body=await async_maybe_transform(
{
"name": name,
"type": type,
@ -1142,7 +1145,7 @@ class AsyncRecords(AsyncAPIResource):
RecordEditResponse,
await self._patch(
f"/zones/{zone_id}/dns_records/{dns_record_id}",
body=maybe_transform(
body=await async_maybe_transform(
{
"name": name,
"type": type,
@ -1308,7 +1311,7 @@ class AsyncRecords(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `zone_id` but received {zone_id!r}")
return await self._post(
f"/zones/{zone_id}/dns_records/import",
body=maybe_transform(
body=await async_maybe_transform(
{
"file": file,
"proxied": proxied,

7
src/cloudflare/resources/dnssec.py
View file

@ -9,7 +9,10 @@ import httpx
from ..types import DNSSECGetResponse, DNSSECEditResponse, DNSSECDeleteResponse, dnssec_edit_params
from .._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from .._utils import maybe_transform
from .._utils import (
maybe_transform,
async_maybe_transform,
)
from .._compat import cached_property
from .._resource import SyncAPIResource, AsyncAPIResource
from .._response import (
@ -292,7 +295,7 @@ class AsyncDNSSEC(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `zone_id` but received {zone_id!r}")
return await self._patch(
f"/zones/{zone_id}/dnssec",
body=maybe_transform(
body=await async_maybe_transform(
{
"dnssec_multi_signer": dnssec_multi_signer,
"dnssec_presigned": dnssec_presigned,

7
src/cloudflare/resources/durable_objects/namespaces/objects.py
View file

@ -7,7 +7,10 @@ from typing import Type, Optional, cast
import httpx
from ...._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ...._utils import maybe_transform
from ...._utils import (
maybe_transform,
async_maybe_transform,
)
from ...._compat import cached_property
from ...._resource import SyncAPIResource, AsyncAPIResource
from ...._response import (
@ -152,7 +155,7 @@ class AsyncObjects(AsyncAPIResource):
extra_query=extra_query,
extra_body=extra_body,
timeout=timeout,
query=maybe_transform(
query=await async_maybe_transform(
{
"cursor": cursor,
"limit": limit,

9
src/cloudflare/resources/emails/routing/addresses.py
View file

@ -8,7 +8,10 @@ from typing_extensions import Literal
import httpx
from ...._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ...._utils import maybe_transform
from ...._utils import (
maybe_transform,
async_maybe_transform,
)
from ...._compat import cached_property
from ...._resource import SyncAPIResource, AsyncAPIResource
from ...._response import (
@ -286,7 +289,7 @@ class AsyncAddresses(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `account_identifier` but received {account_identifier!r}")
return await self._post(
f"/accounts/{account_identifier}/email/routing/addresses",
body=maybe_transform({"email": email}, address_create_params.AddressCreateParams),
body=await async_maybe_transform({"email": email}, address_create_params.AddressCreateParams),
options=make_request_options(
extra_headers=extra_headers,
extra_query=extra_query,
@ -389,7 +392,7 @@ class AsyncAddresses(AsyncAPIResource):
extra_query=extra_query,
extra_body=extra_body,
timeout=timeout,
query=maybe_transform(
query=await async_maybe_transform(
{
"direction": direction,
"page": page,

7
src/cloudflare/resources/emails/routing/rules/catch_alls.py
View file

@ -8,7 +8,10 @@ from typing_extensions import Literal
import httpx
from ....._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ....._utils import maybe_transform
from ....._utils import (
maybe_transform,
async_maybe_transform,
)
from ....._compat import cached_property
from ....._resource import SyncAPIResource, AsyncAPIResource
from ....._response import (
@ -187,7 +190,7 @@ class AsyncCatchAlls(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `zone_identifier` but received {zone_identifier!r}")
return await self._put(
f"/zones/{zone_identifier}/email/routing/rules/catch_all",
body=maybe_transform(
body=await async_maybe_transform(
{
"actions": actions,
"matchers": matchers,

9
src/cloudflare/resources/emails/routing/rules/rules.py
View file

@ -8,7 +8,10 @@ from typing_extensions import Literal
import httpx
from ....._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ....._utils import maybe_transform
from ....._utils import (
maybe_transform,
async_maybe_transform,
)
from .catch_alls import (
CatchAlls,
AsyncCatchAlls,
@ -397,7 +400,7 @@ class AsyncRules(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `zone_identifier` but received {zone_identifier!r}")
return await self._post(
f"/zones/{zone_identifier}/email/routing/rules",
body=maybe_transform(
body=await async_maybe_transform(
{
"actions": actions,
"matchers": matchers,
@ -466,7 +469,7 @@ class AsyncRules(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `rule_identifier` but received {rule_identifier!r}")
return await self._put(
f"/zones/{zone_identifier}/email/routing/rules/{rule_identifier}",
body=maybe_transform(
body=await async_maybe_transform(
{
"actions": actions,
"matchers": matchers,

9
src/cloudflare/resources/filters.py
View file

@ -17,7 +17,10 @@ from ..types import (
filter_update_params,
)
from .._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from .._utils import maybe_transform
from .._utils import (
maybe_transform,
async_maybe_transform,
)
from .._compat import cached_property
from .._resource import SyncAPIResource, AsyncAPIResource
from .._response import (
@ -330,7 +333,7 @@ class AsyncFilters(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `zone_identifier` but received {zone_identifier!r}")
return await self._post(
f"/zones/{zone_identifier}/filters",
body=maybe_transform(body, filter_create_params.FilterCreateParams),
body=await async_maybe_transform(body, filter_create_params.FilterCreateParams),
options=make_request_options(
extra_headers=extra_headers,
extra_query=extra_query,
@ -376,7 +379,7 @@ class AsyncFilters(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `id` but received {id!r}")
return await self._put(
f"/zones/{zone_identifier}/filters/{id}",
body=maybe_transform(body, filter_update_params.FilterUpdateParams),
body=await async_maybe_transform(body, filter_update_params.FilterUpdateParams),
options=make_request_options(
extra_headers=extra_headers,
extra_query=extra_query,

9
src/cloudflare/resources/firewall/access_rules.py
View file

@ -8,7 +8,10 @@ from typing_extensions import Literal
import httpx
from ..._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ..._utils import maybe_transform
from ..._utils import (
maybe_transform,
async_maybe_transform,
)
from ..._compat import cached_property
from ..._resource import SyncAPIResource, AsyncAPIResource
from ..._response import (
@ -480,7 +483,7 @@ class AsyncAccessRules(AsyncAPIResource):
Optional[AccessRuleCreateResponse],
await self._post(
f"/{account_or_zone}/{account_or_zone_id}/firewall/access_rules/rules",
body=maybe_transform(
body=await async_maybe_transform(
{
"configuration": configuration,
"mode": mode,
@ -701,7 +704,7 @@ class AsyncAccessRules(AsyncAPIResource):
Optional[AccessRuleEditResponse],
await self._patch(
f"/{account_or_zone}/{account_or_zone_id}/firewall/access_rules/rules/{identifier}",
body=maybe_transform(
body=await async_maybe_transform(
{
"configuration": configuration,
"mode": mode,

9
src/cloudflare/resources/firewall/lockdowns.py
View file

@ -7,7 +7,10 @@ from typing import Type, Optional, cast
import httpx
from ..._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ..._utils import maybe_transform
from ..._utils import (
maybe_transform,
async_maybe_transform,
)
from ..._compat import cached_property
from ..._resource import SyncAPIResource, AsyncAPIResource
from ..._response import (
@ -345,7 +348,7 @@ class AsyncLockdowns(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `zone_identifier` but received {zone_identifier!r}")
return await self._post(
f"/zones/{zone_identifier}/firewall/lockdowns",
body=maybe_transform(body, lockdown_create_params.LockdownCreateParams),
body=await async_maybe_transform(body, lockdown_create_params.LockdownCreateParams),
options=make_request_options(
extra_headers=extra_headers,
extra_query=extra_query,
@ -391,7 +394,7 @@ class AsyncLockdowns(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `id` but received {id!r}")
return await self._put(
f"/zones/{zone_identifier}/firewall/lockdowns/{id}",
body=maybe_transform(body, lockdown_update_params.LockdownUpdateParams),
body=await async_maybe_transform(body, lockdown_update_params.LockdownUpdateParams),
options=make_request_options(
extra_headers=extra_headers,
extra_query=extra_query,

13
src/cloudflare/resources/firewall/rules.py
View file

@ -7,7 +7,10 @@ from typing import Type, Optional, cast
import httpx
from ..._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ..._utils import maybe_transform
from ..._utils import (
maybe_transform,
async_maybe_transform,
)
from ..._compat import cached_property
from ..._resource import SyncAPIResource, AsyncAPIResource
from ..._response import (
@ -382,7 +385,7 @@ class AsyncRules(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `zone_identifier` but received {zone_identifier!r}")
return await self._post(
f"/zones/{zone_identifier}/firewall/rules",
body=maybe_transform(body, rule_create_params.RuleCreateParams),
body=await async_maybe_transform(body, rule_create_params.RuleCreateParams),
options=make_request_options(
extra_headers=extra_headers,
extra_query=extra_query,
@ -428,7 +431,7 @@ class AsyncRules(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `id` but received {id!r}")
return await self._put(
f"/zones/{zone_identifier}/firewall/rules/{id}",
body=maybe_transform(body, rule_update_params.RuleUpdateParams),
body=await async_maybe_transform(body, rule_update_params.RuleUpdateParams),
options=make_request_options(
extra_headers=extra_headers,
extra_query=extra_query,
@ -543,7 +546,7 @@ class AsyncRules(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `id` but received {id!r}")
return await self._delete(
f"/zones/{zone_identifier}/firewall/rules/{id}",
body=maybe_transform(
body=await async_maybe_transform(
{"delete_filter_if_unused": delete_filter_if_unused}, rule_delete_params.RuleDeleteParams
),
options=make_request_options(
@ -591,7 +594,7 @@ class AsyncRules(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `id` but received {id!r}")
return await self._patch(
f"/zones/{zone_identifier}/firewall/rules/{id}",
body=maybe_transform(body, rule_edit_params.RuleEditParams),
body=await async_maybe_transform(body, rule_edit_params.RuleEditParams),
options=make_request_options(
extra_headers=extra_headers,
extra_query=extra_query,

9
src/cloudflare/resources/firewall/ua_rules.py
View file

@ -7,7 +7,10 @@ from typing import Any, Type, Optional, cast
import httpx
from ..._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ..._utils import maybe_transform
from ..._utils import (
maybe_transform,
async_maybe_transform,
)
from ..._compat import cached_property
from ..._resource import SyncAPIResource, AsyncAPIResource
from ..._response import (
@ -344,7 +347,7 @@ class AsyncUARules(AsyncAPIResource):
Optional[UARuleCreateResponse],
await self._post(
f"/zones/{zone_identifier}/firewall/ua_rules",
body=maybe_transform(body, ua_rule_create_params.UARuleCreateParams),
body=await async_maybe_transform(body, ua_rule_create_params.UARuleCreateParams),
options=make_request_options(
extra_headers=extra_headers,
extra_query=extra_query,
@ -395,7 +398,7 @@ class AsyncUARules(AsyncAPIResource):
Optional[UARuleUpdateResponse],
await self._put(
f"/zones/{zone_identifier}/firewall/ua_rules/{id}",
body=maybe_transform(body, ua_rule_update_params.UARuleUpdateParams),
body=await async_maybe_transform(body, ua_rule_update_params.UARuleUpdateParams),
options=make_request_options(
extra_headers=extra_headers,
extra_query=extra_query,

9
src/cloudflare/resources/firewall/waf/overrides.py
View file

@ -7,7 +7,10 @@ from typing import Type, Optional, cast
import httpx
from ...._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ...._utils import maybe_transform
from ...._utils import (
maybe_transform,
async_maybe_transform,
)
from ...._compat import cached_property
from ...._resource import SyncAPIResource, AsyncAPIResource
from ...._response import (
@ -330,7 +333,7 @@ class AsyncOverrides(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `zone_identifier` but received {zone_identifier!r}")
return await self._post(
f"/zones/{zone_identifier}/firewall/waf/overrides",
body=maybe_transform(body, override_create_params.OverrideCreateParams),
body=await async_maybe_transform(body, override_create_params.OverrideCreateParams),
options=make_request_options(
extra_headers=extra_headers,
extra_query=extra_query,
@ -379,7 +382,7 @@ class AsyncOverrides(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `id` but received {id!r}")
return await self._put(
f"/zones/{zone_identifier}/firewall/waf/overrides/{id}",
body=maybe_transform(body, override_update_params.OverrideUpdateParams),
body=await async_maybe_transform(body, override_update_params.OverrideUpdateParams),
options=make_request_options(
extra_headers=extra_headers,
extra_query=extra_query,

7
src/cloudflare/resources/firewall/waf/packages/groups.py
View file

@ -8,7 +8,10 @@ from typing_extensions import Literal
import httpx
from ....._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ....._utils import maybe_transform
from ....._utils import (
maybe_transform,
async_maybe_transform,
)
from ....._compat import cached_property
from ....._resource import SyncAPIResource, AsyncAPIResource
from ....._response import (
@ -380,7 +383,7 @@ class AsyncGroups(AsyncAPIResource):
GroupEditResponse,
await self._patch(
f"/zones/{zone_id}/firewall/waf/packages/{package_id}/groups/{group_id}",
body=maybe_transform({"mode": mode}, group_edit_params.GroupEditParams),
body=await async_maybe_transform({"mode": mode}, group_edit_params.GroupEditParams),
options=make_request_options(
extra_headers=extra_headers,
extra_query=extra_query,

7
src/cloudflare/resources/firewall/waf/packages/rules.py
View file

@ -8,7 +8,10 @@ from typing_extensions import Literal
import httpx
from ....._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ....._utils import maybe_transform
from ....._utils import (
maybe_transform,
async_maybe_transform,
)
from ....._compat import cached_property
from ....._resource import SyncAPIResource, AsyncAPIResource
from ....._response import (
@ -376,7 +379,7 @@ class AsyncRules(AsyncAPIResource):
RuleEditResponse,
await self._patch(
f"/zones/{zone_id}/firewall/waf/packages/{package_id}/rules/{rule_id}",
body=maybe_transform({"mode": mode}, rule_edit_params.RuleEditParams),
body=await async_maybe_transform({"mode": mode}, rule_edit_params.RuleEditParams),
options=make_request_options(
extra_headers=extra_headers,
extra_query=extra_query,

11
src/cloudflare/resources/healthchecks/healthchecks.py
View file

@ -19,7 +19,10 @@ from ...types import (
healthcheck_update_params,
)
from ..._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ..._utils import maybe_transform
from ..._utils import (
maybe_transform,
async_maybe_transform,
)
from .previews import (
Previews,
AsyncPreviews,
@ -676,7 +679,7 @@ class AsyncHealthchecks(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `zone_identifier` but received {zone_identifier!r}")
return await self._post(
f"/zones/{zone_identifier}/healthchecks",
body=maybe_transform(
body=await async_maybe_transform(
{
"address": address,
"name": name,
@ -805,7 +808,7 @@ class AsyncHealthchecks(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `identifier` but received {identifier!r}")
return await self._put(
f"/zones/{zone_identifier}/healthchecks/{identifier}",
body=maybe_transform(
body=await async_maybe_transform(
{
"address": address,
"name": name,
@ -1017,7 +1020,7 @@ class AsyncHealthchecks(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `identifier` but received {identifier!r}")
return await self._patch(
f"/zones/{zone_identifier}/healthchecks/{identifier}",
body=maybe_transform(
body=await async_maybe_transform(
{
"address": address,
"name": name,

7
src/cloudflare/resources/healthchecks/previews.py
View file

@ -8,7 +8,10 @@ from typing_extensions import Literal
import httpx
from ..._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ..._utils import maybe_transform
from ..._utils import (
maybe_transform,
async_maybe_transform,
)
from ..._compat import cached_property
from ..._resource import SyncAPIResource, AsyncAPIResource
from ..._response import (
@ -358,7 +361,7 @@ class AsyncPreviews(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `zone_identifier` but received {zone_identifier!r}")
return await self._post(
f"/zones/{zone_identifier}/healthchecks/preview",
body=maybe_transform(
body=await async_maybe_transform(
{
"address": address,
"name": name,

7
src/cloudflare/resources/hostnames/settings/tls.py
View file

@ -8,7 +8,10 @@ from typing_extensions import Literal
import httpx
from ...._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ...._utils import maybe_transform
from ...._utils import (
maybe_transform,
async_maybe_transform,
)
from ...._compat import cached_property
from ...._resource import SyncAPIResource, AsyncAPIResource
from ...._response import (
@ -233,7 +236,7 @@ class AsyncTLS(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `hostname` but received {hostname!r}")
return await self._put(
f"/zones/{zone_id}/hostnames/settings/{setting_id}/{hostname}",
body=maybe_transform({"value": value}, tls_update_params.TLSUpdateParams),
body=await async_maybe_transform({"value": value}, tls_update_params.TLSUpdateParams),
options=make_request_options(
extra_headers=extra_headers,
extra_query=extra_query,

11
src/cloudflare/resources/hyperdrive/configs.py
View file

@ -7,7 +7,10 @@ from typing import Any, Type, Optional, cast
import httpx
from ..._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ..._utils import maybe_transform
from ..._utils import (
maybe_transform,
async_maybe_transform,
)
from ..._compat import cached_property
from ..._resource import SyncAPIResource, AsyncAPIResource
from ..._response import (
@ -351,7 +354,7 @@ class AsyncConfigs(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `account_id` but received {account_id!r}")
return await self._post(
f"/accounts/{account_id}/hyperdrive/configs",
body=maybe_transform({"origin": origin}, config_create_params.ConfigCreateParams),
body=await async_maybe_transform({"origin": origin}, config_create_params.ConfigCreateParams),
options=make_request_options(
extra_headers=extra_headers,
extra_query=extra_query,
@ -397,7 +400,7 @@ class AsyncConfigs(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `hyperdrive_id` but received {hyperdrive_id!r}")
return await self._put(
f"/accounts/{account_id}/hyperdrive/configs/{hyperdrive_id}",
body=maybe_transform({"origin": origin}, config_update_params.ConfigUpdateParams),
body=await async_maybe_transform({"origin": origin}, config_update_params.ConfigUpdateParams),
options=make_request_options(
extra_headers=extra_headers,
extra_query=extra_query,
@ -533,7 +536,7 @@ class AsyncConfigs(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `hyperdrive_id` but received {hyperdrive_id!r}")
return await self._patch(
f"/accounts/{account_id}/hyperdrive/configs/{hyperdrive_id}",
body=maybe_transform({"origin": origin}, config_edit_params.ConfigEditParams),
body=await async_maybe_transform({"origin": origin}, config_edit_params.ConfigEditParams),
options=make_request_options(
extra_headers=extra_headers,
extra_query=extra_query,

9
src/cloudflare/resources/images/v1/v1.py
View file

@ -39,7 +39,10 @@ from .variants import (
AsyncVariantsWithStreamingResponse,
)
from ...._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ...._utils import maybe_transform
from ...._utils import (
maybe_transform,
async_maybe_transform,
)
from ...._compat import cached_property
from ...._resource import SyncAPIResource, AsyncAPIResource
from ...._response import (
@ -417,7 +420,7 @@ class AsyncV1(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `account_id` but received {account_id!r}")
return await self._post(
f"/accounts/{account_id}/images/v1",
body=maybe_transform(
body=await async_maybe_transform(
{
"metadata": metadata,
"require_signed_urls": require_signed_urls,
@ -584,7 +587,7 @@ class AsyncV1(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `image_id` but received {image_id!r}")
return await self._patch(
f"/accounts/{account_id}/images/v1/{image_id}",
body=maybe_transform(
body=await async_maybe_transform(
{
"metadata": metadata,
"require_signed_urls": require_signed_urls,

9
src/cloudflare/resources/images/v1/variants.py
View file

@ -7,7 +7,10 @@ from typing import Any, Type, cast
import httpx
from ...._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ...._utils import maybe_transform
from ...._utils import (
maybe_transform,
async_maybe_transform,
)
from ...._compat import cached_property
from ...._resource import SyncAPIResource, AsyncAPIResource
from ...._response import (
@ -322,7 +325,7 @@ class AsyncVariants(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `account_id` but received {account_id!r}")
return await self._post(
f"/accounts/{account_id}/images/v1/variants",
body=maybe_transform(
body=await async_maybe_transform(
{
"id": id,
"options": options,
@ -461,7 +464,7 @@ class AsyncVariants(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `account_id` but received {account_id!r}")
return await self._patch(
f"/accounts/{account_id}/images/v1/variants/{variant_id}",
body=maybe_transform(
body=await async_maybe_transform(
{
"options": options,
"never_require_signed_urls": never_require_signed_urls,

7
src/cloudflare/resources/images/v2/direct_uploads.py
View file

@ -8,7 +8,10 @@ from datetime import datetime
import httpx
from ...._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ...._utils import maybe_transform
from ...._utils import (
maybe_transform,
async_maybe_transform,
)
from ...._compat import cached_property
from ...._resource import SyncAPIResource, AsyncAPIResource
from ...._response import (
@ -157,7 +160,7 @@ class AsyncDirectUploads(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `account_id` but received {account_id!r}")
return await self._post(
f"/accounts/{account_id}/images/v2/direct_upload",
body=maybe_transform(
body=await async_maybe_transform(
{
"expiry": expiry,
"metadata": metadata,

7
src/cloudflare/resources/images/v2/v2.py
View file

@ -8,7 +8,10 @@ from typing_extensions import Literal
import httpx
from ...._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ...._utils import maybe_transform
from ...._utils import (
maybe_transform,
async_maybe_transform,
)
from ...._compat import cached_property
from ...._resource import SyncAPIResource, AsyncAPIResource
from ...._response import (
@ -166,7 +169,7 @@ class AsyncV2(AsyncAPIResource):
extra_query=extra_query,
extra_body=extra_body,
timeout=timeout,
query=maybe_transform(
query=await async_maybe_transform(
{
"continuation_token": continuation_token,
"per_page": per_page,

7
src/cloudflare/resources/intel/dns.py
View file

@ -7,7 +7,10 @@ from typing import Type, cast
import httpx
from ..._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ..._utils import maybe_transform
from ..._utils import (
maybe_transform,
async_maybe_transform,
)
from ..._compat import cached_property
from ..._resource import SyncAPIResource, AsyncAPIResource
from ..._response import (
@ -142,7 +145,7 @@ class AsyncDNS(AsyncAPIResource):
extra_query=extra_query,
extra_body=extra_body,
timeout=timeout,
query=maybe_transform(
query=await async_maybe_transform(
{
"ipv4": ipv4,
"page": page,

9
src/cloudflare/resources/intel/domain_histories.py
View file

@ -7,7 +7,10 @@ from typing import Type, Optional, cast
import httpx
from ..._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ..._utils import maybe_transform
from ..._utils import (
maybe_transform,
async_maybe_transform,
)
from ..._compat import cached_property
from ..._resource import SyncAPIResource, AsyncAPIResource
from ..._response import (
@ -120,7 +123,9 @@ class AsyncDomainHistories(AsyncAPIResource):
extra_query=extra_query,
extra_body=extra_body,
timeout=timeout,
query=maybe_transform({"domain": domain}, domain_history_list_params.DomainHistoryListParams),
query=await async_maybe_transform(
{"domain": domain}, domain_history_list_params.DomainHistoryListParams
),
post_parser=ResultWrapper._unwrapper,
),
cast_to=cast(Type[Optional[DomainHistoryListResponse]], ResultWrapper[DomainHistoryListResponse]),

7
src/cloudflare/resources/intel/domains/bulks.py
View file

@ -7,7 +7,10 @@ from typing import Type, Optional, cast
import httpx
from ...._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ...._utils import maybe_transform
from ...._utils import (
maybe_transform,
async_maybe_transform,
)
from ...._compat import cached_property
from ...._resource import SyncAPIResource, AsyncAPIResource
from ...._response import (
@ -124,7 +127,7 @@ class AsyncBulks(AsyncAPIResource):
extra_query=extra_query,
extra_body=extra_body,
timeout=timeout,
query=maybe_transform({"domain": domain}, bulk_get_params.BulkGetParams),
query=await async_maybe_transform({"domain": domain}, bulk_get_params.BulkGetParams),
post_parser=ResultWrapper._unwrapper,
),
cast_to=cast(Type[Optional[BulkGetResponse]], ResultWrapper[BulkGetResponse]),

7
src/cloudflare/resources/intel/domains/domains.py
View file

@ -15,7 +15,10 @@ from .bulks import (
AsyncBulksWithStreamingResponse,
)
from ...._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ...._utils import maybe_transform
from ...._utils import (
maybe_transform,
async_maybe_transform,
)
from ...._compat import cached_property
from ...._resource import SyncAPIResource, AsyncAPIResource
from ...._response import (
@ -136,7 +139,7 @@ class AsyncDomains(AsyncAPIResource):
extra_query=extra_query,
extra_body=extra_body,
timeout=timeout,
query=maybe_transform({"domain": domain}, domain_get_params.DomainGetParams),
query=await async_maybe_transform({"domain": domain}, domain_get_params.DomainGetParams),
post_parser=ResultWrapper._unwrapper,
),
cast_to=cast(Type[DomainGetResponse], ResultWrapper[DomainGetResponse]),

11
src/cloudflare/resources/intel/indicator_feeds/indicator_feeds.py
View file

@ -7,7 +7,10 @@ from typing import Type, cast
import httpx
from ...._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ...._utils import maybe_transform
from ...._utils import (
maybe_transform,
async_maybe_transform,
)
from ...._compat import cached_property
from .permissions import (
Permissions,
@ -320,7 +323,7 @@ class AsyncIndicatorFeeds(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `account_id` but received {account_id!r}")
return await self._post(
f"/accounts/{account_id}/intel/indicator-feeds",
body=maybe_transform(
body=await async_maybe_transform(
{
"description": description,
"name": name,
@ -372,7 +375,9 @@ class AsyncIndicatorFeeds(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `account_id` but received {account_id!r}")
return await self._put(
f"/accounts/{account_id}/intel/indicator-feeds/{feed_id}/snapshot",
body=maybe_transform({"source": source}, indicator_feed_update_params.IndicatorFeedUpdateParams),
body=await async_maybe_transform(
{"source": source}, indicator_feed_update_params.IndicatorFeedUpdateParams
),
options=make_request_options(
extra_headers=extra_headers,
extra_query=extra_query,

9
src/cloudflare/resources/intel/indicator_feeds/permissions.py
View file

@ -7,7 +7,10 @@ from typing import Type, cast
import httpx
from ...._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ...._utils import maybe_transform
from ...._utils import (
maybe_transform,
async_maybe_transform,
)
from ...._compat import cached_property
from ...._resource import SyncAPIResource, AsyncAPIResource
from ...._response import (
@ -228,7 +231,7 @@ class AsyncPermissions(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `account_id` but received {account_id!r}")
return await self._put(
f"/accounts/{account_id}/intel/indicator-feeds/permissions/add",
body=maybe_transform(
body=await async_maybe_transform(
{
"account_tag": account_tag,
"feed_id": feed_id,
@ -319,7 +322,7 @@ class AsyncPermissions(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `account_id` but received {account_id!r}")
return await self._put(
f"/accounts/{account_id}/intel/indicator-feeds/permissions/remove",
body=maybe_transform(
body=await async_maybe_transform(
{
"account_tag": account_tag,
"feed_id": feed_id,

7
src/cloudflare/resources/intel/ips.py
View file

@ -7,7 +7,10 @@ from typing import Type, Optional, cast
import httpx
from ..._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ..._utils import maybe_transform
from ..._utils import (
maybe_transform,
async_maybe_transform,
)
from ..._compat import cached_property
from ..._resource import SyncAPIResource, AsyncAPIResource
from ..._response import (
@ -128,7 +131,7 @@ class AsyncIPs(AsyncAPIResource):
extra_query=extra_query,
extra_body=extra_body,
timeout=timeout,
query=maybe_transform(
query=await async_maybe_transform(
{
"ipv4": ipv4,
"ipv6": ipv6,

7
src/cloudflare/resources/intel/miscategorizations.py
View file

@ -8,7 +8,10 @@ from typing_extensions import Literal
import httpx
from ..._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ..._utils import maybe_transform
from ..._utils import (
maybe_transform,
async_maybe_transform,
)
from ..._compat import cached_property
from ..._resource import SyncAPIResource, AsyncAPIResource
from ..._response import (
@ -174,7 +177,7 @@ class AsyncMiscategorizations(AsyncAPIResource):
MiscategorizationCreateResponse,
await self._post(
f"/accounts/{account_id}/intel/miscategorization",
body=maybe_transform(
body=await async_maybe_transform(
{
"content_adds": content_adds,
"content_removes": content_removes,

7
src/cloudflare/resources/intel/whois.py
View file

@ -7,7 +7,10 @@ from typing import Type, cast
import httpx
from ..._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ..._utils import maybe_transform
from ..._utils import (
maybe_transform,
async_maybe_transform,
)
from ..._compat import cached_property
from ..._resource import SyncAPIResource, AsyncAPIResource
from ..._response import (
@ -120,7 +123,7 @@ class AsyncWhois(AsyncAPIResource):
extra_query=extra_query,
extra_body=extra_body,
timeout=timeout,
query=maybe_transform({"domain": domain}, whois_get_params.WhoisGetParams),
query=await async_maybe_transform({"domain": domain}, whois_get_params.WhoisGetParams),
post_parser=ResultWrapper._unwrapper,
),
cast_to=cast(Type[WhoisGetResponse], ResultWrapper[WhoisGetResponse]),

7
src/cloudflare/resources/ips.py
View file

@ -8,7 +8,10 @@ import httpx
from ..types import IPListResponse, ip_list_params
from .._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from .._utils import maybe_transform
from .._utils import (
maybe_transform,
async_maybe_transform,
)
from .._compat import cached_property
from .._resource import SyncAPIResource, AsyncAPIResource
from .._response import (
@ -127,7 +130,7 @@ class AsyncIPs(AsyncAPIResource):
extra_query=extra_query,
extra_body=extra_body,
timeout=timeout,
query=maybe_transform({"networks": networks}, ip_list_params.IPListParams),
query=await async_maybe_transform({"networks": networks}, ip_list_params.IPListParams),
post_parser=ResultWrapper._unwrapper,
),
cast_to=cast(

9
src/cloudflare/resources/keyless_certificates.py
View file

@ -17,7 +17,10 @@ from ..types import (
keyless_certificate_create_params,
)
from .._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from .._utils import maybe_transform
from .._utils import (
maybe_transform,
async_maybe_transform,
)
from .._compat import cached_property
from .._resource import SyncAPIResource, AsyncAPIResource
from .._response import (
@ -381,7 +384,7 @@ class AsyncKeylessCertificates(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `zone_id` but received {zone_id!r}")
return await self._post(
f"/zones/{zone_id}/keyless_certificates",
body=maybe_transform(
body=await async_maybe_transform(
{
"certificate": certificate,
"host": host,
@ -541,7 +544,7 @@ class AsyncKeylessCertificates(AsyncAPIResource):
)
return await self._patch(
f"/zones/{zone_id}/keyless_certificates/{keyless_certificate_id}",
body=maybe_transform(
body=await async_maybe_transform(
{
"enabled": enabled,
"host": host,

9
src/cloudflare/resources/kv/namespaces/bulk.py
View file

@ -7,7 +7,10 @@ from typing import Any, List, Iterable, cast
import httpx
from ...._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ...._utils import maybe_transform
from ...._utils import (
maybe_transform,
async_maybe_transform,
)
from ...._compat import cached_property
from ...._resource import SyncAPIResource, AsyncAPIResource
from ...._response import (
@ -197,7 +200,7 @@ class AsyncBulk(AsyncAPIResource):
BulkUpdateResponse,
await self._put(
f"/accounts/{account_id}/storage/kv/namespaces/{namespace_id}/bulk",
body=maybe_transform(body, bulk_update_params.BulkUpdateParams),
body=await async_maybe_transform(body, bulk_update_params.BulkUpdateParams),
options=make_request_options(
extra_headers=extra_headers,
extra_query=extra_query,
@ -250,7 +253,7 @@ class AsyncBulk(AsyncAPIResource):
BulkDeleteResponse,
await self._delete(
f"/accounts/{account_id}/storage/kv/namespaces/{namespace_id}/bulk",
body=maybe_transform(body, bulk_delete_params.BulkDeleteParams),
body=await async_maybe_transform(body, bulk_delete_params.BulkDeleteParams),
options=make_request_options(
extra_headers=extra_headers,
extra_query=extra_query,

7
src/cloudflare/resources/kv/namespaces/keys.py
View file

@ -7,7 +7,10 @@ from typing import Type, cast
import httpx
from ...._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ...._utils import maybe_transform
from ...._utils import (
maybe_transform,
async_maybe_transform,
)
from ...._compat import cached_property
from ...._resource import SyncAPIResource, AsyncAPIResource
from ...._response import (
@ -163,7 +166,7 @@ class AsyncKeys(AsyncAPIResource):
extra_query=extra_query,
extra_body=extra_body,
timeout=timeout,
query=maybe_transform(
query=await async_maybe_transform(
{
"cursor": cursor,
"limit": limit,

9
src/cloudflare/resources/kv/namespaces/namespaces.py
View file

@ -40,7 +40,10 @@ from .metadata import (
AsyncMetadataWithStreamingResponse,
)
from ...._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ...._utils import maybe_transform
from ...._utils import (
maybe_transform,
async_maybe_transform,
)
from ...._compat import cached_property
from ....types.kv import (
NamespaceListResponse,
@ -362,7 +365,7 @@ class AsyncNamespaces(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `account_id` but received {account_id!r}")
return await self._post(
f"/accounts/{account_id}/storage/kv/namespaces",
body=maybe_transform({"title": title}, namespace_create_params.NamespaceCreateParams),
body=await async_maybe_transform({"title": title}, namespace_create_params.NamespaceCreateParams),
options=make_request_options(
extra_headers=extra_headers,
extra_query=extra_query,
@ -412,7 +415,7 @@ class AsyncNamespaces(AsyncAPIResource):
NamespaceUpdateResponse,
await self._put(
f"/accounts/{account_id}/storage/kv/namespaces/{namespace_id}",
body=maybe_transform({"title": title}, namespace_update_params.NamespaceUpdateParams),
body=await async_maybe_transform({"title": title}, namespace_update_params.NamespaceUpdateParams),
options=make_request_options(
extra_headers=extra_headers,
extra_query=extra_query,

7
src/cloudflare/resources/kv/namespaces/values.py
View file

@ -7,7 +7,10 @@ from typing import Any, cast
import httpx
from ...._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ...._utils import maybe_transform
from ...._utils import (
maybe_transform,
async_maybe_transform,
)
from ...._compat import cached_property
from ...._resource import SyncAPIResource, AsyncAPIResource
from ...._response import (
@ -280,7 +283,7 @@ class AsyncValues(AsyncAPIResource):
ValueUpdateResponse,
await self._put(
f"/accounts/{account_id}/storage/kv/namespaces/{namespace_id}/values/{key_name}",
body=maybe_transform(
body=await async_maybe_transform(
{
"metadata": metadata,
"value": value,

11
src/cloudflare/resources/load_balancers/load_balancers.py
View file

@ -35,7 +35,10 @@ from .regions import (
AsyncRegionsWithStreamingResponse,
)
from ..._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ..._utils import maybe_transform
from ..._utils import (
maybe_transform,
async_maybe_transform,
)
from .monitors import (
Monitors,
AsyncMonitors,
@ -1028,7 +1031,7 @@ class AsyncLoadBalancers(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `zone_id` but received {zone_id!r}")
return await self._post(
f"/zones/{zone_id}/load_balancers",
body=maybe_transform(
body=await async_maybe_transform(
{
"default_pools": default_pools,
"fallback_pool": fallback_pool,
@ -1232,7 +1235,7 @@ class AsyncLoadBalancers(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `load_balancer_id` but received {load_balancer_id!r}")
return await self._put(
f"/zones/{zone_id}/load_balancers/{load_balancer_id}",
body=maybe_transform(
body=await async_maybe_transform(
{
"default_pools": default_pools,
"fallback_pool": fallback_pool,
@ -1514,7 +1517,7 @@ class AsyncLoadBalancers(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `load_balancer_id` but received {load_balancer_id!r}")
return await self._patch(
f"/zones/{zone_id}/load_balancers/{load_balancer_id}",
body=maybe_transform(
body=await async_maybe_transform(
{
"adaptive_routing": adaptive_routing,
"country_pools": country_pools,

11
src/cloudflare/resources/load_balancers/monitors/monitors.py
View file

@ -16,7 +16,10 @@ from .previews import (
AsyncPreviewsWithStreamingResponse,
)
from ...._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ...._utils import maybe_transform
from ...._utils import (
maybe_transform,
async_maybe_transform,
)
from ...._compat import cached_property
from .references import (
References,
@ -685,7 +688,7 @@ class AsyncMonitors(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `account_id` but received {account_id!r}")
return await self._post(
f"/accounts/{account_id}/load_balancers/monitors",
body=maybe_transform(
body=await async_maybe_transform(
{
"expected_codes": expected_codes,
"allow_insecure": allow_insecure,
@ -813,7 +816,7 @@ class AsyncMonitors(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `monitor_id` but received {monitor_id!r}")
return await self._put(
f"/accounts/{account_id}/load_balancers/monitors/{monitor_id}",
body=maybe_transform(
body=await async_maybe_transform(
{
"expected_codes": expected_codes,
"allow_insecure": allow_insecure,
@ -1022,7 +1025,7 @@ class AsyncMonitors(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `monitor_id` but received {monitor_id!r}")
return await self._patch(
f"/accounts/{account_id}/load_balancers/monitors/{monitor_id}",
body=maybe_transform(
body=await async_maybe_transform(
{
"expected_codes": expected_codes,
"allow_insecure": allow_insecure,

7
src/cloudflare/resources/load_balancers/monitors/previews.py
View file

@ -8,7 +8,10 @@ from typing_extensions import Literal
import httpx
from ...._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ...._utils import maybe_transform
from ...._utils import (
maybe_transform,
async_maybe_transform,
)
from ...._compat import cached_property
from ...._resource import SyncAPIResource, AsyncAPIResource
from ...._response import (
@ -274,7 +277,7 @@ class AsyncPreviews(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `monitor_id` but received {monitor_id!r}")
return await self._post(
f"/accounts/{account_id}/load_balancers/monitors/{monitor_id}/preview",
body=maybe_transform(
body=await async_maybe_transform(
{
"expected_codes": expected_codes,
"allow_insecure": allow_insecure,

7
src/cloudflare/resources/load_balancers/pools/health.py
View file

@ -8,7 +8,10 @@ from typing_extensions import Literal
import httpx
from ...._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ...._utils import maybe_transform
from ...._utils import (
maybe_transform,
async_maybe_transform,
)
from ...._compat import cached_property
from ...._resource import SyncAPIResource, AsyncAPIResource
from ...._response import (
@ -321,7 +324,7 @@ class AsyncHealth(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `pool_id` but received {pool_id!r}")
return await self._post(
f"/accounts/{account_id}/load_balancers/pools/{pool_id}/preview",
body=maybe_transform(
body=await async_maybe_transform(
{
"expected_codes": expected_codes,
"allow_insecure": allow_insecure,

13
src/cloudflare/resources/load_balancers/pools/pools.py
View file

@ -16,7 +16,10 @@ from .health import (
AsyncHealthWithStreamingResponse,
)
from ...._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ...._utils import maybe_transform
from ...._utils import (
maybe_transform,
async_maybe_transform,
)
from ...._compat import cached_property
from .references import (
References,
@ -673,7 +676,7 @@ class AsyncPools(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `account_id` but received {account_id!r}")
return await self._post(
f"/accounts/{account_id}/load_balancers/pools",
body=maybe_transform(
body=await async_maybe_transform(
{
"name": name,
"origins": origins,
@ -807,7 +810,7 @@ class AsyncPools(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `pool_id` but received {pool_id!r}")
return await self._put(
f"/accounts/{account_id}/load_balancers/pools/{pool_id}",
body=maybe_transform(
body=await async_maybe_transform(
{
"name": name,
"origins": origins,
@ -873,7 +876,7 @@ class AsyncPools(AsyncAPIResource):
extra_query=extra_query,
extra_body=extra_body,
timeout=timeout,
query=maybe_transform({"monitor": monitor}, pool_list_params.PoolListParams),
query=await async_maybe_transform({"monitor": monitor}, pool_list_params.PoolListParams),
post_parser=ResultWrapper._unwrapper,
),
cast_to=cast(Type[Optional[PoolListResponse]], ResultWrapper[PoolListResponse]),
@ -1028,7 +1031,7 @@ class AsyncPools(AsyncAPIResource):
raise ValueError(f"Expected a non-empty value for `pool_id` but received {pool_id!r}")
return await self._patch(
f"/accounts/{account_id}/load_balancers/pools/{pool_id}",
body=maybe_transform(
body=await async_maybe_transform(
{
"check_regions": check_regions,
"description": description,

7
src/cloudflare/resources/load_balancers/regions.py
View file

@ -8,7 +8,10 @@ from typing_extensions import Literal
import httpx
from ..._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ..._utils import maybe_transform
from ..._utils import (
maybe_transform,
async_maybe_transform,
)
from ..._compat import cached_property
from ..._resource import SyncAPIResource, AsyncAPIResource
from ..._response import (
@ -206,7 +209,7 @@ class AsyncRegions(AsyncAPIResource):
extra_query=extra_query,
extra_body=extra_body,
timeout=timeout,
query=maybe_transform(
query=await async_maybe_transform(
{
"country_code_a2": country_code_a2,
"subdivision_code": subdivision_code,

7
src/cloudflare/resources/load_balancers/searches.py
View file

@ -7,7 +7,10 @@ from typing import Type, Optional, cast
import httpx
from ..._types import NOT_GIVEN, Body, Query, Headers, NotGiven
from ..._utils import maybe_transform
from ..._utils import (
maybe_transform,
async_maybe_transform,
)
from ..._compat import cached_property
from ..._resource import SyncAPIResource, AsyncAPIResource
from ..._response import (
@ -131,7 +134,7 @@ class AsyncSearches(AsyncAPIResource):
extra_query=extra_query,
extra_body=extra_body,
timeout=timeout,
query=maybe_transform(
query=await async_maybe_transform(
{
"page": page,
"per_page": per_page,

Some files were not shown because too many files have changed in this diff Show more