
    _iJx                       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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/r0 " S S\5      r1 " S S\5      r2 " S S5      r3 " S S5      r4 " S S5      r5 " S S5      r6g)    )annotationsN)UnionIterableOptional)Literal   )_legacy_response)BodyOmitQueryHeadersNotGivenomit	not_given)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    b/var/www/html/land-ocr/venv/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roler7   r8   r9   r:   r;   r<   bodyoptionscast_to)
ValueError_postr   r   MessageCreateParamsr   r   
r+   	thread_idrE   rF   r7   r8   r9   r:   r;   r<   s
             r,   createMessages.create3   s    ^ WXaWdeff&QM<ORQzz	{), & #. (	 &99 )+Q[   
 	
r/   rG   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@   rA   rB   
/messages/rG   rJ   rK   rL   _getr   r   r+   
message_idrP   r9   r:   r;   r<   s          r,   retrieveMessages.retrievev   s    2 WXaWdeffXYcXfghh&QM<ORQyy	{*ZL9(+Q[   
 	
r/   r8   r9   r:   r;   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?   rU   r@   rA   rB   rV   r8   rG   rH   )rL   rM   r   r   MessageUpdateParamsr   r   r+   r[   rP   r8   r9   r:   r;   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_idr9   r:   r;   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@   rA   rB   rC   )rf   rg   rh   ri   rj   )r9   r:   r;   r<   query)pagerJ   model)rL   _get_api_listr   r   r   r   r   MessageListParamsr+   rP   rf   rg   rh   ri   rj   r9   r:   r;   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?   rU   r@   rA   rB   rV   rG   rW   rL   _deleter   r!   rZ   s          r,   deleteMessages.delete  s    2 WXaWdeffXYcXfghh&QM<ORQ||	{*ZL9(+Q[ #  
 	
r/    )returnr)   )r|   r2   rP   strrE   z-Union[str, Iterable[MessageContentPartParam]]rF   zLiteral['user', 'assistant']r7   z;Optional[Iterable[message_create_params.Attachment]] | Omitr8   Optional[Metadata] | Omitr9   Headers | Noner:   Query | Noner;   Body | Noner<   'float | httpx.Timeout | None | NotGivenr|   r   r[   r~   rP   r~   r9   r   r:   r   r;   r   r<   r   r|   r   r[   r~   rP   r~   r8   r   r9   r   r:   r   r;   r   r<   r   r|   r   )rP   r~   rf   
str | Omitrg   r   rh   
int | Omitri   Literal['asc', 'desc'] | Omitrj   r   r9   r   r:   r   r;   r   r<   r   r|   zSyncCursorPage[Message]r[   r~   rP   r~   r9   r   r:   r   r;   r   r<   r   r|   r!   __name__
__module____qualname____firstlineno__r   r-   r3   typing_extensions
deprecatedr   r   rQ   r\   rc   rs   ry   __static_attributes__r{   r/   r,   r#   r#      s   - - 3 3 !!"bc TX.2 )-$("&;D@
@
 ?	@

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

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

 E
 E
 -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      $ r1   )"AsyncMessagesWithStreamingResponser*   s    r,   r3   %AsyncMessages.with_streaming_responseE  s     2$77r/   r5   Nr6   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@   rA   rB   rC   rD   NrG   rH   )rL   rM   r   r   rN   r   r   rO   s
             r,   rQ   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;rG   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?   rU   r@   rA   rB   rV   rG   rW   NrX   rZ   s          r,   r\   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?   rU   r@   rA   rB   rV   r8   NrG   rH   )rL   rM   r   r   ra   r   r   rb   s           r,   rc   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re   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$ rl   )rL   rp   r   r   r   r   r   rq   rr   s              r,   rs   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)
rv   r?   rU   r@   rA   rB   rV   rG   rW   Nrw   rZ   s          r,   ry   AsyncMessages.delete.  s     2 WXaWdeffXYcXfghh&QM<ORQ\\	{*ZL9(+Q[ # " 
 
 	
 
r   r{   )r|   r   )r|   r   r}   r   r   )rP   r~   rf   r   rg   r   rh   r   ri   r   rj   r   r9   r   r:   r   r;   r   r<   r   r|   z1AsyncPaginator[Message, AsyncCursorPage[Message]]r   r   r{   r/   r,   r$   r$   :  s   2 2 8 8 !!"bc TX.2 )-$("&;D@
@
 ?	@

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

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

 E
 E
 -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_wrapperrQ   r\   rc   rs   ry   r+   messagess     r,   __init__ MessagesWithRawResponse.__init__V  s    ! 44 	 44!! 	 44 	 44 		 44 	r/   r   rQ   ry   rs   r\   rc   Nr   r#   r|   Noner   r   r   r   r   r   r{   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_wrapperrQ   r\   rc   rs   ry   r   s     r,   r   %AsyncMessagesWithRawResponse.__init__u  s    ! :: 	 ::!! 	 :: 	 :: 		 :: 	r/   r   Nr   r$   r|   r   r   r{   r/   r,   r   r   t  r   r/   r   c                      \ rS rSrSS jrSrg)r2   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   rQ   r\   rc   rs   ry   r   s     r,   r   &MessagesWithStreamingResponse.__init__  s    ! ) 	 )!! 	 ) 	 ) 		 ) 	r/   r   Nr   r   r{   r/   r,   r2   r2     r   r/   r2   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   rQ   r\   rc   rs   ry   r   s     r,   r   +AsyncMessagesWithStreamingResponse.__init__  s    ! / 	 /!! 	 / 	 / 		 / 	r/   r   Nr   r   r{   r/   r,   r   r     r   r/   r   )7
__future__r   r   typingr   r   r   r   httpx r	   _typesr
   r   r   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   r2   r   r{   r/   r,   <module>r      s    #  , , %  ! L L L = ' ; Z : e d 2 5 A U
'X
 X
vX
$ X
v
 
>
 
>
 
>
 
r/   