chore(internal): codegen related update

Author: stainless-app[bot]

src/cloudflare/resources/radar/ai/to_markdown.py

@@ -4,8 +4,8 @@
 
 import httpx
 
-from ...._types import NOT_GIVEN, Body, Query, Headers, NotGiven, FileTypes
-from ...._utils import maybe_transform
+from ...._files import read_file_content
+from ...._types import NOT_GIVEN, Body, Query, Headers, NotGiven, FileContent
 from ...._compat import cached_property
 from ...._resource import SyncAPIResource, AsyncAPIResource
 from ...._response import (
@@ -16,7 +16,6 @@
 )
 from ....pagination import SyncSinglePage, AsyncSinglePage
 from ...._base_client import AsyncPaginator, make_request_options
-from ....types.radar.ai import to_markdown_create_params
 from ....types.radar.ai.to_markdown_create_response import ToMarkdownCreateResponse
 
 __all__ = ["ToMarkdownResource", "AsyncToMarkdownResource"]
@@ -44,7 +43,7 @@ def with_streaming_response(self) -> ToMarkdownResourceWithStreamingResponse:
 
     def create(
         self,
-        body: FileTypes | NotGiven = NOT_GIVEN,
+        body: FileContent,
         *,
         account_id: str,
         # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
@@ -68,10 +67,11 @@ def create(
         """
         if not account_id:
             raise ValueError(f"Expected a non-empty value for `account_id` but received {account_id!r}")
+        extra_headers = {"Content-Type": "application/octet-stream", **(extra_headers or {})}
         return self._get_api_list(
             f"/accounts/{account_id}/ai/tomarkdown",
             page=SyncSinglePage[ToMarkdownCreateResponse],
-            body=maybe_transform(body, to_markdown_create_params.ToMarkdownCreateParams),
+            body=read_file_content(body),
             options=make_request_options(
                 extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
             ),
@@ -102,7 +102,7 @@ def with_streaming_response(self) -> AsyncToMarkdownResourceWithStreamingRespons
 
     def create(
         self,
-        body: FileTypes | NotGiven = NOT_GIVEN,
+        body: FileContent,
         *,
         account_id: str,
         # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
@@ -126,10 +126,11 @@ def create(
         """
         if not account_id:
             raise ValueError(f"Expected a non-empty value for `account_id` but received {account_id!r}")
+        extra_headers = {"Content-Type": "application/octet-stream", **(extra_headers or {})}
         return self._get_api_list(
             f"/accounts/{account_id}/ai/tomarkdown",
             page=AsyncSinglePage[ToMarkdownCreateResponse],
-            body=maybe_transform(body, to_markdown_create_params.ToMarkdownCreateParams),
+            body=read_file_content(body),
             options=make_request_options(
                 extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
             ),

tests/api_resources/radar/ai/test_to_markdown.py

@@ -21,14 +21,6 @@ class TestToMarkdown:
     @pytest.mark.skip(reason="TODO: investigate prism error for invalid security scheme used")
     @parametrize
     def test_method_create(self, client: Cloudflare) -> None:
-        to_markdown = client.radar.ai.to_markdown.create(
-            account_id="023e105f4ecef8ad9ca31a8372d0c353",
-        )
-        assert_matches_type(SyncSinglePage[ToMarkdownCreateResponse], to_markdown, path=["response"])
-
-    @pytest.mark.skip(reason="TODO: investigate prism error for invalid security scheme used")
-    @parametrize
-    def test_method_create_with_all_params(self, client: Cloudflare) -> None:
         to_markdown = client.radar.ai.to_markdown.create(
             body=b"raw file contents",
             account_id="023e105f4ecef8ad9ca31a8372d0c353",
@@ -39,6 +31,7 @@ def test_method_create_with_all_params(self, client: Cloudflare) -> None:
     @parametrize
     def test_raw_response_create(self, client: Cloudflare) -> None:
         response = client.radar.ai.to_markdown.with_raw_response.create(
+            body=b"raw file contents",
             account_id="023e105f4ecef8ad9ca31a8372d0c353",
         )
 
@@ -51,6 +44,7 @@ def test_raw_response_create(self, client: Cloudflare) -> None:
     @parametrize
     def test_streaming_response_create(self, client: Cloudflare) -> None:
         with client.radar.ai.to_markdown.with_streaming_response.create(
+            body=b"raw file contents",
             account_id="023e105f4ecef8ad9ca31a8372d0c353",
         ) as response:
             assert not response.is_closed
@@ -66,6 +60,7 @@ def test_streaming_response_create(self, client: Cloudflare) -> None:
     def test_path_params_create(self, client: Cloudflare) -> None:
         with pytest.raises(ValueError, match=r"Expected a non-empty value for `account_id` but received ''"):
             client.radar.ai.to_markdown.with_raw_response.create(
+                body=b"raw file contents",
                 account_id="",
             )
 
@@ -78,14 +73,6 @@ class TestAsyncToMarkdown:
     @pytest.mark.skip(reason="TODO: investigate prism error for invalid security scheme used")
     @parametrize
     async def test_method_create(self, async_client: AsyncCloudflare) -> None:
-        to_markdown = await async_client.radar.ai.to_markdown.create(
-            account_id="023e105f4ecef8ad9ca31a8372d0c353",
-        )
-        assert_matches_type(AsyncSinglePage[ToMarkdownCreateResponse], to_markdown, path=["response"])
-
-    @pytest.mark.skip(reason="TODO: investigate prism error for invalid security scheme used")
-    @parametrize
-    async def test_method_create_with_all_params(self, async_client: AsyncCloudflare) -> None:
         to_markdown = await async_client.radar.ai.to_markdown.create(
             body=b"raw file contents",
             account_id="023e105f4ecef8ad9ca31a8372d0c353",
@@ -96,6 +83,7 @@ async def test_method_create_with_all_params(self, async_client: AsyncCloudflare
     @parametrize
     async def test_raw_response_create(self, async_client: AsyncCloudflare) -> None:
         response = await async_client.radar.ai.to_markdown.with_raw_response.create(
+            body=b"raw file contents",
             account_id="023e105f4ecef8ad9ca31a8372d0c353",
         )
 
@@ -108,6 +96,7 @@ async def test_raw_response_create(self, async_client: AsyncCloudflare) -> None:
     @parametrize
     async def test_streaming_response_create(self, async_client: AsyncCloudflare) -> None:
         async with async_client.radar.ai.to_markdown.with_streaming_response.create(
+            body=b"raw file contents",
             account_id="023e105f4ecef8ad9ca31a8372d0c353",
         ) as response:
             assert not response.is_closed
@@ -123,5 +112,6 @@ async def test_streaming_response_create(self, async_client: AsyncCloudflare) ->
     async def test_path_params_create(self, async_client: AsyncCloudflare) -> None:
         with pytest.raises(ValueError, match=r"Expected a non-empty value for `account_id` but received ''"):
             await async_client.radar.ai.to_markdown.with_raw_response.create(
+                body=b"raw file contents",
                 account_id="",
             )