o lWi6z@sddlZddlmZddlmZddlmZmZddlm Z m Z ddl m Z ddl mZdd lmZdd lmZdd lmZdd lmZdd lmZddlmZddlmZddlmZddlm Z GdddZ!GdddZ"dS)N)JSONDecodeError)ApiError)AsyncClientWrapperSyncClientWrapper)AsyncHttpResponse HttpResponse)jsonable_encoder)RequestOptions)construct_type)UnprocessableEntityError)"ConversationSignedUrlResponseModel)EvaluationSuccessResult)GetConversationResponseModel)!GetConversationsPageResponseModel)HttpValidationError)TokenResponseModel)#ConversationsListRequestSummaryModec(@eZdZdefddZddddedejedeje d e e fd d Z ddd ded ejedeje d e e fddZddddddddddddddddddddejedejedejedejedejedejedejedejedejedejedejedejejeejefdejejeejefdejejeejefdejedejed ejedeje d e ef&d!d"Zdd#d$edeje d e efd%d&Zdd#d$edeje d e ejfd'd(ZdS))RawConversationsClientclient_wrappercC ||_dSN_client_wrapperselfrry/var/www/html/asistente-voz-ia/venv/lib/python3.10/site-packages/elevenlabs/conversational_ai/conversations/raw_client.py__init__ zRawConversationsClient.__init__Ninclude_conversation_idrequest_optionsagent_idr#r$returnc C|jjjdd||d|d}z>d|jkrdkr/nntttt|d}t ||dWS|jd krGt t |j tt tt |dd |}Wnty_t|jt |j |jd wt|jt |j |d ) 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 ------- HttpResponse[ConversationSignedUrlResponseModel] Successful Response %v1/convai/conversation/get-signed-urlGETr%r#methodparamsr$,type_object_responsedataheadersbody status_coder8r9)r httpx_clientrequestr;typingcastr r jsonrr dictr8rrrtextrr%r#r$ _response_data_response_jsonrrrget_signed_urlD   z%RawConversationsClient.get_signed_urlparticipant_namer$rJc Cr') 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 ------- HttpResponse[TokenResponseModel] Successful Response v1/convai/conversation/tokenr)r%rJr+r.r/r0r3r6r7r:)rr<r=r;r>r?rr r@rr rAr8rrrrBrr%rJr$rDrErFrrrget_webrtc_tokenWrHz'RawConversationsClient.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$rPrQrRrSrTrUrVrWrXrYrZr[r\r]r^r_c Cs6|jjjddid|d|d|d|d|d|d |d |d | d | d | d| d| d|d|d|d||d}z>d|jkrJdkr_nntttt|d}t ||dWS|jdkrwt t |j tt tt |dd|}Wntyt|jt |j |jdwt|jt |j |d)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 ------- HttpResponse[GetConversationsPageResponseModel] Successful Response v1/convai/conversationsr)rPr%rQrRrSrTrUrVrWrXrYrZr[r\r]r^r_r+r.r/r0r3r6r7r:)rr<r=r;r>r?rr r@rr rAr8rrrrBrrPr%rQrRrSrTrUrVrWrXrYrZr[r\r]r^r_r$rDrErFrrrlistsV       zRawConversationsClient.listr$conversation_idc Cs|jjjdt|d|d}z>d|jkrdkr0nntttt| d}t ||dWS|jdkrHt t |j tttt| dd | }Wnty`t|jt |j |jd wt|jt |j |d ) 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 ------- HttpResponse[GetConversationResponseModel] Successful Response v1/convai/conversations/r)r,r$r.r/r0r3r6r7r:)rr<r=r r;r>r?rr r@rr rAr8rrrrBrrdr$rDrErFrrrgets>   zRawConversationsClient.getc Cs|jjjdt|d|d}zP|dus|js t|ddWSd|jkr+dkrBnnt tj t tj | d}t||dWS|jd krZt t|jt tt t| dd | }Wntyrt|jt|j|jd wt|jt|j|d ) 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 ------- HttpResponse[typing.Any] Successful Response reDELETErfNr3r.r/r0r6r7r:)rr<r=r rBstriprr;r>r?Anyr r@r rAr8rrrrgrrrdeleteNsB   zRawConversationsClient.delete)__name__ __module__ __qualname__rr strr>Optionalboolr rr rGrrNrintUnionSequencerrrbrrhrkrlrrrrr A @        3rc(@r))AsyncRawConversationsClientrcCrrrrrrrr r!z$AsyncRawConversationsClient.__init__Nr"r%r#r$r&c |jjjdd||d|dIdH}z>d|jkrdkr3nntttt|d}t ||d WS|jd krKt t |j tt tt |dd |}Wntyct|jt |j |jd wt|jt |j |d ) 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 ------- AsyncHttpResponse[ConversationSignedUrlResponseModel] Successful Response r(r)r*r+Nr.r/r0r3r6r7r:)rr<r=r;r>r?r r r@rr rAr8rrrrBrCrrrrGF    z*AsyncRawConversationsClient.get_signed_urlrIrJc rx) 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 ------- AsyncHttpResponse[TokenResponseModel] Successful Response rKr)rLr+Nr.r/r0r3r6r7r:)rr<r=r;r>r?rr r@rr rAr8rrrrBrMrrrrNryz,AsyncRawConversationsClient.get_webrtc_tokenrOrPrQrRrSrTrUrVrWrXrYrZr[r\r]r^r_c s>|jjjddid|d|d|d|d|d|d |d |d | d | d | d| d| d|d|d|d||dIdH}z>d|jkrNdkrcnntttt|d}t ||dWS|jdkr{t t |j tt tt |dd|}Wntyt|jt |j |jdwt|jt |j |d)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 ------- AsyncHttpResponse[GetConversationsPageResponseModel] Successful Response r`r)rPr%rQrRrSrTrUrVrWrXrYrZr[r\r]r^r_r+Nr.r/r0r3r6r7r:)rr<r=r;r>r?rr r@rr rAr8rrrrBrarrrrbsV        z AsyncRawConversationsClient.listrcrdc s|jjjdt|d|dIdH}z>d|jkrdkr4nntttt| d}t ||dWS|jd krLt t |j tttt| dd | }Wntydt|jt |j |jd wt|jt |j |d ) 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 ------- AsyncHttpResponse[GetConversationResponseModel] Successful Response rer)rfNr.r/r0r3r6r7r:)rr<r=r r;r>r?rr r@rr rAr8rrrrBrgrrrrhs@    zAsyncRawConversationsClient.getc s|jjjdt|d|dIdH}zP|dus|js$t|ddWSd|jkr/dkrFnnt tj t tj | d}t||dWS|jd kr^t t|jt tt t| dd | }Wntyvt|jt|j|jd wt|jt|j|d ) 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 ------- AsyncHttpResponse[typing.Any] Successful Response rerirfNr3r.r/r0r6r7r:)rr<r=r rBrjrr;r>r?rkr r@r rAr8rrrrgrrrrlsD    z"AsyncRawConversationsClient.delete)rmrnrorr rpr>rqrrr rr rGrrNrrsrtrurrrbrrhrkrlrrrrrwrvrw)#r> json.decoderrcore.api_errorrcore.client_wrapperrrcore.http_responserrcore.jsonable_encoderr core.request_optionsr core.unchecked_base_modelr !errors.unprocessable_entity_errorr ,types.conversation_signed_url_response_modelr types.evaluation_success_resultr%types.get_conversation_response_modelr+types.get_conversations_page_response_modelrtypes.http_validation_errorrtypes.token_response_modelr-types.conversations_list_request_summary_moderrrwrrrrs(             o