+
    ~j)~                       ^ RI Ht ^ RIt^ RIHtHtHt ^ RIHt ^ RIt^RI	H
t
 ^RIHtHtHtHtHtHtHt ^RIHtHtHt ^RIHt ^R	IHtHt ^R
IHtHt ^RIH t H!t! ^RI"H#t#H$t$ ^RI%H&t&H't'H(t( ^RI)H*t* ^RI+H,t, ^RI-H.t. ^RI/H0t0 RR.t1 ! R R]4      t2 ! R R]4      t3 ! R R4      t4 ! R R4      t5 ! R R4      t6 ! R R4      t7R# )    )annotationsN)UnionIterableOptional)Literal)_legacy_response)BodyOmitQueryHeadersNotGivenomit	not_given)path_templatemaybe_transformasync_maybe_transform)cached_property)SyncAPIResourceAsyncAPIResource)to_streamed_response_wrapper"async_to_streamed_response_wrapper)SyncCursorPageAsyncCursorPage)AsyncPaginatormake_request_options)message_list_paramsmessage_create_paramsmessage_update_params)Message)Metadata)MessageDeleted)MessageContentPartParamMessagesAsyncMessagesc                     ] tR t^tRt]R R l4       t]R R l4       t]P                  ! R4      R]
R]
R	R
RR
RR
R]/R R ll4       t]P                  ! R4      R	R
RR
RR
R]/R R ll4       t]P                  ! R4      R]
R	R
RR
RR
R]/R R ll4       t]P                  ! R4      R]
R]
R]
R]
R]
R	R
RR
RR
R]/	R R ll4       t]P                  ! R4      R	R
RR
RR
R]/R R ll4       tRtR
# )r#   4Build Assistants that can call models and use tools.c                   V ^8  d   QhRR/# )   returnMessagesWithRawResponse )formats   "{/Users/mitch_tango/dev/rabbit-r1-livekit/agent/.venv/lib/python3.14/site-packages/openai/resources/beta/threads/messages.py__annotate__Messages.__annotate__#   s     - -#: -    c                    \        V 4      # z
This property can be used as a prefix for any HTTP method call to return
the raw response object instead of the parsed content.

For more information, see https://www.github.com/openai/openai-python#accessing-raw-response-data-eg-headers
)r*   selfs   &r-   with_raw_responseMessages.with_raw_response"   s     't,,r0   c                   V ^8  d   QhRR/# )r(   r)   MessagesWithStreamingResponser+   )r,   s   "r-   r.   r/   -   s     3 3)F 3r0   c                    \        V 4      # z
An alternative to `.with_raw_response` that doesn't eagerly read the response body.

For more information, see https://www.github.com/openai/openai-python#with_streaming_response
)r8   r3   s   &r-   with_streaming_response Messages.with_streaming_response,   s     -T22r0   >The Assistants API is deprecated in favor of the Responses APIattachmentsmetadataextra_headersNextra_query
extra_bodytimeoutc               @    V ^8  d   QhRRRRRRRRR	R
RRRRRRRRRR/
# r(   	thread_idstrcontentz-Union[str, Iterable[MessageContentPartParam]]rolezLiteral['user', 'assistant']r>   z;Optional[Iterable[message_create_params.Attachment]] | Omitr?   Optional[Metadata] | Omitr@   Headers | NonerA   Query | NonerB   Body | NonerC   'float | httpx.Timeout | None | NotGivenr)   r   r+   )r,   s   "r-   r.   r/   6   {     D
 D
D
 ?	D

 +D
 QD
 ,D
 &D
 "D
  D
 9D
 
D
r0   c                   V'       g   \        RV: 24      hRR/T;'       g    / CpV P                  \        RVR7      \        RVRVRVR	V/\        P
                  4      \        VVVV	R
R/R7      \        R7      # )  
Create a message.

