o ưi1@sdZddlZddlmZmZmZmZmZmZddl Z ddl m Z ddl m Z mZddlmZddlmZmZmZdd lmZmZmZd d lmZGd d d e ZdS)z) A2A Protocol Transformation for LiteLLM N)AnyDictIteratorListOptionalUnion)BaseModelResponseIterator) BaseConfigBaseLLMException)AllMessageValues)ChoicesMessage ModelResponse)A2AErrorconvert_messages_to_promptextract_text_from_a2a_responseA2AModelResponseIteratorc@seZdZdZededeedeedeeeefdeeefde eeeeeeeefff dd Z dede efd d Z d e de ded ede f ddZ  d.de dede ede de deedeede fddZ d/deedeedede de deedefddZdede ede de de de f ddZ  d.dedejdedede de ede de dedeedeedefd d!Z "d0d#eeefd$edeedefd%d&Zd'eeefdeeeffd(d)Zd*ed+edee ejfdefd,d-Z dS)1 A2AConfigz Configuration for A2A (Agent-to-Agent) Protocol. Handles transformation between OpenAI and A2A JSON-RPC 2.0 formats. modelapi_baseapi_keyheadersoptional_paramsreturnc Csd|vr |dddnd}|r|dur!|dur!|dur!|||fSzMddlm}||}|rm|dur<|jr<|jd}|jrm|durI|jd}|durW|jd}|rW|}|jD]\} } | d vrl| |vrl| || <q\Wn tywYnw|||fS) a Resolve agent configuration from registry if model format is "a2a/". Extracts agent name from model string and looks up configuration in the agent registry (if available in proxy context). Args: model: Model string (e.g., "a2a/my-agent") api_base: Explicit api_base (takes precedence over registry) api_key: Explicit api_key (takes precedence over registry) headers: Explicit headers (takes precedence over registry) optional_params: Dict to merge additional litellm_params into Returns: Tuple of (api_base, api_key, headers) with registry values filled in /rNr)global_agent_registryurlrr)rrrr) splitZ,litellm.proxy.agent_endpoints.agent_registryrZget_agent_by_nameZagent_card_paramsgetlitellm_paramsitems ImportError) rrrrrZ agent_namerZagentZ agent_headerskeyvaluer'[/home/app/Keep/.python/lib/python3.10/site-packages/litellm/llms/a2a/chat/transformation.py"resolve_agent_config_from_registrys0        z,A2AConfig.resolve_agent_config_from_registrycCsgdS)z*Return list of supported OpenAI parameters)streamZ temperatureZ max_tokensZtop_pr')selfrr'r'r(get_supported_openai_params[sz%A2AConfig.get_supported_openai_paramsnon_default_params drop_paramscCs.|D]\}}|dkr|dur||d<q|S)z Map OpenAI parameters to A2A parameters. For A2A protocol, we need to map the stream parameter so transform_request can determine which JSON-RPC method to use. r*T)r#)r+r-rrr.paramr&r'r'r(map_openai_paramsds zA2AConfig.map_openai_paramsNmessagesr"cCs2d|vr d|vr d|d<|durd||d<|S)a Validate environment and set headers for A2A requests. Args: headers: Request headers dict model: Model name messages: Messages list optional_params: Optional parameters litellm_params: LiteLLM parameters api_key: API key (optional for A2A) api_base: API base URL Returns: Updated headers dict z content-typez Content-Typezapplication/jsonNzBearer Authorizationr')r+rrr1rr"rrr'r'r(validate_environmentxs zA2AConfig.validate_environmentr*cCs|durtd|dS)a Get the complete A2A agent endpoint URL. A2A agents use JSON-RPC 2.0 at the base URL, not specific paths. The method (message/send or message/stream) is specified in the JSON-RPC request body, not in the URL. Args: api_base: Base URL of the A2A agent (e.g., "http://0.0.0.0:9999") api_key: API key (not used for URL construction) model: Model name (not used for A2A, agent determined by api_base) optional_params: Optional parameters litellm_params: LiteLLM parameters stream: Whether this is a streaming request (affects JSON-RPC method) Returns: Complete URL for the A2A endpoint (base URL) Nz%api_base is required for A2A providerr) ValueErrorrstrip)r+rrrrr"r*r'r'r(get_complete_urls zA2AConfig.get_complete_urlc Csjtt}|s tdt|}dd|dgttd}|dd} | r(dnd } d || d |id } | S) ar Transform OpenAI request to A2A JSON-RPC 2.0 format. Args: model: Model name messages: List of OpenAI messages optional_params: Optional parameters litellm_params: LiteLLM parameters headers: Request headers Returns: A2A JSON-RPC 2.0 request dict z3At least one message is required for A2A completionusertextkindr8rolepartsZ messageIdr*Fzmessage/streamz message/sendz2.0message)Zjsonrpcidmethodparams)struuiduuid4r4rr!) r+rr1rr"rZ request_idZ full_contextZ a2a_messager*r@ request_datar'r'r(transform_requests"     zA2AConfig.transform_request raw_responsemodel_response logging_objrEencoding json_modec  Csz|} Wnty"} zt|jdt| t|jdd} ~ wwd| vr=| d}t|jd|ddt|jdt| }t dd t |d d d g|_ ||_ | d tt |_|S)a Transform A2A JSON-RPC 2.0 response to OpenAI format. Args: model: Model name raw_response: HTTP response from A2A agent model_response: Model response object to populate logging_obj: Logging object request_data: Original request data messages: Original messages optional_params: Optional parameters litellm_params: LiteLLM parameters encoding: Encoding object api_key: API key json_mode: JSON mode flag Returns: Populated ModelResponse object zFailed to parse A2A response:  status_coder>rNerrorz A2A error: r>z Unknown errorstoprZ assistant)contentr<)Z finish_reasonindexr>r?)json ExceptionrrMrBdictrr!rr r choicesrrCrDr?)r+rrGrHrIrEr1rr"rJrrKZ response_jsonerNr8r'r'r(transform_responses<!   zA2AConfig.transform_responseFstreaming_response sync_streamcCst|||dS)a( Get streaming iterator for A2A responses. Args: streaming_response: Streaming response iterator sync_stream: Whether this is a sync stream json_mode: JSON mode flag Returns: A2A streaming iterator )rXrYrKr)r+rXrYrKr'r'r(get_model_response_iterator>s z%A2AConfig.get_model_response_iteratorr>cCs8|dd}|dd}|dt|dgttdS)z Convert OpenAI message to A2A message format. Args: message: OpenAI message dict Returns: A2A message dict rPr<r7r8r9r;)r!rBrCrD)r+r>rPr<r'r'r(_openai_message_to_a2a_messageUs  z(A2AConfig._openai_message_to_a2a_message error_messagerMcCs&t|tjr t|n|}t|||dS)z-Return appropriate error class for A2A errorsrL) isinstancehttpxHeadersrTr)r+r]rMrZ headers_dictr'r'r(get_error_classhs zA2AConfig.get_error_class)NN)N)F)!__name__ __module__ __qualname____doc__ staticmethodrBrrrtupler)rr,rTboolr0r r3r6rFr_ResponserrWrrrrZr\intr`r rar'r'r'r(rs   =   * " B     N  " r)rerCtypingrrrrrrr_Z)litellm.llms.base_llm.base_model_iteratorrZ)litellm.llms.base_llm.chat.transformationr r Zlitellm.types.llms.openair Zlitellm.types.utilsr r rZ common_utilsrrrZstreaming_iteratorrrr'r'r'r(s