i ZdZddlmZmZddlmZmZmZmZddl m Z GddeZ dS)u8Abstract base for provider transports. A transport owns the data path for one api_mode: convert_messages → convert_tools → build_kwargs → normalize_response It does NOT own: client construction, streaming, credential refresh, prompt caching, interrupt handling, or retry logic. Those stay on AIAgent. )ABCabstractmethod)AnyDictListOptional)NormalizedResponsec eZdZdZeedefdZedee ee fde fdZ edee ee fde fdZ e dd edee ee fde ee ee fde ee ffd Zed e defd Zd e defd Zd e de e eeffdZdedefdZdS)ProviderTransportzEBase class for provider-specific format conversion and normalization.returncdS)zGThe api_mode string this transport handles (e.g. 'anthropic_messages').N)selfs :/home/ubuntu/.hermes/hermes-agent/agent/transports/base.pyapi_modezProviderTransport.api_modes  messagesc dS)zConvert OpenAI-format messages to provider-native format. Returns provider-specific structure (e.g. (system, messages) for Anthropic, or the messages list unchanged for chat_completions). Nr)rrkwargss rconvert_messagesz"ProviderTransport.convert_messagess  rtoolscdS)zConvert OpenAI-format tool definitions to provider-native format. Returns provider-specific tool list (e.g. Anthropic input_schema format). Nr)rrs r convert_toolszProviderTransport.convert_tools" rNmodelc dS)uBuild the complete API call kwargs dict. This is the primary entry point — it typically calls convert_messages() and convert_tools() internally, then adds model-specific config. Returns a dict ready to be passed to the provider's SDK client. Nr)rrrrparamss r build_kwargszProviderTransport.build_kwargs*s  rresponsec dS)zNormalize a raw provider response to the shared NormalizedResponse type. This is the only method that returns a transport-layer type. Nr)rrrs rnormalize_responsez$ProviderTransport.normalize_response;rrcdS)zOptional: check if the raw response is structurally valid. Returns True if valid, False if the response should be treated as invalid. Default implementation always returns True. Trrrs rvalidate_responsez#ProviderTransport.validate_responseC trcdS)zOptional: extract provider-specific cache hit/creation stats. Returns dict with 'cached_tokens' and 'creation_tokens', or None. Default returns None. Nrr#s rextract_cache_statsz%ProviderTransport.extract_cache_statsKr%r raw_reasonc|S)zOptional: map provider-specific stop reason to OpenAI equivalent. Default returns the raw reason unchanged. Override for providers with different stop reason vocabularies. r)rr(s rmap_finish_reasonz#ProviderTransport.map_finish_reasonSs r)N)__name__ __module__ __qualname____doc__propertyrstrrrrrrrrrr r!boolr$intr'r*rrrr r sOO  #   ^X  d38n)= C   ^  4S#X#7 C   ^  15    tCH~& T#s(^,-  c3h    ^  3 =O   ^ #$CHT#s(^4LCCrr N) r.abcrrtypingrrrragent.transports.typesr r rrrr6s$#######,,,,,,,,,,,,555555IIIIIIIIIIr