iRddlmZddlmZmZddlmZddlZddlm 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/piyush/.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||||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}r5 bearer_authTr1r2r3r4securityoptionscast_to ValueError_getrrrr(r5r1r2r3r4s r)retrievezThreads.retrieve.s. geXaeeff f&(9Sm>QrS yy 8I N N N(+'%'. "   r+ afterbeforelimitorderuserr1r2r3r4rN str | OmitrOrP int | OmitrQLiteral['asc', 'desc'] | OmitrR)SyncConversationCursorPage[ChatKitThread]c ddi|pi}|dttt|||| t |||||dt jdditS 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 r>r?z/chatkit/threads)rNrOrPrQrRrBTr1r2r3r4queryrDpagerFmodel) _get_api_listrrrrrThreadListParams r(rNrOrPrQrRr1r2r3r4s r)listz Threads.listTsP'(9Sm>QrS !! +M:(+'%%!&"(!&!& $ '7  (." )"   r+rc |std|ddi|pi}|td|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 r=r>r?r@rArBTrCrErI_deleterrrrKs r)deletezThreads.deletes. geXaeeff f&(9Sm>QrS || 8I N N N(+'%'. )   r+rNrOrPrQr1r2r3r4 SyncConversationCursorPage[Data]c>|std|ddi|pi}|td|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 r=r>r?z"/chatkit/threads/{thread_id}/itemsrA)rNrOrPrQrBTrYr[) rIr^rrrrrrThreadListItemsParamsrr r(r5rNrOrPrQr1r2r3r4s r) list_itemszThreads.list_itemssJ geXaeeff f&(9Sm>QrS !! >) T T T+D1(+'%%!&"(!&!&  -B(. sD//'"   r+)r#r$)r#r, r5r6r1r7r2r8r3r9r4r:r#r)rNrSrOrSrPrTrQrUrRrSr1r7r2r8r3r9r4r:r#rV r5r6r1r7r2r8r3r9r4r:r#r)r5r6rNrSrOrSrPrTrQrUr1r7r2r8r3r9r4r:r#rh __name__ __module__ __qualname__rr*r/rrLrrarfrmr+r)r r s$,,,_,222_2)-$("&;D$ $ $ $ $ $ R!! /3)-$("&;D> > > > > > L)-$("&;D$ $ $ $ $ $ T!! /3)-$("&;D< < < < < < < < r+c eZdZed$dZed%dZdddedd&dZeeeeeddded d'dZ dddedd(d Z eeeeddded!d)d#Z dS)*r!r#AsyncThreadsWithRawResponsec t|Sr&)rvr's r)r*zAsyncThreads.with_raw_responses+4000r+!AsyncThreadsWithStreamingResponsec t|Sr.)rxr's r)r/z$AsyncThreads.with_streaming_responses1666r+Nr0r5r6r1r7r2r8r3r9r4r:rc K|std|ddi|pi}|td|t||||ddit d {VS) r<r=r>r?r@rArBTrCrENrHrKs r)rLzAsyncThreads.retrieve s. geXaeeff f&(9Sm>QrS YY 8I N N N(+'%'. "         r+rMrNrSrOrPrTrQrUrRIAsyncPaginator[ChatKitThread, AsyncConversationCursorPage[ChatKitThread]]c ddi|pi}|dttt|||| t |||||dt jdditSrX)r^rrrrrr_r`s r)razAsyncThreads.list3sP'(9Sm>QrS !! ,];(+'%%!&"(!&!& $ '7  (." )"   r+rc K|std|ddi|pi}|td|t||||ddit d {VS) rcr=r>r?r@rArBTrCrENrdrKs r)rfzAsyncThreads.deletess. geXaeeff f&(9Sm>QrS \\ 8I N N N(+'%'. )"         r+rg7AsyncPaginator[Data, AsyncConversationCursorPage[Data]]c>|std|ddi|pi}|td|ttt |||| t ||||dtjddi ttt Srj) rIr^rrrrrrrkrrrls r)rmzAsyncThreads.list_itemssJ geXaeeff f&(9Sm>QrS !! >) T T T,T2(+'%%!&"(!&!&  -B(. sD//'"   r+)r#rv)r#rxrn)rNrSrOrSrPrTrQrUrRrSr1r7r2r8r3r9r4r:r#r{ro)r5r6rNrSrOrSrPrTrQrUr1r7r2r8r3r9r4r:r#r~rprtr+r)r!r!s$111_1777_7)-$("&;D$ $ $ $ $ $ R!! /3)-$("&;D> > > > > > L)-$("&;D$ $ $ $ $ $ T!! /3)-$("&;D< < < < < < < < r+ceZdZddZdS)r$threadsr r#Nonec||_tj|j|_tj|j|_tj|j|_tj|j|_dSN)_threadsrto_raw_response_wrapperrLrarfrmr(rs r)__init__zThreadsWithRawResponse.__init__sy (@     %< L   '> N   +B    r+Nrr r#rrqrrrsrrtr+r)r$r$(      r+r$ceZdZddZdS)rvrr!r#rc||_tj|j|_tj|j|_tj|j|_tj|j|_dSr)rrasync_to_raw_response_wrapperrLrarfrmrs r)rz$AsyncThreadsWithRawResponse.__init__sy (F     %B L   'D N   +H    r+Nrr!r#rrrtr+r)rvrvrr+rvceZdZddZdS)r,rr r#rc||_t|j|_t|j|_t|j|_t|j|_dSr)rrrLrarfrmrs r)rz%ThreadsWithStreamingResponse.__init__sm 4     1 L   3 N   7    r+Nrrrtr+r)r,r,rr+r,ceZdZddZdS)rxrr!r#rc||_t|j|_t|j|_t|j|_t|j|_dSr)rrrLrarfrmrs r)rz*AsyncThreadsWithStreamingResponse.__init__sm :     7 L   9 N   =    r+Nrrrtr+r)rxrxrr+rx)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$rvr,rxrtr+r)rs#"""""%%%%%% !!!!!!LLLLLLLLLLLLLLLLLL55555555'''''';;;;;;;;ZZZZZZZZRRRRRRRRAAAAAAAAOOOOOOOO??????NNNNNN@@@@@@ n %\ \ \ \ \ o\ \ \ ~\ \ \ \ \ #\ \ \ ~        $        $        $          r+