
    epj(                        d Z ddlmZ ddlZddlmZmZ ddlmZ  ej	        e
          Z e            ZddZe G d	 d
                      ZdS )u  Provider profile base class.

A ProviderProfile declares everything about an inference provider in one place:
auth, endpoints, client quirks, request-time quirks. The transport reads this
instead of receiving 20+ boolean flags.

Provider profiles are DECLARATIVE — they describe the provider's behavior.
They do NOT own client construction, credential rotation, or streaming.
Those stay on AIAgent.
    )annotationsN)	dataclassfield)Anyreturnstrc                 <    	 ddl m}  d|  S # t          $ r Y dS w xY w)u  Return a ``hermes-cli/<version>`` UA string, with a stable fallback.

    Used by ``ProviderProfile.fetch_models`` so the catalog probe is not
    served the default ``Python-urllib/<ver>`` UA — some providers
    (OpenCode Zen, etc.) sit behind a WAF that returns 403 for that.
    r   )__version__zhermes-cli/z
hermes-cli)
hermes_clir
   	Exception)_vers    4/home/thesage/.hermes/hermes-agent/providers/base.py_profile_user_agentr      sI    222222#T###   ||s   
 
c                     e Zd ZU dZded<   dZded<   dZded<   d	Zded
<   d	Zded<   d	Z	ded<   dZ
ded<   d	Zded<   d	Zded<   dZded<   dZded<   dZded<   dZded<   dZded<   dZded<   d	Zded<    ee          Zded<   dZded <   dZd!ed"<   d	Zded#<   d=d%Zd>d(Zdd)d?d.Zdd/d@d3ZdAd4ZdBd6Zddd7d8dCd<Z dS )DProviderProfileuA   Base provider profile — subclass or instantiate with overrides.r   namechat_completionsapi_mode tuplealiases display_namedescription
signup_urlenv_varsbase_url
models_urlapi_key	auth_typeTboolsupports_health_checkFsupports_visionsupports_vision_tool_messagessupports_prompt_cache_keyfallback_modelshostname)default_factoryzdict[str, str]default_headersNr   fixed_temperature
int | Nonedefault_max_tokensdefault_aux_modelr   c                j    | j         r| j         S | j        rddlm}  || j                  j         pdS dS )u   Return the provider's base hostname for URL-based detection.

        Uses self.hostname if set explicitly, otherwise derives it from base_url.
        e.g. 'https://api.gmi-serving.com/v1' → 'api.gmi-serving.com'
        r   )urlparser   )r'   r   urllib.parser/   )selfr/   s     r   get_hostnamezProviderProfile.get_hostnameh   sQ     = 	!= = 	:------8DM**39r9r    messageslist[dict[str, Any]]c                    |S )zProvider-specific message preprocessing.

        Called AFTER codex field sanitization, BEFORE developer role swap.
        Default: pass-through.
        r   )r1   r4   s     r   prepare_messagesz ProviderProfile.prepare_messagesu   s	     r3   )
session_idr8   
str | Nonecontextdict[str, Any]c                   i S )zrProvider-specific extra_body fields.

        Merged into the API kwargs extra_body. Default: empty dict.
        r   )r1   r8   r:   s      r   build_extra_bodyz ProviderProfile.build_extra_body}   s	     	r3   )reasoning_configr>   dict | None%tuple[dict[str, Any], dict[str, Any]]c               
    i i fS )a  Provider-specific kwargs split between extra_body and top-level api_kwargs.

        Returns (extra_body_additions, top_level_kwargs).
        The transport merges extra_body_additions into extra_body, and
        top_level_kwargs directly into api_kwargs.

        This split exists because some providers put reasoning config in
        extra_body (OpenRouter: extra_body.reasoning) while others put it
        as top-level api_kwargs (Kimi: api_kwargs.reasoning_effort).

        Default: ({}, {}).
        r   )r1   r>   r:   s      r   build_api_kwargs_extrasz'ProviderProfile.build_api_kwargs_extras   s    $ 2vr3   c                    dS )u  Return a default vision model id for this provider, or None.

        Overrideable hook for providers that discover their vision default at
        runtime (e.g. from a live catalog) rather than pinning one in code.
        Keeps provider-specific vision discovery inside the provider's plugin
        instead of a name-check branch in shared vision resolution.

        Default: None (no provider-specific vision model — the caller falls
        back to the user's chat model or the aggregator chain).
        Nr   )r1   s    r   default_vision_modelz$ProviderProfile.default_vision_model   s	     tr3   modelc                    | j         S )u  Return the default max_tokens cap for *model*.

        Overrideable hook for providers that need per-model output caps —
        e.g. a relay that fronts several upstream backends, each with a
        different completion-token limit. The transport calls this when
        the user hasn't set an explicit max_tokens.

        Default: return self.default_max_tokens (the static profile field),
        ignoring the model name. Override in a subclass to vary the cap
        per-model.
        )r,   )r1   rE   s     r   get_max_tokenszProviderProfile.get_max_tokens   s     &&r3   g       @)r   r   timeoutrH   floatlist[str] | Nonec                  |p| j         }| j        pd                                }|s|sdS |                    d          dz   }ddl}ddl}ddlm} |j        	                    |          }	|r|	
                    dd|            |	
                    d	d
           |	
                    dt                                 | j                                        D ]\  }
}|	
                    |
