o RWj1@sLddlmZddlZddlmZddlmZmZmZm Z m Z m Z m Z ddl mZmZmZddlmZddlmZmZdd lmZmZdd lmZdd lmZmZmZmZm Z dd l!m"Z"dd l#mZddl$mZddl%mZddl&mZddgZ'GdddeZ(GdddeZ)GdddZ*GdddZ+GdddZ,GdddZ-dS)) annotationsN)_legacy_response)BodyOmitQueryHeadersNotGivenomit not_given) path_templatemaybe_transformasync_maybe_transform)cached_property)SyncAPIResourceAsyncAPIResource)to_streamed_response_wrapper"async_to_streamed_response_wrapper)make_request_options)ChatSessionWorkflowParamChatSessionRateLimitsParamChatSessionExpiresAfterParam$ChatSessionChatKitConfigurationParamsession_create_params) ChatSession)r)r)r)rSessions AsyncSessionsc@ZeZdZed#ddZed$ddZeeeddded d%ddZdddedd&d!d"Z dS)'rreturnSessionsWithRawResponsecCt|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 )rselfr$u/home/esfera/Documents/content_generation/venv/lib/python3.10/site-packages/openai/resources/beta/chatkit/sessions.pywith_raw_responsezSessions.with_raw_responseSessionsWithStreamingResponsecCr 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)z Sessions.with_streaming_responseNchatkit_configuration expires_after rate_limits extra_headers extra_query extra_bodytimeoutuserstrworkflowrr-+ChatSessionChatKitConfigurationParam | Omitr.#ChatSessionExpiresAfterParam | Omitr/!ChatSessionRateLimitsParam | Omitr0Headers | Noner1 Query | Noner2 Body | Noner3'float | httpx.Timeout | None | NotGivenrc CsHddi|pi}|jdt|||||dtjt|||| ddidtdS) u Create a ChatKit session. Args: user: A free-form string that identifies your end user; ensures this Session can access other objects that have the same `user` scope. workflow: Workflow that powers the session. chatkit_configuration: Optional overrides for ChatKit runtime configuration features expires_after: Optional override for session expiration timing in seconds from creation. Defaults to 10 minutes. rate_limits: Optional override for per-minute request limits. When omitted, defaults to 10. 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 OpenAI-Betachatkit_beta=v1/chatkit/sessionsr4r6r-r.r/ bearer_authTr0r1r2r3securitybodyoptionscast_to)_postr rSessionCreateParamsrr r#r4r6r-r.r/r0r1r2r3r$r$r%create2s*' zSessions.creater0r1r2r3 session_idc CsL|s td|ddi|pi}|jtd|dt||||ddidtd S)  Cancel an active ChatKit session and return its most recent metadata. Cancelling prevents new requests from using the issued client secret. 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 9Expected a non-empty value for `session_id` but received r?r@%/chatkit/sessions/{session_id}/cancelrOrCTrDrHrI ValueErrorrJr rrr#rOr0r1r2r3r$r$r%cancelps zSessions.cancel)rr)rr(r4r5r6rr-r7r.r8r/r9r0r:r1r;r2r<r3r=rr rOr5r0r:r1r;r2r<r3r=rr __name__ __module__ __qualname__rr&r*r r rMrXr$r$r$r%r$   Dc@r)'rrAsyncSessionsWithRawResponsecCr r!)r`r"r$r$r%r&r'zAsyncSessions.with_raw_response"AsyncSessionsWithStreamingResponsecCr r))rar"r$r$r%r*r+z%AsyncSessions.with_streaming_responseNr,r4r5r6rr-r7r.r8r/r9r0r:r1r;r2r<r3r=rc sVddi|pi}|jdt|||||dtjIdHt|||| ddidtd IdHS) r>r?r@rArBNrCTrDrF)rJrrrKrrrLr$r$r%rMs,'  zAsyncSessions.createrNrOc sT|s td|ddi|pi}|jtd|dt||||ddidtd Id HS) rPrQr?r@rRrSrCTrDrTNrUrWr$r$r%rXs  zAsyncSessions.cancel)rr`)rrarYrZr[r$r$r$r%rr_c@eZdZdddZdS) rsessionsrrNonecC&||_t|j|_t|j|_dSN) _sessionsrto_raw_response_wrapperrMrXr#rcr$r$r%__init__ z SessionsWithRawResponse.__init__Nrcrrrdr\r]r^rjr$r$r$r%rrc@rb) r`rcrrrdcCrerf)rgrasync_to_raw_response_wrapperrMrXrir$r$r%rj!rkz%AsyncSessionsWithRawResponse.__init__Nrcrrrdrmr$r$r$r%r` rnr`c@rb) r(rcrrrdcC"||_t|j|_t|j|_dSrf)rgrrMrXrir$r$r%rj- z&SessionsWithStreamingResponse.__init__Nrlrmr$r$r$r%r(,rnr(c@rb) rarcrrrdcCrqrf)rgrrMrXrir$r$r%rj9rrz+AsyncSessionsWithStreamingResponse.__init__Nrprmr$r$r$r%ra8rnra). __future__rhttpxr_typesrrrrr r r _utilsr r r_compatr _resourcerr _responserr _base_clientrtypes.beta.chatkitrrrrrtypes.beta.chatkit.chat_sessionr.types.beta.chatkit.chat_session_workflow_param1types.beta.chatkit.chat_session_rate_limits_param3types.beta.chatkit.chat_session_expires_after_param;types.beta.chatkit.chat_session_chatkit_configuration_param__all__rrrr`r(rar$r$r$r%s,  $       {{