Args:
  content: The text contents of the message.

  role:
      The role of the entity that is creating the message. Allowed values include:

      - `user`: Indicates the message is sent by an actual user and should be used in
        most cases to represent user-generated messages.
      - `assistant`: Indicates the message is generated by the assistant. Use this
        value to insert messages from the assistant into the conversation.

  attachments: A list of files attached to the message, and the tools they should be added to.

  metadata: Set of 16 key-value pairs that can be attached to an object. This can be useful
      for storing additional information about the object in a structured format, and
      querying for objects via API or the dashboard.

      Keys are strings with a maximum length of 64 characters. Values are strings with
      a maximum length of 512 characters.

  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
8Expected a non-empty value for `thread_id` but received OpenAI-Betaassistants=v2/threads/{thread_id}/messagesrF   rH   rI   r>   r?   bearer_authTr@   rA   rB   rC   securitybodyoptionscast_to)
ValueError_postr   r   r   MessageCreateParamsr   r   
r4   rF   rH   rI   r>   r?   r@   rA   rB   rC   s
   &&$$$$$$$$r-   createMessages.create5   s    ^ WXaWdeff&QM<O<ORQzz9YO wD!;	 &99 )+'%'. %  
 	
r0   c               4    V ^8  d   QhRRRRRRRRRR	R
RRR/# r(   
message_idrG   rF   r@   rK   rA   rL   rB   rM   rC   rN   r)   r   r+   )r,   s   "r-   r.   r/   }   P     '
 '
'
 	'
 &'
 "'
  '
 9'
 
'
r0   c                   V'       g   \        RV: 24      hV'       g   \        RV: 24      hRR/T;'       g    / CpV P                  \        RW!R7      \        VVVVRR/R	7      \        R
7      # )  
Retrieve a message.

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
rR   9Expected a non-empty value for `message_id` but received rS   rT   */threads/{thread_id}/messages/{message_id}rF   rf   rW   TrX   r\   r]   r^   _getr   r   r   r4   rf   rF   r@   rA   rB   rC   s   &&$$$$$r-   retrieveMessages.retrieve|   s    2 WXaWdeffXYcXfghh&QM<O<ORQyyFR[s(+'%'.   

 
	
r0   c               8    V ^8  d   QhRRRRRRRRRR	R
RRRRR/# r(   rf   rG   rF   r?   rJ   r@   rK   rA   rL   rB   rM   rC   rN   r)   r   r+   )r,   s   "r-   r.   r/      Z     0
 0
0
 	0

 ,0
 &0
 "0
  0
 90
 
0
r0   c                  V'       g   \        RV: 24      hV'       g   \        RV: 24      hRR/T;'       g    / CpV P                  \        RW!R7      \        RV/\        P
                  4      \        VVVVRR	/R
7      \        R7      # )y  
Modifies a message.

Args:
  metadata: Set of 16 key-value pairs that can be attached to an object. This can be useful
      for storing additional information about the object in a structured format, and
      querying for objects via API or the dashboard.

      Keys are strings with a maximum length of 64 characters. Values are strings with
      a maximum length of 512 characters.

  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
rR   rj   rS   rT   rk   rl   r?   rW   TrX   rZ   )r^   r_   r   r   r   MessageUpdateParamsr   r   r4   rf   rF   r?   r@   rA   rB   rC   s   &&$$$$$$r-   updateMessages.update   s    B WXaWdeffXYcXfghh&QM<O<ORQzzFR[s *h!79N9b9bc(+'%'.   
 	
r0   afterbeforelimitorderrun_idc               D    V ^8  d   QhRRRRRRRRRR	R
RRRRRRRRRRR/# )r(   rF   rG   r|   
str | Omitr}   r~   
int | Omitr   Literal['asc', 'desc'] | Omitr   r@   rK   rA   rL   rB   rM   rC   rN   r)   zSyncCursorPage[Message]r+   )r,   s   "r-   r.   r/      s     F
 F
F
 	F

 F
 F
 -F
 F
 &F
 "F
  F
 9F
 
!F
r0   c       	           V'       g   \        RV: 24      hRR/T;'       g    / CpV P                  \        RVR7      \        \        ,          \        VVV	V
\        RVRVRVR	VR
V/\        P                  4      RR/R7      \        R7      # a  
Returns a list of messages for a given thread.

