FjRxddlmZddlmZmZddlmZddlZddlm Z ddl m Z m Z m Z mZmZmZmZddlmZmZdd lmZdd lmZmZdd lmZmZdd lmZmZdd l m!Z!m"Z"ddl#m$Z$m%Z%ddl&m'Z'ddl(m)Z)ddl*m+Z+ddgZ,GddeZ-GddeZ.GddZ/GddZ0GddZ1GddZ2y)) annotations)Anycast)LiteralN)_legacy_response)BodyOmitQueryHeadersNotGivenomit not_given) path_templatemaybe_transform)cached_property)SyncAPIResourceAsyncAPIResource)to_streamed_response_wrapper"async_to_streamed_response_wrapper)SyncConversationCursorPageAsyncConversationCursorPage)AsyncPaginatormake_request_options)thread_list_paramsthread_list_items_params) ChatKitThread)ThreadDeleteResponse)DataThreads AsyncThreadsc  eZdZed dZed dZddded d dZeeeeeddded ddZ ddded ddZ eeeeddded  dd Z y)r ct|Sa 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 )ThreadsWithRawResponseselfs c/root/workspace/ytshorts/venv/lib/python3.12/site-packages/openai/resources/beta/chatkit/threads.pywith_raw_responsezThreads.with_raw_responses&d++ct|Sz 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_responsezThreads.with_streaming_response%s,D11r*N extra_headers extra_query extra_bodytimeoutc |std|ddi|xsi}|jtd|t||||ddit S) ` 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-Betachatkit_beta=v1/chatkit/threads/{thread_id} thread_id bearer_authTr0r1r2r3securityoptionscast_to ValueError_getrrrr'r;r0r1r2r3s r(retrievezThreads.retrieve.ss.WXaWdef f&(9Sm>QrS yy 8I N(+'%'. "  r* afterbeforelimitorderuserr0r1r2r3c ddi|xsi}|jdttt|||| t |||||dt j dditS as 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 r7r8z/chatkit/threads)rHrIrJrKrLr<Tr0r1r2r3queryr>pager@model) _get_api_listrrrrrThreadListParams r'rHrIrJrKrLr0r1r2r3s r(listz Threads.listTsP'(9Sm>QrS !! +M:(+'%%!&"(!&!& $ '77 (." )"  r*c |std|ddi|xsi}|jtd|t||||ddit S) x 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 r6r7r8r9r:r<Tr=r?rC_deleterrrrEs r(deletezThreads.deletess.WXaWdef f&(9Sm>QrS || 8I N(+'%'. )  r*rHrIrJrKr0r1r2r3c |std|ddi|xsi}|jtd|ttt |||| t ||||dtjddi ttt S 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 r6r7r8z"/chatkit/threads/{thread_id}/itemsr:)rHrIrJrKr<TrOrQ) rCrTrrrrrrThreadListItemsParamsrr r'r;rHrIrJrKr0r1r2r3s r( list_itemszThreads.list_itemssJWXaWdef f&(9Sm>QrS !! >) T+D1(+'%%!&"(!&!&  -BB(. sD/'"  r*)returnr%)rcr- r;strr0Headers | Noner1 Query | Noner2 Body | Noner3(float | httpx2.Timeout | None | NotGivenrcr)rH str | OmitrIrjrJ int | OmitrKLiteral['asc', 'desc'] | OmitrLrjr0rfr1rgr2rhr3rircz)SyncConversationCursorPage[ChatKitThread] r;rer0rfr1rgr2rhr3rircr)r;rerHrjrIrjrJrkrKrlr0rfr1rgr2rhr3rircz SyncConversationCursorPage[Data] __name__ __module__ __qualname__rr)r.rrFrrWr\rbr*r(r r s,,22)-$("& >  >  > - > > &> ">  > :>  3> L)-$("&QrS YY 8I N(+'%'. "    AAAArGc ddi|xsi}|jdttt|||| t |||||dt j dditSrN)rTrrrrrrUrVs r(rWzAsyncThreads.list3sP'(9Sm>QrS !! ,];(+'%%!&"(!&!& $ '77 (." )"  r*c K|std|ddi|xsi}|jtd|t||||ddit d {S7w) rYr6r7r8r9r:r<Tr=r?NrZrEs r(r\zAsyncThreads.deletess.WXaWdef f&(9Sm>QrS \\ 8I N(+'%'. )"    ryr]c |std|ddi|xsi}|jtd|ttt |||| t ||||dtjddi ttt Sr_) rCrTrrrrrrr`rrras r(rbzAsyncThreads.list_itemssJWXaWdef f&(9Sm>QrS !! >) T,T2(+'%%!&"(!&!&  -BB(. sD/'"  r*)rcru)rcrwrd)rHrjrIrjrJrkrKrlrLrjr0rfr1rgr2rhr3rirczIAsyncPaginator[ChatKitThread, AsyncConversationCursorPage[ChatKitThread]]rm)r;rerHrjrIrjrJrkrKrlr0rfr1rgr2rhr3rircz7AsyncPaginator[Data, AsyncConversationCursorPage[Data]]rnrrr*r(r!r!s1177)-$("& >  >  > - > > &> ">  > :>  S> L)-$("&> NN  +BB    r*Nrr rcNonerorprqrrrr*r(r%r% r*r%ceZdZddZy)ruc2||_tj|j|_tj|j|_tj|j |_tj|j |_yr)rrasync_to_raw_response_wrapperrFrWr\rbrs r(rz$AsyncThreadsWithRawResponse.__init__sw (FF     %BB LL  'DD NN  +HH    r*Nrr!rcrrrrr*r(rururr*ruceZdZddZy)r-c||_t|j|_t|j|_t|j|_t|j |_yr)rrrFrWr\rbrs r(rz%ThreadsWithStreamingResponse.__init__s_ 4     1 LL  3 NN  7    r*Nrrrrr*r(r-r-rr*r-ceZdZddZy)rwc||_t|j|_t|j|_t|j|_t|j |_yr)rrrFrWr\rbrs r(rz*AsyncThreadsWithStreamingResponse.__init__s_ :     7 LL  9 NN  =    r*Nrrrrr*r(rwrwrr*rw)3 __future__rtypingrrtyping_extensionsrhttpx2r_typesr r r r r rr_utilsrr_compatr _resourcerr _responserr paginationrr _base_clientrrtypes.beta.chatkitrr!types.beta.chatkit.chatkit_threadr)types.beta.chatkit.thread_delete_responser+types.beta.chatkit.chatkit_thread_item_listr__all__r r!r%rur-rwrrr*r(rs#% !LLL5';ZRAO?N@ n %\ o\ ~\ #\ ~  $  $  $  r*