b6iJfddlmZddlZddlmZmZddlmZddlm Z ddl m Z ddl m Z dd lmZdd lmZdd lmZd d lmZmZd dlmZej2rd dlmZmZd dlmZmZGddZ GddZ!y)) annotationsN)AsyncClientWrapperSyncClientWrapper)RequestOptions)ConversationInitiationSource)"ConversationSignedUrlResponseModel)EvaluationSuccessResult)GetConversationResponseModel)!GetConversationsPageResponseModel)TokenResponseModel)AsyncRawConversationsClientRawConversationsClient)#ConversationsListRequestSummaryMode)AsyncAudioClient AudioClient)AsyncFeedbackClientFeedbackClientc@eZdZddZeddZdddd ddZdddd ddZdddddddddddddddddddddd dd Zdd  dd Z dd dd Z ed Z edZ y)ConversationsClientcPt||_||_d|_d|_yNclient_wrapper)r _raw_client_client_wrapper_audio _feedbackselfrs |/root/.openclaw/workspace/visionaryfx/venv/lib/python3.12/site-packages/elevenlabs/conversational_ai/conversations/client.py__init__zConversationsClient.__init__s%1P-48 :>c|jS)z Retrieves a raw implementation of this client that returns raw responses. Returns ------- RawConversationsClient rr!s r"with_raw_responsez%ConversationsClient.with_raw_responser$Ninclude_conversation_id branch_idrequest_optionscX|jj||||}|jS)a) Get a signed url to start a conversation with an agent with an agent that requires authorization Parameters ---------- agent_id : str The id of the agent you're taking the action on. include_conversation_id : typing.Optional[bool] Whether to include a conversation_id with the response. If included, the conversation_signature cannot be used again. branch_id : typing.Optional[str] The ID of the branch to use request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- ConversationSignedUrlResponseModel Successful Response Examples -------- from elevenlabs import ElevenLabs client = ElevenLabs( api_key="YOUR_API_KEY", ) client.conversational_ai.conversations.get_signed_url( agent_id="21m00Tcm4TlvDq8ikWAM", include_conversation_id=True, branch_id="branch_id", ) agent_idr+r,r-rget_signed_urldatar!r0r+r,r- _responses r"r2z"ConversationsClient.get_signed_url)s8V$$33$;+ 4 ~~r$participant_namer,r-cX|jj||||}|jS)a Get a WebRTC session token for real-time communication. Parameters ---------- agent_id : str The id of the agent you're taking the action on. participant_name : typing.Optional[str] Optional custom participant name. If not provided, user ID will be used branch_id : typing.Optional[str] The ID of the branch to use request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- TokenResponseModel Successful Response Examples -------- from elevenlabs import ElevenLabs client = ElevenLabs( api_key="YOUR_API_KEY", ) client.conversational_ai.conversations.get_webrtc_token( agent_id="21m00Tcm4TlvDq8ikWAM", participant_name="participant_name", branch_id="branch_id", ) r0r7r,r-rget_webrtc_tokenr3r!r0r7r,r-r5s r"r;z$ConversationsClient.get_webrtc_token\s7V$$550@Igv6 ~~r$cursorr0call_successfulcall_start_before_unixcall_start_after_unixcall_duration_min_secscall_duration_max_secs rating_max rating_minhas_feedback_commentuser_idevaluation_paramsdata_collection_params tool_namesmain_languages page_size summary_modesearchconversation_initiation_sourcer,r-cz|jj||||||||| | | | | ||||||||}|jS)aI Get all conversations of agents that user owns. With option to restrict to a specific agent. Parameters ---------- cursor : typing.Optional[str] Used for fetching next page. Cursor is returned in the response. agent_id : typing.Optional[str] The id of the agent you're taking the action on. call_successful : typing.Optional[EvaluationSuccessResult] The result of the success evaluation call_start_before_unix : typing.Optional[int] Unix timestamp (in seconds) to filter conversations up to this start date. call_start_after_unix : typing.Optional[int] Unix timestamp (in seconds) to filter conversations after to this start date. call_duration_min_secs : typing.Optional[int] Minimum call duration in seconds. call_duration_max_secs : typing.Optional[int] Maximum call duration in seconds. rating_max : typing.Optional[int] Maximum overall rating (1-5). rating_min : typing.Optional[int] Minimum overall rating (1-5). has_feedback_comment : typing.Optional[bool] Filter conversations with user feedback comments. user_id : typing.Optional[str] Filter conversations by the user ID who initiated them. evaluation_params : typing.Optional[typing.Union[str, typing.Sequence[str]]] Evaluation filters. Repeat param. Format: criteria_id:result. Example: eval=value_framing:success data_collection_params : typing.Optional[typing.Union[str, typing.Sequence[str]]] Data collection filters. Repeat param. Format: id:op:value where op is one of eq|neq|gt|gte|lt|lte|in|exists|missing. For in, pipe-delimit values. tool_names : typing.Optional[typing.Union[str, typing.Sequence[str]]] Filter conversations by tool names used during the call. main_languages : typing.Optional[typing.Union[str, typing.Sequence[str]]] Filter conversations by detected main language (language code). page_size : typing.Optional[int] How many conversations to return at maximum. Can not exceed 100, defaults to 30. summary_mode : typing.Optional[ConversationsListRequestSummaryMode] Whether to include transcript summaries in the response. search : typing.Optional[str] Full-text or fuzzy search over transcript messages conversation_initiation_source : typing.Optional[ConversationInitiationSource] branch_id : typing.Optional[str] Filter conversations by branch ID. request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- GetConversationsPageResponseModel Successful Response Examples -------- from elevenlabs import ElevenLabs client = ElevenLabs( api_key="YOUR_API_KEY", ) client.conversational_ai.conversations.list( cursor="cursor", agent_id="agent_id", call_successful="success", call_start_before_unix=1, call_start_after_unix=1, call_duration_min_secs=1, call_duration_max_secs=1, rating_max=1, rating_min=1, has_feedback_comment=True, user_id="user_id", page_size=1, summary_mode="exclude", search="search", conversation_initiation_source="unknown", branch_id="branch_id", ) r=rlistr3r!r>r0r?r@rArBrCrDrErFrGrHrIrJrKrLrMrNrOr,r-r5s r"rRzConversationsClient.listskv$$))+#9"7#9#9!!!5/#9!)%+I++* .~~r$r-cT|jj||}|jS)a Get the details of a particular conversation Parameters ---------- conversation_id : str The id of the conversation you're taking the action on. request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- GetConversationResponseModel Successful Response Examples -------- from elevenlabs import ElevenLabs client = ElevenLabs( api_key="YOUR_API_KEY", ) client.conversational_ai.conversations.get( conversation_id="123", ) rTrgetr3r!conversation_idr-r5s r"rWzConversationsClient.get s)<$$((/(Z ~~r$cT|jj||}|jS)a Delete a particular conversation Parameters ---------- conversation_id : str The id of the conversation you're taking the action on. request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- typing.Any Successful Response Examples -------- from elevenlabs import ElevenLabs client = ElevenLabs( api_key="YOUR_API_KEY", ) client.conversational_ai.conversations.delete( conversation_id="21m00Tcm4TlvDq8ikWAM", ) rTrdeleter3rXs r"r\zConversationsClient.deleteAs)8$$++O_+] ~~r$cn|jddlm}||j|_|jS)Nr)rr)r audio.clientrr)r!rs r"audiozConversationsClient.audio`s+ ;;  1%T5I5IJDK{{r$cn|jddlm}||j|_|jS)Nr)rr)rfeedback.clientrr)r!rs r"feedbackzConversationsClient.feedbackhs+ >> ! 7+4;O;OPDN~~r$)rr)returnr r0strr+typing.Optional[bool]r,typing.Optional[str]r-typing.Optional[RequestOptions]rcr r0rer7rgr,rgr-rhrcr ,r>rgr0rgr?z(typing.Optional[EvaluationSuccessResult]r@typing.Optional[int]rArkrBrkrCrkrDrkrErkrFrfrGrgrH8typing.Optional[typing.Union[str, typing.Sequence[str]]]rIrlrJrlrKrlrLrkrMz4typing.Optional[ConversationsListRequestSummaryMode]rNrgrOz-typing.Optional[ConversationInitiationSource]r,rgr-rhrcr rYrer-rhrcr rYrer-rhrcz typing.Any __name__ __module__ __qualname__r#propertyr(r2r;rRrWr\r_rbr$r"rrs;?   :>*.;? 11"7 1 ( 1 9 1 ,1n26*.;? ../ . ( . 9 . .f(,)-DH7;6:7;7;+/+/6:(,VZ[_OSSW*.MQ'+X\*.;?/R%R' R B R !5 R 4R!5R!5R)R)R4R&RTR!YR M!R"Q#R$(%R&K'R(%)R*)V+R,(-R.9/R0 +1Rj[_"8W %Bbf>r$rcJeZdZddZeddZdddd ddZdddd ddZdddddddddddddddddddddd dd Zdd  dd Z dd  dd Z ed Z edZ y)AsyncConversationsClientcPt||_||_d|_d|_yr)rrrrrr s r"r#z!AsyncConversationsClient.__init__rs%6nU-9= ?Cr$c|jS)z Retrieves a raw implementation of this client that returns raw responses. Returns ------- AsyncRawConversationsClient r&r's r"r(z*AsyncConversationsClient.with_raw_responsexr)r$Nr*ctK|jj||||d{}|jS7w)a Get a signed url to start a conversation with an agent with an agent that requires authorization Parameters ---------- agent_id : str The id of the agent you're taking the action on. include_conversation_id : typing.Optional[bool] Whether to include a conversation_id with the response. If included, the conversation_signature cannot be used again. branch_id : typing.Optional[str] The ID of the branch to use request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- ConversationSignedUrlResponseModel Successful Response Examples -------- import asyncio from elevenlabs import AsyncElevenLabs client = AsyncElevenLabs( api_key="YOUR_API_KEY", ) async def main() -> None: await client.conversational_ai.conversations.get_signed_url( agent_id="21m00Tcm4TlvDq8ikWAM", include_conversation_id=True, branch_id="branch_id", ) asyncio.run(main()) r/Nr1r4s r"r2z'AsyncConversationsClient.get_signed_urlsFf**99$;+ :  ~~  #868r6ctK|jj||||d{}|jS7w)aA Get a WebRTC session token for real-time communication. Parameters ---------- agent_id : str The id of the agent you're taking the action on. participant_name : typing.Optional[str] Optional custom participant name. If not provided, user ID will be used branch_id : typing.Optional[str] The ID of the branch to use request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- TokenResponseModel Successful Response Examples -------- import asyncio from elevenlabs import AsyncElevenLabs client = AsyncElevenLabs( api_key="YOUR_API_KEY", ) async def main() -> None: await client.conversational_ai.conversations.get_webrtc_token( agent_id="21m00Tcm4TlvDq8ikWAM", participant_name="participant_name", branch_id="branch_id", ) asyncio.run(main()) r9Nr:r<s r"r;z)AsyncConversationsClient.get_webrtc_tokensEf**;;0@Igv<  ~~ rzr=cK|jj||||||||| | | | | ||||||||d{}|jS7w)a Get all conversations of agents that user owns. With option to restrict to a specific agent. Parameters ---------- cursor : typing.Optional[str] Used for fetching next page. Cursor is returned in the response. agent_id : typing.Optional[str] The id of the agent you're taking the action on. call_successful : typing.Optional[EvaluationSuccessResult] The result of the success evaluation call_start_before_unix : typing.Optional[int] Unix timestamp (in seconds) to filter conversations up to this start date. call_start_after_unix : typing.Optional[int] Unix timestamp (in seconds) to filter conversations after to this start date. call_duration_min_secs : typing.Optional[int] Minimum call duration in seconds. call_duration_max_secs : typing.Optional[int] Maximum call duration in seconds. rating_max : typing.Optional[int] Maximum overall rating (1-5). rating_min : typing.Optional[int] Minimum overall rating (1-5). has_feedback_comment : typing.Optional[bool] Filter conversations with user feedback comments. user_id : typing.Optional[str] Filter conversations by the user ID who initiated them. evaluation_params : typing.Optional[typing.Union[str, typing.Sequence[str]]] Evaluation filters. Repeat param. Format: criteria_id:result. Example: eval=value_framing:success data_collection_params : typing.Optional[typing.Union[str, typing.Sequence[str]]] Data collection filters. Repeat param. Format: id:op:value where op is one of eq|neq|gt|gte|lt|lte|in|exists|missing. For in, pipe-delimit values. tool_names : typing.Optional[typing.Union[str, typing.Sequence[str]]] Filter conversations by tool names used during the call. main_languages : typing.Optional[typing.Union[str, typing.Sequence[str]]] Filter conversations by detected main language (language code). page_size : typing.Optional[int] How many conversations to return at maximum. Can not exceed 100, defaults to 30. summary_mode : typing.Optional[ConversationsListRequestSummaryMode] Whether to include transcript summaries in the response. search : typing.Optional[str] Full-text or fuzzy search over transcript messages conversation_initiation_source : typing.Optional[ConversationInitiationSource] branch_id : typing.Optional[str] Filter conversations by branch ID. request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- GetConversationsPageResponseModel Successful Response Examples -------- import asyncio from elevenlabs import AsyncElevenLabs client = AsyncElevenLabs( api_key="YOUR_API_KEY", ) async def main() -> None: await client.conversational_ai.conversations.list( cursor="cursor", agent_id="agent_id", call_successful="success", call_start_before_unix=1, call_start_after_unix=1, call_duration_min_secs=1, call_duration_max_secs=1, rating_max=1, rating_min=1, has_feedback_comment=True, user_id="user_id", page_size=1, summary_mode="exclude", search="search", conversation_initiation_source="unknown", branch_id="branch_id", ) asyncio.run(main()) r=NrQrSs r"rRzAsyncConversationsClient.listsyF**//+#9"7#9#9!!!5/#9!)%+I++0  .~~/ s4A AA rTcpK|jj||d{}|jS7w)a Get the details of a particular conversation Parameters ---------- conversation_id : str The id of the conversation you're taking the action on. request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- GetConversationResponseModel Successful Response Examples -------- import asyncio from elevenlabs import AsyncElevenLabs client = AsyncElevenLabs( api_key="YOUR_API_KEY", ) async def main() -> None: await client.conversational_ai.conversations.get( conversation_id="123", ) asyncio.run(main()) rTNrVrXs r"rWzAsyncConversationsClient.gets8L**..P_.`` ~~a !646cpK|jj||d{}|jS7w)a Delete a particular conversation Parameters ---------- conversation_id : str The id of the conversation you're taking the action on. request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- typing.Any Successful Response Examples -------- import asyncio from elevenlabs import AsyncElevenLabs client = AsyncElevenLabs( api_key="YOUR_API_KEY", ) async def main() -> None: await client.conversational_ai.conversations.delete( conversation_id="21m00Tcm4TlvDq8ikWAM", ) asyncio.run(main()) rTNr[rXs r"r\zAsyncConversationsClient.deletes8L**11/Sb1cc ~~dr~cn|jddlm}||j|_|jS)Nr)rr)rr^rr)r!rs r"r_zAsyncConversationsClient.audios+ ;;  6*$:N:NODK{{r$cn|jddlm}||j|_|jS)Nr)rr)rrarr)r!rs r"rbz!AsyncConversationsClient.feedbacks+ >> ! <0@T@TUDN~~r$)rr)rcrrdrirjrmrnrortr$r"rvrvqsUD   :>*.;? 99"7 9 ( 9 9 9 ,9~26*.;? 66/ 6 ( 6 9 6 6v(,)-DH7;6:7;7;+/+/6:(,VZ[_OSSW*.MQ'+X\*.;?/Z%Z' Z B Z !5 Z 4Z!5Z!5Z)Z)Z4Z&ZTZ!YZ M!Z"Q#Z$(%Z&K'Z(%)Z*)V+Z,(-Z.9/Z0 +1Zz[_'"'8W' %'T[_'"'8W' 'Rr$rv)" __future__rtypingcore.client_wrapperrrcore.request_optionsr$types.conversation_initiation_sourcer,types.conversation_signed_url_response_modelr types.evaluation_success_resultr %types.get_conversation_response_modelr +types.get_conversations_page_response_modelr types.token_response_modelr raw_clientrr-types.conversations_list_request_summary_moder TYPE_CHECKINGr^rrrarrrrvrtr$r"rsS# H2P^FQ\<K^ ;DWWt AAr$