Args:
  after: A cursor for use in pagination. `after` is an object ID that defines your place
      in the list. For instance, if you make a list request and receive 100 objects,
      ending with obj_foo, your subsequent call can include after=obj_foo in order to
      fetch the next page of the list.

  before: A cursor for use in pagination. `before` is an object ID that defines your place
      in the list. For instance, if you make a list request and receive 100 objects,
      starting with obj_foo, your subsequent call can include before=obj_foo in order
      to fetch the previous page of the list.

  limit: A limit on the number of objects to be returned. Limit can range between 1 and
      100, and the default is 20.

  order: Sort order by the `created_at` timestamp of the objects. `asc` for ascending
      order and `desc` for descending order.

  run_id: Filter messages by the run ID that generated them.

  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
rR   rS   rT   rU   rV   r|   r}   r~   r   r   rW   T)r@   rA   rB   rC   queryrY   )pager\   model)	r^   _get_api_listr   r   r   r   r   r   MessageListParamsr4   rF   r|   r}   r~   r   r   r@   rA   rB   rC   s   &&$$$$$$$$$r-   listMessages.list   s    ^ WXaWdeff&QM<O<ORQ!!9YO((+'%% & & (99	 (." ) " 
 	
r0   c               4    V ^8  d   QhRRRRRRRRRR	R
RRR/# r(   rf   rG   rF   r@   rK   rA   rL   rB   rM   rC   rN   r)   r!   r+   )r,   s   "r-   r.   r/   #  P     '
 '
'
 	'
 &'
 "'
  '
 9'
 
'
r0   c                   V'       g   \        RV: 24      hV'       g   \        RV: 24      hRR/T;'       g    / CpV P                  \        RW!R7      \        VVVVRR/R	7      \        R
7      # )  
Deletes a message.

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
rR   rj   rS   rT   rk   rl   rW   TrX   rm   r^   _deleter   r   r!   rp   s   &&$$$$$r-   deleteMessages.delete"  s    2 WXaWdeffXYcXfghh&QM<O<ORQ||FR[s(+'%'. #  

 
	
r0   r+   __name__
__module____qualname____firstlineno____doc__r   r5   r;   typing_extensions
deprecatedr   r   rb   rq   rz   r   r   __static_attributes__r+   r0   r-   r#   r#      s   >- - 3 3 !!"bcD
 TXD
 /3D
 )-D
 %)D
 #'D
 <ED
 dD
L !!"bc'
 )-'
 %)'
 #''
 <E'
 d'
R !!"bc0

 /30
 )-0
 %)0
 #'0
 <E0
 d0
d !!"bcF
 !	F

 "F
 !F
 04F
 "F
 )-F
 %)F
 #'F
 <EF
 dF
P !!"bc'
 )-'
 %)'
 #''
 <E'
 d'
r0   c                     ] tR tRtRt]R R l4       t]R R l4       t]P                  ! R4      R]
R	]
R
RRRRRR]/R R ll4       t]P                  ! R4      R
RRRRRR]/R R ll4       t]P                  ! R4      R	]
R
RRRRRR]/R R ll4       t]P                  ! R4      R]
R]
R]
R]
R]
R
RRRRRR]/	R R ll4       t]P                  ! R4      R
RRRRRR]/R R ll4       tRtR# )r$   iM  r&   c                   V ^8  d   QhRR/# )r(   r)   AsyncMessagesWithRawResponser+   )r,   s   "r-   r.   AsyncMessages.__annotate__Q  s     2 2#? 2r0   c                    \        V 4      # r2   )r   r3   s   &r-   r5   AsyncMessages.with_raw_responseP  s     ,D11r0   c                   V ^8  d   QhRR/# )r(   r)   "AsyncMessagesWithStreamingResponser+   )r,   s   "r-   r.   r   [  s     8 8)K 8r0   c                    \        V 4      # r:   )r   r3   s   &r-   r;   %AsyncMessages.with_streaming_responseZ  s     2$77r0   r=   r>   r?   r@   NrA   rB   rC   c               @    V ^8  d   QhRRRRRRRRR	R
RRRRRRRRRR/
# rE   r+   )r,   s   "r-   r.   r   d  rO   r0   c               (  "   V'       g   \        RV: 24      hRR/T;'       g    / CpT P                  \        RVR7      \        RVRVRVR	V/\        P
                  4      G R
