1515 BatchResourceWithStreamingResponse ,
1616 AsyncBatchResourceWithStreamingResponse ,
1717)
18- from ...types import (
19- message_list_params ,
20- message_create_params ,
21- message_update_params ,
22- message_list_paginated_params ,
23- )
18+ from ...types import message_list_params , message_create_params , message_update_params
2419from ..._types import Body , Omit , Query , Headers , NotGiven , omit , not_given
2520from ..._utils import maybe_transform , async_maybe_transform
2621from ..._compat import cached_property
3530from ...types .task_message import TaskMessage
3631from ...types .message_list_response import MessageListResponse
3732from ...types .task_message_content_param import TaskMessageContentParam
38- from ...types .message_list_paginated_response import MessageListPaginatedResponse
3933
4034__all__ = ["MessagesResource" , "AsyncMessagesResource" ]
4135
@@ -198,10 +192,7 @@ def list(
198192 timeout : float | httpx .Timeout | None | NotGiven = not_given ,
199193 ) -> MessageListResponse :
200194 """
201- List messages for a task with offset-based pagination.
202-
203- For cursor-based pagination with infinite scroll support, use
204- /messages/paginated.
195+ List Messages
205196
206197 Args:
207198 task_id: The task ID
@@ -235,70 +226,6 @@ def list(
235226 cast_to = MessageListResponse ,
236227 )
237228
238- def list_paginated (
239- self ,
240- * ,
241- task_id : str ,
242- cursor : Optional [str ] | Omit = omit ,
243- direction : Literal ["older" , "newer" ] | Omit = omit ,
244- limit : int | Omit = omit ,
245- # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
246- # The extra values given here take precedence over values defined on the client or passed to this method.
247- extra_headers : Headers | None = None ,
248- extra_query : Query | None = None ,
249- extra_body : Body | None = None ,
250- timeout : float | httpx .Timeout | None | NotGiven = not_given ,
251- ) -> MessageListPaginatedResponse :
252- """
253- List messages for a task with cursor-based pagination.
254-
255- This endpoint is designed for infinite scroll UIs where new messages may arrive
256- while paginating through older ones.
257-
258- Args: task_id: The task ID to filter messages by limit: Maximum number of
259- messages to return (default: 50) cursor: Opaque cursor string for pagination.
260- Pass the `next_cursor` from a previous response to get the next page. direction:
261- Pagination direction - "older" to get older messages (default), "newer" to get
262- newer messages.
263-
264- Returns: PaginatedMessagesResponse with: - data: List of messages (newest first
265- when direction="older") - next_cursor: Cursor for fetching the next page (null
266- if no more pages) - has_more: Whether there are more messages to fetch
267-
268- Example: First request: GET /messages/paginated?task_id=xxx&limit=50 Next page:
269- GET /messages/paginated?task_id=xxx&limit=50&cursor=<next_cursor>
270-
271- Args:
272- task_id: The task ID
273-
274- extra_headers: Send extra headers
275-
276- extra_query: Add additional query parameters to the request
277-
278- extra_body: Add additional JSON properties to the request
279-
280- timeout: Override the client-level default timeout for this request, in seconds
281- """
282- return self ._get (
283- "/messages/paginated" ,
284- options = make_request_options (
285- extra_headers = extra_headers ,
286- extra_query = extra_query ,
287- extra_body = extra_body ,
288- timeout = timeout ,
289- query = maybe_transform (
290- {
291- "task_id" : task_id ,
292- "cursor" : cursor ,
293- "direction" : direction ,
294- "limit" : limit ,
295- },
296- message_list_paginated_params .MessageListPaginatedParams ,
297- ),
298- ),
299- cast_to = MessageListPaginatedResponse ,
300- )
301-
302229
303230class AsyncMessagesResource (AsyncAPIResource ):
304231 @cached_property
@@ -458,10 +385,7 @@ async def list(
458385 timeout : float | httpx .Timeout | None | NotGiven = not_given ,
459386 ) -> MessageListResponse :
460387 """
461- List messages for a task with offset-based pagination.
462-
463- For cursor-based pagination with infinite scroll support, use
464- /messages/paginated.
388+ List Messages
465389
466390 Args:
467391 task_id: The task ID
@@ -495,70 +419,6 @@ async def list(
495419 cast_to = MessageListResponse ,
496420 )
497421
498- async def list_paginated (
499- self ,
500- * ,
501- task_id : str ,
502- cursor : Optional [str ] | Omit = omit ,
503- direction : Literal ["older" , "newer" ] | Omit = omit ,
504- limit : int | Omit = omit ,
505- # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
506- # The extra values given here take precedence over values defined on the client or passed to this method.
507- extra_headers : Headers | None = None ,
508- extra_query : Query | None = None ,
509- extra_body : Body | None = None ,
510- timeout : float | httpx .Timeout | None | NotGiven = not_given ,
511- ) -> MessageListPaginatedResponse :
512- """
513- List messages for a task with cursor-based pagination.
514-
515- This endpoint is designed for infinite scroll UIs where new messages may arrive
516- while paginating through older ones.
517-
518- Args: task_id: The task ID to filter messages by limit: Maximum number of
519- messages to return (default: 50) cursor: Opaque cursor string for pagination.
520- Pass the `next_cursor` from a previous response to get the next page. direction:
521- Pagination direction - "older" to get older messages (default), "newer" to get
522- newer messages.
523-
524- Returns: PaginatedMessagesResponse with: - data: List of messages (newest first
525- when direction="older") - next_cursor: Cursor for fetching the next page (null
526- if no more pages) - has_more: Whether there are more messages to fetch
527-
528- Example: First request: GET /messages/paginated?task_id=xxx&limit=50 Next page:
529- GET /messages/paginated?task_id=xxx&limit=50&cursor=<next_cursor>
530-
531- Args:
532- task_id: The task ID
533-
534- extra_headers: Send extra headers
535-
536- extra_query: Add additional query parameters to the request
537-
538- extra_body: Add additional JSON properties to the request
539-
540- timeout: Override the client-level default timeout for this request, in seconds
541- """
542- return await self ._get (
543- "/messages/paginated" ,
544- options = make_request_options (
545- extra_headers = extra_headers ,
546- extra_query = extra_query ,
547- extra_body = extra_body ,
548- timeout = timeout ,
549- query = await async_maybe_transform (
550- {
551- "task_id" : task_id ,
552- "cursor" : cursor ,
553- "direction" : direction ,
554- "limit" : limit ,
555- },
556- message_list_paginated_params .MessageListPaginatedParams ,
557- ),
558- ),
559- cast_to = MessageListPaginatedResponse ,
560- )
561-
562422
563423class MessagesResourceWithRawResponse :
564424 def __init__ (self , messages : MessagesResource ) -> None :
@@ -576,9 +436,6 @@ def __init__(self, messages: MessagesResource) -> None:
576436 self .list = to_raw_response_wrapper (
577437 messages .list ,
578438 )
579- self .list_paginated = to_raw_response_wrapper (
580- messages .list_paginated ,
581- )
582439
583440 @cached_property
584441 def batch (self ) -> BatchResourceWithRawResponse :
@@ -601,9 +458,6 @@ def __init__(self, messages: AsyncMessagesResource) -> None:
601458 self .list = async_to_raw_response_wrapper (
602459 messages .list ,
603460 )
604- self .list_paginated = async_to_raw_response_wrapper (
605- messages .list_paginated ,
606- )
607461
608462 @cached_property
609463 def batch (self ) -> AsyncBatchResourceWithRawResponse :
@@ -626,9 +480,6 @@ def __init__(self, messages: MessagesResource) -> None:
626480 self .list = to_streamed_response_wrapper (
627481 messages .list ,
628482 )
629- self .list_paginated = to_streamed_response_wrapper (
630- messages .list_paginated ,
631- )
632483
633484 @cached_property
634485 def batch (self ) -> BatchResourceWithStreamingResponse :
@@ -651,9 +502,6 @@ def __init__(self, messages: AsyncMessagesResource) -> None:
651502 self .list = async_to_streamed_response_wrapper (
652503 messages .list ,
653504 )
654- self .list_paginated = async_to_streamed_response_wrapper (
655- messages .list_paginated ,
656- )
657505
658506 @cached_property
659507 def batch (self ) -> AsyncBatchResourceWithStreamingResponse :
0 commit comments