
    oq'j#                        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    3/home/ubuntu/.hermes/hermes-agent/providers/base.py_profile_user_agentr      sI    222222#T###   ||s   
 
c                  r   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<    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>d2Zd?d4Zdd5d6d@d:ZdS )A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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_hostnameb   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   )r0   r3   s     r   prepare_messagesz ProviderProfile.prepare_messageso   s	     r2   )
session_idr7   
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   )r0   r7   r9   s      r   build_extra_bodyz ProviderProfile.build_extra_bodyw   s	     	r2   )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   )r0   r=   r9   s      r   build_api_kwargs_extrasz'ProviderProfile.build_api_kwargs_extras   s    $ 2vr2   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+   )r0   rB   s     r   get_max_tokenszProviderProfile.get_max_tokens   s     &&r2   g       @)r   timeoutrE   floatlist[str] | Nonec                  | j         pd                                }|s&| j        sdS | j                            d          dz   }ddl}ddl}|j                            |          }|r|                    dd|            |                    dd	           |                    d
t                                 | j
                                        D ]\  }}|                    ||           	 |j                            ||          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. 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   AuthorizationzBearer Acceptzapplication/jsonz
User-Agent)rE   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PdaiiAdGiiir2   zfetch_models(%s): %s)r   stripr   rstripjsonurllib.requestrequestRequest
add_headerr   r(   itemsurlopenloadsreaddecoderO   listgetr   loggerdebugr   )r0   r   rE   urlrV   urllibreqkvresprL   r[   excs                r   fetch_modelszProviderProfile.fetch_models   s   2 $"++-- 	8= t-&&s++i7Cn$$S)) 	ANN?,?g,?,?@@@x!3444 	|%8%:%:;;;(..00 	! 	!DAqNN1a    	''W'== 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<   /F :EF EF E;F 
G!GGr   r   )r3   r4   r   r4   )r7   r8   r9   r   r   r:   )r=   r>   r9   r   r   r?   )rB   r8   r   r*   )r   r8   rE   rF   r   rG   )__name__
__module____qualname____doc____annotations__r   r   r   r   r   r   r   r   r    r"   r#   r$   r%   r&   r   rP   r(   r)   r+   r,   r1   r6   r<   rA   rD   rk   r   r2   r   r   r   &   s-        KK III&H&&&&G LKJ HHJI"&&&&& "O!!!! +/!....
  O H ',eD&A&A&AOAAAA "!!!!%)))))
            +/      )-     (' ' ' '" #	4 4 4 4 4 4 4 4r2   r   rl   )rp   
__future__r   loggingdataclassesr   r   typingr   	getLoggerrm   rb   objectOMIT_TEMPERATUREr   r   r   r2   r   <module>ry      s   	 	 # " " " " "  ( ( ( ( ( ( ( (      		8	$	$ 688     o o o o o o o o o or2   