o Tj\m@s8ddlmZddlZddlmZddlmZmZmZm 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)GdddeZ*GdddeZ+GdddZ,GdddZ-GdddZ.GdddZ/dS)) 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 AsyncSessionsc@eZdZed,ddZed-ddZddded d.ddZddded d/ddZe dddedd0d!d"Z ddded d1d#d$Z ddded d2d&d'Z ddded d3d*d+Z dS)4r returnSessionsWithRawResponsecCt|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)a/home/dinkstrade/pdmp-scanner/venv/lib/python3.10/site-packages/openai/resources/live/sessions.pywith_raw_response"zSessions.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_responseN extra_headers extra_query extra_bodytimeout session_idstrsessionsession_accept_params.Sessionr2Headers | Noner3 Query | Noner4 Body | Noner5(float | httpx2.Timeout | None | NotGivenNonec CZ|s td|ddi|pi}|jtd|dtd|itjt||||ddid td 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}/acceptr6r8 bearer_authTr2r3r4r5securitybodyoptionscast_to) ValueError_postr rrSessionAcceptParamsrr r(r6r8r2r3r4r5r)r)r*accept5s  zSessions.accept+_legacy_response.HttpxBinaryResponseContentc CsN|s td|ddi|pi}|jtd|dt||||ddidtjd 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 rArBapplication/binary#/live/sessions/{session_id}/contentrErFTrGrKrLrM_getr rrHttpxBinaryResponseContentr(r6r2r3r4r5r)r)r*download_recordinges zSessions.download_recordingr8r2r3r4r5 transportsession_fork_params.Transport"MediaSessionForkConfigParam | Omitrc CsL|s td||jtd|dt||dtjt||||ddidtdS)  Fork a stored Live session onto a new WebRTC connection. Args: transport: WebRTC transport with an SDP offer for the new connection to the forked session. session: Optional configuration overrides for the new Live session. Omit this object or send an empty object to inherit the stored session's settings. 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 rA /live/sessions/{session_id}/forkrEr]r8rFTrGrI)rMrNr rrSessionForkParamsrrr(r6r]r8r2r3r4r5r)r)r*forks& z Sessions.forkc CsL|s td|ddi|pi}|jtd|dt||||ddidtd 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 rArBrC"/live/sessions/{session_id}/hanguprErFTrGrVrMrNr rr rZr)r)r*hangups zSessions.hangup target_uric Cr?) #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 rArBrC!/live/sessions/{session_id}/referrErjrFTrGrI)rMrNr rrSessionReferParamsrr r(r6rjr2r3r4r5r)r)r*refers zSessions.refer status_codeintc Cr?) 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 rArBrC"/live/sessions/{session_id}/rejectrErprFTrGrI)rMrNr rrSessionRejectParamsrr r(r6rpr2r3r4r5r)r)r*rejects zSessions.reject)r#r$)r#r-r6r7r8r9r2r:r3r;r4r<r5r=r#r> r6r7r2r:r3r;r4r<r5r=r#rRr6r7r]r^r8r_r2r:r3r;r4r<r5r=r#r r6r7r2r:r3r;r4r<r5r=r#r>r6r7rjr7r2r:r3r;r4r<r5r=r#r>r6r7rprqr2r:r3r;r4r<r5r=r#r>__name__ __module__ __qualname__rr+r/r rQr[r rerirorvr)r)r)r*r !H  6.9-4c@r")4r!r#AsyncSessionsWithRawResponsecCr%r&)rr'r)r)r*r+Br,zAsyncSessions.with_raw_response"AsyncSessionsWithStreamingResponsecCr%r.)rr'r)r)r*r/Lr0z%AsyncSessions.with_streaming_responseNr1r6r7r8r9r2r:r3r;r4r<r5r=r>c h|s td|ddi|pi}|jtd|dtd|itjIdHt||||dd id td IdHS) r@rArBrCrDrEr8NrFTrGrI)rMrNr rrrOrr rPr)r)r*rQUs    zAsyncSessions.acceptrRc sV|s td|ddi|pi}|jtd|dt||||ddidtjd Id HS) rSrArBrTrUrErFTrGrVNrWrZr)r)r*r[s  z AsyncSessions.download_recordingr\r]r^r_rc sZ|s td||jtd|dt||dtjIdHt||||ddidtd IdHS) r`rArarErbNrFTrGrI)rMrNr rrrcrrrdr)r)r*res(  zAsyncSessions.forkc sT|s td|ddi|pi}|jtd|dt||||ddidtd Id HS) rfrArBrCrgrErFTrGrVNrhrZr)r)r*ris  zAsyncSessions.hanguprjc r) rkrArBrCrlrErjNrFTrGrI)rMrNr rrrmrr rnr)r)r*ros   zAsyncSessions.referrprqc r) rrrArBrCrsrErpNrFTrGrI)rMrNr rrrtrr rur)r)r*rv4s   zAsyncSessions.reject)r#r)r#rrwrxryrzr{r|r}r)r)r)r*r!Arc@eZdZdddZdS) r$sessionsr r#r>cC^||_t|j|_t|j|_t|j|_t|j|_t|j|_t|j|_dSN) _sessionsrto_raw_response_wrapperrQr[rerirorvr(rr)r)r*__init__b& z SessionsWithRawResponse.__init__Nrr r#r>r~rrrr)r)r)r*r$ar$c@r) rrr!r#r>cCrr) rrasync_to_raw_response_wrapperrQr[rerirorvrr)r)r*rzrz%AsyncSessionsWithRawResponse.__init__Nrr!r#r>rr)r)r)r*ryrrc@r) r-rr r#r>cCT||_t|j|_t|jt|_t|j|_t|j|_t|j|_t|j |_ dSr) rrrQrr[rrerirorvrr)r)r*r( z&SessionsWithStreamingResponse.__init__Nrrr)r)r)r*r-rr-c@r) rrr!r#r>cCrr) rrrQrr[rrerirorvrr)r)r*rrz+AsyncSessionsWithStreamingResponse.__init__Nrrr)r)r)r*rrr)0 __future__rhttpx2r_typesrrrrr r r r _utilsr rr_compatr _resourcerr _responserrrrrr types.liverrrr _base_clientr types.live.session_fork_responser*types.live.media_session_fork_config_paramr__all__r r!r$rr-rr)r)r)r*s.  (     ""