`gj RdZddlmZmZddlmZmZmZmZddl m Z GddeZ y)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 4eZdZdZeedefdZedee 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 eeffdZdedefdZy)ProviderTransportzEBase class for provider-specific format conversion and normalization.returncy)zGThe api_mode string this transport handles (e.g. 'anthropic_messages').N)selfs H/root/.hermes/venv/lib/python3.12/site-packages/agent/transports/base.pyapi_modezProviderTransport.api_modes messagesc y)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 rtoolscy)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 y)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 y)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;rrcy)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 rcy)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 sSO  #   d38n)= C   4S#X#7 C   15   tCH~& T#s(^,-  c3h    3 =O  #$CHT#s(^4LCCrr N) r.abcrrtypingrrrragent.transports.typesr r rrrr6s&$,,5IIr