-2imNddlmZddlmZmZddlmZddlZddlm Z ddl m Z m Z m Z mZmZmZmZddlmZdd lmZdd lmZmZdd lmZmZdd lmZmZdd lm Z m!Z!ddl"m#Z#m$Z$ddl%m&Z&ddl'm(Z(ddl)m*Z*ddgZ+GddeZ,GddeZ-GddZ.GddZ/GddZ0GddZ1dS)) annotations)Anycast)LiteralN)_legacy_response)BodyOmitQueryHeadersNotGivenomit not_given)maybe_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%dZdddedd&dZeeeeeddded d'dZ dddedd(d Z eeeeddded!d)d#Z dS)*rreturnThreadsWithRawResponsec t|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 )r#selfs d/var/www/html/pixcura-vrs/venv/lib/python3.11/site-packages/openai/resources/beta/chatkit/threads.pywith_raw_responsezThreads.with_raw_responses&d+++ThreadsWithStreamingResponsec t|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 )r+r&s r(with_streaming_responsezThreads.with_streaming_response%s,D111r*N extra_headers extra_query extra_bodytimeout thread_idstrr0Headers | Noner1 Query | Noner2 Body | Noner3'float | httpx.Timeout | None | NotGivenrc |std|ddi|pi}|d|t||||tS)M Retrieve a ChatKit thread 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/r/optionscast_to ValueError_getrrr'r4r0r1r2r3s r(retrievezThreads.retrieve.s. geXaeeff f&(9Sm>QrS yy + + +(+Q[el"    r* afterbeforelimitorderuserr0r1r2r3rI str | OmitrJrK int | OmitrLLiteral['asc', 'desc'] | OmitrM)SyncConversationCursorPage[ChatKitThread]c ddi|pi}|dttt|||| t |||||dt jtSaH List ChatKit threads 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)rIrJrKrLrMr0r1r2r3querypagerAmodel) _get_api_listrrrrrThreadListParams r'rIrJrKrLrMr0r1r2r3s r(listz Threads.listPsP'(9Sm>QrS !! +M:(+'%%!&"(!&!& $ '7     '"   r*rc |std|ddi|pi}|d|t||||tS)K Delete a ChatKit thread 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<r=r>r?r/r@rD_deleterrrFs r(deletezThreads.deletes. geXaeeff f&(9Sm>QrS || + + +(+Q[el)    r*rIrJrKrLr0r1r2r3 SyncConversationCursorPage[Data]c"|std|ddi|pi}|d|dttt |||| t ||||dt jtttS a List ChatKit thread items 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 r<r=r>r?z/items)rIrJrKrLrTrV) rDrYrrrrrThreadListItemsParamsrr r'r4rIrJrKrLr0r1r2r3s r( list_itemszThreads.list_itemssJ geXaeeff f&(9Sm>QrS !! 1 1 1 1+D1(+'%%!&"(!&!&  -B sD//%"   r*)r"r#)r"r+ r4r5r0r6r1r7r2r8r3r9r"r)rIrNrJrNrKrOrLrPrMrNr0r6r1r7r2r8r3r9r"rQ r4r5r0r6r1r7r2r8r3r9r"r)r4r5rIrNrJrNrKrOrLrPr0r6r1r7r2r8r3r9r"rc __name__ __module__ __qualname__rr)r.rrGrr\rarhr*r(rrs$,,,_,222_2)-$("&;D       J!! /3)-$("&;D= = = = = = J)-$("&;D       L!! /3)-$("&;D; ; ; ; ; ; ; ; r*c eZdZed$dZed%dZdddedd&dZeeeeeddded d'dZ dddedd(d Z eeeeddded!d)d#Z dS)*r r"AsyncThreadsWithRawResponsec t|Sr%)rqr&s r(r)zAsyncThreads.with_raw_responses+4000r*!AsyncThreadsWithStreamingResponsec t|Sr-)rsr&s r(r.z$AsyncThreads.with_streaming_responses1666r*Nr/r4r5r0r6r1r7r2r8r3r9rc K|std|ddi|pi}|d|t||||td{VS)r;r<r=r>r?r/r@NrCrFs r(rGzAsyncThreads.retrieves. geXaeeff f&(9Sm>QrS YY + + +(+Q[el"          r*rHrIrNrJrKrOrLrPrMIAsyncPaginator[ChatKitThread, AsyncConversationCursorPage[ChatKitThread]]c ddi|pi}|dttt|||| t |||||dt jtSrS)rYrrrrrrZr[s r(r\zAsyncThreads.list%sP'(9Sm>QrS !! ,];(+'%%!&"(!&!& $ '7     '"   r*rc K|std|ddi|pi}|d|t||||td{VS)r^r<r=r>r?r/r@Nr_rFs r(razAsyncThreads.deleteds. geXaeeff f&(9Sm>QrS \\ + + +(+Q[el) "         r*rb7AsyncPaginator[Data, AsyncConversationCursorPage[Data]]c"|std|ddi|pi}|d|dttt |||| t ||||dt jtttSre) rDrYrrrrrrfrrrgs r(rhzAsyncThreads.list_itemssJ geXaeeff f&(9Sm>QrS !! 1 1 1 1,T2(+'%%!&"(!&!&  -B sD//%"   r*)r"rq)r"rsri)rIrNrJrNrKrOrLrPrMrNr0r6r1r7r2r8r3r9r"rvrj)r4r5rIrNrJrNrKrOrLrPr0r6r1r7r2r8r3r9r"ryrkror*r(r r s$111_1777_7)-$("&;D       J!! /3)-$("&;D= = = = = = J)-$("&;D       L!! /3)-$("&;D; ; ; ; ; ; ; ; r*ceZdZddZdS)r#threadsrr"Nonec||_tj|j|_tj|j|_tj|j|_tj|j|_dSN)_threadsrto_raw_response_wrapperrGr\rarhr'r|s r(__init__zThreadsWithRawResponse.__init__sy (@     %< L   '> N   +B    r*Nr|rr"r}rlrmrnrror*r(r#r#(      r*r#ceZdZddZdS)rqr|r r"r}c||_tj|j|_tj|j|_tj|j|_tj|j|_dSr)rrasync_to_raw_response_wrapperrGr\rarhrs r(rz$AsyncThreadsWithRawResponse.__init__sy (F     %B L   'D N   +H    r*Nr|r r"r}rror*r(rqrqrr*rqceZdZddZdS)r+r|rr"r}c||_t|j|_t|j|_t|j|_t|j|_dSr)rrrGr\rarhrs r(rz%ThreadsWithStreamingResponse.__init__sm 4     1 L   3 N   7    r*Nrrror*r(r+r+rr*r+ceZdZddZdS)rsr|r r"r}c||_t|j|_t|j|_t|j|_t|j|_dSr)rrrGr\rarhrs r(rz*AsyncThreadsWithStreamingResponse.__init__sm :     7 L   9 N   =    r*Nrrror*r(rsrsrr*rs)2 __future__rtypingrrtyping_extensionsrhttpxr_typesr r r r r rr_utilsr_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__rr r#rqr+rsror*r(rs#"""""%%%%%% !!!!!!LLLLLLLLLLLLLLLLLL&&&&&&'''''';;;;;;;;ZZZZZZZZRRRRRRRRAAAAAAAAOOOOOOOO??????NNNNNN@@@@@@ n %R R R R R oR R R jR R R R R #R R R j        $        $        $          r*