o ưi@sdZddlmZmZmZmZmZmZddlZddl m Z er&ddl m Z m Z GdddZded efd d Zd eeefd efd dZdS)z% Utility functions for A2A protocol. ) TYPE_CHECKINGAnyDictListTupleUnionN)verbose_logger)SendMessageRequestSendStreamingMessageRequestc @seZdZdZededefddZedeeefdefddZ ed d defd d Z ed ede fddZ ed d deeefde e e e ffddZdS)A2ARequestUtilsz2Utility class for A2A request/response processing.messagereturncCs|durdSt|tr|dg}nt|dgpg}g}|D])}t|tr6|ddkr5||ddqt|dddkrG|t|ddqd|S)z Extract text content from A2A message parts. Args: message: A2A message dict or object with 'parts' containing text parts Returns: Concatenated text from all text parts Npartskindtext ) isinstancedictgetgetattrappendjoin)r rZ text_partspartrQ/home/app/Keep/.python/lib/python3.10/site-packages/litellm/a2a_protocol/utils.pyextract_text_from_messages    z)A2ARequestUtils.extract_text_from_message response_dictcCs0|di}t|ts dS|di}t|S)z Extract text content from A2A response result. Args: response_dict: A2A response dict with 'result' containing message Returns: Text from response message parts resultrr )rrrr r)rrr rrrextract_text_from_response0s   z*A2ARequestUtils.extract_text_from_responserequestz6Union[SendMessageRequest, SendStreamingMessageRequest]cCs$t|dd}|dur dSt|ddS)z Extract the input message from an A2A request. Args: request: The A2A SendMessageRequest or SendStreamingMessageRequest Returns: The message object/dict or None paramsNr )r)r r!rrrget_input_message_from_requestBs  z.A2ARequestUtils.get_input_message_from_requestrcCs6|sdSztj|dWStytdYdSw)z Count tokens in text using litellm.token_counter. Args: text: Text to count tokens for Returns: Token count, or 0 if counting fails rrzFailed to count tokens)litellmZ token_counter Exceptionrdebugr#rrr count_tokensTs   zA2ARequestUtils.count_tokenscCsDt|}t|}t|}t|}t|}||}|||fS)a2 Calculate token usage from A2A request and response. Args: request: The A2A SendMessageRequest or SendStreamingMessageRequest response_dict: The A2A response as a dict Returns: Tuple of (prompt_tokens, completion_tokens, total_tokens) )r r"rr'r)r rZ input_messageZ input_textZ prompt_tokensZ output_textZcompletion_tokensZ total_tokensrrr%calculate_usage_from_request_responsegs      z5A2ARequestUtils.calculate_usage_from_request_responseN)__name__ __module__ __qualname____doc__ staticmethodrstrrrrr"intr'rr(rrrrr s,   r r r cC t|SN)r r)r rrrextract_text_from_a2a_message r2rcCr0r1)r r)rrrrextract_text_from_a2a_responser3r4)r,typingrrrrrrr$Zlitellm._loggingrZ a2a.typesr r r r.r2r4rrrrs  w