feat(api): manual updates

Author: stainless-app[bot]

.stats.yml

@@ -1,4 +1,4 @@
 configured_endpoints: 42
-openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/imagekit-inc%2Fimagekit-911102f2eaf3be4b34381f6ba089330bed099bb72eb93667ce2f6e72b5934c8c.yml
-openapi_spec_hash: 637ad417a580137914441bd790b04cc2
+openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/imagekit-inc%2Fimagekit-0726d89b19f532c7fb92990d688a9bfb5aa4a9a871d64f49d4ba45bac6998e4a.yml
+openapi_spec_hash: 9525bb02ab496b3459a1f93ac50968e3
 config_hash: 70f9408b8d1dfbcf262a20d6eed50e1c

README.md

@@ -41,7 +41,7 @@ client = ImageKit(
 )
 
 response = client.files.upload(
-    file="https://www.example.com/public-url.jpg",
+    file=b"https://www.example.com/public-url.jpg",
     file_name="file-name.jpg",
 )
 print(response.video_codec)
@@ -73,7 +73,7 @@ client = AsyncImageKit(
 
 async def main() -> None:
     response = await client.files.upload(
-        file="https://www.example.com/public-url.jpg",
+        file=b"https://www.example.com/public-url.jpg",
         file_name="file-name.jpg",
     )
     print(response.video_codec)
@@ -110,7 +110,7 @@ async def main() -> None:
         http_client=DefaultAioHttpClient(),
     ) as client:
         response = await client.files.upload(
-            file="https://www.example.com/public-url.jpg",
+            file=b"https://www.example.com/public-url.jpg",
             file_name="file-name.jpg",
         )
         print(response.video_codec)
