Fj\m\ddlmZddlZddlmZddlmZmZmZm Z m Z m Z m Z m Z ddlmZmZmZddlmZddlmZmZdd lmZmZmZmZmZmZdd lmZm Z m!Z!m"Z"dd l#m$Z$dd l%m&Z&dd l'm(Z(ddgZ)GddeZ*GddeZ+GddZ,GddZ-GddZ.GddZ/y)) annotationsN)_legacy_response)BodyOmitQueryHeadersNoneTypeNotGivenomit not_given) path_templatemaybe_transformasync_maybe_transform)cached_property)SyncAPIResourceAsyncAPIResource)StreamedBinaryAPIResponseAsyncStreamedBinaryAPIResponseto_streamed_response_wrapper"async_to_streamed_response_wrapper#to_custom_streamed_response_wrapper)async_to_custom_streamed_response_wrapper)session_fork_paramssession_refer_paramssession_accept_paramssession_reject_params)make_request_options)SessionForkResponse)MediaSessionForkConfigParamSessions AsyncSessionscBeZdZed dZed dZddded ddZddded ddZe ddded ddZ ddded dd Z ddded dd Z ddded dd Z y)r!ct|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 )SessionsWithRawResponseselfs \/root/workspace/ytshorts/venv/lib/python3.12/site-packages/openai/resources/live/sessions.pywith_raw_responsezSessions.with_raw_response"s't,,ct|Sz 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 )SessionsWithStreamingResponser's r)with_streaming_responsez Sessions.with_streaming_response,s-T22r+N extra_headers extra_query extra_bodytimeoutc |std|ddi|xsi}|jtd|td|itj t ||||ddi t S) &Accept an incoming SIP call. Supply session with type live, the model, and startup configuration. Before accepting calls, follow the [Live prompting guide](https://developers.openai.com/api/docs/guides/live-prompting) to write frontend conversation instructions and a separate backend prompt. SIP media format is negotiated; omit audio.format. Args: session: Model and startup configuration for the Live session that answers the incoming SIP call. 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 Accept*/*"/live/sessions/{session_id}/accept session_idsession bearer_authTr1r2r3r4securitybodyoptionscast_to) ValueError_postrrrSessionAcceptParamsrr r(r<r=r1r2r3r4s r)acceptzSessions.accept5s@XYcXfgh h!5B]-@bB zz >: V )W!57L7`7`a(+'%'.   r+c |std|ddi|xsi}|jtd|t||||dditj S)  Get Live session content Args: session_id: The ID of the stored Live session to download. Use the session ID returned when the session started with storage enabled. 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 r7r8application/binary#/live/sessions/{session_id}/contentr;r>Tr?rCrDrE_getrrrHttpxBinaryResponseContentr(r<r1r2r3r4s r)download_recordingzSessions.download_recordingesy4XYcXfgh h!#7QMTr?rA)rErFrrrSessionForkParamsrrr(r<rYr=r1r2r3r4s r)forkz Sessions.forks~<XYcXfgh hzz < T !*&$55 )+'%'. (!  r+c |std|ddi|xsi}|jtd|t||||ddit S) \ End a SIP call identified by session_id. 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 r7r8r9"/live/sessions/{session_id}/hangupr;r>Tr?rNrErFrrr rRs r)hangupzSessions.hangupsr.XYcXfgh h!5B]-@bB zz >: V(+'%'.   r+c |std|ddi|xsi}|jtd|td|itj t ||||ddi t S) #Transfer a SIP call to another destination. Supply a nonblank target_uri for the SIP Refer-To header. Args: target_uri: Nonblank URI for the SIP Refer-To header, such as tel:+14155550123 or sip:agent@example.com. 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 r7r8r9!/live/sessions/{session_id}/referr; target_urir>Tr?rA)rErFrrrSessionReferParamsrr r(r<rer1r2r3r4s r)referzSessions.refers:XYcXfgh h!5B]-@bB zz =* U , !;=Q=d=de(+'%'.   r+c |std|ddi|xsi}|jtd|td|itj t ||||ddi t S) Reject an incoming SIP call. Send a required SIP rejection status_code between 300 and 699. Args: status_code: SIP rejection status sent to the caller. This field is required. 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 r7r8r9"/live/sessions/{session_id}/rejectr; status_coder>Tr?rA)rErFrrrSessionRejectParamsrr r(r<rlr1r2r3r4s r)rejectzSessions.rejects8XYcXfgh h!5B]-@bB zz >: V -!=?T?h?hi(+'%'.   r+)returnr&)rpr.r<strr=zsession_accept_params.Sessionr1Headers | Noner2 Query | Noner3 Body | Noner4(float | httpx2.Timeout | None | NotGivenrpNone r<rrr1rsr2rtr3rur4rvrpz+_legacy_response.HttpxBinaryResponseContentr<rrrYzsession_fork_params.Transportr=z"MediaSessionForkConfigParam | Omitr1rsr2rtr3rur4rvrpr r<rrr1rsr2rtr3rur4rvrprwr<rrrerrr1rsr2rtr3rur4rvrprwr<rrrlintr1rsr2rtr3rur4rvrprw__name__ __module__ __qualname__rr*r/r rIrSr r\rarhror+r)r!r!!s2--33)-$("&Tr?rA)rErFrrrrGrr rHs r)rIzAsyncSessions.acceptUs@XYcXfgh h!5B]-@bB ZZ >: V,i-ACXClClmm(+'%'.    m  $AA?A; "A?6A=7A?=A?c K|std|ddi|xsi}|jtd|t||||dditj d {S7w) rKr7r8rLrMr;r>Tr?rNNrOrRs r)rSz AsyncSessions.download_recordings4XYcXfgh h!#7QMTr?rA)rErFrrrrZrrr[s r)r\zAsyncSessions.forks<XYcXfgh hZZ < T,!*&$55 )+'%'. (!     s$AA6 A2 "A6-A4.A64A6c K|std|ddi|xsi}|jtd|t||||ddit d {S7w) r^r7r8r9r_r;r>Tr?rNNr`rRs r)razAsyncSessions.hangups.XYcXfgh h!5B]-@bB ZZ >: V(+'%'.     sAAAAc K|std|ddi|xsi}|jtd|td|itj d{t ||||dd i t d{S7'7w) rcr7r8r9rdr;reNr>Tr?rA)rErFrrrrfrr rgs r)rhzAsyncSessions.refers:XYcXfgh h!5B]-@bB ZZ =* U,lJ-GI]IpIpqq(+'%'.    q  rc K|std|ddi|xsi}|jtd|td|itj d{t ||||dd i t d{S7'7w) rjr7r8r9rkr;rlNr>Tr?rA)rErFrrrrmrr rns r)rozAsyncSessions.reject4s8XYcXfgh h!5B]-@bB ZZ >: V,m[-IK`KtKtuu(+'%'.    u  r)rpr)rprrqrxryrzr{r|r~rr+r)r"r"As22288)-$("&> OO  #3"J"J  ' '# %<< MM  '>> OO  &== NN  '>> OO  r+Nrr!rprwrrrrrr+r)r&r&a r+r&ceZdZddZy)rc||_tj|j|_tj|j|_tj|j |_tj|j |_tj|j|_tj|j|_yr) rrasync_to_raw_response_wrapperrIrSr\rarhrors r)rz%AsyncSessionsWithRawResponse.__init__zs!&DD OO  #3"P"P  ' '# %BB MM  'DD OO  &CC NN  'DD OO  r+Nrr"rprwrrr+r)rryrr+rceZdZddZy)r.cT||_t|j|_t|jt |_t|j |_t|j|_t|j|_t|j|_ yr) rrrIrrSrr\rarhrors r)rz&SessionsWithStreamingResponse.__init__s!2 OO  #F  ' ' %# 1 MM  3 OO  2 NN  3 OO  r+Nrrrr+r)r.r. r+r.ceZdZddZy)rcT||_t|j|_t|jt |_t|j |_t|j|_t|j|_t|j|_ yr) rrrIrrSrr\rarhrors r)rz+AsyncSessionsWithStreamingResponse.__init__s!8 OO  #L  ' ' *# 7 MM  9 OO  8 NN  9 OO  r+Nrrrr+r)rrrr+r)0 __future__rhttpx2r_typesrrrr r r r r _utilsrrr_compatr _resourcerr _responserrrrrr types.liverrrr _base_clientr types.live.session_fork_responser*types.live.media_session_fork_config_paramr __all__r!r"r&rr.rrr+r)rs# UUUKK&: 1CU  '] ] @ ] $] @   0  0  2  r+