KhmNtddlmZddlmZmZddlmZddlZddlm 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/GddZ0GddZ1y)) 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 dZddded d dZeeeeeddded ddZ ddded ddZ eeeeddded  dd Z y)rct|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 X/var/www/html/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}|jd|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& thread_idr/r0r1r2s r'retrievezThreads.retrieve.si.WXaWdef f&(9Sm>QrS yy { +(+Q[el"   r) afterbeforelimitorderuserr/r0r1r2c ddi|xsi}|jdttt|||| t |||||dt j tSaH 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 r6r7z/chatkit/threads)rCrDrErFrGr/r0r1r2querypager:model) _get_api_listrrrrrThreadListParams r&rCrDrErFrGr/r0r1r2s r'listz Threads.listPs}P'(9Sm>QrS !! +M:(+'%%!&"(!&!& $ '77    '"  r)c |std|ddi|xsi}|jd|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 r5r6r7r8r.r9r=_deleterrr?s r'deletezThreads.deletesi.WXaWdef f&(9Sm>QrS || { +(+Q[el)   r)rCrDrErFr/r0r1r2c|std|ddi|xsi}|jd|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 r5r6r7r8z/items)rCrDrErFrJrL) r=rOrrrrrThreadListItemsParamsrr r&r@rCrDrErFr/r0r1r2s r' list_itemszThreads.list_itemssJWXaWdef f&(9Sm>QrS !! {& 1+D1(+'%%!&"(!&!&  -BB sD/%"  r))returnr$)r^r, r@strr/Headers | Noner0 Query | Noner1 Body | Noner2'float | httpx.Timeout | None | NotGivenr^r)rC str | OmitrDrerE int | OmitrFLiteral['asc', 'desc'] | OmitrGrer/rar0rbr1rcr2rdr^z)SyncConversationCursorPage[ChatKitThread] r@r`r/rar0rbr1rcr2rdr^r)r@r`rCrerDrerErfrFrgr/rar0rbr1rcr2rdr^z SyncConversationCursorPage[Data] __name__ __module__ __qualname__rr(r-rrArrRrWr]r)r'rrs,,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}|jd|t||||td{S7w)r4r5r6r7r8r.r9Nr<r?s r'rAzAsyncThreads.retrievesw.WXaWdef f&(9Sm>QrS YY { +(+Q[el"     AAA  ArBc ddi|xsi}|jdttt|||| t |||||dt j tSrI)rOrrrrrrPrQs r'rRzAsyncThreads.list%s}P'(9Sm>QrS !! ,];(+'%%!&"(!&!& $ '77    '"  r)c K|std|ddi|xsi}|jd|t||||td{S7w)rTr5r6r7r8r.r9NrUr?s r'rWzAsyncThreads.deletedsw.WXaWdef f&(9Sm>QrS \\ { +(+Q[el) "    rtrXc|std|ddi|xsi}|jd|dttt |||| t ||||dt jtttSrZ) r=rOrrrrrr[rrr\s r'r]zAsyncThreads.list_itemssJWXaWdef f&(9Sm>QrS !! {& 1,T2(+'%%!&"(!&!&  -BB sD/%"  r))r^rp)r^rrr_)rCrerDrerErfrFrgrGrer/rar0rbr1rcr2rdr^zIAsyncPaginator[ChatKitThread, AsyncConversationCursorPage[ChatKitThread]]rh)r@r`rCrerDrerErfrFrgr/rar0rbr1rcr2rdr^z7AsyncPaginator[Data, AsyncConversationCursorPage[Data]]rirmr)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_wrapperrArRrWr]r&threadss r'__init__zThreadsWithRawResponse.__init__sw (@@     %<< LL  '>> NN  +BB    r)Nr~rr^Nonerjrkrlrrmr)r'r$r$ r)r$ceZdZddZy)rpc2||_tj|j|_tj|j|_tj|j |_tj|j |_yrz)r{rasync_to_raw_response_wrapperrArRrWr]r}s r'rz$AsyncThreadsWithRawResponse.__init__sw (FF     %BB LL  'DD NN  +HH    r)Nr~r r^rrrmr)r'rprprr)rpceZdZddZy)r,c||_t|j|_t|j|_t|j|_t|j |_yrz)r{rrArRrWr]r}s r'rz%ThreadsWithStreamingResponse.__init__s_ 4     1 LL  3 NN  7    r)Nrrrmr)r'r,r,rr)r,ceZdZddZy)rrc||_t|j|_t|j|_t|j|_t|j |_yrz)r{rrArRrWr]r}s r'rz*AsyncThreadsWithStreamingResponse.__init__s_ :     7 LL  9 NN  =    r)Nrrrmr)r'rrrrrr)rr)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$rpr,rrrmr)r'rs#% !LLL&';ZRAO?N@ n %R oR jR #R j  $  $  $  r)