@@ -138,7 +138,7 @@ from imagekit import ImageKit
 client = ImageKit()
 
 response = client.files.upload(
-    file="file",
+    file=b"raw file contents",
     file_name="fileName",
     transformation={
         "post": [
@@ -167,7 +167,7 @@ from imagekit import ImageKit
 
 client = ImageKit()
 
-client.beta.v2.files.upload(
+client.files.upload(
     file=Path("/path/to/file"),
     file_name="fileName",
 )
@@ -192,7 +192,7 @@ client = ImageKit()
 
 try:
     client.files.upload(
-        file="https://www.example.com/public-url.jpg",
+        file=b"https://www.example.com/public-url.jpg",
         file_name="file-name.jpg",
     )
 except imagekit.APIConnectionError as e:
@@ -238,7 +238,7 @@ client = ImageKit(
 
 # Or, configure per-request:
 client.with_options(max_retries=5).files.upload(
-    file="https://www.example.com/public-url.jpg",
+    file=b"https://www.example.com/public-url.jpg",
     file_name="file-name.jpg",
 )
 ```
@@ -264,7 +264,7 @@ client = ImageKit(
 
 # Override per-request:
 client.with_options(timeout=5.0).files.upload(
-    file="https://www.example.com/public-url.jpg",
+    file=b"https://www.example.com/public-url.jpg",
     file_name="file-name.jpg",
 )
 ```
@@ -308,7 +308,7 @@ from imagekit import ImageKit
 
 client = ImageKit()
 response = client.files.with_raw_response.upload(
-    file="https://www.example.com/public-url.jpg",
+    file=b"https://www.example.com/public-url.jpg",
     file_name="file-name.jpg",
 )
 print(response.headers.get('X-My-Header'))
@@ -329,7 +329,7 @@ To stream the response body, use `.with_streaming_response` instead, which requi
 
 ```python
 with client.files.with_streaming_response.upload(
-    file="https://www.example.com/public-url.jpg",
+    file=b"https://www.example.com/public-url.jpg",
     file_name="file-name.jpg",
 ) as response:
     print(response.headers.get("X-My-Header"))

src/imagekit/resources/files/files.py

@@ -2,7 +2,7 @@
 
 from __future__ import annotations
 
-from typing import Dict, List, Iterable
+from typing import Dict, List, Mapping, Iterable, cast
 from typing_extensions import Literal
 
 import httpx
@@ -16,8 +16,8 @@
     AsyncBulkResourceWithStreamingResponse,
 )
 from ...types import file_copy_params, file_move_params, file_rename_params, file_update_params, file_upload_params
-from ..._types import NOT_GIVEN, Body, Query, Headers, NoneType, NotGiven
-from ..._utils import maybe_transform, async_maybe_transform
+from ..._types import NOT_GIVEN, Body, Query, Headers, NoneType, NotGiven, FileTypes
+from ..._utils import extract_files, maybe_transform, deepcopy_minimal, async_maybe_transform
 from .metadata import (
     MetadataResource,
     AsyncMetadataResource,
@@ -368,7 +368,7 @@ def rename(
     def upload(
         self,
         *,
-        file: str,
+        file: FileTypes,
         file_name: str,
         token: str | NotGiven = NOT_GIVEN,
         checks: str | NotGiven = NOT_GIVEN,
@@ -579,6 +579,34 @@ def upload(
 
           timeout: Override the client-level default timeout for this request, in seconds
         """
+        body = deepcopy_minimal(
+            {
+                "file": file,
+                "file_name": file_name,
+                "token": token,
+                "checks": checks,
+                "custom_coordinates": custom_coordinates,
+                "custom_metadata": custom_metadata,
+                "description": description,
+                "expire": expire,
+                "extensions": extensions,
+                "folder": folder,
+                "is_private_file": is_private_file,
+                "is_published": is_published,
+                "overwrite_ai_tags": overwrite_ai_tags,
+                "overwrite_custom_metadata": overwrite_custom_metadata,
+                "overwrite_file": overwrite_file,
+                "overwrite_tags": overwrite_tags,
+                "public_key": public_key,
+                "response_fields": response_fields,
+                "signature": signature,
+                "tags": tags,
+                "transformation": transformation,
+                "use_unique_file_name": use_unique_file_name,
+                "webhook_url": webhook_url,
+            }
+        )
+        files = extract_files(cast(Mapping[str, object], body), paths=[["file"]])
         # It should be noted that the actual Content-Type header that will be
         # sent to the server will contain a `boundary` parameter, e.g.
         # multipart/form-data; boundary=---abc--
@@ -587,34 +615,8 @@ def upload(
             "/api/v1/files/upload"
             if self._client._base_url_overridden
             else "https://upload.imagekit.io/api/v1/files/upload",
-            body=maybe_transform(
-                {
-                    "file": file,
-                    "file_name": file_name,
-                    "token": token,
-                    "checks": checks,
-                    "custom_coordinates": custom_coordinates,
-                    "custom_metadata": custom_metadata,
-                    "description": description,
-                    "expire": expire,
-                    "extensions": extensions,
-                    "folder": folder,
-                    "is_private_file": is_private_file,
-                    "is_published": is_published,
-                    "overwrite_ai_tags": overwrite_ai_tags,
-                    "overwrite_custom_metadata": overwrite_custom_metadata,
-                    "overwrite_file": overwrite_file,
-                    "overwrite_tags": overwrite_tags,
-                    "public_key": public_key,
-                    "response_fields": response_fields,
-                    "signature": signature,
-                    "tags": tags,
-                    "transformation": transformation,
-                    "use_unique_file_name": use_unique_file_name,
-                    "webhook_url": webhook_url,
-                },
-                file_upload_params.FileUploadParams,
-            ),
+            body=maybe_transform(body, file_upload_params.FileUploadParams),
+            files=files,
             options=make_request_options(
                 extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
             ),
@@ -937,7 +939,7 @@ async def rename(
     async def upload(
         self,
         *,
-        file: str,
+        file: FileTypes,
         file_name: str,
         token: str | NotGiven = NOT_GIVEN,
         checks: str | NotGiven = NOT_GIVEN,
@@ -1148,6 +1150,34 @@ async def upload(
 
           timeout: Override the client-level default timeout for this request, in seconds
         """
+        body = deepcopy_minimal(
+            {
+                "file": file,
+                "file_name": file_name,
+                "token": token,
+                "checks": checks,
+                "custom_coordinates": custom_coordinates,
+                "custom_metadata": custom_metadata,
+                "description": description,
+                "expire": expire,
+                "extensions": extensions,
+                "folder": folder,
+                "is_private_file": is_private_file,
+                "is_published": is_published,
+                "overwrite_ai_tags": overwrite_ai_tags,
+                "overwrite_custom_metadata": overwrite_custom_metadata,
+                "overwrite_file": overwrite_file,
+                "overwrite_tags": overwrite_tags,
+                "public_key": public_key,
+                "response_fields": response_fields,
+                "signature": signature,
+                "tags": tags,
+                "transformation": transformation,
+                "use_unique_file_name": use_unique_file_name,
+                "webhook_url": webhook_url,
+            }
+        )
+        files = extract_files(cast(Mapping[str, object], body), paths=[["file"]])
         # It should be noted that the actual Content-Type header that will be
         # sent to the server will contain a `boundary` parameter, e.g.
         # multipart/form-data; boundary=---abc--
@@ -1156,34 +1186,8 @@ async def upload(
             "/api/v1/files/upload"
             if self._client._base_url_overridden
             else "https://upload.imagekit.io/api/v1/files/upload",
-            body=await async_maybe_transform(
-                {
-                    "file": file,
-                    "file_name": file_name,
-                    "token": token,
-                    "checks": checks,
-                    "custom_coordinates": custom_coordinates,
-                    "custom_metadata": custom_metadata,
-                    "description": description,
-                    "expire": expire,
-                    "extensions": extensions,
-                    "folder": folder,
-                    "is_private_file": is_private_file,
-                    "is_published": is_published,
-                    "overwrite_ai_tags": overwrite_ai_tags,
-                    "overwrite_custom_metadata": overwrite_custom_metadata,
-                    "overwrite_file": overwrite_file,
-                    "overwrite_tags": overwrite_tags,
-                    "public_key": public_key,
-                    "response_fields": response_fields,
-                    "signature": signature,
-                    "tags": tags,
-                    "transformation": transformation,
-                    "use_unique_file_name": use_unique_file_name,
-                    "webhook_url": webhook_url,
-                },
-                file_upload_params.FileUploadParams,
-            ),
+            body=await async_maybe_transform(body, file_upload_params.FileUploadParams),
+            files=files,
             options=make_request_options(
                 extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
             ),

src/imagekit/types/file_upload_params.py

@@ -5,6 +5,7 @@
 from typing import Dict, List, Union, Iterable
 from typing_extensions import Literal, Required, Annotated, TypeAlias, TypedDict
 
+from .._types import FileTypes
 from .._utils import PropertyInfo
 
 __all__ = [
@@ -24,7 +25,7 @@
 
 
 class FileUploadParams(TypedDict, total=False):
-    file: Required[str]
+    file: Required[FileTypes]
     """The API accepts any of the following:
 
     - **Binary data** – send the raw bytes as `multipart/form-data`.

tests/api_resources/test_files.py

@@ -326,7 +326,7 @@ def test_streaming_response_rename(self, client: ImageKit) -> None:
     @parametrize
     def test_method_upload(self, client: ImageKit) -> None:
         file = client.files.upload(
-            file="file",
+            file=b"raw file contents",
             file_name="fileName",
         )
         assert_matches_type(FileUploadResponse, file, path=["response"])
@@ -335,7 +335,7 @@ def test_method_upload(self, client: ImageKit) -> None:
     @parametrize
     def test_method_upload_with_all_params(self, client: ImageKit) -> None:
         file = client.files.upload(
-            file="file",
+            file=b"raw file contents",
             file_name="fileName",
             token="token",
             checks='"request.folder" : "marketing/"\n',
@@ -397,7 +397,7 @@ def test_method_upload_with_all_params(self, client: ImageKit) -> None:
     @parametrize
     def test_raw_response_upload(self, client: ImageKit) -> None:
         response = client.files.with_raw_response.upload(
-            file="file",
+            file=b"raw file contents",
             file_name="fileName",
         )
 
@@ -410,7 +410,7 @@ def test_raw_response_upload(self, client: ImageKit) -> None:
     @parametrize
     def test_streaming_response_upload(self, client: ImageKit) -> None:
         with client.files.with_streaming_response.upload(
-            file="file",
+            file=b"raw file contents",
             file_name="fileName",
         ) as response:
             assert not response.is_closed
@@ -729,7 +729,7 @@ async def test_streaming_response_rename(self, async_client: AsyncImageKit) -> N
     @parametrize
     async def test_method_upload(self, async_client: AsyncImageKit) -> None:
         file = await async_client.files.upload(
-            file="file",
+            file=b"raw file contents",
             file_name="fileName",
         )
         assert_matches_type(FileUploadResponse, file, path=["response"])
@@ -738,7 +738,7 @@ async def test_method_upload(self, async_client: AsyncImageKit) -> None:
     @parametrize
     async def test_method_upload_with_all_params(self, async_client: AsyncImageKit) -> None:
         file = await async_client.files.upload(
-            file="file",
+            file=b"raw file contents",
             file_name="fileName",
             token="token",
             checks='"request.folder" : "marketing/"\n',
@@ -800,7 +800,7 @@ async def test_method_upload_with_all_params(self, async_client: AsyncImageKit)
     @parametrize
     async def test_raw_response_upload(self, async_client: AsyncImageKit) -> None:
         response = await async_client.files.with_raw_response.upload(
-            file="file",
+            file=b"raw file contents",
             file_name="fileName",
         )
 
@@ -813,7 +813,7 @@ async def test_raw_response_upload(self, async_client: AsyncImageKit) -> None:
     @parametrize
     async def test_streaming_response_upload(self, async_client: AsyncImageKit) -> None:
         async with async_client.files.with_streaming_response.upload(
-            file="file",
+            file=b"raw file contents",
             file_name="fileName",
         ) as response:
             assert not response.is_closed