o wq 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'l/home/app/PaddleOCR-VL/.venv_paddleocr/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/optionsZcast_to ValueError_getrrr&r4r0r1r2r3r'r'r(retrieve.zThreads.retrieve afterbeforelimitorderuserr0r1r2r3rI str | OmitrJrK int | OmitrLLiteral['asc', 'desc'] | OmitrM)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)rIrJrKrLrMr0r1r2r3querypagerAmodel) _get_api_listrrrrrThreadListParams r&rIrJrKrLrMr0r1r2r3r'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@rC_deleterrrEr'r'r(deleterGzThreads.deleterIrJrKrLr0r1r2r3 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)rIrJrKrLrTrV) rCrYrrrrrThreadListItemsParamsrr r&r4rIrJrKrLr0r1r2r3r'r'r( list_items,% zThreads.list_items)r!r")r!r+ r4r5r0r6r1r7r2r8r3r9r!r)rIrNrJrNrKrOrLrPrMrNr0r6r1r7r2r8r3r9r!rQ r4r5r0r6r1r7r2r8r3r9r!r)r4r5rIrNrJrNrKrOrLrPr0r6r1r7r2r8r3r9r!rc __name__ __module__ __qualname__rr)r-rrFr r\rarhr'r'r'r(rD  %E&c @r )0rr!AsyncThreadsWithRawResponsecCr#r$)rqr%r'r'r(r)r*zAsyncThreads.with_raw_response!AsyncThreadsWithStreamingResponsecCr#r,)rrr%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@NrBrEr'r'r(rF zAsyncThreads.retrieverHrIrNrJrKrOrLrPrMIAsyncPaginator[ChatKitThread, AsyncConversationCursorPage[ChatKitThread]]c CrRrS)rYrrrrrrZr[r'r'r(r\%r]zAsyncThreads.listrcrs)r^r<r=r>r?r/r@Nr_rEr'r'r(radrtzAsyncThreads.deleterb7AsyncPaginator[Data, AsyncConversationCursorPage[Data]]c Crdre) rCrYrrrrrrfrrrgr'r'r(rhrizAsyncThreads.list_items)r!rq)r!rrrj)rIrNrJrNrKrOrLrPrMrNr0r6r1r7r2r8r3r9r!rurk)r4r5rIrNrJrNrKrOrLrPr0r6r1r7r2r8r3r9r!rvrlr'r'r'r(rrpc@eZdZdddZdS) r"threadsrr!NonecCB||_t|j|_t|j|_t|j|_t|j|_dSN)_threadsrZto_raw_response_wrapperrFr\rarhr&rxr'r'r(__init__ zThreadsWithRawResponse.__init__Nrxrr!ryrmrnror~r'r'r'r(r"r"c@rw) rqrxrr!rycCrzr{)r|rZasync_to_raw_response_wrapperrFr\rarhr}r'r'r(r~rz$AsyncThreadsWithRawResponse.__init__Nrxrr!ryrr'r'r'r(rqrrqc@rw) r+rxrr!rycC:||_t|j|_t|j|_t|j|_t|j|_dSr{)r|rrFr\rarhr}r'r'r(r~ z%ThreadsWithStreamingResponse.__init__Nrrr'r'r'r(r+rr+c@rw) rrrxrr!rycCrr{)r|rrFr\rarhr}r'r'r(r~rz*AsyncThreadsWithStreamingResponse.__init__Nrrr'r'r'r(rrrrr)2 __future__rtypingrrZtyping_extensionsrZhttpxr_typesrr r r r r r_utilsrZ_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__rrr"rqr+rrr'r'r'r(s2   $     VV