Ë
    ñEjêf  ã                  óx  — d dl mZ d dlmZmZmZ d dlmZ d dlZddl	m
Z
 ddlmZmZmZmZmZ ddlmZmZ dd	lmZ dd
lmZmZ ddlmZmZ ddlmZmZ ddlm Z m!Z! ddl"m#Z#m$Z$m%Z% ddl&m'Z' ddl(m)Z) ddl*m+Z+ ddgZ, G d„ de«      Z- G d„ de«      Z. G d„ d«      Z/ G d„ d«      Z0 G d„ d«      Z1 G d„ d«      Z2y)é    )Úannotations)ÚUnionÚIterableÚOptional)ÚLiteralNé   )Ú_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)ÚMessageDeleted)ÚMessageContentPartParamÚMessagesÚAsyncMessagesc            
      óF  — e Zd Zedd„«       Zedd„«       Zeedddedœ	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 dd„Zdddedœ	 	 	 	 	 	 	 	 	 	 	 	 	 dd„Zedddedœ	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 dd	„Z	eeeeeddded
œ		 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 dd„Z
dddedœ	 	 	 	 	 	 	 	 	 	 	 	 	 dd„Zy)r    c                ó   — t        | «      S ©N)ÚMessagesWithRawResponse©Úselfs    úi/var/www/html/peoplehubportal/venv/lib/python3.12/site-packages/openai/resources/beta/threads/messages.pyÚwith_raw_responsezMessages.with_raw_response!   s   € ä& tÓ,Ð,ó    c                ó   — t        | «      S r$   )ÚMessagesWithStreamingResponser&   s    r(   Úwith_streaming_responsez Messages.with_streaming_response%   s   € ä,¨TÓ2Ð2r*   N©ÚattachmentsÚmetadataÚextra_headersÚextra_queryÚ
extra_bodyÚtimeoutc          
     óÄ   — |st        d|›�«      ‚ddi|xs i ¥}| j                  d|› d�t        ||||dœt        j                  «      t        ||||	¬«      t        ¬«      S )	á×  
        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. Keys
              can be a maximum of 64 characters long and values can be a maxium of 512
              characters long.

          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Úroler/   r0   ©r1   r2   r3   r4   ©ÚbodyÚoptionsÚcast_to)Ú
ValueErrorÚ_postr   r   ÚMessageCreateParamsr   r   ©
r'   Ú	thread_idr=   r>   r/   r0   r1   r2   r3   r4   s
             r(   ÚcreatezMessages.create)   s‘   € ñX ÜÐWÐXaÐWdÐeÓfÐfØ&¨ÐQ¸MÒ<OÈRÐQˆØ�z‰zØ˜	�{ )Ð,Ü à&Ø Ø#.Ø (ñ	ô &×9Ñ9óô )Ø+¸ÐQ[Ðelôô ð ó 
ð 	
r*   r?   c          	     ó¬   — |st        d|›�«      ‚|st        d|›�«      ‚ddi|xs i ¥}| j                  d|› d|› �t        ||||¬«      t        ¬«      S )	áG  
        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
        r7   ú9Expected a non-empty value for `message_id` but received r8   r9   r:   ú
