o niHP@sTddlmZddlmZmZddlmZddlZddlm 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,GdddeZ-GdddeZ.GdddZ/GdddZ0GdddZ1GdddZ2dS)) 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*ddZed+ddZddded d,ddZeeeeeddded d-d!d"Z ddded d.d$d%Z eeeeddded&d/d(d)Z dS)0rreturnThreadsWithRawResponsecCt|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#selfr(e/var/www/html/arapca_proje/venv/lib/python3.10/site-packages/openai/resources/beta/chatkit/threads.pywith_raw_responsezThreads.with_raw_responseThreadsWithStreamingResponsecCr$z 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&r(r(r)with_streaming_response%zThreads.with_streaming_responseN extra_headers extra_query extra_bodytimeout thread_idstrr1Headers | Noner2 Query | Noner3 Body | Noner4'float | httpx.Timeout | None | NotGivenrcCF|s td|ddi|pi}|jtd|dt||||dtdS)` 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'r5r1r2r3r4r(r(r)retrieve. zThreads.retrieve afterbeforelimitorderuserr1r2r3r4rL str | OmitrMrN int | OmitrOLiteral['asc', 'desc'] | OmitrP)SyncConversationCursorPage[ChatKitThread]c CHddi|pi}|jdttt|||| t|||||dtjdtdSas 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)rLrMrNrOrPr1r2r3r4querypagerCmodel) _get_api_listrrrrrThreadListParams r'rLrMrNrOrPr1r2r3r4r(r(r)listP*(z Threads.listrcCr;)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_deleterrrrHr(r(r)deleterJzThreads.deleterLrMrNrOr1r2r3r4 SyncConversationCursorPage[Data]c Cf|s td|ddi|pi}|jtd|dttt|||| t||||dtjdt t tdS 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)rLrMrNrOrWrY) rFr\rrrrrrThreadListItemsParamsrr r'r5rLrMrNrOr1r2r3r4r(r(r) list_items,% zThreads.list_items)r"r#)r"r, r5r6r1r7r2r8r3r9r4r:r"r)rLrQrMrQrNrRrOrSrPrQr1r7r2r8r3r9r4r:r"rT r5r6r1r7r2r8r3r9r4r:r"r)r5r6rLrQrMrQrNrRrOrSr1r7r2r8r3r9r4r:r"rf __name__ __module__ __qualname__rr*r.rrIr r_rdrkr(r(r(r)rD  %E&c @r!)0r r"AsyncThreadsWithRawResponsecCr$r%)rtr&r(r(r)r*r+zAsyncThreads.with_raw_response!AsyncThreadsWithStreamingResponsecCr$r-)rur&r(r(r)r.r/z$AsyncThreads.with_streaming_responseNr0r5r6r1r7r2r8r3r9r4r:rcN|s td|ddi|pi}|jtd|dt||||dtdIdHS) r<r=r>r?r@rAr0rBNrErHr(r(r)rI  zAsyncThreads.retrieverKrLrQrMrNrRrOrSrPIAsyncPaginator[ChatKitThread, AsyncConversationCursorPage[ChatKitThread]]c CrUrV)r\rrrrrr]r^r(r(r)r_%r`zAsyncThreads.listrcrv) rar=r>r?r@rAr0rBNrbrHr(r(r)rddrwzAsyncThreads.deletere7AsyncPaginator[Data, AsyncConversationCursorPage[Data]]c Crgrh) rFr\rrrrrrrirrrjr(r(r)rkrlzAsyncThreads.list_items)r"rt)r"rurm)rLrQrMrQrNrRrOrSrPrQr1r7r2r8r3r9r4r:r"rxrn)r5r6rLrQrMrQrNrRrOrSr1r7r2r8r3r9r4r:r"ryror(r(r(r)r rsc@eZdZdddZdS) r#threadsrr"NonecCB||_t|j|_t|j|_t|j|_t|j|_dSN)_threadsrto_raw_response_wrapperrIr_rdrkr'r{r(r(r)__init__ zThreadsWithRawResponse.__init__Nr{rr"r|rprqrrrr(r(r(r)r#r#c@rz) rtr{r r"r|cCr}r~)rrasync_to_raw_response_wrapperrIr_rdrkrr(r(r)rrz$AsyncThreadsWithRawResponse.__init__Nr{r r"r|rr(r(r(r)rtrrtc@rz) r,r{rr"r|cC:||_t|j|_t|j|_t|j|_t|j|_dSr~)rrrIr_rdrkrr(r(r)r z%ThreadsWithStreamingResponse.__init__Nrrr(r(r(r)r,rr,c@rz) rur{r r"r|cCrr~)rrrIr_rdrkrr(r(r)rrz*AsyncThreadsWithStreamingResponse.__init__Nrrr(r(r(r)rurru)3 __future__rtypingrrtyping_extensionsrhttpxr_typesrr r r r r r_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__rr r#rtr,rur(r(r(r)s2   $    VV