feat(api): manual updates

Author: stainless-app[bot]

.stats.yml

@@ -1,4 +1,4 @@
 configured_endpoints: 15
-openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/beeper%2Fbeeper-desktop-api-a3fb0de6dd98f8a51d73e3fdf51de6143f2e8e764048246392624a56b4a3a481.yml
-openapi_spec_hash: 50e1001c340cb0bd3436b6329240769b
+openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/beeper%2Fbeeper-desktop-api-100e7052e74644026f594642a424e04ab306d44e6c73a1f4761cf8a7d7ee0d8f.yml
+openapi_spec_hash: 3437145a74c032f2319a235bf40baa88
 config_hash: 2e31d02f28a11ef29eb747bcf559786a

api.md

@@ -70,11 +70,11 @@ Methods:
 Types:
 
 ```python
-from beeper_desktop_api.types import MessageSendResponse
+from beeper_desktop_api.types import MessageListResponse, MessageSendResponse
 ```
 
 Methods:
 
-- <code title="get /v1/messages">client.messages.<a href="./src/beeper_desktop_api/resources/messages.py">list</a>(\*\*<a href="src/beeper_desktop_api/types/message_list_params.py">params</a>) -> <a href="./src/beeper_desktop_api/types/shared/message.py">SyncCursorList[Message]</a></code>
+- <code title="get /v1/messages">client.messages.<a href="./src/beeper_desktop_api/resources/messages.py">list</a>(\*\*<a href="src/beeper_desktop_api/types/message_list_params.py">params</a>) -> <a href="./src/beeper_desktop_api/types/message_list_response.py">MessageListResponse</a></code>
 - <code title="get /v1/messages/search">client.messages.<a href="./src/beeper_desktop_api/resources/messages.py">search</a>(\*\*<a href="src/beeper_desktop_api/types/message_search_params.py">params</a>) -> <a href="./src/beeper_desktop_api/types/shared/message.py">SyncCursorSearch[Message]</a></code>
 - <code title="post /v1/messages">client.messages.<a href="./src/beeper_desktop_api/resources/messages.py">send</a>(\*\*<a href="src/beeper_desktop_api/types/message_send_params.py">params</a>) -> <a href="./src/beeper_desktop_api/types/message_send_response.py">MessageSendResponse</a></code>

src/beeper_desktop_api/resources/messages.py

@@ -19,9 +19,10 @@
     async_to_raw_response_wrapper,
     async_to_streamed_response_wrapper,
 )
-from ..pagination import SyncCursorList, AsyncCursorList, SyncCursorSearch, AsyncCursorSearch
+from ..pagination import SyncCursorSearch, AsyncCursorSearch
 from .._base_client import AsyncPaginator, make_request_options
 from ..types.shared.message import Message
+from ..types.message_list_response import MessageListResponse
 from ..types.message_send_response import MessageSendResponse
 
 __all__ = ["MessagesResource", "AsyncMessagesResource"]
@@ -61,7 +62,7 @@ def list(
         extra_query: Query | None = None,
         extra_body: Body | None = None,
         timeout: float | httpx.Timeout | None | NotGiven = not_given,
-    ) -> SyncCursorList[Message]:
+    ) -> MessageListResponse:
         """List all messages in a chat with cursor-based pagination.
 
         Sorted by timestamp.
@@ -83,9 +84,8 @@ def list(
 
           timeout: Override the client-level default timeout for this request, in seconds
         """