/messages/r?   ©rB   rC   ©rD   Ú_getr   r   ©r'   Ú
message_idrH   r1   r2   r3   r4   s          r(   ÚretrievezMessages.retrievei   s†   € ñ0 ÜÐWÐXaÐWdÐeÓfÐfÙÜÐXÐYcÐXfÐgÓhÐhØ&¨ÐQ¸MÒ<OÈRÐQˆØ�y‰yØ˜	�{ *¨Z¨LÐ9Ü(Ø+¸ÐQ[Ðelôô ð ó 
ð 	
r*   ©r0   r1   r2   r3   r4   c          
     óâ   — |st        d|›�«      ‚|st        d|›�«      ‚ddi|xs i ¥}| j                  d|› d|› �t        d|it        j                  «      t        ||||¬«      t        ¬	«      S )
á�  
        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. Keys
              can be a maximum of 64 characters long and values can be a maxium of 512
              characters long.

          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
        r7   rL   r8   r9   r:   rM   r0   r?   r@   )rD   rE   r   r   ÚMessageUpdateParamsr   r   ©r'   rR   rH   r0   r1   r2   r3   r4   s           r(   ÚupdatezMessages.updateŽ   sœ   € ñ< ÜÐWÐXaÐWdÐeÓfÐfÙÜÐXÐYcÐXfÐgÓhÐhØ&¨ÐQ¸MÒ<OÈRÐQˆØ�z‰zØ˜	�{ *¨Z¨LÐ9Ü  *¨hÐ!7Ô9N×9bÑ9bÓcÜ(Ø+¸ÐQ[Ðelôô ð ó 
ð 	
r*   ©	ÚafterÚbeforeÚlimitÚorderÚrun_idr1   r2   r3   r4   c       	        óÞ   — |st        d|›�«      ‚ddi|xs i ¥}| j                  d|› d�t        t           t	        |||	|
t        |||||dœt        j                  «      ¬«      t        ¬«      S ©	af  
        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,
              ending 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
        r7   r8   r9   r:   r;   )r[   r\   r]   r^   r_   )r1   r2   r3   r4   Úquery)ÚpagerB   Úmodel)rD   Ú_get_api_listr   r   r   r   r   ÚMessageListParams©r'   rH   r[   r\   r]   r^   r_   r1   r2   r3   r4   s              r(   ÚlistzMessages.listº   s�   € ñ\ ÜÐWÐXaÐWdÐeÓfÐfØ&¨ÐQ¸MÒ<OÈRÐQˆØ×!Ñ!Ø˜	�{ )Ð,Ü¤Ñ(Ü(Ø+Ø'Ø%ØÜ%à!&Ø"(Ø!&Ø!&Ø"(ñô (×9Ñ9ó	ôô  ð' "ó 
ð 	
r*   c          	     ó¬   — |st        d|›�«      ‚|st        d|›�«      ‚ddi|xs i ¥}| j                  d|› d|› �t        ||||¬«      t        ¬«      S )	áF  
        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
        r7   rL   r8   r9   r:   rM   r?   rN   ©rD   Ú_deleter   r   rQ   s          r(   ÚdeletezMessages.delete  s†   € ñ0 ÜÐWÐXaÐWdÐeÓfÐfÙÜÐXÐYcÐXfÐgÓhÐhØ&¨ÐQ¸MÒ<OÈRÐQˆØ�|‰|Ø˜	�{ *¨Z¨LÐ9Ü(Ø+¸ÐQ[Ðelôô #ð ó 
ð 	
r*   )Úreturnr%   )rn   r,   ©rH   Ústrr=   z-Union[str, Iterable[MessageContentPartParam]]r>   zLiteral['user', 'assistant']r/   z?Optional[Iterable[message_create_params.Attachment]] | NotGivenr0   úOptional[object] | NotGivenr1   úHeaders | Noner2   úQuery | Noner3   úBody | Noner4   ú'float | httpx.Timeout | None | NotGivenrn   r   ©rR   rp   rH   rp   r1   rr   r2   rs   r3   rt   r4   ru   rn   r   ©rR   rp   rH   rp   r0   rq   r1   rr   r2   rs   r3   rt   r4   ru   rn   r   )rH   rp   r[   ústr | NotGivenr\   rx   r]   úint | NotGivenr^   ú!Literal['asc', 'desc'] | NotGivenr_   rx   r1   rr   r2   rs   r3   rt   r4   ru   rn   zSyncCursorPage[Message]©rR   rp   rH   rp   r1   rr   r2   rs   r3   rt   r4   ru   rn   r   ©Ú__name__Ú
__module__Ú__qualname__r   r)   r-   r
   rI   rS   rY   rh   rm   © r*   r(   r    r        s\  „ Øò-ó ð-ð ò3ó ð3ð XaØ09ð )-Ø$(Ø"&Ø;Dñ>
àð>
ð ?ð	>
ð
 +ð>
ð Uð>
ð .ð>
ð &ð>
ð "ð>
ð  ð>
ð 9ð>
ð 
ó>
ðN )-Ø$(Ø"&Ø;Dñ#
àð#
ð ð	#
ð &ð#
ð "ð#
ð  ð#
ð 9ð#
ð 
ó#
ðT 1:ð )-Ø$(Ø"&Ø;Dñ*
àð*
ð ð	*
ð
 .ð*
ð &ð*
ð "ð*
ð  ð*
ð 9ð*
ð 
ó*
ð` !*Ø!*Ø )Ø3<Ø!*ð )-Ø$(Ø"&Ø;DñE
àðE
ð ð	E
ð
 ðE
ð ðE
ð 1ðE
ð ðE
ð &ðE
ð "ðE
ð  ðE
ð 9ðE
ð 
!óE
ð\ )-Ø$(Ø"&Ø;Dñ#
àð#
ð ð	#
ð &ð#
ð "ð#
ð  ð#
ð 9ð#
ð 
ô#
r*   c            
      óF  — e Zd Zedd„«       Zedd„«       Zeedddedœ	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 dd„Zdddedœ	 	 	 	 	 	 	 	 	 	 	 	 	 dd„Zedddedœ	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 dd	„Z	eeeeeddded
œ		 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 dd„Z
dddedœ	 	 	 	 	 	 	 	 	 	 	 	 	 dd„Zy)r!   c                ó   — t        | «      S r$   )ÚAsyncMessagesWithRawResponser&   s    r(   r)   zAsyncMessages.with_raw_response(  s   € ä+¨DÓ1Ð1r*   c                ó   — t        | «      S r$   )Ú"AsyncMessagesWithStreamingResponser&   s    r(   r-   z%AsyncMessages.with_streaming_response,  s   € ä1°$Ó7Ð7r*   Nr.   c          
   ƒ  óô   K  — |st        d|›�«      ‚ddi|xs i ¥}| j                  d|› d�t        ||||dœt        j                  «      ƒ d{  –—† t        ||||	¬«      t        ¬	«      ƒ d{  –—† S 7 Œ$7 Œ­w)
r6   r7   r8   r9   r:   r;   r<   Nr?   r@   )rD   rE   r   r   rF   r   r   rG   s
             r(   rI   zAsyncMessages.create0  sª   è ø€ ñX ÜÐWÐXaÐWdÐeÓfÐfØ&¨ÐQ¸MÒ<OÈRÐQˆØ—Z‘ZØ˜	�{ )Ð,Ü,à&Ø Ø#.Ø (ñ	ô &×9Ñ9ó÷ ô )Ø+¸ÐQ[Ðelôô ð  ó 
÷ 
ð 	
ðøð
ús$   ‚AA8ÁA4
ÁA8Á/A6Á0A8Á6A8r?   c          	   ƒ  óÈ   K  — |st        d|›�«      ‚|st        d|›�«      ‚ddi|xs i ¥}| j                  d|› d|› �t        ||||¬«      t        ¬«      ƒ d	{  –—† S 7 Œ­w)
rK   r7   rL   r8   r9   r:   rM   r?   rN   NrO   rQ   s          r(   rS   zAsyncMessages.retrievep  s”   è ø€ ñ0 ÜÐWÐXaÐWdÐeÓfÐfÙÜÐXÐYcÐXfÐgÓhÐhØ&¨ÐQ¸MÒ<OÈRÐQˆØ—Y‘YØ˜	�{ *¨Z¨LÐ9Ü(Ø+¸ÐQ[Ðelôô ð ó 
÷ 
ð 	
ð 
úó   ‚AA"ÁA ÁA"rT   c          
   ƒ  ó  K  — |st        d|›�«      ‚|st        d|›�«      ‚ddi|xs i ¥}| j                  d|› d|› �t        d|it        j                  «      ƒ d{  –—† t        ||||¬	«      t        ¬
«      ƒ d{  –—† S 7 Œ$7 Œ­w)rV   r7   rL   r8   r9   r:   rM   r0   Nr?   r@   )rD   rE   r   r   rW   r   r   rX   s           r(   rY   zAsyncMessages.update•  s±   è ø€ ñ< ÜÐWÐXaÐWdÐeÓfÐfÙÜÐXÐYcÐXfÐgÓhÐhØ&¨ÐQ¸MÒ<OÈRÐQˆØ—Z‘ZØ˜	�{ *¨Z¨LÐ9Ü,¨j¸(Ð-CÔEZ×EnÑEnÓo×oÜ(Ø+¸ÐQ[Ðelôô ð  ó 
÷ 
ð 	
àoøð
ús$   ‚ABÁB
ÁBÁ>BÁ?BÂBrZ   c       	        óÞ   — |st        d|›�«      ‚ddi|xs i ¥}| j                  d|› d�t        t           t	        |||	|
t        |||||dœt        j                  «      ¬«      t        ¬«      S ra   )rD   re   r   r   r   r   r   rf   rg   s              r(   rh   zAsyncMessages.listÁ  s�   € ñ\ ÜÐWÐXaÐWdÐeÓfÐfØ&¨ÐQ¸MÒ<OÈRÐQˆØ×!Ñ!Ø˜	�{ )Ð,Ü ¤Ñ)Ü(Ø+Ø'Ø%ØÜ%à!&Ø"(Ø!&Ø!&Ø"(ñô (×9Ñ9ó	ôô  ð' "ó 
ð 	
r*   c          	   ƒ  óÈ   K  — |st        d|›�«      ‚|st        d|›�«      ‚ddi|xs i ¥}| j                  d|› d|› �t        ||||¬«      t        ¬«      ƒ d	{  –—† S 7 Œ­w)
rj   r7   rL   r8   r9   r:   rM   r?   rN   Nrk   rQ   s          r(   rm   zAsyncMessages.delete  s”   è ø€ ñ0 ÜÐWÐXaÐWdÐeÓfÐfÙÜÐXÐYcÐXfÐgÓhÐhØ&¨ÐQ¸MÒ<OÈRÐQˆØ—\‘\Ø˜	�{ *¨Z¨LÐ9Ü(Ø+¸ÐQ[Ðelôô #ð "ó 
÷ 
ð 	
ð 
úrˆ   )rn   rƒ   )rn   r…   ro   rv   rw   )rH   rp   r[   rx   r\   rx   r]   ry   r^   rz   r_   rx   r1   rr   r2   rs   r3   rt   r4   ru   rn   z1AsyncPaginator[Message, AsyncCursorPage[Message]]r{   r|   r€   r*   r(   r!   r!   '  s\  „ Øò2ó ð2ð ò8ó ð8ð XaØ09ð )-Ø$(Ø"&Ø;Dñ>
àð>
ð ?ð	>
ð
 +ð>
ð Uð>
ð .ð>
ð &ð>
ð "ð>
ð  ð>
ð 9ð>
ð 
ó>
ðN )-Ø$(Ø"&Ø;Dñ#
àð#
ð ð	#
ð &ð#
ð "ð#
ð  ð#
ð 9ð#
ð 
ó#
ðT 1:ð )-Ø$(Ø"&Ø;Dñ*
àð*
ð ð	*
ð
 .ð*
ð &ð*
ð "ð*
ð  ð*
ð 9ð*
ð 
ó*
ð` !*Ø!*Ø )Ø3<Ø!*ð )-Ø$(Ø"&Ø;DñE
àðE
ð ð	E
ð
 ðE
ð ðE
ð 1ðE
ð ðE
ð &ðE
ð "ðE
ð  ðE
ð 9ðE
ð 
;óE
ð\ )-Ø$(Ø"&Ø;Dñ#
àð#
ð ð	#
ð &ð#
ð "ð#
ð  ð#
ð 9ð#
ð 
ô#
r*   c                  ó   — e Zd Zdd„Zy)r%   c                óz  — || _         t        j                  |j                  «      | _        t        j                  |j                  «      | _        t        j                  |j
                  «      | _        t        j                  |j                  «      | _        t        j                  |j                  «      | _        y r$   )Ú	_messagesr	   Úto_raw_response_wrapperrI   rS   rY   rh   rm   ©r'   Úmessagess     r(   Ú__init__z MessagesWithRawResponse.__init__/  s�   € Ø!ˆŒä&×>Ñ>Ø�O‰Oó
