iHPxddlmZddlmZmZddlmZddlZddlm 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 v/Users/manta/Documents/Projects/TheRoad-I1/.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||||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} thread_idr/optionscast_to ValueError_getrrrr'r;r0r1r2r3s r(retrievezThreads.retrieve.sj.WXaWdef f&(9Sm>QrS yy 8I N(+Q[el"   r* afterbeforelimitorderuserr0r1r2r3c ddi|xsi}|jdttt|||| t |||||dt j tSas 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)rErFrGrHrIr0r1r2r3querypager=model) _get_api_listrrrrrThreadListParams r'rErFrGrHrIr0r1r2r3s r(listz Threads.listPs}P'(9Sm>QrS !! +M:(+'%%!&"(!&!& $ '77    '"  r*c |std|ddi|xsi}|jtd|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 r6r7r8r9r:r/r<r@_deleterrrrBs r(deletezThreads.deletesj.WXaWdef f&(9Sm>QrS || 8I N(+Q[el)   r*rErFrGrHr0r1r2r3c|std|ddi|xsi}|jtd|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 r6r7r8z"/chatkit/threads/{thread_id}/itemsr:)rErFrGrHrLrN) r@rQrrrrrrThreadListItemsParamsrr r'r;rErFrGrHr0r1r2r3s r( list_itemszThreads.list_itemssJWXaWdef f&(9Sm>QrS !! >) T+D1(+'%%!&"(!&!&  -BB sD/%"  r*)returnr%)r`r- r;strr0Headers | Noner1 Query | Noner2 Body | Noner3'float | httpx.Timeout | None | NotGivenr`r)rE str | OmitrFrgrG int | OmitrHLiteral['asc', 'desc'] | OmitrIrgr0rcr1rdr2rer3rfr`z)SyncConversationCursorPage[ChatKitThread] r;rbr0rcr1rdr2rer3rfr`r)r;rbrErgrFrgrGrhrHrir0rcr1rdr2rer3rfr`z SyncConversationCursorPage[Data] __name__ __module__ __qualname__rr)r.rrCrrTrYr_r*r(r r s,,22)-$("&;D    &  "     9     J!! /3)-$("&;D= =  =  = - = = &= "=  = 9=  3= J)-$("&;D    &  "     9     L!! /3)-$("&;D; ;  ;  ;  ; -; &; ";  ; 9;  *; r*c  eZdZed dZed dZddded d dZeeeeeddded ddZ ddded ddZ eeeeddded  dd Z y)r!ct|Sr$)AsyncThreadsWithRawResponser&s r(r)zAsyncThreads.with_raw_responses+400r*ct|Sr,)!AsyncThreadsWithStreamingResponser&s r(r.z$AsyncThreads.with_streaming_responses166r*Nr/c K|std|ddi|xsi}|jtd|t||||td{S7w) r5r6r7r8r9r:r/r<Nr?rBs r(rCzAsyncThreads.retrievesx.WXaWdef f&(9Sm>QrS YY 8I N(+Q[el"     AAAArDc ddi|xsi}|jdttt|||| t |||||dt j tSrK)rQrrrrrrRrSs r(rTzAsyncThreads.list%s}P'(9Sm>QrS !! ,];(+'%%!&"(!&!& $ '77    '"  r*c K|std|ddi|xsi}|jtd|t||||td{S7w) rVr6r7r8r9r:r/r<NrWrBs r(rYzAsyncThreads.deletedsx.WXaWdef f&(9Sm>QrS \\ 8I N(+Q[el) "    rvrZc|std|ddi|xsi}|jtd|ttt |||| t ||||dtjtttSr\) r@rQrrrrrrr]rrr^s r(r_zAsyncThreads.list_itemssJWXaWdef f&(9Sm>QrS !! >) T,T2(+'%%!&"(!&!&  -BB sD/%"  r*)r`rr)r`rtra)rErgrFrgrGrhrHrirIrgr0rcr1rdr2rer3rfr`zIAsyncPaginator[ChatKitThread, AsyncConversationCursorPage[ChatKitThread]]rj)r;rbrErgrFrgrGrhrHrir0rcr1rdr2rer3rfr`z7AsyncPaginator[Data, AsyncConversationCursorPage[Data]]rkror*r(r!r!s1177)-$("&;D    &  "     9     J!! /3)-$("&;D= =  =  = - = = &= "=  = 9=  S= J)-$("&;D    &  "     9     L!! /3)-$("&;D; ;  ;  ;  ; -; &; ";  ; 9;  A; r*ceZdZddZy)r%c2||_tj|j|_tj|j|_tj|j |_tj|j |_yN)_threadsrto_raw_response_wrapperrCrTrYr_r'threadss r(__init__zThreadsWithRawResponse.__init__sw (@@     %<< LL  '>> NN  +BB    r*Nrr r`Nonerlrmrnrror*r(r%r% r*r%ceZdZddZy)rrc2||_tj|j|_tj|j|_tj|j |_tj|j |_yr|)r}rasync_to_raw_response_wrapperrCrTrYr_rs r(rz$AsyncThreadsWithRawResponse.__init__sw (FF     %BB LL  'DD NN  +HH    r*Nrr!r`rrror*r(rrrrrr*rrceZdZddZy)r-c||_t|j|_t|j|_t|j|_t|j |_yr|)r}rrCrTrYr_rs r(rz%ThreadsWithStreamingResponse.__init__s_ 4     1 LL  3 NN  7    r*Nrrror*r(r-r-rr*r-ceZdZddZy)rtc||_t|j|_t|j|_t|j|_t|j |_yr|)r}rrCrTrYr_rs r(rz*AsyncThreadsWithStreamingResponse.__init__s_ :     7 LL  9 NN  =    r*Nrrror*r(rtrtrr*rt)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%rrr-rtror*r(rs#% !LLL5';ZRAO?N@ n %R oR jR #R j  $  $  $  r*