o lWii\@sddlmZddlZddlmZmZddlmZddlm Z ddl m Z ddl m Z dd lmZdd lmZd d lmZmZd d lmZejrWd dlmZmZd dlmZmZGdddZGdddZdS)) annotationsN)AsyncClientWrapperSyncClientWrapper)RequestOptions)"ConversationSignedUrlResponseModel)EvaluationSuccessResult)GetConversationResponseModel)!GetConversationsPageResponseModel)TokenResponseModel)AsyncRawConversationsClientRawConversationsClient)#ConversationsListRequestSummaryMode)AsyncAudioClient AudioClient)AsyncFeedbackClientFeedbackClientc@eZdZd>ddZed?ddZd d d d@ddZd d ddAddZd d d d d d d d d d d d d d d d d d ddBd0d1Zd d2dCd5d6Z d d2dDd8d9Z ed:d;Z edSr8z$ConversationsClient.get_webrtc_tokencursorr-call_successfulcall_start_before_unixcall_start_after_unixcall_duration_min_secscall_duration_max_secs rating_max rating_minhas_feedback_commentuser_idevaluation_paramsdata_collection_params tool_names page_size summary_modesearchr,rArB(typing.Optional[EvaluationSuccessResult]rCtyping.Optional[int]rDrErFrGrHrIrJrK8typing.Optional[typing.Union[str, typing.Sequence[str]]]rLrMrNrO4typing.Optional[ConversationsListRequestSummaryMode]rPr cCs|jjdid|d|d|d|d|d|d|d|d | d | d | d | d | d|d|d|d|d|}|jS)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. 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 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", ) rAr-rBrCrDrErFrGrHrIrJrKrLrMrNrOrPr,Nr rlistr5rrAr-rBrCrDrErFrGrHrIrJrKrLrMrNrOrPr,r7r r r!rV~sL n     zConversationsClient.listr,conversation_idr cC|jj||d}|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", ) rXrgetr5rrYr,r7r r r!r\szConversationsClient.get typing.AnycCrZ)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", ) rXrdeleter5r]r r r!r`#szConversationsClient.deletecC*|jdurddlm}||jd|_|jS)Nr )rr)r audio.clientrr)rrr r r!audioB  zConversationsClient.audiocCra)Nr )rr)rfeedback.clientrr)rrr r r!feedbackJrdzConversationsClient.feedback)rr)r$rr-r.r+r/r,r0r$rr-r.r:r;r,r0r$r &rAr;r-r;rBrQrCrRrDrRrErRrFrRrGrRrHrRrIr/rJr;rKrSrLrSrMrSrNrRrOrTrPr;r,r0r$r rYr.r,r0r$r rYr.r,r0r$r^ __name__ __module__ __qualname__r"propertyr(r4r>rVr\r`rcrfr r r r!rsJ  /.! rc@r)EAsyncConversationsClientrrcCrr)r rrrrrr r r!r"Tr#z!AsyncConversationsClient.__init__r$r cCr%)z Retrieves a raw implementation of this client that returns raw responses. Returns ------- AsyncRawConversationsClient r&r'r r r!r(Zr)z*AsyncConversationsClient.with_raw_responseNr*r-r.r+r/r,r0rc |jj|||dIdH}|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. 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, ) asyncio.run(main()) r2Nr3r6r r r!r4e . z'AsyncConversationsClient.get_signed_urlr9r:r;r crr)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 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", ) asyncio.run(main()) r<Nr=r?r r r!r>rsz)AsyncConversationsClient.get_webrtc_tokenr@rArBrQrCrRrDrErFrGrHrIrJrKrSrLrMrNrOrTrPr cs|jjdid|d|d|d|d|d|d|d|d | d | d | d | d | d|d|d|d|d|IdH}|jS)aJ 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. 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 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", ) asyncio.run(main()) rAr-rBrCrDrErFrGrHrIrJrKrLrMrNrOrPr,Nr rUrWr r r!rVsN v      zAsyncConversationsClient.listrXrYr c|jj||dIdH}|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 -------- 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()) rXNr[r]r r r!r\W&zAsyncConversationsClient.getr^crt)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()) rXNr_r]r r r!r`ruzAsyncConversationsClient.deletecCra)Nr )rr)rrbrr)rrr r r!rcrdzAsyncConversationsClient.audiocCra)Nr )rr)rrerr)rrr r r!rfrdz!AsyncConversationsClient.feedback)rr)r$r rgrhrirjrkrlr r r r!rqSsL  76*) rq) __future__rtypingcore.client_wrapperrrcore.request_optionsr,types.conversation_signed_url_response_modelrtypes.evaluation_success_resultr%types.get_conversation_response_modelr +types.get_conversations_page_response_modelr types.token_response_modelr raw_clientr r-types.conversations_list_request_summary_moder TYPE_CHECKINGrbrrrerrrrqr r r r!s$        ?