|           	  ||	|          5 }|                    |                                                                          }ddd           n# 1 swxY w Y   t#          |t$                    r|n|                    dg           }d |D             S # t(          $ r,}t*                              d| j        |           Y d}~dS d}~ww xY w)u  Fetch the live model list from the provider's models endpoint.

        Returns a list of model ID strings, or None if the fetch failed or
        the provider does not support live model listing.

        Resolution order for the endpoint URL:
          1. self.models_url  (explicit override — use when the models
             endpoint differs from the inference base URL, e.g. OpenRouter
             exposes a public catalog at /api/v1/models while inference is
             at /api/v1)
          2. base_url (caller override — user-configured model.base_url)
          3. self.base_url + "/models"  (standard OpenAI-compat fallback)

        The default implementation sends Bearer auth when api_key is given
        and forwards self.default_headers. Override to customise auth, path,
        response shape, or to return None for providers with no REST catalog.

        Callers must always fall back to the static _PROVIDER_MODELS list
        when this returns None.
        r   N/z/modelsr   )open_credentialed_urlAuthorizationzBearer Acceptzapplication/jsonz
User-Agent)rH   datac                P    g | ]#}t          |t                    d |v |d          $S )id)
isinstancedict).0ms     r   
<listcomp>z0ProviderProfile.fetch_models.<locals>.<listcomp>   s0    PPPjD.A.APdaiiAdGiiir3   zfetch_models(%s): %s)r   r   striprstripjsonurllib.requesthermes_cli.urllib_securityrM   requestRequest
add_headerr   r)   itemsloadsreaddecoderS   listgetr   loggerdebugr   )r1   r   r   rH   effective_baseurlrZ   urllibrM   reqkvresprP   r`   excs                   r   fetch_modelszProviderProfile.fetch_models   s3   6 "2T]$"++-- 	9! t '',,y8CDDDDDDn$$S)) 	ANN?,?g,?,?@@@x!3444 	|%8%:%:;;;(..00 	! 	!DAqNN1a    	&&sG<<< 8zz$))++"4"4"6"6778 8 8 8 8 8 8 8 8 8 8 8 8 8 8&tT22LDD8L8LEPPUPPPP 	 	 	LL/C@@@44444	s<   4F :E;F EF E;F 
G!F<<Gr   r   )r4   r5   r   r5   )r8   r9   r:   r   r   r;   )r>   r?   r:   r   r   r@   )r   r9   )rE   r9   r   r+   )r   r9   r   r9   rH   rI   r   rJ   )!__name__
__module____qualname____doc____annotations__r   r   r   r   r   r   r   r   r    r"   r#   r$   r%   r&   r'   r   rT   r)   r*   r,   r-   r2   r7   r=   rB   rD   rG   rp   r   r3   r   r   r   &   sX        KK III&H&&&&G LKJ HHJI"&&&&& "O!!!! +/!.... ',++++
  O H ',eD&A&A&AOAAAA "!!!!%)))))
            +/      )-     (   ' ' ' '" ##9 9 9 9 9 9 9 9r3   r   rq   )ru   
__future__r   loggingdataclassesr   r   typingr   	getLoggerrr   rf   objectOMIT_TEMPERATUREr   r   r   r3   r   <module>r~      s   	 	 # " " " " "  ( ( ( ( ( ( ( (      		8	$	$ 688     G G G G G G G G G Gr3   