feat(api): api update

Author: stainless-app[bot]

.stats.yml

@@ -1,4 +1,4 @@
 configured_endpoints: 17
-openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/groqcloud%2Fgroqcloud-780f9b139f5c909c5896f2f12043529ba9eb68c60ccd7c62b717c98694656ec0.yml
-openapi_spec_hash: b5e6dad1b275951040d6330e39e13e83
+openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/groqcloud%2Fgroqcloud-71c67ebb4a7c6e403c7ff4097875bb7d7477f4c11c9ea133302676f25af1af80.yml
+openapi_spec_hash: 0bcea04a8f775a28c9081ecddde169ab
 config_hash: 6b1c374dcc1ffa3165dd22f52a77ff89

api.md

@@ -129,19 +129,13 @@ Methods:
 Types:
 
 ```python
-from groq.types import (
-    FileCreateResponse,
-    FileListResponse,
-    FileDeleteResponse,
-    FileContentResponse,
-    FileInfoResponse,
-)
+from groq.types import FileCreateResponse, FileListResponse, FileDeleteResponse, FileInfoResponse
 ```
 
 Methods:
 
 - <code title="post /openai/v1/files">client.files.<a href="./src/groq/resources/files.py">create</a>(\*\*<a href="src/groq/types/file_create_params.py">params</a>) -> <a href="./src/groq/types/file_create_response.py">FileCreateResponse</a></code>
 - <code title="get /openai/v1/files">client.files.<a href="./src/groq/resources/files.py">list</a>() -> <a href="./src/groq/types/file_list_response.py">FileListResponse</a></code>
 - <code title="delete /openai/v1/files/{file_id}">client.files.<a href="./src/groq/resources/files.py">delete</a>(file_id) -> <a href="./src/groq/types/file_delete_response.py">FileDeleteResponse</a></code>
-- <code title="get /openai/v1/files/{file_id}/content">client.files.<a href="./src/groq/resources/files.py">content</a>(file_id) -> str</code>
+- <code title="get /openai/v1/files/{file_id}/content">client.files.<a href="./src/groq/resources/files.py">content</a>(file_id) -> BinaryAPIResponse</code>
 - <code title="get /openai/v1/files/{file_id}">client.files.<a href="./src/groq/resources/files.py">info</a>(file_id) -> <a href="./src/groq/types/file_info_response.py">FileInfoResponse</a></code>

src/groq/resources/files.py

@@ -18,10 +18,18 @@
 from .._compat import cached_property
 from .._resource import SyncAPIResource, AsyncAPIResource
 from .._response import (
+    BinaryAPIResponse,
+    AsyncBinaryAPIResponse,
+    StreamedBinaryAPIResponse,
+    AsyncStreamedBinaryAPIResponse,
     to_raw_response_wrapper,
     to_streamed_response_wrapper,
     async_to_raw_response_wrapper,
+    to_custom_raw_response_wrapper,
     async_to_streamed_response_wrapper,
+    to_custom_streamed_response_wrapper,
+    async_to_custom_raw_response_wrapper,
+    async_to_custom_streamed_response_wrapper,
 )
 from .._base_client import make_request_options
 from ..types.file_info_response import FileInfoResponse
@@ -169,7 +177,7 @@ def content(
         extra_query: Query | None = None,
         extra_body: Body | None = None,
         timeout: float | httpx.Timeout | None | NotGiven = NOT_GIVEN,
-    ) -> str:
+    ) -> BinaryAPIResponse:
         """
         Returns the contents of the specified file.
 
@@ -184,12 +192,13 @@ def content(
         """
         if not file_id:
             raise ValueError(f"Expected a non-empty value for `file_id` but received {file_id!r}")
+        extra_headers = {"Accept": "application/octet-stream", **(extra_headers or {})}
         return self._get(
             f"/openai/v1/files/{file_id}/content",
             options=make_request_options(
                 extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
             ),
-            cast_to=str,
+            cast_to=BinaryAPIResponse,
         )
 
     def info(
@@ -363,7 +372,7 @@ async def content(
         extra_query: Query | None = None,
         extra_body: Body | None = None,
         timeout: float | httpx.Timeout | None | NotGiven = NOT_GIVEN,
-    ) -> str:
+    ) -> AsyncBinaryAPIResponse:
         """
         Returns the contents of the specified file.
 
@@ -378,12 +387,13 @@ async def content(
         """
         if not file_id:
             raise ValueError(f"Expected a non-empty value for `file_id` but received {file_id!r}")
