+ jHj,7 NRt^RIHt^RIt^RIt^RIt^RIt^RIt^RIt^RI t ^RI H t ^RI Ht^RIHtHtHt]P&!R4t]]]]]]3,,3,tRtRR ltRCtR R ltR R ltRRltRRltRRltRRlt RRlt!RRlt"] !RR7!RR44t#RDRR /R!R"lllt$R#R$lt%R%R&lt&R'R(lt'R)R*lt(R+t)]#!R,R-R.R/R04t*]#!R1R2R3R4R5RR67t+R7R8lt,R9RR:R /R;R<llt-R9RR:R /R=R>llt.R?R@lt/RARBlt0R#)Eu)Per-model reasoning capabilities from OpenRouter-schema ``/v1/models`` catalogs. Split out of ``hermes_cli.models``. OpenRouter and Nous Portal share one implementation parametrized by :class:`_CapsSource`; the per-source module globals (``_openrouter_reasoning_caps_cache``, ``_nous_caps_disk_checked``, ...) stay defined on ``hermes_cli.models`` — tests reset them there — and are read/written by attribute name. Tri-state contract for callers deciding whether to emit reasoning controls: a dict with ``supports_reasoning: True`` (+ ``supported_efforts``, ``mandatory``) — the route advertises reasoning controls; ``supports_reasoning: False`` — the catalog knows the model and it does NOT accept them (definitive negative); ``None`` — unknown (catalog not loaded, model not listed, malformed). ) annotationsN) dataclass)Path)AnyCallableOptionalzhermes_cli.modelsc^RIHpV#)models) hermes_clir r s E/home/ubuntu/.hermes/hermes-agent/hermes_cli/models_reasoning_caps.py_originr"s ! Mc V^8dQhRRRR/#)itemrreturnOptional[dict[str, Any]])formats"r __annotate__r'sww#w:Rwrc\V\4'gR#VPR4p\V\4'gR#RV9dRR/#VPR4p\V\4'g/pVPR4pRp\V\4'd&\\P RV444pRRRVR VPR 4RJ/#) abNormalize one OpenRouter catalog entry's reasoning metadata. ``supported_parameters`` contains ``"reasoning"`` when the route accepts reasoning controls at all; a top-level ``reasoning`` object may add ``mandatory`` / ``supported_efforts``. A missing or malformed ``supported_parameters`` is "unknown" (None), like ``_openrouter_model_supports_tools``. Nsupported_parameters reasoningsupports_reasoningFsupported_effortsc3"TFMp\V4P4'gK$\V4P4P4xKO R#5iN)strstriplower).0es& r :parse_openrouter_reasoning_capabilities..;s;$c[TWXYTZT`T`Tb%;SV\\^%9%9%;%;[s !A/AT mandatory) isinstancedictgetlistfromkeys)rparamsr raw_effortseffortss& r 'parse_openrouter_reasoning_capabilitiesr/'s dD ! ! XX, -F fd # #& $e,,%I i & & -- 34K#'G+t$$t}}$c[$ccd $(;WkS\S`S`alSmquSu vvrcV^8dQhRR/#)rrrr)rs"r rrIs??4?rc8^RIHpV!4R, R, #)r get_hermes_homecachezreasoning_caps.json)hermes_constantsr3r2s r _reasoning_caps_disk_pathr6Is0  w &)> >>rcV^8dQhRR/#)rrzdict[str, Any]r)rs"r rrNs??>?rcB^RIHpV!\44;'g/#)r _read_json_cache)hermes_cli.modelsr:r6r9s r _read_reasoning_caps_diskr<Ns2 57 8 > >B>rc V^8dQhRRRR/#)rurlrrztuple[Optional[Caps], float]r)rs"r rrSs K K3 K+G Krc \4PV4p\V\4'dVPR4MRp\V\4'd V'gR#\ R\ P !4\ VPR4;'g^4, 4pVP4UUu/uFwrE\V4VbK uppV3# \\3d\ \4pLRi;iuuppi)z=Return ``(caps, age_seconds)`` for *url*, or ``(None, 0.0)``.capsNts)NrA) r<r)r'r(maxtimefloat TypeError ValueError _REASONING_CAPS_DISK_TTL_SECONDSitemsr)r>entryr@agemid model_capss& r _load_reasoning_caps_diskrNSs % ' + +C 0E *5$ 7 7599V TD dD ! !6#tyy{U599T?+?+?a%@@A9= E _SCHj Es JJ z "6456 Es$6CC?D C?>C?c$V^8dQhRRRRRR/#)rr>rr@CapsrNoner)rs"r rr`s&JJ3JdJtJrc^RIHp\4pR\P!4RV/W0&V!\ 4V^RR7R# \ d"p\ PRT4Rp?R#Rp?ii;i)z>Merge *url*'s catalog into the shared disk mirror, atomically.)_write_json_cacherBr@)indent separatorsz,Failed to save reasoning-caps disk cache: %sN),:)r;rSr<rDr6 Exceptionloggerdebug)r>r@rSdataexcs&& r _save_reasoning_caps_diskr]`s`3J(*499;5 35tAR\] J CSIIJs9A A/A**A/cV^8dQhRR/#rrrQr)rs"r rrks~~4~rc\PPR4'dR#\P!\ P !4PV3RRR7P4R#)zRun *refresh* in a daemon thread (fire-and-forget) so a cold/stale cache is warm for the next call or, via the disk mirror, the next process without this turn blocking on HTTP. Callers own the once-per-process guard; the fetch keeps its own failure TTL.PYTEST_CURRENT_TESTNzreasoning-caps-warmT)targetargsnamedaemon) osenvironr) threadingThread contextvars copy_contextrunstart)refreshs&r _warm_reasoning_caps_asyncroksK zz~~+,, K446::'Rgptu{{}rc V^8dQhRRRR/#)rr>rrOptional[Caps]r)rs"r rrus3NrcT\V4wr#VeV\8d \V4V#)uThe disk copy of *url*'s catalog, queueing *refresh* when it's stale. A copy past its TTL is still returned — a stale verdict beats no verdict, and capabilities change rarely.)rNrHro)r>rnr@rKs&& r !_hydrate_reasoning_caps_from_diskrsus+*#.ID C#CC"7+ Krc$V^8dQhRRRRRR/#)rr>rrIrrrqr)rs"r rr~s!c#.rc8\V\4'gR#/pVFdp\V\4'd3\VP R4;'gR4P 4MRpV'gKW\ V4W$&Kf V'gR#\W4V#)u/Parse a ``/v1/models`` ``data`` array and mirror it for *url*. Takes the payload rather than fetching it, so picker and pricing fetches (same document) leave the mirror warm at no network cost. None when the array has no usable entries — callers remember that as a failure rather than caching empty. Nid)r'r*r(rr)r r/r])r>rI caps_by_idrrLs&& r _seed_reasoning_capsry~s{ eT " "J3=dD3I3Ic$((4.&&B'--/r 3EdKJO c. rc$V^8dQhRRRRRR/#)rr>rtimeoutrErrqr)rs"r rrs! : :s :U :~ :rc\4p\PPVRRRVP/R7pVP W1R7;_uu_4p\ P!VP4P44pRRR4\TXPR44# +'giL+;i \dR#i;i)uFetch one OpenRouter-shaped ``/v1/models`` catalog → per-model caps; None when unreachable or empty so callers remember the failure. Sends a User-Agent: the Portal 403s anonymous reads.Acceptzapplication/jsonz User-Agent)headersr{Nr[) rurllibrequestRequest_HERMES_USER_AGENT_urlopen_model_catalog_requestjsonloadsreaddecoderXryr))r>r{mreqresppayloads&& r _fetch_reasoning_caps_catalogrs  Ann$$S8=OQ]_`_s_s2t$u  - -c - C Ctjj!3!3!56GD W[[%8 99 D C s0A B>3B+B>+ B; 6B>;B>> C  C T)frozenct]tRt^t$RtR]R&R]R&R]R&R]R&R]R&R tR ]R &R R ltRRltRt R#) _CapsSourceuOne catalog's cache slots on ``hermes_cli.models`` plus how to name its URL. ``cache``: model id → parsed caps from one full-catalog fetch, kept for the process lifetime. ``failed_at``: monotonic timestamp of the last FAILED fetch; suppresses re-fetch storms from per-turn callers for 60s (mirrors the LM Studio/Ollama probe caching). ``disk_checked`` / ``warm_started``: once-per-process guards for the disk hydrate and the background warm. rr4 failed_at disk_checked warm_startedzCallable[[], str]r>Fbool per_profilecV^8dQhRR/#)rslotrr)rs"r r_CapsSource.__annotate__s}}}rc VP'g\\4\W44#^RIHpT!\4\W4VR9dR4#R4#)r )profile_slot_getFN)rr)rgetattrrhermes_cli.models_profile_cacher)selfrrs&& r r)_CapsSource.getsL79gd&9: :D 74+>QqIq||w{||rc V^8dQhRRRR/#)rrrrrQr)rs"r rrs@@@t@rc VP'g!\\4\W4V4R#^RIHpV!\4\W4V4R#)N)profile_slot_set)rsetattrrrrr)rrvaluers&&& r set_CapsSource.sets: GIwt2E : DGD$7?rrN) __name__ __module__ __qualname____firstlineno____doc____annotations__rr)r__static_attributes__rrr rrsC JN K} @@rr@forceFc(V^8dQhRRRRRRRR/#) rsrcrr{rErrrrqr)rs"r rrs)[5$SarcbVPR4pVe V'gV#VPR4pVe$\P!4V, ^<8dR#\VP 4V4pVf(VP R\P!44R#VP RV4V#)zFetch + cache the source's per-model caps. None (without poisoning the cache) when unreachable, so callers retry later and fall back meanwhile.r4Nr)r)rD monotonicrr>r)rr{rcachedrrxs&&$ r _fetch_capsrsWWW F %  $I$.."2Y">"!D.swwy'BJ  T^^-.GGGZ rc V^8dQhRRRR/#)rrrrrqr)rs"r rrs  k n rcaSPR4fXSPR4'gASPRR4SPR\SP4V3Rl44SPR4#)uCache-only caps: memory, else the disk mirror. Never HTTP. One disk attempt per process: for the Portal, naming the catalog means resolving credentials, which can itself reach the network to refresh a token — too expensive for a per-turn caller. r4rTc<\SRR7#T)rrrsr _caps_cached..skZ]eiNjr)r)rrsr>rsfr _caps_cachedrs\  www(?(? % :3779Fjkl 777 rc ,V^8dQhRRRRRRRRR R /#) rrrmodel_id Optional[str]r{rE allow_fetchrrrr)rs"r rrs8EE[EMEuE[_Ed|Erc\T;'gR4P4pV'gR#\V4pVfV'd \WR7pVeVP V4#R#)rwNr)rr rrr))rrr{rmodelrxs&&$$ r _model_capsrsV B  % % 'E c"Jk 6 $.$::>>% DDrc V^8dQhRRRR/#)rrrrrQr)rs"r rrsEE+E$ErcaSPR4'g\S4eR#SPRR4\V3Rl4R#)rNTc<\SRR7#rrrsr r"_warm_caps_async..s {3d'Cr)r)rrrorsfr _warm_caps_asyncrs6 ww~,s"3"?GGND!CDrc V^8dQhRRRR/#)rproviderrrrQr)rs"r rrs I I= IT IrcaR\R\R\R\/P\T;'gR4P 4P 44oSe\ V3Rl4R#R#)aForce a background re-fetch of *provider*'s reasoning-capability catalog. The in-memory cache is otherwise held for the process lifetime, so a route that flips to reasoning-mandatory mid-process (GLM-5.3-flash, Sep 2026) keeps being sent disables it now rejects. Called from the conversation loop's reasoning_mandatory recovery so the profile guard is right again on the next request; no-op for providers without a catalog. nousz nous-portal nousresearch openrouterrwNc<\SRR7#rrrsr r.refresh_reasoning_caps_async..s ;s$+Gr) _NOUS_CAPS_OPENROUTER_CAPSr)rr r!ro)rrs&@r refresh_reasoning_caps_asyncrs\ :}j.* ) ++.3s8>>r/B/H/H/J/P/P/R+S "#GHrz#https://openrouter.ai/api/v1/models _openrouter_reasoning_caps_cache$_openrouter_reasoning_caps_failed_at_openrouter_caps_disk_checked_openrouter_caps_warm_startedc\#r)_OPENROUTER_CATALOG_URLrrr rrs #r_nous_reasoning_caps_cache_nous_reasoning_caps_failed_at_nous_caps_disk_checked_nous_caps_warm_startedc\4#r)nous_catalog_urlrrr rr s  r)rcV^8dQhRR/#)rrrr)rs"r rrsAA#Arc0^RIHpV!4^, R2#)uThe Portal ``/v1/models`` URL for the endpoint we actually talk to (``NOUS_INFERENCE_BASE_URL`` → resolved credential base → prod), so a staging profile reads staging's capabilities.!_resolve_nous_pricing_credentialsz /v1/models)hermes_cli.models_pricingrrs r rrsL/1!4 5Z @@rr{rc(V^8dQhRRRRRRRR/# rrrr{rErrrrr)rs"r rrs2]]]).]CG]]rc&\\WVR7#)uLive-catalog reasoning capabilities for an OpenRouter model (tri-state, see module doc). CACHE-ONLY by default — safe on per-request hot paths (never blocks on HTTP).r{r)rrrr{rs&$$r 'openrouter_model_reasoning_capabilitiesrs 'P[ \\rc(V^8dQhRRRRRRRR/#rr)rs"r rr#s2WWW).WCGWWrc&\\WVR7#)zNous Portal counterpart of :func:`openrouter_model_reasoning_capabilities`; warm the cache with :func:`warm_nous_reasoning_caps_async` from hot paths.r)rrrs&$$r !nous_model_reasoning_capabilitiesr#s z8+ VVrcV^8dQhRR/#r_r)rs"r rr+s''d'rc$\\4R#)zAWarm the OpenRouter reasoning-capability cache in the background.N)rrrrr $warm_openrouter_reasoning_caps_asyncr+s %&rcV^8dQhRR/#r_r)rs"r rr0s!!!rc$\\4R#)zHNous Portal counterpart of :func:`warm_openrouter_reasoning_caps_async`.N)rrrrr warm_nous_reasoning_caps_asyncr0s Z riQ)r)1r __future__rrjrloggingrfrhrDurllib.requestr dataclassesrpathlibrtypingrrr getLoggerrYr(rrPrr/rHr6r<rNr]rorsryrrrrrrrrrrrrrrrrrr rsg #   !**   . / C$sCx.) )* w>$- ? ? KJ~( : $@@@@" EE I@&(N#%D# "B8D A]14]JO]W14WJOW' !r