*3j+zdZddlmZmZmZmZddlmZddlm Z GddeZ ddl m Z e de d S) 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 deZdZdZedefdZdeeee fde fdZ deeee fde fdZ dd edeeee fde eeee fdeee ffd Z d e defd Zd e defd Zd e de eeeffdZdddddddZdedefdZdS)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. returncdS)Nanthropic_messages)selfs @/home/rurouni/.hermes/hermes-agent/agent/transports/anthropic.pyapi_modezAnthropicTransport.api_modes##messagesc Rddlm}|d}|||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> JIIIII::j)),,XIIIIrtoolsc$ddlm}||S)z=Convert OpenAI tool schemas to Anthropic input_schema format.r)convert_tools_to_anthropic)rr)rrrs r convert_toolsz AnthropicTransport.convert_tools#s%FFFFFF))%000rNmodelc ddlm}|||||dd|d|d|dd|d d|d |d |d d|d 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, CBBBBB%%zz,66#ZZ(:;; =11ZZ E22 **_e<<!::&677ZZ ++jje44!',BE!J!J    rresponsec Nddl}ddlm}m}ddlm}|dd}d}g} g} g} g} g} |jD]}||}d}t|tr"||}|| ||j dkr| |j m|j d vr{|j d kr| |j t|tr| |t|tr| ||j d kr|j}|r{||rfdd lm}||sK|t'|d}d |z}||r|}n||r|}| ||j|||j|j|jd}i}| r| |d<t3d| D}t3d| D}|r|r| |d<t5| rd| nd| pd|| rd| ndd|pdS)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|]Z}t|to@|ddvo)|dp|dV[dS)typer4 signaturedataN isinstancedictr.0bs r z8AnthropicTransport.normalize_response..s}# #  q$   6f !BB 6{##4quuV}}# # # # # # rc3rK|]2}t|to|ddkV3dS)r@r7NrCrFs rrIz8AnthropicTransport.normalize_response..sT   q$   ?AEE&MMZ$?      ranthropic_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_responsePs  RRRRRRRR333333"JJ':EBB   %3 3 E'..JK*d++ 7 54Z@@ *"))+666zV##!!%*----@@@:++#**5>:::k4009%,,[9999 D119%,,Z888z))z$()E)E(JIIIII)33D99(#C $4$4$5$56!'$)33F;;(#)DD+55d;;(#'D!!H 8!"&**U["9"9-11(2FOO   C1BM- . ## # $ # # #      #       GM G8FM4 5!-7ADIIj)))T!)T'6EOfkk/2224'/4     rc|dSt|dd}t|tsdS|st|dddvSdS)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_responses]&  5 9d;;.$// 5 U8]D99=TT Ttrct|dd}|dSt|ddpd}t|ddpd}|s|r||dSdS)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_statsso'400 =4 91==B%!>BBGa  IW I%+HH Htrr=rNlengthcontent_filter)ror7r" stop_sequencernmodel_context_window_exceeded raw_reasonc8|j|dS)z2Map Anthropic stop_reason to OpenAI finish_reason.r=)r\r)rrs rmap_finish_reasonz$AnthropicTransport.map_finish_reasons$((V<<rs -,,,,,,,,,,,333333555555h=h=h=h=h=*h=h=h=X0/////');<<<<