
    2hx                       S SK Jr  S SKrS SKJrJrJr  S SKJr  S SKrSSK	J
r
  SSKJrJrJrJrJr  SSKJrJr  SS	KJr  SS
KJrJr  SSKJrJr  SSKJrJr  SSKJ r J!r!  SSK"J#r#J$r$J%r%  SSK&J'r'  SSK(J)r)  SSK*J+r+  SSK,J-r-  SS/r. " S S\5      r/ " S S\5      r0 " S S5      r1 " S S5      r2 " S S5      r3 " S S5      r4g)    )annotationsN)UnionIterableOptional)Literal   )_legacy_response)	NOT_GIVENBodyQueryHeadersNotGiven)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                  8   \ rS rSr\SS j5       r\SS j5       r\R                  " S5      \	\	SSS\	S.                   SS jj5       r
\R                  " S5      SSS\	S.             SS	 jj5       r\R                  " S5      \	SSS\	S
.               SS jj5       r\R                  " S5      \	\	\	\	\	SSS\	S.	                     SS jj5       r\R                  " S5      SSS\	S.             SS jj5       rSrg)r!      c                    [        U 5      $ 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
)MessagesWithRawResponseselfs    ^/var/www/auris/envauris/lib/python3.13/site-packages/openai/resources/beta/threads/messages.pywith_raw_responseMessages.with_raw_response    s     't,,    c                    [        U 5      $ 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
)MessagesWithStreamingResponser(   s    r*   with_streaming_response Messages.with_streaming_response*   s     -T22r-   >The Assistants API is deprecated in favor of the Responses APINattachmentsmetadataextra_headersextra_query
extra_bodytimeoutc                   U(       d  [        SU< 35      eSS0U=(       d    0 EnU R                  SU S3[        UUUUS.[        R                  5      [        XgXS9[        S9$ )	  
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/	/messagescontentroler5   r6   r7   r8   r9   r:   bodyoptionscast_to)
ValueError_postr   r   MessageCreateParamsr   r   
r)   	thread_idrC   rD   r5   r6   r7   r8   r9   r:   s
             r*   createMessages.create3   s    ^ WXaWdeff&QM<ORQzz	{), & #. (	 &99 )+Q[   
 	
r-   rE   c          
         U(       d  [        SU< 35      eU(       d  [        SU< 35      eSS0U=(       d    0 EnU R                  SU SU 3[        X4XVS9[        S9$ )	  
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
r=   9Expected a non-empty value for `message_id` but received r>   r?   r@   
/messages/rE   rH   rI   rJ   _getr   r   r)   
message_idrN   r7   r8   r9   r:   s          r*   retrieveMessages.retrievev   s    2 WXaWdeffXYcXfghh&QM<ORQyy	{*ZL9(+Q[   
 	
r-   r6   r7   r8   r9   r:   c                   U(       d  [        SU< 35      eU(       d  [        SU< 35      eSS0U=(       d    0 EnU R                  SU SU 3[        SU0[        R                  5      [        XEXgS9[        S	9$ )
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
r=   rS   r>   r?   r@   rT   r6   rE   rF   )rJ   rK   r   r   MessageUpdateParamsr   r   r)   rY   rN   r6   r7   r8   r9   r:   s           r*   updateMessages.update   s    B WXaWdeffXYcXfghh&QM<ORQzz	{*ZL9 *h!79N9b9bc(+Q[   
 	
r-   	afterbeforelimitorderrun_idr7   r8   r9   r:   c       	            U(       d  [        SU< 35      eSS0U=(       d    0 EnU R                  SU S3[        [           [	        UUU	U
[        UUUUUS.[        R                  5      S9[        S9$ 	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
r=   r>   r?   r@   rA   )rd   re   rf   rg   rh   )r7   r8   r9   r:   query)pagerH   model)rJ   _get_api_listr   r   r   r   r   MessageListParamsr)   rN   rd   re   rf   rg   rh   r7   r8   r9   r:   s              r*   listMessages.list   s    ^ WXaWdeff&QM<ORQ!!	{),((+'%%!&"(!&!&"( (99	  ' " 
 	
r-   c          
         U(       d  [        SU< 35      eU(       d  [        SU< 35      eSS0U=(       d    0 EnU R                  SU SU 3[        X4XVS9[        S9$ )	  
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
r=   rS   r>   r?   r@   rT   rE   rU   rJ   _deleter   r   rX   s          r*   deleteMessages.delete  s    2 WXaWdeffXYcXfghh&QM<ORQ||	{*ZL9(+Q[ #  
 	
r-    )returnr'   )rz   r0   rN   strrC   z-Union[str, Iterable[MessageContentPartParam]]rD   zLiteral['user', 'assistant']r5   z?Optional[Iterable[message_create_params.Attachment]] | NotGivenr6   Optional[Metadata] | NotGivenr7   Headers | Noner8   Query | Noner9   Body | Noner:   'float | httpx.Timeout | None | NotGivenrz   r   rY   r|   rN   r|   r7   r~   r8   r   r9   r   r:   r   rz   r   rY   r|   rN   r|   r6   r}   r7   r~   r8   r   r9   r   r:   r   rz   r   )rN   r|   rd   str | NotGivenre   r   rf   int | NotGivenrg   !Literal['asc', 'desc'] | NotGivenrh   r   r7   r~   r8   r   r9   r   r:   r   rz   zSyncCursorPage[Message]rY   r|   rN   r|   r7   r~   r8   r   r9   r   r:   r   rz   r   __name__
__module____qualname____firstlineno__r   r+   r1   typing_extensions
deprecatedr
   rO   rZ   ra   rq   rw   __static_attributes__ry   r-   r*   r!   r!      s   - - 3 3 !!"bc Xa2; )-$("&;D@
@
 ?	@

 +@
 U@
 0@
 &@
 "@
  @
 9@
 
@
 d@
D !!"bc )-$("&;D#
#
 	#
 &#
 "#
  #
 9#
 
#
 d#
J !!"bc 3< )-$("&;D,
,
 	,

 0,
 &,
 ",
  ,
 9,
 
,
 d,
\ !!"bc
 !*!* )3<!* )-$("&;DE
E
 	E

 E
 E
 1E
 E
 &E
 "E
  E
 9E
 
!E
 dE
N !!"bc )-$("&;D#
#
 	#
 &#
 "#
  #
 9#
 
#
 d#
r-   c                  8   \ rS rSr\SS j5       r\SS j5       r\R                  " S5      \	\	SSS\	S.                   SS jj5       r
\R                  " S5      SSS\	S.             SS	 jj5       r\R                  " S5      \	SSS\	S
.               SS jj5       r\R                  " S5      \	\	\	\	\	SSS\	S.	                     SS jj5       r\R                  " S5      SSS\	S.             SS jj5       rSrg)r"   i:  c                    [        U 5      $ r&   )AsyncMessagesWithRawResponser(   s    r*   r+   AsyncMessages.with_raw_response;  s     ,D11r-   c                    [        U 5      $ r/   )"AsyncMessagesWithStreamingResponser(   s    r*   r1   %AsyncMessages.with_streaming_responseE  s     2$77r-   r3   Nr4   c                  #    U(       d  [        SU< 35      eSS0U=(       d    0 EnU R                  SU S3[        UUUUS.[        R                  5      I Sh  vN [        XgXS9[        S	9I Sh  vN $  N N7f)
r<   r=   r>   r?   r@   rA   rB   NrE   rF   )rJ   rK   r   r   rL   r   r   rM   s
             r*   rO   AsyncMessages.createN  s     ^ WXaWdeff&QM<ORQZZ	{),,& #. (	 &99  )+Q[    
 
 	

s$   AA;A7
A;2A93A;9A;rE   c          
        #    U(       d  [        SU< 35      eU(       d  [        SU< 35      eSS0U=(       d    0 EnU R                  SU SU 3[        X4XVS9[        S9I S	h  vN $  N7f)
rR   r=   rS   r>   r?   r@   rT   rE   rU   NrV   rX   s          r*   rZ   AsyncMessages.retrieve  s     2 WXaWdeffXYcXfghh&QM<ORQYY	{*ZL9(+Q[   
 
 	
 
   A"A+$A)%A+r\   c               $  #    U(       d  [        SU< 35      eU(       d  [        SU< 35      eSS0U=(       d    0 EnU R                  SU SU 3[        SU0[        R                  5      I Sh  vN [        XEXgS	9[        S
9I Sh  vN $  N N7f)r^   r=   rS   r>   r?   r@   rT   r6   NrE   rF   )rJ   rK   r   r   r_   r   r   r`   s           r*   ra   AsyncMessages.update  s     B WXaWdeffXYcXfghh&QM<ORQZZ	{*ZL9,j(-CEZEnEnoo(+Q[    
 
 	
o
s$   A-B/B
0BBBBrc   c       	            U(       d  [        SU< 35      eSS0U=(       d    0 EnU R                  SU S3[        [           [	        UUU	U
[        UUUUUS.[        R                  5      S9[        S9$ rj   )rJ   rn   r   r   r   r   r   ro   rp   s              r*   rq   AsyncMessages.list  s    ^ WXaWdeff&QM<ORQ!!	{), )(+'%%!&"(!&!&"( (99	  ' " 
 	
r-   c          
        #    U(       d  [        SU< 35      eU(       d  [        SU< 35      eSS0U=(       d    0 EnU R                  SU SU 3[        X4XVS9[        S9I S	h  vN $  N7f)
rt   r=   rS   r>   r?   r@   rT   rE   rU   Nru   rX   s          r*   rw   AsyncMessages.delete.  s     2 WXaWdeffXYcXfghh&QM<ORQ\\	{*ZL9(+Q[ # " 
 
 	
 
r   ry   )rz   r   )rz   r   r{   r   r   )rN   r|   rd   r   re   r   rf   r   rg   r   rh   r   r7   r~   r8   r   r9   r   r:   r   rz   z1AsyncPaginator[Message, AsyncCursorPage[Message]]r   r   ry   r-   r*   r"   r"   :  s   2 2 8 8 !!"bc Xa2; )-$("&;D@
@
 ?	@

 +@
 U@
 0@
 &@
 "@
  @
 9@
 
@
 d@
D !!"bc )-$("&;D#
#
 	#
 &#
 "#
  #
 9#
 
#
 d#
J !!"bc 3< )-$("&;D,
,
 	,

 0,
 &,
 ",
  ,
 9,
 
,
 d,
\ !!"bc
 !*!* )3<!* )-$("&;DE
E
 	E

 E
 E
 1E
 E
 &E
 "E
  E
 9E
 
;E
 dE
N !!"bc )-$("&;D#
#
 	#
 &#
 "#
  #
 9#
 
#
 d#
r-   c                      \ rS rSrSS jrSrg)r'   iU  c                   Xl         [        R                  " UR                  5      U l        [        R                  " UR                  5      U l        [        R                  " UR
                  5      U l        [        R                  " UR                  5      U l        [        R                  " UR                  5      U l        g N)	_messagesr	   to_raw_response_wrapperrO   rZ   ra   rq   rw   r)   messagess     r*   __init__ MessagesWithRawResponse.__init__V  s    ! 44 	 44!! 	 44 	 44 		 44 	r-   r   rO   rw   rq   rZ   ra   Nr   r!   rz   Noner   r   r   r   r   r   ry   r-   r*   r'   r'   U      
r-   r'   c                      \ rS rSrSS jrSrg)r   it  c                   Xl         [        R                  " UR                  5      U l        [        R                  " UR                  5      U l        [        R                  " UR
                  5      U l        [        R                  " UR                  5      U l        [        R                  " UR                  5      U l        g r   )r   r	   async_to_raw_response_wrapperrO   rZ   ra   rq   rw   r   s     r*   r   %AsyncMessagesWithRawResponse.__init__u  s    ! :: 	 ::!! 	 :: 	 :: 		 :: 	r-   r   Nr   r"   rz   r   r   ry   r-   r*   r   r   t  r   r-   r   c                      \ rS rSrSS jrSrg)r0   i  c                   Xl         [        UR                  5      U l        [        UR                  5      U l        [        UR                  5      U l        [        UR
                  5      U l        [        UR                  5      U l        g r   )r   r   rO   rZ   ra   rq   rw   r   s     r*   r   &MessagesWithStreamingResponse.__init__  s    ! ) 	 )!! 	 ) 	 ) 		 ) 	r-   r   Nr   r   ry   r-   r*   r0   r0     r   r-   r0   c                      \ rS rSrSS jrSrg)r   i  c                   Xl         [        UR                  5      U l        [        UR                  5      U l        [        UR                  5      U l        [        UR
                  5      U l        [        UR                  5      U l        g r   )r   r   rO   rZ   ra   rq   rw   r   s     r*   r   +AsyncMessagesWithStreamingResponse.__init__  s    ! / 	 /!! 	 / 	 / 		 / 	r-   r   Nr   r   ry   r-   r*   r   r     r   r-   r   )5
__future__r   r   typingr   r   r   r   httpx r	   _typesr
   r   r   r   r   _utilsr   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   r0   r   ry   r-   r*   <module>r      s    #  , , %  ! @ @ = ' ; Z : e d 2 5 A U
'X
 X
vX
$ X
v
 
>
 
>
 
>
 
r-   