ˆŒô )×@Ñ@Ø×Ñó
ˆŒô '×>Ñ>Ø�O‰Oó
ˆŒô %×<Ñ<Ø�M‰Mó
ˆŒ	ô '×>Ñ>Ø�O‰Oó
ˆ�r*   N©r‘   r    rn   ÚNone©r}   r~   r   r’   r€   r*   r(   r%   r%   .  ó   „ ô
r*   r%   c                  ó   — e Zd Zdd„Zy)rƒ   c                óz  — || _         t        j                  |j                  «      | _        t        j                  |j                  «      | _        t        j                  |j
                  «      | _        t        j                  |j                  «      | _        t        j                  |j                  «      | _        y r$   )rŽ   r	   Úasync_to_raw_response_wrapperrI   rS   rY   rh   rm   r�   s     r(   r’   z%AsyncMessagesWithRawResponse.__init__D  s�   € Ø!ˆŒä&×DÑDØ�O‰Oó
ˆŒô )×FÑFØ×Ñó
ˆŒô '×DÑDØ�O‰Oó
ˆŒô %×BÑBØ�M‰Mó
ˆŒ	ô '×DÑDØ�O‰Oó
ˆ�r*   N©r‘   r!   rn   r”   r•   r€   r*   r(   rƒ   rƒ   C  r–   r*   rƒ   c                  ó   — e Zd Zdd„Zy)r,   c                ó  — || _         t        |j                  «      | _        t        |j                  «      | _        t        |j                  «      | _        t        |j
                  «      | _        t        |j                  «      | _        y r$   )rŽ   r   rI   rS   rY   rh   rm   r�   s     r(   r’   z&MessagesWithStreamingResponse.__init__Y  sr   € Ø!ˆŒä2Ø�O‰Oó
ˆŒô 5Ø×Ñó
ˆŒô 3Ø�O‰Oó
ˆŒô 1Ø�M‰Mó
ˆŒ	ô 3Ø�O‰Oó
ˆ�r*   Nr“   r•   r€   r*   r(   r,   r,   X  r–   r*   r,   c                  ó   — e Zd Zdd„Zy)r…   c                ó  — || _         t        |j                  «      | _        t        |j                  «      | _        t        |j                  «      | _        t        |j
                  «      | _        t        |j                  «      | _        y r$   )rŽ   r   rI   rS   rY   rh   rm   r�   s     r(   r’   z+AsyncMessagesWithStreamingResponse.__init__n  sr   € Ø!ˆŒä8Ø�O‰Oó
ˆŒô ;Ø×Ñó
ˆŒô 9Ø�O‰Oó
ˆŒô 7Ø�M‰Mó
ˆŒ	ô 9Ø�O‰Oó
ˆ�r*   Nrš   r•   r€   r*   r(   r…   r…   m  r–   r*   r…   )3Ú
__future__r   Útypingr   r   r   Útyping_extensionsr   Ú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.beta.threads.message_deletedr   Ú-types.beta.threads.message_content_part_paramr   Ú__all__r    r!   r%   rƒ   r,   r…   r€   r*   r(   ú<module>r°      sš   ðõ #ç ,Ñ ,Ý %ã å !ß @Õ @÷õ (ß ;ß Zß :÷÷ eÑ dÝ 2Ý AÝ Uà�Ð
'€ôD
ˆô D
ôND
Ð$ô D
÷N
ñ 
÷*
ñ 
÷*
ñ 
÷*
ò 
r*   