chore(api): upload stainless config from cloudflare-config

Author: stainless-app[bot]

.stats.yml

@@ -1,4 +1,4 @@
-configured_endpoints: 1793
+configured_endpoints: 1794
 openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/cloudflare%2Fcloudflare-bf6dcd562e592c1c6d992e04b39d5b372e2a7cb4d3fdcad23e483e21389bd3aa.yml
 openapi_spec_hash: 8b8da2355d909906fe7af3bc6f507487
-config_hash: fbc4fd68812ca98330ce3b204d1d103b
+config_hash: 0057f65f1f8efd88feb20d082d893305

api.md

@@ -3376,6 +3376,7 @@ Methods:
 
 - <code title="post /accounts/{account_id}/brand-protection/queries">client.brand_protection.queries.<a href="./src/cloudflare/resources/brand_protection/queries.py">create</a>(\*, account_id, \*\*<a href="src/cloudflare/types/brand_protection/query_create_params.py">params</a>) -> None</code>
 - <code title="delete /accounts/{account_id}/brand-protection/queries">client.brand_protection.queries.<a href="./src/cloudflare/resources/brand_protection/queries.py">delete</a>(\*, account_id, \*\*<a href="src/cloudflare/types/brand_protection/query_delete_params.py">params</a>) -> None</code>
+- <code title="post /accounts/{account_id}/brand-protection/queries/bulk">client.brand_protection.queries.<a href="./src/cloudflare/resources/brand_protection/queries.py">bulk</a>(\*, account_id, \*\*<a href="src/cloudflare/types/brand_protection/query_bulk_params.py">params</a>) -> None</code>
 
 ## Matches
 

src/cloudflare/resources/brand_protection/queries.py

@@ -2,7 +2,7 @@
 
 from __future__ import annotations
 
-from typing import Union
+from typing import Dict, Union, Iterable
 from datetime import datetime
 
 import httpx
@@ -18,7 +18,7 @@
     async_to_streamed_response_wrapper,
 )
 from ..._base_client import make_request_options
-from ...types.brand_protection import query_create_params, query_delete_params
+from ...types.brand_protection import query_bulk_params, query_create_params, query_delete_params
 
 __all__ = ["QueriesResource", "AsyncQueriesResource"]
 
@@ -154,6 +154,42 @@ def delete(
             cast_to=NoneType,
         )
 
+    def bulk(
+        self,
+        *,
+        account_id: str,
+        queries: Iterable[Dict[str, object]] | NotGiven = NOT_GIVEN,
+        # 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,
+    ) -> None:
+        """
+        Return a success message after creating new saved string queries in bulk
+
+        Args:
+          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}")
+        extra_headers = {"Accept": "*/*", **(extra_headers or {})}
+        return self._post(
+            f"/accounts/{account_id}/brand-protection/queries/bulk",
+            body=maybe_transform({"queries": queries}, query_bulk_params.QueryBulkParams),
+            options=make_request_options(
+                extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
+            ),
+            cast_to=NoneType,
+        )
+
 
 class AsyncQueriesResource(AsyncAPIResource):
     @cached_property
@@ -286,6 +322,42 @@ async def delete(
             cast_to=NoneType,
         )
 
+    async def bulk(
+        self,
+        *,
+        account_id: str,
+        queries: Iterable[Dict[str, object]] | NotGiven = NOT_GIVEN,
+        # 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,
+    ) -> None:
+        """
+        Return a success message after creating new saved string queries in bulk
+
+        Args:
+          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}")
+        extra_headers = {"Accept": "*/*", **(extra_headers or {})}
+        return await self._post(
+            f"/accounts/{account_id}/brand-protection/queries/bulk",
+            body=await async_maybe_transform({"queries": queries}, query_bulk_params.QueryBulkParams),
+            options=make_request_options(
+                extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
+            ),
+            cast_to=NoneType,
+        )
+
 
 class QueriesResourceWithRawResponse:
     def __init__(self, queries: QueriesResource) -> None:
@@ -297,6 +369,9 @@ def __init__(self, queries: QueriesResource) -> None:
         self.delete = to_raw_response_wrapper(
             queries.delete,
         )
+        self.bulk = to_raw_response_wrapper(
+            queries.bulk,
+        )
 
 
 class AsyncQueriesResourceWithRawResponse:
@@ -309,6 +384,9 @@ def __init__(self, queries: AsyncQueriesResource) -> None:
         self.delete = async_to_raw_response_wrapper(
             queries.delete,
         )
+        self.bulk = async_to_raw_response_wrapper(
+            queries.bulk,
+        )
 
 
 class QueriesResourceWithStreamingResponse:
@@ -321,6 +399,9 @@ def __init__(self, queries: QueriesResource) -> None:
         self.delete = to_streamed_response_wrapper(
             queries.delete,
         )
+        self.bulk = to_streamed_response_wrapper(
+            queries.bulk,
+        )
 
 
 class AsyncQueriesResourceWithStreamingResponse:
@@ -333,3 +414,6 @@ def __init__(self, queries: AsyncQueriesResource) -> None:
         self.delete = async_to_streamed_response_wrapper(
             queries.delete,
         )
+        self.bulk = async_to_streamed_response_wrapper(
+            queries.bulk,
+        )

src/cloudflare/types/brand_protection/__init__.py

@@ -3,6 +3,7 @@
 from __future__ import annotations
 
 from .match_get_params import MatchGetParams as MatchGetParams
