+ jHjMzRt^RIHt^RIHtHt^RIHtHtRRlt RRRllt RR R llt R R lt R Rlt R#)zAFail-closed URL identity normalization for model/provider routes.) annotations)AnyOptional)urlsplit urlunsplitc V^8dQhRRRR/#)base_urlrreturnstr)formats">/home/ubuntu/.hermes/hermes-agent/hermes_cli/route_identity.py __annotate__r s##s#s#cX\T;'gR4pV'gR#\;QJdRV4F 'gK RM RM !RV44'dV#RVPR^4^,9p\V4pVPpVP 'd V'gV#VP P 4pRV9d+VPR^4wrgVP 4 RV 2pMVP 4pVPp TPPR^4R,p T PR 4'gR T9dR T R 2pT eYY3R9dT R T 2pRTP9d)TPPR^4^, RT 2pTPp T PR 4'dT'gT R Rp \YXYP R34p T'dTP 'g T R, p T # \\3dTu#i;i)z"TFp\V4^ 8*xK R#5i) N)ord).0chars& r +normalize_route_base_url..s -3t9 sTF?#%@[:]N/>httpPhttpsi)r anysplitrhostnameschemelowerport TypeError ValueErrornetlocrsplit startswithpathendswithrquery) r rawhad_query_delimiterparsedr*r+addresszonehostr- route_hostr3 normalizeds & rnormalize_route_base_urlr> s hnn" C  s - -sss - --- 3!21!55 #??}}}HJ$$& (?$NN32MGmmo&av.D>>#D{{%%c1-b1JS!!SD[4&{ VN2PPq fmm--&&sA.q12!D6: ;;D }}S"5CRyV4rBCJ6<<<c  z " s90H*H,A'HH)(H)Nc(V^8dQhRRRRRRRR/#)rproviderrr configr zOptional[bool]r )r s"rrr/s($5$5#$5$5c$5^$5rc^RIHpHpHpHp^RIHpT!\T;'gR44pV'gR#\T;'gR4P4P4p V!V 4p V R 9dR#\V\4'dTM/p T!YPR4;'g/4;'gV!WPR44p V e(V P'dV!V P4V8H#V!V RR 7p V e,V P'dV!V P4V8XdR#V fV fR#^R IHpV!\V44pVfR#V!V4V 8H#) u.Whether ``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. ) get_providernormalize_providerresolve_custom_providerresolve_user_provider)base_url_hostnamerNT providerscustom_providersF) allow_network)_infer_provider_from_url)customlocal)hermes_cli.providersrCrDrErFutilsrGr stripr, isinstancedictgetr agent.model_metadatarK)r@r rArCrDrErFrGr;r6 canonicalcfg user_pdefpdefrKinferreds&&& rprovider_owns_routerZ/s>vu' SR0 1D  hnn"  # # % + + -C"3'I''vt,,&"C%c77;+?+E+E2F**Ja WW' (K*I!3!3!3 !3!34<<   7D DMMM.? .NRV.V | )='H 6H h '9 44rc(V^8dQhRRRRRRRR/#)r model_cfgrr@rAr ztuple[dict[str, Any], bool]r )r s"rrrVs)cS#Qlrcn\V\4'g/R3#\VPR4;'gR4P 4pV'd \ WV4MRpV'd/R3#Vf/R3#RUu/uF+qPPV4R9gKWPP V4bK- ppVR3#uupi)u[Pop 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 rT)r api_mode)Nr)rQrRr rSrPrZpop)r\r@rAr ownedkpoppeds&&& rdrop_stale_model_routercVs i & &5y9==,22399;H?G F ;UE 5y }4x+C j+Ca}}UVGW_iGi!aq!!+CF j 5=ks ;B2B2c4V^8dQhRRRRRRRRRRRRRR /#) rconfigured_modelr active_modelconfigured_base_urlactive_base_urlconfigured_provideractive_providerr boolr )r s"rrrjsB  s # \_ ru 25 HK PT rc\T;'gR4P4pV'd+T\T;'gR4P48wdR#^RIHpV!W#WE4# \dR#i;i)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.rT)_context_route_mismatch)r rPagent.agent_initrm Exception)rerfrgrhrirjrms&&&&&& rshould_clear_context_pinrpjsn +11r288:,L4F4FB0G0M0M0OO<&':M`rr sA&& A54A5c V^8dQhRRRR/#)rargsrr rkr )r s"rrrysDDDDrcV"^RIpVP!\.VO5!GRjxL #L5i)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.N)asyncio to_threadrp)rrrts* rshould_clear_context_pin_asyncrvys'""#;CdC CC Cs )'))N)__doc__ __future__rtypingrr urllib.parserrr>rZrcrprvr rrr{s-G" -#L$5N( Dr