feat(api): manual updates

Author: stainless-app[bot]

.stats.yml

@@ -1,4 +1,4 @@
-configured_endpoints: 11
+configured_endpoints: 12
 openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/supermemory--inc%2Fsupermemory-e6735b03c258b382c527550bb78042bdc3aad32a5cf564785dcb9f3fb13a2862.yml
 openapi_spec_hash: 8168fb51314d986893554e1cc935ca7d
-config_hash: c8c1f2b0d63387d621f0cf066ae3379f
+config_hash: 8477e3ee6fd596ab6ac911d052e4de79

README.md

@@ -77,6 +77,23 @@ Nested request parameters are [TypedDicts](https://docs.python.org/3/library/typ
 
 Typed requests and responses provide autocomplete and documentation within your editor. If you would like to see type errors in VS Code to help catch bugs earlier, set `python.analysis.typeCheckingMode` to `basic`.
 
+## File uploads
+
+Request parameters that correspond to file uploads can be passed as `bytes`, or a [`PathLike`](https://docs.python.org/3/library/os.html#os.PathLike) instance or a tuple of `(filename, contents, media type)`.
+
+```python
+from pathlib import Path
+from supermemory import Supermemory
+
+client = Supermemory()
+
+client.memories.upload_file(
+    file=Path("/path/to/file"),
+)
+```
+
+The async client uses the exact same interface. If you pass a [`PathLike`](https://docs.python.org/3/library/os.html#os.PathLike) instance, the file contents will be read asynchronously automatically.
+
 ## Handling errors
 
 When the library is unable to connect to the API (for example, due to network connection problems or a timeout), a subclass of `supermemory.APIConnectionError` is raised.

api.md

@@ -9,6 +9,7 @@ from supermemory.types import (
     MemoryDeleteResponse,
     MemoryAddResponse,
     MemoryGetResponse,
+    MemoryUploadFileResponse,
 )
 ```
 
@@ -19,6 +20,7 @@ Methods:
 - <code title="delete /v3/memories/{id}">client.memories.<a href="./src/supermemory/resources/memories.py">delete</a>(id) -> <a href="./src/supermemory/types/memory_delete_response.py">MemoryDeleteResponse</a></code>
 - <code title="post /v3/memories">client.memories.<a href="./src/supermemory/resources/memories.py">add</a>(\*\*<a href="src/supermemory/types/memory_add_params.py">params</a>) -> <a href="./src/supermemory/types/memory_add_response.py">MemoryAddResponse</a></code>
 - <code title="get /v3/memories/{id}">client.memories.<a href="./src/supermemory/resources/memories.py">get</a>(id) -> <a href="./src/supermemory/types/memory_get_response.py">MemoryGetResponse</a></code>
+- <code title="post /v3/memories/file">client.memories.<a href="./src/supermemory/resources/memories.py">upload_file</a>(\*\*<a href="src/supermemory/types/memory_upload_file_params.py">params</a>) -> <a href="./src/supermemory/types/memory_upload_file_response.py">MemoryUploadFileResponse</a></code>
 
 # Search
 

src/supermemory/_files.py

@@ -34,7 +34,7 @@ def assert_is_file_content(obj: object, *, key: str | None = None) -> None:
     if not is_file_content(obj):
         prefix = f"Expected entry at `{key}`" if key is not None else f"Expected file input `{obj!r}`"
         raise RuntimeError(
-            f"{prefix} to be bytes, an io.IOBase instance, PathLike or a tuple but received {type(obj)} instead."
+            f"{prefix} to be bytes, an io.IOBase instance, PathLike or a tuple but received {type(obj)} instead. See https://github.com/supermemoryai/python-sdk/tree/main#file-uploads"
         ) from None
 
 

src/supermemory/resources/memories.py

@@ -2,14 +2,14 @@
 
 from __future__ import annotations
 
-from typing import Dict, List, Union
+from typing import Dict, List, Union, Mapping, cast
 from typing_extensions import Literal
 
 import httpx
 
-from ..types import memory_add_params, memory_list_params, memory_update_params
-from .._types import NOT_GIVEN, Body, Query, Headers, NotGiven
-from .._utils import maybe_transform, async_maybe_transform
+from ..types import memory_add_params, memory_list_params, memory_update_params, memory_upload_file_params
+from .._types import NOT_GIVEN, Body, Query, Headers, NotGiven, FileTypes
+from .._utils import extract_files, maybe_transform, deepcopy_minimal, async_maybe_transform
 from .._compat import cached_property
 from .._resource import SyncAPIResource, AsyncAPIResource
 from .._response import (
@@ -24,6 +24,7 @@
 from ..types.memory_list_response import MemoryListResponse
 from ..types.memory_delete_response import MemoryDeleteResponse
 from ..types.memory_update_response import MemoryUpdateResponse
+from ..types.memory_upload_file_response import MemoryUploadFileResponse
 
 __all__ = ["MemoriesResource", "AsyncMemoriesResource"]
 
@@ -257,6 +258,45 @@ def get(
             cast_to=MemoryGetResponse,
         )
 
+    def upload_file(
+        self,
+        *,
+        file: FileTypes,
+        # 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,
+    ) -> MemoryUploadFileResponse:
+        """
+        Upload a file to be processed
+
+        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
+        """
+        body = deepcopy_minimal({"file": file})
+        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--
+        extra_headers = {"Content-Type": "multipart/form-data", **(extra_headers or {})}
+        return self._post(
+            "/v3/memories/file",
+            body=maybe_transform(body, memory_upload_file_params.MemoryUploadFileParams),
+            files=files,
+            options=make_request_options(
+                extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
+            ),
+            cast_to=MemoryUploadFileResponse,
+        )
+
 
 class AsyncMemoriesResource(AsyncAPIResource):
     @cached_property
@@ -487,6 +527,45 @@ async def get(
             cast_to=MemoryGetResponse,
         )
 
+    async def upload_file(
+        self,
+        *,
+        file: FileTypes,
+        # 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,
+    ) -> MemoryUploadFileResponse:
+        """
+        Upload a file to be processed
+
+        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
+        """
+        body = deepcopy_minimal({"file": file})
+        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--
+        extra_headers = {"Content-Type": "multipart/form-data", **(extra_headers or {})}
+        return await self._post(
+            "/v3/memories/file",
+            body=await async_maybe_transform(body, memory_upload_file_params.MemoryUploadFileParams),
+            files=files,
+            options=make_request_options(
+                extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
+            ),
+            cast_to=MemoryUploadFileResponse,
+        )
+
 
 class MemoriesResourceWithRawResponse:
     def __init__(self, memories: MemoriesResource) -> None:
@@ -507,6 +586,9 @@ def __init__(self, memories: MemoriesResource) -> None:
         self.get = to_raw_response_wrapper(
             memories.get,
         )
+        self.upload_file = to_raw_response_wrapper(
+            memories.upload_file,
+        )
 
 
 class AsyncMemoriesResourceWithRawResponse:
@@ -528,6 +610,9 @@ def __init__(self, memories: AsyncMemoriesResource) -> None:
         self.get = async_to_raw_response_wrapper(
             memories.get,
         )
+        self.upload_file = async_to_raw_response_wrapper(
+            memories.upload_file,
+        )
 
 
 class MemoriesResourceWithStreamingResponse:
@@ -549,6 +634,9 @@ def __init__(self, memories: MemoriesResource) -> None:
         self.get = to_streamed_response_wrapper(
             memories.get,
         )
+        self.upload_file = to_streamed_response_wrapper(
+            memories.upload_file,
+        )
 
 
 class AsyncMemoriesResourceWithStreamingResponse:
@@ -570,3 +658,6 @@ def __init__(self, memories: AsyncMemoriesResource) -> None:
         self.get = async_to_streamed_response_wrapper(
             memories.get,
         )
+        self.upload_file = async_to_streamed_response_wrapper(
+            memories.upload_file,
+        )

src/supermemory/types/__init__.py

@@ -19,4 +19,6 @@
 from .setting_update_response import SettingUpdateResponse as SettingUpdateResponse
 from .connection_create_params import ConnectionCreateParams as ConnectionCreateParams
 from .connection_list_response import ConnectionListResponse as ConnectionListResponse
+from .memory_upload_file_params import MemoryUploadFileParams as MemoryUploadFileParams
 from .connection_create_response import ConnectionCreateResponse as ConnectionCreateResponse
+from .memory_upload_file_response import MemoryUploadFileResponse as MemoryUploadFileResponse

src/supermemory/types/memory_upload_file_params.py

@@ -0,0 +1,13 @@
+# File generated from our OpenAPI spec by Stainless. See CONTRIBUTING.md for details.
+
+from __future__ import annotations
+
+from typing_extensions import Required, TypedDict
+
+from .._types import FileTypes
+
+__all__ = ["MemoryUploadFileParams"]
+
+
+class MemoryUploadFileParams(TypedDict, total=False):
+    file: Required[FileTypes]

src/supermemory/types/memory_upload_file_response.py

@@ -0,0 +1,11 @@
+# File generated from our OpenAPI spec by Stainless. See CONTRIBUTING.md for details.
+
+from .._models import BaseModel
+
+__all__ = ["MemoryUploadFileResponse"]
+
+
+class MemoryUploadFileResponse(BaseModel):
+    id: str
+
+    status: str

tests/api_resources/test_memories.py

@@ -15,6 +15,7 @@
     MemoryListResponse,
     MemoryDeleteResponse,
     MemoryUpdateResponse,
+    MemoryUploadFileResponse,
 )
 
 base_url = os.environ.get("TEST_API_BASE_URL", "http://127.0.0.1:4010")
@@ -262,6 +263,40 @@ def test_path_params_get(self, client: Supermemory) -> None:
                 "",
             )
 
+    @pytest.mark.skip()
+    @parametrize
+    def test_method_upload_file(self, client: Supermemory) -> None:
+        memory = client.memories.upload_file(
+            file=b"raw file contents",
+        )
+        assert_matches_type(MemoryUploadFileResponse, memory, path=["response"])
+
+    @pytest.mark.skip()
+    @parametrize
+    def test_raw_response_upload_file(self, client: Supermemory) -> None:
+        response = client.memories.with_raw_response.upload_file(
+            file=b"raw file contents",
+        )
+
+        assert response.is_closed is True
+        assert response.http_request.headers.get("X-Stainless-Lang") == "python"
+        memory = response.parse()
+        assert_matches_type(MemoryUploadFileResponse, memory, path=["response"])
+
+    @pytest.mark.skip()
+    @parametrize
+    def test_streaming_response_upload_file(self, client: Supermemory) -> None:
+        with client.memories.with_streaming_response.upload_file(
+            file=b"raw file contents",
+        ) as response:
+            assert not response.is_closed
+            assert response.http_request.headers.get("X-Stainless-Lang") == "python"
+
+            memory = response.parse()
+            assert_matches_type(MemoryUploadFileResponse, memory, path=["response"])
+
+        assert cast(Any, response.is_closed) is True
+
 
 class TestAsyncMemories:
     parametrize = pytest.mark.parametrize("async_client", [False, True], indirect=True, ids=["loose", "strict"])
@@ -504,3 +539,37 @@ async def test_path_params_get(self, async_client: AsyncSupermemory) -> None:
             await async_client.memories.with_raw_response.get(
                 "",
             )
+
+    @pytest.mark.skip()
+    @parametrize
+    async def test_method_upload_file(self, async_client: AsyncSupermemory) -> None:
+        memory = await async_client.memories.upload_file(
+            file=b"raw file contents",
+        )
+        assert_matches_type(MemoryUploadFileResponse, memory, path=["response"])
+
+    @pytest.mark.skip()
+    @parametrize
+    async def test_raw_response_upload_file(self, async_client: AsyncSupermemory) -> None:
+        response = await async_client.memories.with_raw_response.upload_file(
+            file=b"raw file contents",
+        )
+
+        assert response.is_closed is True
+        assert response.http_request.headers.get("X-Stainless-Lang") == "python"
+        memory = await response.parse()
+        assert_matches_type(MemoryUploadFileResponse, memory, path=["response"])
+
+    @pytest.mark.skip()
+    @parametrize
+    async def test_streaming_response_upload_file(self, async_client: AsyncSupermemory) -> None:
+        async with async_client.memories.with_streaming_response.upload_file(
+            file=b"raw file contents",
+        ) as response:
+            assert not response.is_closed
+            assert response.http_request.headers.get("X-Stainless-Lang") == "python"
+
+            memory = await response.parse()
+            assert_matches_type(MemoryUploadFileResponse, memory, path=["response"])
+
+        assert cast(Any, response.is_closed) is True