o RWjR@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(t/home/esfera/Documents/content_generation/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 | NotGivenrc CL|s td|ddi|pi}|jtd|dt||||ddidtd 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'r5r1r2r3r4r(r(r)retrieve. zThreads.retrieve afterbeforelimitorderuserr1r2r3r4rO str | OmitrPrQ int | OmitrRLiteral['asc', 'desc'] | OmitrS)SyncConversationCursorPage[ChatKitThread]c CNddi|pi}|jdttt|||| t|||||dtjddidtdS 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)rOrPrQrRrSrBTr1r2r3r4queryrDpagerFmodel) _get_api_listrrrrrThreadListParams r'rOrPrQrRrSr1r2r3r4r(r(r)listT,( z Threads.listrc Cr;) 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_deleterrrrKr(r(r)deleterMzThreads.deleterOrPrQrRr1r2r3r4 SyncConversationCursorPage[Data]c Cl|s td|ddi|pi}|jtd|dttt|||| t||||dtjddid t t td 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)rOrPrQrRrBTrZr\) rIr_rrrrrrThreadListItemsParamsrr r'r5rOrPrQrRr1r2r3r4r(r(r) list_items.%  zThreads.list_items)r"r#)r"r, r5r6r1r7r2r8r3r9r4r:r"r)rOrTrPrTrQrUrRrVrSrTr1r7r2r8r3r9r4r:r"rW r5r6r1r7r2r8r3r9r4r:r"r)r5r6rOrTrPrTrQrUrRrVr1r7r2r8r3r9r4r:r"ri __name__ __module__ __qualname__rr*r.rrLr rbrgrnr(r(r(r)rD  )F*c @r!)0r r"AsyncThreadsWithRawResponsecCr$r%)rwr&r(r(r)r*r+zAsyncThreads.with_raw_response!AsyncThreadsWithStreamingResponsecCr$r-)rxr&r(r(r)r.r/z$AsyncThreads.with_streaming_responseNr0r5r6r1r7r2r8r3r9r4r:rc T|s td|ddi|pi}|jtd|dt||||ddidtd Id HS) r<r=r>r?r@rArBTrCrENrHrKr(r(r)rL   zAsyncThreads.retrieverNrOrTrPrQrUrRrVrSIAsyncPaginator[ChatKitThread, AsyncConversationCursorPage[ChatKitThread]]c CrXrY)r_rrrrrr`rar(r(r)rb3rczAsyncThreads.listrc ry) rdr=r>r?r@rArBTrCrENrerKr(r(r)rgsrzzAsyncThreads.deleterh7AsyncPaginator[Data, AsyncConversationCursorPage[Data]]c Crjrk) rIr_rrrrrrrlrrrmr(r(r)rnrozAsyncThreads.list_items)r"rw)r"rxrp)rOrTrPrTrQrUrRrVrSrTr1r7r2r8r3r9r4r:r"r{rq)r5r6rOrTrPrTrQrUrRrVr1r7r2r8r3r9r4r:r"r|rrr(r(r(r)r rvc@eZdZdddZdS) r#threadsrr"NonecCB||_t|j|_t|j|_t|j|_t|j|_dSN)_threadsrto_raw_response_wrapperrLrbrgrnr'r~r(r(r)__init__ zThreadsWithRawResponse.__init__Nr~rr"rrsrtrurr(r(r(r)r#r#c@r}) rwr~r r"rcCrr)rrasync_to_raw_response_wrapperrLrbrgrnrr(r(r)rrz$AsyncThreadsWithRawResponse.__init__Nr~r r"rrr(r(r(r)rwrrwc@r}) r,r~rr"rcC:||_t|j|_t|j|_t|j|_t|j|_dSr)rrrLrbrgrnrr(r(r)r z%ThreadsWithStreamingResponse.__init__Nrrr(r(r(r)r,rr,c@r}) rxr~r r"rcCrr)rrrLrbrgrnrr(r(r)rrz*AsyncThreadsWithStreamingResponse.__init__Nrrr(r(r(r)rxrrx)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#rwr,rxr(r(r(r)s2   $    ``