o iHP@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(_/home/kim/smarthome/.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}r5r0optionsZcast_to ValueError_getrrrr'r5r1r2r3r4r(r(r)retrieve. zThreads.retrieve afterbeforelimitorderuserr1r2r3r4rK str | OmitrLrM int | OmitrNLiteral['asc', 'desc'] | OmitrO)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)rKrLrMrNrOr1r2r3r4querypagerCmodel) _get_api_listrrrrrThreadListParams r'rKrLrMrNrOr1r2r3r4r(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@rAr0rBrE_deleterrrrGr(r(r)deleterIzThreads.deleterKrLrMrNr1r2r3r4 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)rKrLrMrNrVrX) rEr[rrrrrrThreadListItemsParamsrr r'r5rKrLrMrNr1r2r3r4r(r(r) list_items,% zThreads.list_items)r"r#)r"r, r5r6r1r7r2r8r3r9r4r:r"r)rKrPrLrPrMrQrNrRrOrPr1r7r2r8r3r9r4r:r"rS r5r6r1r7r2r8r3r9r4r:r"r)r5r6rKrPrLrPrMrQrNrRr1r7r2r8r3r9r4r:r"re __name__ __module__ __qualname__rr*r.rrHr r^rcrjr(r(r(r)rD  %E&c @r!)0r r"AsyncThreadsWithRawResponsecCr$r%)rsr&r(r(r)r*r+zAsyncThreads.with_raw_response!AsyncThreadsWithStreamingResponsecCr$r-)rtr&r(r(r)r.r/z$AsyncThreads.with_streaming_responseNr0r5r6r1r7r2r8r3r9r4r:rcN|s td|ddi|pi}|jtd|dt||||dtdIdHS) r<r=r>r?r@rAr0rBNrDrGr(r(r)rH  zAsyncThreads.retrieverJrKrPrLrMrQrNrRrOIAsyncPaginator[ChatKitThread, AsyncConversationCursorPage[ChatKitThread]]c CrTrU)r[rrrrrr\r]r(r(r)r^%r_zAsyncThreads.listrcru) r`r=r>r?r@rAr0rBNrarGr(r(r)rcdrvzAsyncThreads.deleterd7AsyncPaginator[Data, AsyncConversationCursorPage[Data]]c Crfrg) rEr[rrrrrrrhrrrir(r(r)rjrkzAsyncThreads.list_items)r"rs)r"rtrl)rKrPrLrPrMrQrNrRrOrPr1r7r2r8r3r9r4r:r"rwrm)r5r6rKrPrLrPrMrQrNrRr1r7r2r8r3r9r4r:r"rxrnr(r(r(r)r rrc@eZdZdddZdS) r#threadsrr"NonecCB||_t|j|_t|j|_t|j|_t|j|_dSN)_threadsrZto_raw_response_wrapperrHr^rcrjr'rzr(r(r)__init__ zThreadsWithRawResponse.__init__Nrzrr"r{rorprqrr(r(r(r)r#r#c@ry) rsrzr r"r{cCr|r})r~rZasync_to_raw_response_wrapperrHr^rcrjrr(r(r)rrz$AsyncThreadsWithRawResponse.__init__Nrzr r"r{rr(r(r(r)rsrrsc@ry) r,rzrr"r{cC:||_t|j|_t|j|_t|j|_t|j|_dSr})r~rrHr^rcrjrr(r(r)r z%ThreadsWithStreamingResponse.__init__Nrrr(r(r(r)r,rr,c@ry) rtrzr r"r{cCrr})r~rrHr^rcrjrr(r(r)rrz*AsyncThreadsWithStreamingResponse.__init__Nrrr(r(r(r)rtrrt)3 __future__rtypingrrZtyping_extensionsrZhttpxr_typesrr r r r r rZ_utilsrrZ_compatrZ _resourcerr _responserrZ paginationrrZ _base_clientrrZtypes.beta.chatkitrrZ!types.beta.chatkit.chatkit_threadrZ)types.beta.chatkit.thread_delete_responserZ+types.beta.chatkit.chatkit_thread_item_listr__all__rr r#rsr,rtr(r(r(r)s2   $    VV