߲jOldZddlmZddlmZmZddlmZmZd dZ d d dZ d ddZ dd Z dd Z y)zAFail-closed URL identity normalization for model/provider routes.) annotations)AnyOptional)urlsplit urlunsplitc`t|xsd}|sytd|Dr|Sd|jdddv} t|}|j}|j r|s|S|j j }d|vr+|jdd\}}|j d|}n|j }|j} |jjddd } | jd sd |vrd |d }| || fdvr|d | }d|jvr$|jjdddd|}|j} | jdr|s| d d } t||| |j df} |r|j s| dz } | S#ttf$r|cYSwxYw)z/home/ubuntu/.hermes/hermes-agent/hermes_cli/route_identity.py z+normalize_route_base_url..s -3t9  -s?#r%@[:]N>httpPhttpsi/)stranysplitrhostnameschemelowerport TypeError ValueErrornetlocrsplit startswithpathendswithrquery) base_urlrawhad_query_delimiterparsedr#r$addresszonehostr& route_hostr, normalizeds rnormalize_route_base_urlr8 s hn" C  - -- 3!21!55 #??}}HJ$$& (?$NN32MGTmmo&av.D>>#D{{%%c1-b1JS!SD[4&{ VTN2PPq fmm--&&sA.q12!D6: ;;D }}S"5CRyVT4rBCJ6<<c  z " s&F&A%FF-,F-NcPddlm}m}m}m}ddlm}|t|xsd}|syt|xsdjj} || } | dvryt|tr|ni} || | jdxsixs|| | jd } | !| jr|| j|k(S|| d } | "| jr|| j|k(ry| | ydd lm}|t|}|y||| k(S) uJWhether ``model.base_url`` is *provider*'s own endpoint. ``True``: the host is the provider's registry/plugin endpoint or the endpoint of a ``providers:``/``custom_providers:`` entry that resolves to *provider*, or *provider* is bare ``custom``/``local`` (the URL *is* the route). ``False``: the host is another known provider's stock endpoint, or *provider* names a user entry with a different endpoint. ``None``: unknown host (a proxy, a LAN server) — nothing here can say whose it is. Offline: the registry lookup never fetches the models.dev catalog. r) get_providernormalize_providerresolve_custom_providerresolve_user_provider)base_url_hostnamer N)customlocalT providerscustom_providersF) allow_network)_infer_provider_from_url)hermes_cli.providersr:r;r<r=utilsr>r stripr% isinstancedictgetr/agent.model_metadatarD)providerr/configr:r;r<r=r>r5r0 canonicalcfg user_pdefpdefrDinferreds rprovider_owns_routerS/s.vu' SR0 1D  hn"  # # % + + -C"3'I''vt,&"C%c377;+?+E2F*Ja SWW' (K*I!3!3 !3!34<<   7D DMM.? .NRV.V | )='H 6H h '9 44c4t|tsidfSt|jdxsdj }|r t |||nd}|ridfS|idfSdDcic](}|j|dvs||j |*}}|dfScc}w)usPop the route keys (``base_url``, ``api_mode``) a previous provider left in ``model:`` when the block is re-pointed at *provider* without a fresh route (``hermes config set model.provider``). Mirrors what a persisted ``/model`` switch writes: the route is synced to the target, never carried over. Returns ``(popped {key: old value}, unverified)`` where ``unverified`` is True when a base_url of unknown ownership was kept — the caller should say so. A base_url that belongs to *provider* is kept together with its api_mode; with no base_url the api_mode alone is wire state of the old route and goes.Fr/r T)r/api_mode)Nr )rHrIr rJrGrSpop) model_cfgrLrMr/ownedkpoppeds rdrop_stale_model_router\Vs i &5y9==,2399;H?G (F ;UE 5y }4x+C jay}}UVGW_iGiaq!! jF j 5=ks "B;Bct|xsdj}|r!|t|xsdjk7ry ddlm}|||||S#t$rYywxYw)zTrue when a configured ``model.context_length`` pin no longer matches its runtime route. Fail-closed: any error during route comparison returns ``True`` (drop the pin) so a stale window never silently inflates the compression threshold.r Tr)_context_route_mismatch)r rGagent.agent_initr^ Exception)configured_model active_modelconfigured_base_urlactive_base_urlconfigured_provideractive_providerr^s rshould_clear_context_pinrgjsm +1r288:,L4FB0G0M0M0OO<&':OM`bqrr sA AAcTKddl}|jtg|d{S7w)u``should_clear_context_pin`` on a worker thread so async gateway handlers never run it on the event loop — the resolution chain is cache-only (``allow_network=False``) but can still do cold-start disk I/O.rN)asyncio to_threadrg)argsris rshould_clear_context_pin_asyncrlys*"""#;CdC CC Cs (&()r/rreturnr )N)rLrr/rrMrrmzOptional[bool])rXrrLrrMrrmz'tuple[dict[str, Any], bool]')rarrbrrcrrdrrerrfrrmbool)rkrrmrn)__doc__ __future__rtypingrr urllib.parserrr8rSr\rgrlrTrrtsEG" -#L$5N( 25 HK PT DrT