o $imN@sPddlmZddlmZmZddlmZddlZddlm 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+GdddeZ,GdddeZ-GdddZ.GdddZ/GdddZ0GdddZ1dS)) 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*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/flask_server/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_idstrr0Headers | Noner1 Query | Noner2 Body | Noner3'float | httpx.Timeout | None | NotGivenrcCD|s td|ddi|pi}|jd|t||||dtdS)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&r4r0r1r2r3r'r'r(retrieve.zThreads.retrieve afterbeforelimitorderuserr0r1r2r3rJ str | OmitrKrL int | OmitrMLiteral['asc', 'desc'] | OmitrN)SyncConversationCursorPage[ChatKitThread]c CHddi|pi}|jdttt|||| t|||||dtjdtdSaH 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 r=r>z/chatkit/threads)rJrKrLrMrNr0r1r2r3querypagerAmodel) _get_api_listrrrrrThreadListParams r&rJrKrLrMrNr0r1r2r3r'r'r(listP*(z Threads.listrcCr:)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 r<r=r>r?r/r@rD_deleterrrFr'r'r(deleterHzThreads.deleterJrKrLrMr0r1r2r3 SyncConversationCursorPage[Data]c Cf|s td|ddi|pi}|jd|dttt|||| t||||dtjdtt tdS 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 r<r=r>r?z/items)rJrKrLrMrUrW) rDrZrrrrrThreadListItemsParamsrr r&r4rJrKrLrMr0r1r2r3r'r'r( list_items,% zThreads.list_items)r!r")r!r+ r4r5r0r6r1r7r2r8r3r9r!r)rJrOrKrOrLrPrMrQrNrOr0r6r1r7r2r8r3r9r!rR r4r5r0r6r1r7r2r8r3r9r!r)r4r5rJrOrKrOrLrPrMrQr0r6r1r7r2r8r3r9r!rd __name__ __module__ __qualname__rr)r-rrGr r]rbrir'r'r'r(rD  %E&c @r )0rr!AsyncThreadsWithRawResponsecCr#r$)rrr%r'r'r(r)r*zAsyncThreads.with_raw_response!AsyncThreadsWithStreamingResponsecCr#r,)rsr%r'r'r(r-r.z$AsyncThreads.with_streaming_responseNr/r4r5r0r6r1r7r2r8r3r9rcL|s td|ddi|pi}|jd|t||||dtdIdHS)r;r<r=r>r?r/r@NrCrFr'r'r(rG zAsyncThreads.retrieverIrJrOrKrLrPrMrQrNIAsyncPaginator[ChatKitThread, AsyncConversationCursorPage[ChatKitThread]]c CrSrT)rZrrrrrr[r\r'r'r(r]%r^zAsyncThreads.listrcrt)r_r<r=r>r?r/r@Nr`rFr'r'r(rbdruzAsyncThreads.deleterc7AsyncPaginator[Data, AsyncConversationCursorPage[Data]]c Crerf) rDrZrrrrrrgrrrhr'r'r(rirjzAsyncThreads.list_items)r!rr)r!rsrk)rJrOrKrOrLrPrMrQrNrOr0r6r1r7r2r8r3r9r!rvrl)r4r5rJrOrKrOrLrPrMrQr0r6r1r7r2r8r3r9r!rwrmr'r'r'r(rrqc@eZdZdddZdS) r"threadsrr!NonecCB||_t|j|_t|j|_t|j|_t|j|_dSN)_threadsrto_raw_response_wrapperrGr]rbrir&ryr'r'r(__init__ zThreadsWithRawResponse.__init__Nryrr!rzrnrorprr'r'r'r(r"r"c@rx) rrryrr!rzcCr{r|)r}rasync_to_raw_response_wrapperrGr]rbrirr'r'r(rrz$AsyncThreadsWithRawResponse.__init__Nryrr!rzrr'r'r'r(rrrrrc@rx) r+ryrr!rzcC:||_t|j|_t|j|_t|j|_t|j|_dSr|)r}rrGr]rbrirr'r'r(r z%ThreadsWithStreamingResponse.__init__Nrrr'r'r'r(r+rr+c@rx) rsryrr!rzcCrr|)r}rrGr]rbrirr'r'r(rrz*AsyncThreadsWithStreamingResponse.__init__Nrrr'r'r'r(rsrrs)2 __future__rtypingrrtyping_extensionsrhttpxr_typesrr r r r r r_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__rrr"rrr+rsr'r'r'r(s2   $     VV