ó
    ûÞ j”R  ã                  óx  • S SK Jr  S SK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%  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      r. " S S5      r/ " S S5      r0 " S S5      r1 " S S5      r2g)é    )Úannotations)ÚAnyÚcast)ÚLiteralNé   )Ú_legacy_response)ÚBodyÚOmitÚQueryÚHeadersÚNotGivenÚomitÚ	not_given)Úpath_templateÚmaybe_transform)Úcached_property)ÚSyncAPIResourceÚAsyncAPIResource)Úto_streamed_response_wrapperÚ"async_to_streamed_response_wrapper)ÚSyncConversationCursorPageÚAsyncConversationCursorPage)ÚAsyncPaginatorÚmake_request_options)Úthread_list_paramsÚthread_list_items_params)ÚChatKitThread)ÚThreadDeleteResponse)ÚDataÚThreadsÚAsyncThreadsc            
      ó&  • \ rS rSr\SS j5       r\SS j5       rSSS\S.           SS jjr\	\	\	\	\	SSS\S.	                   SS jjr
SSS\S.           SS	 jjr\	\	\	\	SSS\S
.                   SS jj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
)ÚThreadsWithRawResponse©Úselfs    Ú_/var/www/html/gaurav/venv/lib/python3.13/site-packages/openai/resources/beta/chatkit/threads.pyÚwith_raw_responseÚThreads.with_raw_response   s   € ô & dÓ+Ð+ó    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
)ÚThreadsWithStreamingResponser'   s    r)   Úwith_streaming_responseÚThreads.with_streaming_response%   s   € ô ,¨DÓ1Ð1r,   N©Ú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9[        UUUUSS0S9[        S	9$ )
á(  
Retrieve a ChatKit thread by its identifier.

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
ú8Expected a non-empty value for `thread_id` but received úOpenAI-Betaúchatkit_beta=v1ú/chatkit/threads/{thread_id}©Ú	thread_idÚbearer_authT©r3   r4   r5   r6   Úsecurity©ÚoptionsÚcast_to©Ú
ValueErrorÚ_getr   r   r   ©r(   r>   r3   r4   r5   r6   s         r)   ÚretrieveÚThreads.retrieve.   ss   € ö. ÜÐWÐXaÑWdÐeÓfÐfØ&Ð(9ÐS¸m×>QÈrÐSˆØ�y‰yÜÐ8ÀIÑNÜ(Ø+Ø'Ø%ØØ'¨Ð.ñô "ð ð 

ð 
	
r,   ©	ÚafterÚbeforeÚlimitÚorderÚuserr3   r4   r5   r6   c       	        óº   • SS0U=(       d    0 EnU R                  S[        [           [        UUUU	[	        UUUUUS.[
        R                  5      SS0S9[        S9$ ©	aû  
List ChatKit threads with optional pagination and user filters.

Args:
  after: List items created after this thread item ID. Defaults to null for the first
      page.

  before: List items created before this thread item ID. Defaults to null for the newest
      results.

  limit: Maximum number of thread items to return. Defaults to 20.

  order: Sort order for results by creation time. Defaults to `desc`.

  user: Filter threads that belong to this user identifier. Defaults to null to return
      all users.

  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;   z/chatkit/threads)rL   rM   rN   rO   rP   r?   T©r3   r4   r5   r6   ÚqueryrA   ©ÚpagerC   Úmodel)Ú_get_api_listr   r   r   r   r   ÚThreadListParams©
r(   rL   rM   rN   rO   rP   r3   r4   r5   r6   s
             r)   ÚlistÚThreads.listT   s‡   € ðP 'Ð(9ÐS¸m×>QÈrÐSˆØ×!Ñ!ØÜ+¬MÑ:Ü(Ø+Ø'Ø%ØÜ%à!&Ø"(Ø!&Ø!&Ø $ñô '×7Ñ7ó	ð (¨Ð.ñô"  ð) "ð 
ð 	
r,   c               ó    • U(       d  [        SU< 35      eSS0U=(       d    0 EnU R                  [        SUS9[        UUUUSS0S9[        S	9$ )
á@  
Delete a ChatKit thread along with its items and stored attachments.

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
r9   r:   r;   r<   r=   r?   Tr@   rB   ©rF   Ú_deleter   r   r   rH   s         r)   ÚdeleteÚThreads.delete”   ss   € ö. ÜÐWÐXaÑWdÐeÓfÐfØ&Ð(9ÐS¸m×>QÈrÐSˆØ�|‰|ÜÐ8ÀIÑNÜ(Ø+Ø'Ø%ØØ'¨Ð.ñô )ð ð 

ð 
	
r,   ©rL   rM   rN   rO   r3   r4   r5   r6   c               ó  • U(       d  [        SU< 35      eSS0U=(       d    0 EnU R                  [        SUS9[        [           [        UUUU	[        UUUUS.[        R                  5      SS0S	9[        [        [        5      S
9$ ©a~  
List items that belong to a ChatKit thread.

Args:
  after: List items created after this thread item ID. Defaults to null for the first
      page.

  before: List items created before this thread item ID. Defaults to null for the newest
      results.

  limit: Maximum number of thread items to return. Defaults to 20.

  order: Sort order for results by creation time. Defaults to `desc`.

  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
r9   r:   r;   z"/chatkit/threads/{thread_id}/itemsr=   )rL   rM   rN   rO   r?   TrS   rU   )rF   rX   r   r   r   r   r   r   ÚThreadListItemsParamsr   r   ©
r(   r>   rL   rM   rN   rO   r3   r4   r5   r6   s
             r)   Ú
list_itemsÚThreads.list_itemsº   sª   € öJ ÜÐWÐXaÑWdÐeÓfÐfØ&Ð(9ÐS¸m×>QÈrÐSˆØ×!Ñ!ÜÐ>È)ÑTÜ+¬DÑ1Ü(Ø+Ø'Ø%ØÜ%à!&Ø"(Ø!&Ø!&ñ	ô -×BÑBóð (¨Ð.ñô  ”sœD“/ð' "ð 
ð 	
r,   © )Úreturnr&   )rk   r/   ©r>   Ústrr3   úHeaders | Noner4   úQuery | Noner5   úBody | Noner6   ú(float | httpx2.Timeout | None | NotGivenrk   r   )rL   ú
str | OmitrM   rr   rN   ú
int | OmitrO   úLiteral['asc', 'desc'] | OmitrP   rr   r3   rn   r4   ro   r5   rp   r6   rq   rk   z)SyncConversationCursorPage[ChatKitThread]©r>   rm   r3   rn   r4   ro   r5   rp   r6   rq   rk   r   )r>   rm   rL   rr   rM   rr   rN   rs   rO   rt   r3   rn   r4   ro   r5   rp   r6   rq   rk   z SyncConversationCursorPage[Data]©Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__r   r*   r0   r   rI   r   r[   ra   rh   Ú__static_attributes__rj   r,   r)   r    r       sÕ  † Øó,ó ð,ð ó2ó ð2ð )-Ø$(Ø"&Ø<Eñ$
àð$
ð &ð$
ð "ð$
ð  ð$
ð :ð$
ð 
õ$
ðR !Ø!Ø Ø/3Øð )-Ø$(Ø"&Ø<Eñ>
ð ð>
ð ð	>
ð
 ð>
ð -ð>
ð ð>
ð &ð>
ð "ð>
ð  ð>
ð :ð>
ð 
3õ>
ðL )-Ø$(Ø"&Ø<Eñ$
àð$
ð &ð$
ð "ð$
ð  ð$
ð :ð$
ð 
õ$
ðT !Ø!Ø Ø/3ð )-Ø$(Ø"&Ø<Eñ<
àð<
ð ð	<
ð
 ð<
ð ð<
ð -ð<
ð &ð<
ð "ð<
ð  ð<
ð :ð<
ð 
*÷<
ð <
r,   c            
      ó&  • \ rS rSr\SS j5       r\SS j5       rSSS\S.           SS jjr\	\	\	\	\	SSS\S.	                   SS jjr
SSS\S.           SS	 jjr\	\	\	\	SSS\S
.                   SS jjrSrg)r!   éù   c                ó   • [        U 5      $ r%   )ÚAsyncThreadsWithRawResponser'   s    r)   r*   ÚAsyncThreads.with_raw_responseú   s   € ô +¨4Ó0Ð0r,   c                ó   • [        U 5      $ r.   )Ú!AsyncThreadsWithStreamingResponser'   s    r)   r0   Ú$AsyncThreads.with_streaming_response  s   € ô 1°Ó6Ð6r,   Nr2   c             ƒ  ó¼   #   • U(       d  [        SU< 35      eSS0U=(       d    0 EnU R                  [        SUS9[        UUUUSS0S9[        S	9I S
h  v•N $  N7f)r8   r9   r:   r;   r<   r=   r?   Tr@   rB   NrE   rH   s         r)   rI   ÚAsyncThreads.retrieve  s€   é € ö. ÜÐWÐXaÑWdÐeÓfÐfØ&Ð(9ÐS¸m×>QÈrÐSˆØ—Y‘YÜÐ8ÀIÑNÜ(Ø+Ø'Ø%ØØ'¨Ð.ñô "ð ð 

÷ 

ð 
	
ñ 

ùó   ‚AAÁAÁArK   c       	        óº   • SS0U=(       d    0 EnU R                  S[        [           [        UUUU	[	        UUUUUS.[
        R                  5      SS0S9[        S9$ rR   )rX   r   r   r   r   r   rY   rZ   s
             r)   r[   ÚAsyncThreads.list3  s‡   € ðP 'Ð(9ÐS¸m×>QÈrÐSˆØ×!Ñ!ØÜ,¬]Ñ;Ü(Ø+Ø'Ø%ØÜ%à!&Ø"(Ø!&Ø!&Ø $ñô '×7Ñ7ó	ð (¨Ð.ñô"  ð) "ð 
ð 	
r,   c             ƒ  ó¼   #   • U(       d  [        SU< 35      eSS0U=(       d    0 EnU R                  [        SUS9[        UUUUSS0S9[        S	9I S
h  v•N $  N7f)r^   r9   r:   r;   r<   r=   r?   Tr@   rB   Nr_   rH   s         r)   ra   ÚAsyncThreads.deletes  s€   é € ö. ÜÐWÐXaÑWdÐeÓfÐfØ&Ð(9ÐS¸m×>QÈrÐSˆØ—\‘\ÜÐ8ÀIÑNÜ(Ø+Ø'Ø%ØØ'¨Ð.ñô )ð "ð 

÷ 

ð 
	
ñ 

ùr†   rc   c               ó  • U(       d  [        SU< 35      eSS0U=(       d    0 EnU R                  [        SUS9[        [           [        UUUU	[        UUUUS.[        R                  5      SS0S	9[        [        [        5      S
9$ re   )rF   rX   r   r   r   r   r   r   rf   r   r   rg   s
             r)   rh   ÚAsyncThreads.list_items™  sª   € öJ ÜÐWÐXaÑWdÐeÓfÐfØ&Ð(9ÐS¸m×>QÈrÐSˆØ×!Ñ!ÜÐ>È)ÑTÜ,¬TÑ2Ü(Ø+Ø'Ø%ØÜ%à!&Ø"(Ø!&Ø!&ñ	ô -×BÑBóð (¨Ð.ñô  ”sœD“/ð' "ð 
ð 	
r,   rj   )rk   r   )rk   r‚   rl   )rL   rr   rM   rr   rN   rs   rO   rt   rP   rr   r3   rn   r4   ro   r5   rp   r6   rq   rk   zIAsyncPaginator[ChatKitThread, AsyncConversationCursorPage[ChatKitThread]]ru   )r>   rm   rL   rr   rM   rr   rN   rs   rO   rt   r3   rn   r4   ro   r5   rp   r6   rq   rk   z7AsyncPaginator[Data, AsyncConversationCursorPage[Data]]rv   rj   r,   r)   r!   r!   ù   s×  † Øó1ó ð1ð ó7ó ð7ð )-Ø$(Ø"&Ø<Eñ$
àð$
ð &ð$
ð "ð$
ð  ð$
ð :ð$
ð 
õ$
ðR !Ø!Ø Ø/3Øð )-Ø$(Ø"&Ø<Eñ>
ð ð>
ð ð	>
ð
 ð>
ð -ð>
ð ð>
ð &ð>
ð "ð>
ð  ð>
ð :ð>
ð 
Sõ>
ðL )-Ø$(Ø"&Ø<Eñ$
àð$
ð &ð$
ð "ð$
ð  ð$
ð :ð$
ð 
õ$
ðT !Ø!Ø Ø/3ð )-Ø$(Ø"&Ø<Eñ<
àð<
ð ð	<
ð
 ð<
ð ð<
ð -ð<
ð &ð<
ð "ð<
ð  ð<
ð :ð<
ð 
A÷<
ð <
r,   c                  ó   • \ rS rSrSS jrSrg)r&   iØ  c                ó8  • 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        g ©N)Ú_threadsr   Úto_raw_response_wrapperrI   r[   ra   rh   ©r(   Úthreadss     r)   Ú__init__ÚThreadsWithRawResponse.__init__Ù  su   € ØŒä(×@Ò@Ø×Ñó
ˆŒô %×<Ò<Ø�L‰Ló
ˆŒ	ô '×>Ò>Ø�N‰Nó
ˆŒô +×BÒBØ×Ñó
ˆ�r,   ©r�   ra   r[   rh   rI   N©r“   r    rk   ÚNone©rw   rx   ry   rz   r”   r{   rj   r,   r)   r&   r&   Ø  ó   † ÷
r,   r&   c                  ó   • \ rS rSrSS jrSrg)r   iê  c                ó8  • 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        g r�   )r�   r   Úasync_to_raw_response_wrapperrI   r[   ra   rh   r’   s     r)   r”   Ú$AsyncThreadsWithRawResponse.__init__ë  su   € ØŒä(×FÒFØ×Ñó
ˆŒô %×BÒBØ�L‰Ló
ˆŒ	ô '×DÒDØ�N‰Nó
ˆŒô +×HÒHØ×Ñó
ˆ�r,   r–   N©r“   r!   rk   r˜   r™   rj   r,   r)   r   r   ê  rš   r,   r   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        g r�   )r�   r   rI   r[   ra   rh   r’   s     r)   r”   Ú%ThreadsWithStreamingResponse.__init__ý  s]   € ØŒä4Ø×Ñó
ˆŒô 1Ø�L‰Ló
ˆŒ	ô 3Ø�N‰Nó
ˆŒô 7Ø×Ñó
ˆ�r,   r–   Nr—   r™   rj   r,   r)   r/   r/   ü  rš   r,   r/   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        g r�   )r�   r   rI   r[   ra   rh   r’   s     r)   r”   Ú*AsyncThreadsWithStreamingResponse.__init__  s]   € ØŒä:Ø×Ñó
ˆŒô 7Ø�L‰Ló
ˆŒ	ô 9Ø�N‰Nó
ˆŒô =Ø×Ñó
ˆ�r,   r–   NrŸ   r™   rj   r,   r)   r‚   r‚     rš   r,   r‚   )3Ú
__future__r   Útypingr   r   Útyping_extensionsr   Úhttpx2Ú r   Ú_typesr	   r
   r   r   r   r   r   Ú_utilsr   r   Ú_compatr   Ú	_resourcer   r   Ú	_responser   r   Ú
paginationr   r   Ú_base_clientr   r   Útypes.beta.chatkitr   r   Ú!types.beta.chatkit.chatkit_threadr   Ú)types.beta.chatkit.thread_delete_responser   Ú+types.beta.chatkit.chatkit_thread_item_listr   Ú__all__r    r!   r&   r   r/   r‚   rj   r,   r)   Ú<module>r·      sŽ   ðõ #ç Ý %ã å !ß L× LÑ Lß 5Ý 'ß ;ß Zß Rß Aß OÝ ?Ý NÝ @à�nÐ
%€ô\
ˆoô \
ô~\
Ð#ô \
÷~
ñ 
÷$
ñ 
÷$
ñ 
÷$
ò 
r,   