cloudflare-python/src/cloudflare/resources/images/v1/variants.py

632 lines
24 KiB
Python

# File generated from our OpenAPI spec by Stainless. See CONTRIBUTING.md for details.
from __future__ import annotations
from typing import Any, Type, cast
import httpx
from ...._types import Body, Omit, Query, Headers, NotGiven, omit, not_given
from ...._utils import maybe_transform, async_maybe_transform
from ...._compat import cached_property
from ...._resource import SyncAPIResource, AsyncAPIResource
from ...._response import (
to_raw_response_wrapper,
to_streamed_response_wrapper,
async_to_raw_response_wrapper,
async_to_streamed_response_wrapper,
)
from ...._wrappers import ResultWrapper
from ...._base_client import make_request_options
from ....types.images.v1 import variant_edit_params, variant_create_params
from ....types.images.v1.variant import Variant
from ....types.images.v1.variant_get_response import VariantGetResponse
from ....types.images.v1.variant_edit_response import VariantEditResponse
from ....types.images.v1.variant_create_response import VariantCreateResponse
from ....types.images.v1.variant_delete_response import VariantDeleteResponse
__all__ = ["VariantsResource", "AsyncVariantsResource"]
class VariantsResource(SyncAPIResource):
@cached_property
def with_raw_response(self) -> VariantsResourceWithRawResponse:
"""
This property can be used as a prefix for any HTTP method call to return
the raw response object instead of the parsed content.
For more information, see https://www.github.com/cloudflare/cloudflare-python#accessing-raw-response-data-eg-headers
"""
return VariantsResourceWithRawResponse(self)
@cached_property
def with_streaming_response(self) -> VariantsResourceWithStreamingResponse:
"""
An alternative to `.with_raw_response` that doesn't eagerly read the response body.
For more information, see https://www.github.com/cloudflare/cloudflare-python#with_streaming_response
"""
return VariantsResourceWithStreamingResponse(self)
def create(
self,
*,
account_id: str,
id: str,
options: variant_create_params.Options,
never_require_signed_urls: bool | Omit = omit,
# Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
# The extra values given here take precedence over values defined on the client or passed to this method.
extra_headers: Headers | None = None,
extra_query: Query | None = None,
extra_body: Body | None = None,
timeout: float | httpx.Timeout | None | NotGiven = not_given,
) -> VariantCreateResponse:
"""
Specify variants that allow you to resize images for different use cases.
Args:
account_id: Account identifier tag.
options: Allows you to define image resizing sizes for different use cases.
never_require_signed_urls: Indicates whether the variant can access an image without a signature,
regardless of image access control.
extra_headers: Send extra headers
extra_query: Add additional query parameters to the request
extra_body: Add additional JSON properties to the request
timeout: Override the client-level default timeout for this request, in seconds
"""
if not account_id:
raise ValueError(f"Expected a non-empty value for `account_id` but received {account_id!r}")
return self._post(
f"/accounts/{account_id}/images/v1/variants",
body=maybe_transform(
{
"id": id,
"options": options,
"never_require_signed_urls": never_require_signed_urls,
},
variant_create_params.VariantCreateParams,
),
options=make_request_options(
extra_headers=extra_headers,
extra_query=extra_query,
extra_body=extra_body,
timeout=timeout,
post_parser=ResultWrapper[VariantCreateResponse]._unwrapper,
),
cast_to=cast(Type[VariantCreateResponse], ResultWrapper[VariantCreateResponse]),
)
def list(
self,
*,
account_id: str,
# Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
# The extra values given here take precedence over values defined on the client or passed to this method.
extra_headers: Headers | None = None,
extra_query: Query | None = None,
extra_body: Body | None = None,
timeout: float | httpx.Timeout | None | NotGiven = not_given,
) -> Variant:
"""
Lists existing variants.
Args:
account_id: Account identifier tag.
extra_headers: Send extra headers
extra_query: Add additional query parameters to the request
extra_body: Add additional JSON properties to the request
timeout: Override the client-level default timeout for this request, in seconds
"""
if not account_id:
raise ValueError(f"Expected a non-empty value for `account_id` but received {account_id!r}")
return self._get(
f"/accounts/{account_id}/images/v1/variants",
options=make_request_options(
extra_headers=extra_headers,
extra_query=extra_query,
extra_body=extra_body,
timeout=timeout,
post_parser=ResultWrapper[Variant]._unwrapper,
),
cast_to=cast(Type[Variant], ResultWrapper[Variant]),
)
def delete(
self,
variant_id: str,
*,
account_id: str,
# Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
# The extra values given here take precedence over values defined on the client or passed to this method.
extra_headers: Headers | None = None,
extra_query: Query | None = None,
extra_body: Body | None = None,
timeout: float | httpx.Timeout | None | NotGiven = not_given,
) -> VariantDeleteResponse:
"""
Deleting a variant purges the cache for all images associated with the variant.
Args:
account_id: Account identifier tag.
extra_headers: Send extra headers
extra_query: Add additional query parameters to the request
extra_body: Add additional JSON properties to the request
timeout: Override the client-level default timeout for this request, in seconds
"""
if not account_id:
raise ValueError(f"Expected a non-empty value for `account_id` but received {account_id!r}")
if not variant_id:
raise ValueError(f"Expected a non-empty value for `variant_id` but received {variant_id!r}")
return cast(
VariantDeleteResponse,
self._delete(
f"/accounts/{account_id}/images/v1/variants/{variant_id}",
options=make_request_options(
extra_headers=extra_headers,
extra_query=extra_query,
extra_body=extra_body,
timeout=timeout,
post_parser=ResultWrapper[VariantDeleteResponse]._unwrapper,
),
cast_to=cast(
Any, ResultWrapper[VariantDeleteResponse]
), # Union types cannot be passed in as arguments in the type system
),
)
def edit(
self,
variant_id: str,
*,
account_id: str,
options: variant_edit_params.Options,
never_require_signed_urls: bool | Omit = omit,
# Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
# The extra values given here take precedence over values defined on the client or passed to this method.
extra_headers: Headers | None = None,
extra_query: Query | None = None,
extra_body: Body | None = None,
timeout: float | httpx.Timeout | None | NotGiven = not_given,
) -> VariantEditResponse:
"""
Updating a variant purges the cache for all images associated with the variant.
Args:
account_id: Account identifier tag.
options: Allows you to define image resizing sizes for different use cases.
never_require_signed_urls: Indicates whether the variant can access an image without a signature,
regardless of image access control.
extra_headers: Send extra headers
extra_query: Add additional query parameters to the request
extra_body: Add additional JSON properties to the request
timeout: Override the client-level default timeout for this request, in seconds
"""
if not account_id:
raise ValueError(f"Expected a non-empty value for `account_id` but received {account_id!r}")
if not variant_id:
raise ValueError(f"Expected a non-empty value for `variant_id` but received {variant_id!r}")
return self._patch(
f"/accounts/{account_id}/images/v1/variants/{variant_id}",
body=maybe_transform(
{
"options": options,
"never_require_signed_urls": never_require_signed_urls,
},
variant_edit_params.VariantEditParams,
),
options=make_request_options(
extra_headers=extra_headers,
extra_query=extra_query,
extra_body=extra_body,
timeout=timeout,
post_parser=ResultWrapper[VariantEditResponse]._unwrapper,
),
cast_to=cast(Type[VariantEditResponse], ResultWrapper[VariantEditResponse]),
)
def get(
self,
variant_id: str,
*,
account_id: str,
# Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
# The extra values given here take precedence over values defined on the client or passed to this method.
extra_headers: Headers | None = None,
extra_query: Query | None = None,
extra_body: Body | None = None,
timeout: float | httpx.Timeout | None | NotGiven = not_given,
) -> VariantGetResponse:
"""
Fetch details for a single variant.
Args:
account_id: Account identifier tag.
extra_headers: Send extra headers
extra_query: Add additional query parameters to the request
extra_body: Add additional JSON properties to the request
timeout: Override the client-level default timeout for this request, in seconds
"""
if not account_id:
raise ValueError(f"Expected a non-empty value for `account_id` but received {account_id!r}")
if not variant_id:
raise ValueError(f"Expected a non-empty value for `variant_id` but received {variant_id!r}")
return self._get(
f"/accounts/{account_id}/images/v1/variants/{variant_id}",
options=make_request_options(
extra_headers=extra_headers,
extra_query=extra_query,
extra_body=extra_body,
timeout=timeout,
post_parser=ResultWrapper[VariantGetResponse]._unwrapper,
),
cast_to=cast(Type[VariantGetResponse], ResultWrapper[VariantGetResponse]),
)
class AsyncVariantsResource(AsyncAPIResource):
@cached_property
def with_raw_response(self) -> AsyncVariantsResourceWithRawResponse:
"""
This property can be used as a prefix for any HTTP method call to return
the raw response object instead of the parsed content.
For more information, see https://www.github.com/cloudflare/cloudflare-python#accessing-raw-response-data-eg-headers
"""
return AsyncVariantsResourceWithRawResponse(self)
@cached_property
def with_streaming_response(self) -> AsyncVariantsResourceWithStreamingResponse:
"""
An alternative to `.with_raw_response` that doesn't eagerly read the response body.
For more information, see https://www.github.com/cloudflare/cloudflare-python#with_streaming_response
"""
return AsyncVariantsResourceWithStreamingResponse(self)
async def create(
self,
*,
account_id: str,
id: str,
options: variant_create_params.Options,
never_require_signed_urls: bool | Omit = omit,
# Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
# The extra values given here take precedence over values defined on the client or passed to this method.
extra_headers: Headers | None = None,
extra_query: Query | None = None,
extra_body: Body | None = None,
timeout: float | httpx.Timeout | None | NotGiven = not_given,
) -> VariantCreateResponse:
"""
Specify variants that allow you to resize images for different use cases.
Args:
account_id: Account identifier tag.
options: Allows you to define image resizing sizes for different use cases.
never_require_signed_urls: Indicates whether the variant can access an image without a signature,
regardless of image access control.
extra_headers: Send extra headers
extra_query: Add additional query parameters to the request
extra_body: Add additional JSON properties to the request
timeout: Override the client-level default timeout for this request, in seconds
"""
if not account_id:
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=await async_maybe_transform(
{
"id": id,
"options": options,
"never_require_signed_urls": never_require_signed_urls,
},
variant_create_params.VariantCreateParams,
),
options=make_request_options(
extra_headers=extra_headers,
extra_query=extra_query,
extra_body=extra_body,
timeout=timeout,
post_parser=ResultWrapper[VariantCreateResponse]._unwrapper,
),
cast_to=cast(Type[VariantCreateResponse], ResultWrapper[VariantCreateResponse]),
)
async def list(
self,
*,
account_id: str,
# Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
# The extra values given here take precedence over values defined on the client or passed to this method.
extra_headers: Headers | None = None,
extra_query: Query | None = None,
extra_body: Body | None = None,
timeout: float | httpx.Timeout | None | NotGiven = not_given,
) -> Variant:
"""
Lists existing variants.
Args:
account_id: Account identifier tag.
extra_headers: Send extra headers
extra_query: Add additional query parameters to the request
extra_body: Add additional JSON properties to the request
timeout: Override the client-level default timeout for this request, in seconds
"""
if not account_id:
raise ValueError(f"Expected a non-empty value for `account_id` but received {account_id!r}")
return await self._get(
f"/accounts/{account_id}/images/v1/variants",
options=make_request_options(
extra_headers=extra_headers,
extra_query=extra_query,
extra_body=extra_body,
timeout=timeout,
post_parser=ResultWrapper[Variant]._unwrapper,
),
cast_to=cast(Type[Variant], ResultWrapper[Variant]),
)
async def delete(
self,
variant_id: str,
*,
account_id: str,
# Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
# The extra values given here take precedence over values defined on the client or passed to this method.
extra_headers: Headers | None = None,
extra_query: Query | None = None,
extra_body: Body | None = None,
timeout: float | httpx.Timeout | None | NotGiven = not_given,
) -> VariantDeleteResponse:
"""
Deleting a variant purges the cache for all images associated with the variant.
Args:
account_id: Account identifier tag.
extra_headers: Send extra headers
extra_query: Add additional query parameters to the request
extra_body: Add additional JSON properties to the request
timeout: Override the client-level default timeout for this request, in seconds
"""
if not account_id:
raise ValueError(f"Expected a non-empty value for `account_id` but received {account_id!r}")
if not variant_id:
raise ValueError(f"Expected a non-empty value for `variant_id` but received {variant_id!r}")
return cast(
VariantDeleteResponse,
await self._delete(
f"/accounts/{account_id}/images/v1/variants/{variant_id}",
options=make_request_options(
extra_headers=extra_headers,
extra_query=extra_query,
extra_body=extra_body,
timeout=timeout,
post_parser=ResultWrapper[VariantDeleteResponse]._unwrapper,
),
cast_to=cast(
Any, ResultWrapper[VariantDeleteResponse]
), # Union types cannot be passed in as arguments in the type system
),
)
async def edit(
self,
variant_id: str,
*,
account_id: str,
options: variant_edit_params.Options,
never_require_signed_urls: bool | Omit = omit,
# Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
# The extra values given here take precedence over values defined on the client or passed to this method.
extra_headers: Headers | None = None,
extra_query: Query | None = None,
extra_body: Body | None = None,
timeout: float | httpx.Timeout | None | NotGiven = not_given,
) -> VariantEditResponse:
"""
Updating a variant purges the cache for all images associated with the variant.
Args:
account_id: Account identifier tag.
options: Allows you to define image resizing sizes for different use cases.
never_require_signed_urls: Indicates whether the variant can access an image without a signature,
regardless of image access control.
extra_headers: Send extra headers
extra_query: Add additional query parameters to the request
extra_body: Add additional JSON properties to the request
timeout: Override the client-level default timeout for this request, in seconds
"""
if not account_id:
raise ValueError(f"Expected a non-empty value for `account_id` but received {account_id!r}")
if not variant_id:
raise ValueError(f"Expected a non-empty value for `variant_id` but received {variant_id!r}")
return await self._patch(
f"/accounts/{account_id}/images/v1/variants/{variant_id}",
body=await async_maybe_transform(
{
"options": options,
"never_require_signed_urls": never_require_signed_urls,
},
variant_edit_params.VariantEditParams,
),
options=make_request_options(
extra_headers=extra_headers,
extra_query=extra_query,
extra_body=extra_body,
timeout=timeout,
post_parser=ResultWrapper[VariantEditResponse]._unwrapper,
),
cast_to=cast(Type[VariantEditResponse], ResultWrapper[VariantEditResponse]),
)
async def get(
self,
variant_id: str,
*,
account_id: str,
# Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
# The extra values given here take precedence over values defined on the client or passed to this method.
extra_headers: Headers | None = None,
extra_query: Query | None = None,
extra_body: Body | None = None,
timeout: float | httpx.Timeout | None | NotGiven = not_given,
) -> VariantGetResponse:
"""
Fetch details for a single variant.
Args:
account_id: Account identifier tag.
extra_headers: Send extra headers
extra_query: Add additional query parameters to the request
extra_body: Add additional JSON properties to the request
timeout: Override the client-level default timeout for this request, in seconds
"""
if not account_id:
raise ValueError(f"Expected a non-empty value for `account_id` but received {account_id!r}")
if not variant_id:
raise ValueError(f"Expected a non-empty value for `variant_id` but received {variant_id!r}")
return await self._get(
f"/accounts/{account_id}/images/v1/variants/{variant_id}",
options=make_request_options(
extra_headers=extra_headers,
extra_query=extra_query,
extra_body=extra_body,
timeout=timeout,
post_parser=ResultWrapper[VariantGetResponse]._unwrapper,
),
cast_to=cast(Type[VariantGetResponse], ResultWrapper[VariantGetResponse]),
)
class VariantsResourceWithRawResponse:
def __init__(self, variants: VariantsResource) -> None:
self._variants = variants
self.create = to_raw_response_wrapper(
variants.create,
)
self.list = to_raw_response_wrapper(
variants.list,
)
self.delete = to_raw_response_wrapper(
variants.delete,
)
self.edit = to_raw_response_wrapper(
variants.edit,
)
self.get = to_raw_response_wrapper(
variants.get,
)
class AsyncVariantsResourceWithRawResponse:
def __init__(self, variants: AsyncVariantsResource) -> None:
self._variants = variants
self.create = async_to_raw_response_wrapper(
variants.create,
)
self.list = async_to_raw_response_wrapper(
variants.list,
)
self.delete = async_to_raw_response_wrapper(
variants.delete,
)
self.edit = async_to_raw_response_wrapper(
variants.edit,
)
self.get = async_to_raw_response_wrapper(
variants.get,
)
class VariantsResourceWithStreamingResponse:
def __init__(self, variants: VariantsResource) -> None:
self._variants = variants
self.create = to_streamed_response_wrapper(
variants.create,
)
self.list = to_streamed_response_wrapper(
variants.list,
)
self.delete = to_streamed_response_wrapper(
variants.delete,
)
self.edit = to_streamed_response_wrapper(
variants.edit,
)
self.get = to_streamed_response_wrapper(
variants.get,
)
class AsyncVariantsResourceWithStreamingResponse:
def __init__(self, variants: AsyncVariantsResource) -> None:
self._variants = variants
self.create = async_to_streamed_response_wrapper(
variants.create,
)
self.list = async_to_streamed_response_wrapper(
variants.list,
)
self.delete = async_to_streamed_response_wrapper(
variants.delete,
)
self.edit = async_to_streamed_response_wrapper(
variants.edit,
)
self.get = async_to_streamed_response_wrapper(
variants.get,
)