j  xL
 \        VVVV	RR/R7      \        R7      G R
j  xL
 #  L' L5i)rQ   rR   rS   rT   rU   rV   rH   rI   r>   r?   NrW   TrX   rZ   )r^   r_   r   r   r   r`   r   r   ra   s
   &&$$$$$$$$r-   rb   AsyncMessages.createc  s     ^ WXaWdeff&QM<O<ORQZZ9YO,wD!;	 &99  )+'%'. %   
 
 	

s)   #BA B&B
'"B	B
BBc               4    V ^8  d   QhRRRRRRRRRR	R
RRR/# re   r+   )r,   s   "r-   r.   r     rg   r0   c                  "   V'       g   \        RV: 24      hV'       g   \        RV: 24      hRR/T;'       g    / CpV P                  \        RW!R7      \        VVVVRR/R	7      \        R
7      G Rj  xL
 #  L5i)ri   rR   rj   rS   rT   rk   rl   rW   TrX   rm   Nrn   rp   s   &&$$$$$r-   rq   AsyncMessages.retrieve  s     2 WXaWdeffXYcXfghh&QM<O<ORQYYFR[s(+'%'.   

 

 
	
 

   A>A>:A>7A<8A>c               8    V ^8  d   QhRRRRRRRRRR	R
RRRRR/# rt   r+   )r,   s   "r-   r.   r     ru   r0   c               J  "   V'       g   \        RV: 24      hV'       g   \        RV: 24      hRR/T;'       g    / CpT P                  \        RW!R7      \        RV/\        P
                  4      G Rj  xL
 \        VVVVR	R
/R7      \        R7      G Rj  xL
 #  L' L5i)rw   rR   rj   rS   rT   rk   rl   r?   NrW   TrX   rZ   )r^   r_   r   r   r   rx   r   r   ry   s   &&$$$$$$r-   rz   AsyncMessages.update  s     B WXaWdeffXYcXfghh&QM<O<ORQZZFR[s,j(-CEZEnEnoo(+'%'.    
 
 	
o
s-   B#B#:B#7B
8"B#B!B#!B#r|   r}   r~   r   r   c               D    V ^8  d   QhRRRRRRRRRR	R
RRRRRRRRRRR/# )r(   rF   rG   r|   r   r}   r~   r   r   r   r   r@   rK   rA   rL   rB   rM   rC   rN   r)   z1AsyncPaginator[Message, AsyncCursorPage[Message]]r+   )r,   s   "r-   r.   r     s     F
 F
F
 	F

 F
 F
 -F
 F
 &F
 "F
  F
 9F
 
;F
r0   c       	           V'       g   \        RV: 24      hRR/T;'       g    / CpV P                  \        RVR7      \        \        ,          \        VVV	V
\        RVRVRVR	VR
V/\        P                  4      RR/R7      \        R7      # r   )	r^   r   r   r   r   r   r   r   r   r   s   &&$$$$$$$$$r-   r   AsyncMessages.list  s    ^ WXaWdeff&QM<O<ORQ!!9YO )(+'%% & & (99	 (." ) " 
 	
r0   c               4    V ^8  d   QhRRRRRRRRRR	R
RRR/# r   r+   )r,   s   "r-   r.   r   Q  r   r0   c                  "   V'       g   \        RV: 24      hV'       g   \        RV: 24      hRR/T;'       g    / CpV P                  \        RW!R7      \        VVVVRR/R	7      \        R
7      G Rj  xL
 #  L5i)r   rR   rj   rS   rT   rk   rl   rW   TrX   rm   Nr   rp   s   &&$$$$$r-   r   AsyncMessages.deleteP  s     2 WXaWdeffXYcXfghh&QM<O<ORQ\\FR[s(+'%'. # " 

 

 
	
 

r   r+   r   r+   r0   r-   r$   r$   M  s   >2 2 8 8 !!"bcD
 TXD
 /3D
 )-D
 %)D
 #'D
 <ED
 dD
