`gj+ldZddlmZmZmZmZddlmZddlm Z GddeZ ddl m Z e de y ) uAnthropic Messages API transport. Delegates to the existing adapter functions in agent/anthropic_adapter.py. This transport owns format conversion and normalization — NOT client lifecycle. )AnyDictListOptional)ProviderTransport)NormalizedResponsec eZdZdZedefdZdeeee fde fdZ deeee fde fdZ dd edeeee fde eeee fdeee ffd Z d e defd Zd e defd Zd e de eeeffdZdddddddZdedefdZy)AnthropicTransportuTransport for api_mode='anthropic_messages'. Wraps the existing functions in anthropic_adapter.py behind the ProviderTransport ABC. Each method delegates — no logic is duplicated. returncy)Nanthropic_messages)selfs M/root/.hermes/venv/lib/python3.12/site-packages/agent/transports/anthropic.pyapi_modezAnthropicTransport.api_modes#messagesc Dddlm}|jd}|||S)uConvert OpenAI messages to Anthropic (system, messages) tuple. kwargs: base_url: Optional[str] — affects thinking signature handling. r)convert_messages_to_anthropicbase_url)r)agent.anthropic_adapterrget)rrkwargsrrs rconvert_messagesz#AnthropicTransport.convert_messagess# J::j),XIIrtoolscddlm}||S)z=Convert OpenAI tool schemas to Anthropic input_schema format.r)convert_tools_to_anthropic)rr)rrrs r convert_toolsz AnthropicTransport.convert_tools#sF)%00rNmodelc Nddlm}|||||jdd|jd|jd|jdd|jd d|jd |jd |jd d|jd d S)aBuild Anthropic messages.create() kwargs. Calls convert_messages and convert_tools internally. params (all optional): max_tokens: int reasoning_config: dict | None tool_choice: str | None is_oauth: bool preserve_dots: bool context_length: int | None base_url: str | None fast_mode: bool drop_context_1m_beta: bool r)build_anthropic_kwargs max_tokensi@reasoning_config tool_choiceis_oauthF preserve_dotscontext_lengthr fast_modedrop_context_1m_beta) rrrr"r#r$r%r&r'rr(r))rr!r)rrrrparamsr!s r build_kwargszAnthropicTransport.build_kwargs)s, C%zz,6#ZZ(:; =1ZZ E2 **_e<!::&67ZZ +jje4!',BE!J  rresponsec ddl}ddlm}m}ddlm}|j dd}d}g} g} g} g} g} |jD]}||}d}t|tr||}|| j||jdk(r| j|jd|jd vro|jd k(r| j|jt|tr| j|t|ts| j||jd k(s|j}|rb|j|rQdd lm}|j%|s:|t'|d}d |z}|j%|r|}n|j%|r|}| j||j(||j+|j,|j.j |j0d}i}| r| |d<t3d| D}t3d| D}|r|r| |d<t5| rdj7| nd| xsd|| rdj7| ndd|xsdS)zNormalize Anthropic response to NormalizedResponse. Parses content blocks (text, thinking, tool_use), maps stop_reason to OpenAI finish_reason, and collects reasoning_details in provider_data. rN)_to_plain_data_sanitize_replay_block)ToolCallstrip_tool_prefixFmcp__textthinkingredacted_thinkingr5tool_use)registrymcp_)idname argumentsstopreasoning_detailsc3K|]O}t|txr9|jddvxr$|jdxs|jdQyw)typer4 signaturedataN isinstancedictr.0bs r z8AnthropicTransport.normalize_response..sZ#  q$  6f !BB 6{#4quuV} 6# sAAc3hK|]*}t|txr|jddk(,yw)r@r7NrCrFs rrIz8AnthropicTransport.normalize_response..s4  q$  ?AEE&MZ$? ? s02anthropic_content_blocks z )content tool_calls finish_reason reasoningusage provider_data)jsonrr.r/agent.transports.typesr0rrMrDrEappendr@r3r5r; startswithtools.registryr8 get_entrylenr:dumpsinput_STOP_REASON_MAP stop_reasonanyrjoin)rr,rrSr.r/r0r1 _MCP_PREFIX text_partsreasoning_partsr>rNordered_blocksblock block_dict clean_blockr;_tool_registrybaresinglerOrR_has_signed_thinking _has_tool_uses rnormalize_responsez%AnthropicTransport.normalize_responsePsp R3"JJ':EB   %%3 E'.JK*d+ 5Z@ *"))+6zzV#!!%**-@@::+#**5>>:k40%,,[9 D1%,,Z8z)zz$)EJ)33D9#C $4$56!'$)33F;#)D+55d;#'D!! 88!"&**U[["9[3 j--11(2F2FO  1BM- . ## $ #    #   M8FM4 5!-7DIIj)T!)T'6Efkk/24'/4   rch|yt|dd}t|tsy|st|dddvSy)uCheck Anthropic response structure is valid. An empty content list is legitimate for terminal stop reasons that carry no text payload: - ``end_turn`` — the model's canonical "nothing more to add" after a tool turn that already delivered the user-facing text. - ``refusal`` — the model declined to respond (Claude 4.5+). The Messages API returns an empty ``content`` list with this stop reason. Treating it as invalid sends a deterministic refusal into the invalid-response retry loop, which reproduces the refusal on every attempt and surfaces a misleading "rate limited / invalid response" error instead of the refusal. ``normalize_response`` maps ``refusal`` → ``content_filter`` so the agent loop's refusal handler can surface it. Treating either as invalid falsely retries a completed response. NFrMr]>refusalend_turnT)getattrrDlist)rr,content_blockss rvalidate_responsez$AnthropicTransport.validate_responsesC&   9d;.$/8]D9=TT Trczt|dd}|yt|ddxsd}t|ddxsd}|s|r||dSy)z=Extract Anthropic cache_read and cache_creation token counts.rQNcache_read_input_tokensrcache_creation_input_tokens) cached_tokenscreation_tokens)rp)rr,rQcachedwrittens rextract_cache_statsz&AnthropicTransport.extract_cache_statssS'40 = 91=B%!>BGa W%+H Hrr=rNlengthcontent_filter)ror7r" stop_sequencernmodel_context_window_exceeded raw_reasonc:|jj|dS)z2Map Anthropic stop_reason to OpenAI finish_reason.r=)r\r)rrs rmap_finish_reasonz$AnthropicTransport.map_finish_reasons$$((V<rs9 -,35h=*h=X0');