iHPddlmZddlmZmZddlmZddlZddlm 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/GddZ0GddZ1GddZ2dS)) 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%dZdddedd&dZeeeeeddded d'dZ dddedd(d Z eeeeddded!d)d#Z dS)*r returnThreadsWithRawResponsec 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 l/home/ubuntu/.hermes/hermes-agent/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_idstrr1Headers | Noner2 Query | Noner3 Body | Noner4'float | httpx.Timeout | None | NotGivenrc |std|ddi|pi}|td|t||||tS)` 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}r5r0optionscast_to ValueError_getrrrr(r5r1r2r3r4s r)retrievezThreads.retrieve.s. geXaeeff f&(9Sm>QrS yy 8I N N N(+Q[el"    r+ afterbeforelimitorderuserr1r2r3r4rK str | OmitrLrM int | OmitrNLiteral['asc', 'desc'] | OmitrO)SyncConversationCursorPage[ChatKitThread]c ddi|pi}|dttt|||| t |||||dt jtSas 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)rKrLrMrNrOr1r2r3r4querypagerCmodel) _get_api_listrrrrrThreadListParams r(rKrLrMrNrOr1r2r3r4s r)listz Threads.listPsP'(9Sm>QrS !! +M:(+'%%!&"(!&!& $ '7     '"   r+rc |std|ddi|pi}|td|t||||tS)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 r=r>r?r@rAr0rBrF_deleterrrrHs r)deletezThreads.deletes. geXaeeff f&(9Sm>QrS || 8I N N N(+Q[el)    r+rKrLrMrNr1r2r3r4 SyncConversationCursorPage[Data]c8|std|ddi|pi}|td|ttt |||| t ||||dtjtttS 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 r=r>r?z"/chatkit/threads/{thread_id}/itemsrA)rKrLrMrNrVrX) rFr[rrrrrrThreadListItemsParamsrr r(r5rKrLrMrNr1r2r3r4s r) list_itemszThreads.list_itemssJ geXaeeff f&(9Sm>QrS !! >) T T T+D1(+'%%!&"(!&!&  -B sD//%"   r+)r#r$)r#r, r5r6r1r7r2r8r3r9r4r:r#r)rKrPrLrPrMrQrNrRrOrPr1r7r2r8r3r9r4r:r#rS r5r6r1r7r2r8r3r9r4r:r#r)r5r6rKrPrLrPrMrQrNrRr1r7r2r8r3r9r4r:r#re __name__ __module__ __qualname__rr*r/rrIrr^rcrjr+r)r r s$,,,_,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&)rsr's r)r*zAsyncThreads.with_raw_responses+4000r+!AsyncThreadsWithStreamingResponsec t|Sr.)rur's r)r/z$AsyncThreads.with_streaming_responses1666r+Nr0r5r6r1r7r2r8r3r9r4r:rc K|std|ddi|pi}|td|t||||td{VS) r<r=r>r?r@rAr0rBNrErHs r)rIzAsyncThreads.retrieves. geXaeeff f&(9Sm>QrS YY 8I N N N(+Q[el"          r+rJrKrPrLrMrQrNrRrOIAsyncPaginator[ChatKitThread, AsyncConversationCursorPage[ChatKitThread]]c ddi|pi}|dttt|||| t |||||dt jtSrU)r[rrrrrr\r]s r)r^zAsyncThreads.list%sP'(9Sm>QrS !! ,];(+'%%!&"(!&!& $ '7     '"   r+rc K|std|ddi|pi}|td|t||||td{VS) r`r=r>r?r@rAr0rBNrarHs r)rczAsyncThreads.deleteds. geXaeeff f&(9Sm>QrS \\ 8I N N N(+Q[el) "         r+rd7AsyncPaginator[Data, AsyncConversationCursorPage[Data]]c8|std|ddi|pi}|td|ttt |||| t ||||dtjtttSrg) rFr[rrrrrrrhrrris r)rjzAsyncThreads.list_itemssJ geXaeeff f&(9Sm>QrS !! >) T T T,T2(+'%%!&"(!&!&  -B sD//%"   r+)r#rs)r#rurk)rKrPrLrPrMrQrNrRrOrPr1r7r2r8r3r9r4r:r#rxrl)r5r6rKrPrLrPrMrQrNrRr1r7r2r8r3r9r4r:r#r{rmrqr+r)r!r!s$111_1777_7)-$("&;D       J!! /3)-$("&;D= = = = = = J)-$("&;D       L!! /3)-$("&;D; ; ; ; ; ; ; ; r+ceZdZddZdS)r$threadsr r#Nonec||_tj|j|_tj|j|_tj|j|_tj|j|_dSN)_threadsrto_raw_response_wrapperrIr^rcrjr(r~s r)__init__zThreadsWithRawResponse.__init__sy (@     %< L   '> N   +B    r+Nr~r r#rrnrorprrqr+r)r$r$(      r+r$ceZdZddZdS)rsr~r!r#rc||_tj|j|_tj|j|_tj|j|_tj|j|_dSr)rrasync_to_raw_response_wrapperrIr^rcrjrs r)rz$AsyncThreadsWithRawResponse.__init__sy (F     %B L   'D N   +H    r+Nr~r!r#rrrqr+r)rsrsrr+rsceZdZddZdS)r,r~r r#rc||_t|j|_t|j|_t|j|_t|j|_dSr)rrrIr^rcrjrs r)rz%ThreadsWithStreamingResponse.__init__sm 4     1 L   3 N   7    r+Nrrrqr+r)r,r,rr+r,ceZdZddZdS)rur~r!r#rc||_t|j|_t|j|_t|j|_t|j|_dSr)rrrIr^rcrjrs r)rz*AsyncThreadsWithStreamingResponse.__init__sm :     7 L   9 N   =    r+Nrrrqr+r)rururr+ru)3 __future__rtypingrrtyping_extensionsrhttpxr_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$rsr,rurqr+r)rs#"""""%%%%%% !!!!!!LLLLLLLLLLLLLLLLLL55555555'''''';;;;;;;;ZZZZZZZZRRRRRRRRAAAAAAAAOOOOOOOO??????NNNNNN@@@@@@ n %R R R R R oR R R jR R R R R #R R R j        $        $        $          r+