+        extra_headers = {"Accept": "application/octet-stream", **(extra_headers or {})}
         return await self._get(
             f"/openai/v1/files/{file_id}/content",
             options=make_request_options(
                 extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
             ),
-            cast_to=str,
+            cast_to=AsyncBinaryAPIResponse,
         )
 
     async def info(
@@ -433,8 +443,9 @@ def __init__(self, files: Files) -> None:
         self.delete = to_raw_response_wrapper(
             files.delete,
         )
-        self.content = to_raw_response_wrapper(
+        self.content = to_custom_raw_response_wrapper(
             files.content,
+            BinaryAPIResponse,
         )
         self.info = to_raw_response_wrapper(
             files.info,
@@ -454,8 +465,9 @@ def __init__(self, files: AsyncFiles) -> None:
         self.delete = async_to_raw_response_wrapper(
             files.delete,
         )
-        self.content = async_to_raw_response_wrapper(
+        self.content = async_to_custom_raw_response_wrapper(
             files.content,
+            AsyncBinaryAPIResponse,
         )
         self.info = async_to_raw_response_wrapper(
             files.info,
@@ -475,8 +487,9 @@ def __init__(self, files: Files) -> None:
         self.delete = to_streamed_response_wrapper(
             files.delete,
         )
-        self.content = to_streamed_response_wrapper(
+        self.content = to_custom_streamed_response_wrapper(
             files.content,
+            StreamedBinaryAPIResponse,
         )
         self.info = to_streamed_response_wrapper(
             files.info,
@@ -496,8 +509,9 @@ def __init__(self, files: AsyncFiles) -> None:
         self.delete = async_to_streamed_response_wrapper(
             files.delete,
         )
-        self.content = async_to_streamed_response_wrapper(
+        self.content = async_to_custom_streamed_response_wrapper(
             files.content,
+            AsyncStreamedBinaryAPIResponse,
         )
         self.info = async_to_streamed_response_wrapper(
             files.info,

src/groq/types/__init__.py

@@ -21,7 +21,6 @@
 from .file_delete_response import FileDeleteResponse as FileDeleteResponse
 from .batch_cancel_response import BatchCancelResponse as BatchCancelResponse
 from .batch_create_response import BatchCreateResponse as BatchCreateResponse
-from .file_content_response import FileContentResponse as FileContentResponse
 from .batch_retrieve_response import BatchRetrieveResponse as BatchRetrieveResponse
 from .embedding_create_params import EmbeddingCreateParams as EmbeddingCreateParams
 from .create_embedding_response import CreateEmbeddingResponse as CreateEmbeddingResponse

src/groq/types/file_content_response.py

@@ -5,16 +5,19 @@
 import os
 from typing import Any, cast
 
+import httpx
 import pytest
+from respx import MockRouter
 
 from groq import Groq, AsyncGroq
-from groq.types import (
-    FileInfoResponse,
-    FileListResponse,
-    FileCreateResponse,
-    FileDeleteResponse,
-)
+from groq.types import FileInfoResponse, FileListResponse, FileCreateResponse, FileDeleteResponse
 from tests.utils import assert_matches_type
+from groq._response import (
+    BinaryAPIResponse,
+    AsyncBinaryAPIResponse,
+    StreamedBinaryAPIResponse,
+    AsyncStreamedBinaryAPIResponse,
+)
 
 base_url = os.environ.get("TEST_API_BASE_URL", "http://127.0.0.1:4010")
 
@@ -120,37 +123,49 @@ def test_path_params_delete(self, client: Groq) -> None:
             )
 
     @parametrize
-    def test_method_content(self, client: Groq) -> None:
+    @pytest.mark.respx(base_url=base_url)
+    def test_method_content(self, client: Groq, respx_mock: MockRouter) -> None:
+        respx_mock.get("/openai/v1/files/file_id/content").mock(return_value=httpx.Response(200, json={"foo": "bar"}))
         file = client.files.content(
             "file_id",
         )
-        assert_matches_type(str, file, path=["response"])
+        assert file.is_closed
+        assert file.json() == {"foo": "bar"}
+        assert cast(Any, file.is_closed) is True
+        assert isinstance(file, BinaryAPIResponse)
 
     @parametrize
-    def test_raw_response_content(self, client: Groq) -> None:
-        response = client.files.with_raw_response.content(
+    @pytest.mark.respx(base_url=base_url)
+    def test_raw_response_content(self, client: Groq, respx_mock: MockRouter) -> None:
+        respx_mock.get("/openai/v1/files/file_id/content").mock(return_value=httpx.Response(200, json={"foo": "bar"}))
+
+        file = client.files.with_raw_response.content(
             "file_id",
         )
 
-        assert response.is_closed is True
-        assert response.http_request.headers.get("X-Stainless-Lang") == "python"
-        file = response.parse()
-        assert_matches_type(str, file, path=["response"])
+        assert file.is_closed is True
+        assert file.http_request.headers.get("X-Stainless-Lang") == "python"
+        assert file.json() == {"foo": "bar"}
+        assert isinstance(file, BinaryAPIResponse)
 
     @parametrize
-    def test_streaming_response_content(self, client: Groq) -> None:
+    @pytest.mark.respx(base_url=base_url)
+    def test_streaming_response_content(self, client: Groq, respx_mock: MockRouter) -> None:
+        respx_mock.get("/openai/v1/files/file_id/content").mock(return_value=httpx.Response(200, json={"foo": "bar"}))
         with client.files.with_streaming_response.content(
             "file_id",
-        ) as response:
-            assert not response.is_closed
-            assert response.http_request.headers.get("X-Stainless-Lang") == "python"
+        ) as file:
+            assert not file.is_closed
+            assert file.http_request.headers.get("X-Stainless-Lang") == "python"
 
-            file = response.parse()
-            assert_matches_type(str, file, path=["response"])
+            assert file.json() == {"foo": "bar"}
+            assert cast(Any, file.is_closed) is True
+            assert isinstance(file, StreamedBinaryAPIResponse)
 
-        assert cast(Any, response.is_closed) is True
+        assert cast(Any, file.is_closed) is True
 
     @parametrize
+    @pytest.mark.respx(base_url=base_url)
     def test_path_params_content(self, client: Groq) -> None:
         with pytest.raises(ValueError, match=r"Expected a non-empty value for `file_id` but received ''"):
             client.files.with_raw_response.content(
@@ -297,37 +312,49 @@ async def test_path_params_delete(self, async_client: AsyncGroq) -> None:
             )
 
     @parametrize
-    async def test_method_content(self, async_client: AsyncGroq) -> None:
+    @pytest.mark.respx(base_url=base_url)
+    async def test_method_content(self, async_client: AsyncGroq, respx_mock: MockRouter) -> None:
+        respx_mock.get("/openai/v1/files/file_id/content").mock(return_value=httpx.Response(200, json={"foo": "bar"}))
         file = await async_client.files.content(
             "file_id",
         )
-        assert_matches_type(str, file, path=["response"])
+        assert file.is_closed
+        assert await file.json() == {"foo": "bar"}
+        assert cast(Any, file.is_closed) is True
+        assert isinstance(file, AsyncBinaryAPIResponse)
 
     @parametrize
-    async def test_raw_response_content(self, async_client: AsyncGroq) -> None:
-        response = await async_client.files.with_raw_response.content(
+    @pytest.mark.respx(base_url=base_url)
+    async def test_raw_response_content(self, async_client: AsyncGroq, respx_mock: MockRouter) -> None:
+        respx_mock.get("/openai/v1/files/file_id/content").mock(return_value=httpx.Response(200, json={"foo": "bar"}))
+
+        file = await async_client.files.with_raw_response.content(
             "file_id",
         )
 
-        assert response.is_closed is True
-        assert response.http_request.headers.get("X-Stainless-Lang") == "python"
-        file = await response.parse()
-        assert_matches_type(str, file, path=["response"])
+        assert file.is_closed is True
+        assert file.http_request.headers.get("X-Stainless-Lang") == "python"
+        assert await file.json() == {"foo": "bar"}
+        assert isinstance(file, AsyncBinaryAPIResponse)
 
     @parametrize
-    async def test_streaming_response_content(self, async_client: AsyncGroq) -> None:
+    @pytest.mark.respx(base_url=base_url)
+    async def test_streaming_response_content(self, async_client: AsyncGroq, respx_mock: MockRouter) -> None:
+        respx_mock.get("/openai/v1/files/file_id/content").mock(return_value=httpx.Response(200, json={"foo": "bar"}))
         async with async_client.files.with_streaming_response.content(
             "file_id",
-        ) as response:
-            assert not response.is_closed
-            assert response.http_request.headers.get("X-Stainless-Lang") == "python"
+        ) as file:
+            assert not file.is_closed
+            assert file.http_request.headers.get("X-Stainless-Lang") == "python"
 
-            file = await response.parse()
-            assert_matches_type(str, file, path=["response"])
+            assert await file.json() == {"foo": "bar"}
+            assert cast(Any, file.is_closed) is True
+            assert isinstance(file, AsyncStreamedBinaryAPIResponse)
 
-        assert cast(Any, response.is_closed) is True
+        assert cast(Any, file.is_closed) is True
 
     @parametrize
+    @pytest.mark.respx(base_url=base_url)
     async def test_path_params_content(self, async_client: AsyncGroq) -> None:
         with pytest.raises(ValueError, match=r"Expected a non-empty value for `file_id` but received ''"):
             await async_client.files.with_raw_response.content(