-        return self._get_api_list(
+        return self._get(
             "/v1/messages",
-            page=SyncCursorList[Message],
             options=make_request_options(
                 extra_headers=extra_headers,
                 extra_query=extra_query,
@@ -100,7 +100,7 @@ def list(
                     message_list_params.MessageListParams,
                 ),
             ),
-            model=Message,
+            cast_to=MessageListResponse,
         )
 
     def search(
@@ -153,8 +153,7 @@ def search(
           include_muted: Include messages in chats marked as Muted by the user, which are usually less
               important. Default: true. Set to false if the user wants a more refined search.
 
-          limit: Maximum number of messages to return (1–500). Defaults to 20. The current
-              implementation caps each page at 20 items even if a higher limit is requested.
+          limit: Maximum number of messages to return.
 
           media_types: Filter messages by media types. Use ['any'] for any media type, or specify exact
               types like ['video', 'image']. Omit for no media filtering.
@@ -208,7 +207,7 @@ def search(
     def send(
         self,
         *,
-        chat_id: str,
+        chat_id: str | Omit = omit,
         reply_to_message_id: str | Omit = omit,
         text: str | Omit = omit,
         # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
@@ -277,7 +276,7 @@ def with_streaming_response(self) -> AsyncMessagesResourceWithStreamingResponse:
         """
         return AsyncMessagesResourceWithStreamingResponse(self)
 
-    def list(
+    async def list(
         self,
         *,
         chat_id: str,
@@ -289,7 +288,7 @@ def list(
         extra_query: Query | None = None,
         extra_body: Body | None = None,
         timeout: float | httpx.Timeout | None | NotGiven = not_given,
-    ) -> AsyncPaginator[Message, AsyncCursorList[Message]]:
+    ) -> MessageListResponse:
         """List all messages in a chat with cursor-based pagination.
 
         Sorted by timestamp.
@@ -311,15 +310,14 @@ def list(
 
           timeout: Override the client-level default timeout for this request, in seconds
         """
-        return self._get_api_list(
+        return await self._get(
             "/v1/messages",
-            page=AsyncCursorList[Message],
             options=make_request_options(
                 extra_headers=extra_headers,
                 extra_query=extra_query,
                 extra_body=extra_body,
                 timeout=timeout,
-                query=maybe_transform(
+                query=await async_maybe_transform(
                     {
                         "chat_id": chat_id,
                         "cursor": cursor,
@@ -328,7 +326,7 @@ def list(
                     message_list_params.MessageListParams,
                 ),
             ),
-            model=Message,
+            cast_to=MessageListResponse,
         )
 
     def search(
@@ -381,8 +379,7 @@ def search(
           include_muted: Include messages in chats marked as Muted by the user, which are usually less
               important. Default: true. Set to false if the user wants a more refined search.
 
-          limit: Maximum number of messages to return (1–500). Defaults to 20. The current
-              implementation caps each page at 20 items even if a higher limit is requested.
+          limit: Maximum number of messages to return.
 
           media_types: Filter messages by media types. Use ['any'] for any media type, or specify exact
               types like ['video', 'image']. Omit for no media filtering.
@@ -436,7 +433,7 @@ def search(
     async def send(
         self,
         *,
-        chat_id: str,
+        chat_id: str | Omit = omit,
         reply_to_message_id: str | Omit = omit,
         text: str | Omit = omit,
         # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.

src/beeper_desktop_api/types/__init__.py

@@ -27,6 +27,7 @@
 from .client_search_params import ClientSearchParams as ClientSearchParams
 from .account_list_response import AccountListResponse as AccountListResponse
 from .contact_search_params import ContactSearchParams as ContactSearchParams
+from .message_list_response import MessageListResponse as MessageListResponse
 from .message_search_params import MessageSearchParams as MessageSearchParams
 from .message_send_response import MessageSendResponse as MessageSendResponse
 from .contact_search_response import ContactSearchResponse as ContactSearchResponse

src/beeper_desktop_api/types/message_list_response.py

@@ -0,0 +1,21 @@
+# File generated from our OpenAPI spec by Stainless. See CONTRIBUTING.md for details.
+
+from typing import List
+
+from pydantic import Field as FieldInfo
+
+from .._models import BaseModel
+from .shared.message import Message
+
+__all__ = ["MessageListResponse"]
+
+
+class MessageListResponse(BaseModel):
+    has_more: bool = FieldInfo(alias="hasMore")
+    """True if additional results can be fetched."""
+
+    items: List[Message]
+    """Messages from the chat, sorted by timestamp.
+
+    Use message.sortKey as cursor for pagination.
+    """

src/beeper_desktop_api/types/message_search_params.py

@@ -56,11 +56,7 @@ class MessageSearchParams(TypedDict, total=False):
     """
 
     limit: int
-    """Maximum number of messages to return (1–500).
-
-    Defaults to 20. The current implementation caps each page at 20 items even if a
-    higher limit is requested.
-    """
+    """Maximum number of messages to return."""
 
     media_types: Annotated[List[Literal["any", "video", "image", "link", "file"]], PropertyInfo(alias="mediaTypes")]
     """Filter messages by media types.

src/beeper_desktop_api/types/message_send_params.py

@@ -2,15 +2,15 @@
 
 from __future__ import annotations
 
-from typing_extensions import Required, Annotated, TypedDict
+from typing_extensions import Annotated, TypedDict
 
 from .._utils import PropertyInfo
 
 __all__ = ["MessageSendParams"]
 
 
 class MessageSendParams(TypedDict, total=False):
-    chat_id: Required[Annotated[str, PropertyInfo(alias="chatID")]]
+    chat_id: Annotated[str, PropertyInfo(alias="chatID")]
     """Unique identifier of the chat."""
 
     reply_to_message_id: Annotated[str, PropertyInfo(alias="replyToMessageID")]

tests/api_resources/test_messages.py

@@ -10,10 +10,11 @@
 from tests.utils import assert_matches_type
 from beeper_desktop_api import BeeperDesktop, AsyncBeeperDesktop
 from beeper_desktop_api.types import (
+    MessageListResponse,
     MessageSendResponse,
 )
 from beeper_desktop_api._utils import parse_datetime
-from beeper_desktop_api.pagination import SyncCursorList, AsyncCursorList, SyncCursorSearch, AsyncCursorSearch
+from beeper_desktop_api.pagination import SyncCursorSearch, AsyncCursorSearch
 from beeper_desktop_api.types.shared import Message
 
 base_url = os.environ.get("TEST_API_BASE_URL", "http://127.0.0.1:4010")
@@ -27,7 +28,7 @@ def test_method_list(self, client: BeeperDesktop) -> None:
         message = client.messages.list(
             chat_id="!NCdzlIaMjZUmvmvyHU:beeper.com",
         )
-        assert_matches_type(SyncCursorList[Message], message, path=["response"])
+        assert_matches_type(MessageListResponse, message, path=["response"])
 
     @parametrize
     def test_method_list_with_all_params(self, client: BeeperDesktop) -> None:
@@ -36,7 +37,7 @@ def test_method_list_with_all_params(self, client: BeeperDesktop) -> None:
             cursor="821744079",
             direction="before",
         )
-        assert_matches_type(SyncCursorList[Message], message, path=["response"])
+        assert_matches_type(MessageListResponse, message, path=["response"])
 
     @parametrize
     def test_raw_response_list(self, client: BeeperDesktop) -> None:
@@ -47,7 +48,7 @@ def test_raw_response_list(self, client: BeeperDesktop) -> None:
         assert response.is_closed is True
         assert response.http_request.headers.get("X-Stainless-Lang") == "python"
         message = response.parse()
-        assert_matches_type(SyncCursorList[Message], message, path=["response"])
+        assert_matches_type(MessageListResponse, message, path=["response"])
 
     @parametrize
     def test_streaming_response_list(self, client: BeeperDesktop) -> None:
@@ -58,7 +59,7 @@ def test_streaming_response_list(self, client: BeeperDesktop) -> None:
             assert response.http_request.headers.get("X-Stainless-Lang") == "python"
 
             message = response.parse()
-            assert_matches_type(SyncCursorList[Message], message, path=["response"])
+            assert_matches_type(MessageListResponse, message, path=["response"])
 
         assert cast(Any, response.is_closed) is True
 
@@ -112,9 +113,7 @@ def test_streaming_response_search(self, client: BeeperDesktop) -> None:
 
     @parametrize
     def test_method_send(self, client: BeeperDesktop) -> None:
-        message = client.messages.send(
-            chat_id="!NCdzlIaMjZUmvmvyHU:beeper.com",
-        )
+        message = client.messages.send()
         assert_matches_type(MessageSendResponse, message, path=["response"])
 
     @parametrize
@@ -128,9 +127,7 @@ def test_method_send_with_all_params(self, client: BeeperDesktop) -> None:
 
     @parametrize
     def test_raw_response_send(self, client: BeeperDesktop) -> None:
-        response = client.messages.with_raw_response.send(
-            chat_id="!NCdzlIaMjZUmvmvyHU:beeper.com",
-        )
+        response = client.messages.with_raw_response.send()
 
         assert response.is_closed is True
         assert response.http_request.headers.get("X-Stainless-Lang") == "python"
@@ -139,9 +136,7 @@ def test_raw_response_send(self, client: BeeperDesktop) -> None:
 
     @parametrize
     def test_streaming_response_send(self, client: BeeperDesktop) -> None:
-        with client.messages.with_streaming_response.send(
-            chat_id="!NCdzlIaMjZUmvmvyHU:beeper.com",
-        ) as response:
+        with client.messages.with_streaming_response.send() as response:
             assert not response.is_closed
             assert response.http_request.headers.get("X-Stainless-Lang") == "python"
 
@@ -161,7 +156,7 @@ async def test_method_list(self, async_client: AsyncBeeperDesktop) -> None:
         message = await async_client.messages.list(
             chat_id="!NCdzlIaMjZUmvmvyHU:beeper.com",
         )
-        assert_matches_type(AsyncCursorList[Message], message, path=["response"])
+        assert_matches_type(MessageListResponse, message, path=["response"])
 
     @parametrize
     async def test_method_list_with_all_params(self, async_client: AsyncBeeperDesktop) -> None:
@@ -170,7 +165,7 @@ async def test_method_list_with_all_params(self, async_client: AsyncBeeperDeskto
             cursor="821744079",
             direction="before",
         )
-        assert_matches_type(AsyncCursorList[Message], message, path=["response"])
+        assert_matches_type(MessageListResponse, message, path=["response"])
 
     @parametrize
     async def test_raw_response_list(self, async_client: AsyncBeeperDesktop) -> None:
@@ -181,7 +176,7 @@ async def test_raw_response_list(self, async_client: AsyncBeeperDesktop) -> None
         assert response.is_closed is True
         assert response.http_request.headers.get("X-Stainless-Lang") == "python"
         message = await response.parse()
-        assert_matches_type(AsyncCursorList[Message], message, path=["response"])
+        assert_matches_type(MessageListResponse, message, path=["response"])
 
     @parametrize
     async def test_streaming_response_list(self, async_client: AsyncBeeperDesktop) -> None:
@@ -192,7 +187,7 @@ async def test_streaming_response_list(self, async_client: AsyncBeeperDesktop) -
             assert response.http_request.headers.get("X-Stainless-Lang") == "python"
 
             message = await response.parse()
-            assert_matches_type(AsyncCursorList[Message], message, path=["response"])
+            assert_matches_type(MessageListResponse, message, path=["response"])
 
         assert cast(Any, response.is_closed) is True
 
@@ -246,9 +241,7 @@ async def test_streaming_response_search(self, async_client: AsyncBeeperDesktop)
 
     @parametrize
     async def test_method_send(self, async_client: AsyncBeeperDesktop) -> None:
-        message = await async_client.messages.send(
-            chat_id="!NCdzlIaMjZUmvmvyHU:beeper.com",
-        )
+        message = await async_client.messages.send()
         assert_matches_type(MessageSendResponse, message, path=["response"])
 
     @parametrize
@@ -262,9 +255,7 @@ async def test_method_send_with_all_params(self, async_client: AsyncBeeperDeskto
 
     @parametrize
     async def test_raw_response_send(self, async_client: AsyncBeeperDesktop) -> None:
-        response = await async_client.messages.with_raw_response.send(
-            chat_id="!NCdzlIaMjZUmvmvyHU:beeper.com",
-        )
+        response = await async_client.messages.with_raw_response.send()
 
         assert response.is_closed is True
         assert response.http_request.headers.get("X-Stainless-Lang") == "python"
@@ -273,9 +264,7 @@ async def test_raw_response_send(self, async_client: AsyncBeeperDesktop) -> None
 
     @parametrize
     async def test_streaming_response_send(self, async_client: AsyncBeeperDesktop) -> None:
-        async with async_client.messages.with_streaming_response.send(
-            chat_id="!NCdzlIaMjZUmvmvyHU:beeper.com",
-        ) as response:
+        async with async_client.messages.with_streaming_response.send() as response:
             assert not response.is_closed
             assert response.http_request.headers.get("X-Stainless-Lang") == "python"