+from .query_bulk_params import QueryBulkParams as QueryBulkParams
 from .logo_create_params import LogoCreateParams as LogoCreateParams
 from .match_get_response import MatchGetResponse as MatchGetResponse
 from .query_create_params import QueryCreateParams as QueryCreateParams

src/cloudflare/types/brand_protection/query_bulk_params.py

@@ -0,0 +1,14 @@
+# File generated from our OpenAPI spec by Stainless. See CONTRIBUTING.md for details.
+
+from __future__ import annotations
+
+from typing import Dict, Iterable
+from typing_extensions import Required, TypedDict
+
+__all__ = ["QueryBulkParams"]
+
+
+class QueryBulkParams(TypedDict, total=False):
+    account_id: Required[str]
+
+    queries: Iterable[Dict[str, object]]

tests/api_resources/brand_protection/test_queries.py

@@ -127,6 +127,57 @@ def test_path_params_delete(self, client: Cloudflare) -> None:
                 account_id="",
             )
 
+    @pytest.mark.skip(reason="TODO: investigate broken test, 401 Unauthorized")
+    @parametrize
+    def test_method_bulk(self, client: Cloudflare) -> None:
+        query = client.brand_protection.queries.bulk(
+            account_id="x",
+        )
+        assert query is None
+
+    @pytest.mark.skip(reason="TODO: investigate broken test, 401 Unauthorized")
+    @parametrize
+    def test_method_bulk_with_all_params(self, client: Cloudflare) -> None:
+        query = client.brand_protection.queries.bulk(
+            account_id="x",
+            queries=[{"foo": "bar"}],
+        )
+        assert query is None
+
+    @pytest.mark.skip(reason="TODO: investigate broken test, 401 Unauthorized")
+    @parametrize
+    def test_raw_response_bulk(self, client: Cloudflare) -> None:
+        response = client.brand_protection.queries.with_raw_response.bulk(
+            account_id="x",
+        )
+
+        assert response.is_closed is True
+        assert response.http_request.headers.get("X-Stainless-Lang") == "python"
+        query = response.parse()
+        assert query is None
+
+    @pytest.mark.skip(reason="TODO: investigate broken test, 401 Unauthorized")
+    @parametrize
+    def test_streaming_response_bulk(self, client: Cloudflare) -> None:
+        with client.brand_protection.queries.with_streaming_response.bulk(
+            account_id="x",
+        ) as response:
+            assert not response.is_closed
+            assert response.http_request.headers.get("X-Stainless-Lang") == "python"
+
+            query = response.parse()
+            assert query is None
+
+        assert cast(Any, response.is_closed) is True
+
+    @pytest.mark.skip(reason="TODO: investigate broken test, 401 Unauthorized")
+    @parametrize
+    def test_path_params_bulk(self, client: Cloudflare) -> None:
+        with pytest.raises(ValueError, match=r"Expected a non-empty value for `account_id` but received ''"):
+            client.brand_protection.queries.with_raw_response.bulk(
+                account_id="",
+            )
+
 
 class TestAsyncQueries:
     parametrize = pytest.mark.parametrize(
@@ -243,3 +294,54 @@ async def test_path_params_delete(self, async_client: AsyncCloudflare) -> None:
             await async_client.brand_protection.queries.with_raw_response.delete(
                 account_id="",
             )
+
+    @pytest.mark.skip(reason="TODO: investigate broken test, 401 Unauthorized")
+    @parametrize
+    async def test_method_bulk(self, async_client: AsyncCloudflare) -> None:
+        query = await async_client.brand_protection.queries.bulk(
+            account_id="x",
+        )
+        assert query is None
+
+    @pytest.mark.skip(reason="TODO: investigate broken test, 401 Unauthorized")
+    @parametrize
+    async def test_method_bulk_with_all_params(self, async_client: AsyncCloudflare) -> None:
+        query = await async_client.brand_protection.queries.bulk(
+            account_id="x",
+            queries=[{"foo": "bar"}],
+        )
+        assert query is None
+
+    @pytest.mark.skip(reason="TODO: investigate broken test, 401 Unauthorized")
+    @parametrize
+    async def test_raw_response_bulk(self, async_client: AsyncCloudflare) -> None:
+        response = await async_client.brand_protection.queries.with_raw_response.bulk(
+            account_id="x",
+        )
+
+        assert response.is_closed is True
+        assert response.http_request.headers.get("X-Stainless-Lang") == "python"
+        query = await response.parse()
+        assert query is None
+
+    @pytest.mark.skip(reason="TODO: investigate broken test, 401 Unauthorized")
+    @parametrize
+    async def test_streaming_response_bulk(self, async_client: AsyncCloudflare) -> None:
+        async with async_client.brand_protection.queries.with_streaming_response.bulk(
+            account_id="x",
+        ) as response:
+            assert not response.is_closed
+            assert response.http_request.headers.get("X-Stainless-Lang") == "python"
+
+            query = await response.parse()
+            assert query is None
+
+        assert cast(Any, response.is_closed) is True
+
+    @pytest.mark.skip(reason="TODO: investigate broken test, 401 Unauthorized")
+    @parametrize
+    async def test_path_params_bulk(self, async_client: AsyncCloudflare) -> None:
+        with pytest.raises(ValueError, match=r"Expected a non-empty value for `account_id` but received ''"):
+            await async_client.brand_protection.queries.with_raw_response.bulk(
+                account_id="",
+            )