L !!"bc'
 )-'
 %)'
 #''
 <E'
 d'
R !!"bc0

 /30
 )-0
 %)0
 #'0
 <E0
 d0
d !!"bcF
 !	F

 "F
 !F
 04F
 "F
 )-F
 %)F
 #'F
 <EF
 dF
P !!"bc'
 )-'
 %)'
 #''
 <E'
 d'
r0   c                  "    ] tR tRtR R ltRtR# )r*   i{  c                    V ^8  d   QhRRRR/# r(   messagesr#   r)   Noner+   )r,   s   "r-   r.   $MessagesWithRawResponse.__annotate__|       
 
 
d 
r0   c                	   Wn         \        P                  ! VP                  4      V n        \        P                  ! VP                  4      V n        \        P                  ! VP
                  4      V n        \        P                  ! VP                  4      V n        \        P                  ! VP                  4      V n        R # N)	_messagesr   to_raw_response_wrapperrb   rq   rz   r   r   r4   r   s   &&r-   __init__ MessagesWithRawResponse.__init__|  s    ! 44 	 44!! 	 44 	 44 		 44 	r0   r   rb   r   r   rq   rz   Nr   r   r   r   r   r   r+   r0   r-   r*   r*   {      
 
r0   r*   c                  "    ] tR tRtR R ltRtR# )r   i  c                    V ^8  d   QhRRRR/# r(   r   r$   r)   r   r+   )r,   s   "r-   r.   )AsyncMessagesWithRawResponse.__annotate__       
 
 
4 
r0   c                	   Wn         \        P                  ! VP                  4      V n        \        P                  ! VP                  4      V n        \        P                  ! VP
                  4      V n        \        P                  ! VP                  4      V n        \        P                  ! VP                  4      V n        R # r   )r   r   async_to_raw_response_wrapperrb   rq   rz   r   r   r   s   &&r-   r   %AsyncMessagesWithRawResponse.__init__  s    ! :: 	 ::!! 	 :: 	 :: 		 :: 	r0   r   Nr   r+   r0   r-   r   r     r   r0   r   c                  "    ] tR tRtR R ltRtR# )r8   i  c                    V ^8  d   QhRRRR/# r   r+   )r,   s   "r-   r.   *MessagesWithStreamingResponse.__annotate__  r   r0   c                	   Wn         \        VP                  4      V n        \        VP                  4      V n        \        VP                  4      V n        \        VP
                  4      V n        \        VP                  4      V n        R # r   )r   r   rb   rq   rz   r   r   r   s   &&r-   r   &MessagesWithStreamingResponse.__init__  s    ! ) 	 )!! 	 ) 	 ) 		 ) 	r0   r   Nr   r+   r0   r-   r8   r8     r   r0   r8   c                  "    ] tR tRtR R ltRtR# )r   i  c                    V ^8  d   QhRRRR/# r   r+   )r,   s   "r-   r.   /AsyncMessagesWithStreamingResponse.__annotate__  r   r0   c                	   Wn         \        VP                  4      V n        \        VP                  4      V n        \        VP                  4      V n        \        VP
                  4      V n        \        VP                  4      V n        R # r   )r   r   rb   rq   rz   r   r   r   s   &&r-   r   +AsyncMessagesWithStreamingResponse.__init__  s    ! / 	 /!! 	 / 	 / 		 / 	r0   r   Nr   r+   r0   r-   r   r     r   r0   r   )8
__future__r   r   typingr   r   r   r   httpx r   _typesr	   r
   r   r   r   r   r   _utilsr   r   r   _compatr   	_resourcer   r   	_responser   r   
paginationr   r   _base_clientr   r   types.beta.threadsr   r   r   types.beta.threads.messager   types.shared_params.metadatar    "types.beta.threads.message_deletedr!   -types.beta.threads.message_content_part_paramr"   __all__r#   r$   r*   r   r8   r   r+   r0   r-   <module>r      s    #  , , %  ! L L L L L ' ; Z : e d 2 5 A U
'k
 k
\	k
$ k
\	
 
>
 
>
 
>
 
r0   