+ lHjZRt^RIt^RIt^RIt^RIt^RIt^RIHtHt]P!R4t !RR4t ] !4t ] !4tRRRlltRtR R ltR tR R lt]P(!R]P*4tRRltRRltRRltRRlt]^3Rlt]!0Rm4t]!0R m4tR!RRllt RRlt!RRlt"R#)"zSmall pure helpers shared by the tools.mcp_tool_* modules: SDK 1.x/2.x field access, error-text sanitising, numeric/bool coercion, timeouts and jitter. No origin state.N)AnyOptionalztools.mcp_toolc:a]tRt^toRtRtV3RlRltRtVtR#) _OriginProxya]Attribute proxy for ``tools.mcp_tool`` resolved at access time. The split modules read origin state (``_servers``, ``_lock``, SDK symbols, patchable helpers) through this so ``mock.patch("tools.mcp_tool.X")`` and origin-side rebinds stay effective, and so no split module needs the origin imported first (the origin imports them while initialising).c <V^8dQhRS[/#)namestr)format __classdict__s":/home/ubuntu/.hermes/hermes-agent/tools/mcp_tool_common.py __annotate___OriginProxy.__annotate__s'''c$^RIHp\W!4#))mcp_tool)toolsrgetattr)selfrrs&& r __getattr___OriginProxy.__getattr__s"x&&rN) __name__ __module__ __qualname____firstlineno____doc__ __slots__r__static_attributes____classdictcell__)r s@r rrs\ I''rrc0V^8dQhR\R\/#)rsnakecamelr )r s"r rrs33#3c3rcr\W\4pV\Jd\W\4pV\JdV#T#)uRead an MCP model field across the 1.x -> 2.x rename to snake_case. Pydantic aliases don't apply to attribute access, so ``getattr(result, "isError", False)`` silently returns the default on 2.x — failed calls read as successful, schemas as empty.)r_MISSING)objr#r$defaultvalues&&&& r mcp_fieldr*s6 C )E H-x'72U2ri,c0V^8dQhR\R\/#)rconfigreturn)dictfloat)r s"r rr,s!!$!5!rcVPR4pVeV#^RIHpV!R\R7pVeV#\# \d \ P RRR7\#i;i)zPer-server tool-call timeout. Precedence: ``mcp_servers..timeout`` > ``timeouts.mcp.tool_call`` > the 300s default; values are platform-clamped by ``resolve_timeout``.timeout)resolve_timeoutz mcp.tool_callr(z'mcp.tool_call timeout resolution failedT)exc_info)getagent.deadliner2_DEFAULT_TOOL_TIMEOUT Exceptionloggerdebug)r, per_serverr2resolveds& r _resolve_tool_timeoutr=,svI&JO2"? N  Os:"A$#A$g?c0V^8dQhR\R\/#)rsecondsr-)r/)r s"r rrAs\\u\\rc ~\RV\P!R\, R\,4,4#)z5``seconds`` with +/-20% uniform jitter, floored at 0.gg?)maxrandomuniform_BACKOFF_JITTER)r?s&r _jitteredrEAs) sGfnnS?-BC/DYZZ [[rz(?:ghp_[A-Za-z0-9_]{1,255}|sk-[A-Za-z0-9_-](?:\.?[A-Za-z0-9_-]){0,254}|Bearer\s+\S+|(?:token|key|API_KEY|password|secret)=[^\s&,;\"']{1,255})c0V^8dQhR\R\/#)rrefr-r )r s"r rrMsssrcVP4pVPR4'dV\R4RP4pV#)zPBare env-var name from a ``${...}`` body; strips a Cursor-style ``env:`` prefix.zenv:N)strip startswithlen)rGs&r _env_ref_namerLMs: ))+C ~~f#f+,%%' Jrc0V^8dQhR\R\/#)rtextr-r )r s"r rrUs77#7#7rc.\PRV4#)zMReplace credential-like patterns with [REDACTED] before text reaches the LLM.z [REDACTED])_CREDENTIAL_PATTERNsub)rNs&r _sanitize_errorrRUs  " "< 66rc0V^8dQhR\R\/#)rexcr-) BaseExceptionr )r s"r rrZs-Crc^\V4P4pT;'g \V4#)zNon-empty string for *exc*: some exceptions (``anyio.ClosedResourceError``) carry no message, so fall back to ``repr`` to keep diagnostics.)r rIrepr)rTrNs& r _exc_strrXZs& s8>> D   49rc<V^8dQhR\R\R\/#)renv directoryr-)r.r )r s"r rras!trcF\T;'g/4pV'dVPRR4P\P4Uu.uFq3'gK VNK ppW9dV.VOpV'd \PP V4MTVR&V#uupi)z=Prepend *directory* to env PATH if it is not already present.PATH)r.r5splitospathsepjoin)rZr[updatedpartpartss&& r _prepend_pathrfas399"oG")++fb"9"?"? "KT"K$t"KT  !''E49"**//%0y N Us  BBcV!V4p\V\4'd\P!V4'gV#\ WC4# \ \ \3dTu#i;i)z{Coerce a config value (YAML strings included) to a number, clamped to *minimum*; *default* on failure or non-finite floats.) isinstancer/mathisfiniterA TypeError ValueError OverflowError)r)r(coerceminimumresults&&&& r _safe_numericrqlsV fe $ $T]]6-B-BN6## z= 1s9A A A A$#A$c<V^8dQhR\R\R\/#)rr)r(r-)rbool)r s"r rr|s!  #   rc2VfV#\V\\\34'd \V4#\V\4'd9VP 4P 4pV\9dR#V\9dR#\PRW4V#)z\Parse a bool-like config value with safe fallback (YAML ``0``/``1`` are numbers, not words).TFzAMCP config expected a boolean-ish value, got %r; using default=%s) rhrsintr/r rIlower _TRUE_WORDS _FALSE_WORDSr9warning)r)r(lowereds&& r _parse_boolishr{|sv }%$U+,,E{%++-%%' k ! l " NNVX]g Nrc0V^8dQhR\R\/#)rcfgr-)r.rs)r s"r rrsBBDBTBrc<\VPRR4RR7#)aWhether ``mcp_servers.`` is on. The ONE reader of the ``enabled`` key: the MCP client, the toolset resolver, the profile editor, and every list/status surface call it, so a value can never be on for one surface and off for another. Absent, ``null`` or unparseable = on.enabledTr3)r{r5)r}s&r mcp_server_enabledrs #'')T2D AArcRV^8dQhR\R\R\\,/#)rr,keyr-)r.r rr/)r s"r rrs%4chuorc|VPV4pVf>\VPR4\4'dVR,PV4pVfR#\V4pT^8d\ PRY4R#T;'gR# \\ 3d\ PRY4R#i;i)zOptional positive lifecycle timeout from top-level/nested ``lifecycle`` config (``0`` disables; negatives and non-numbers are warned about and ignored).N lifecyclez6MCP config %s must be a number of seconds; ignoring %rz+MCP config %s must be positive; ignoring %r)r5rhr.r/rkrlr9ry)r,rrawr?s&& r _get_lifecycle_secondsrs **S/C {z&**["94@@[!%%c* {*{DcO ??d z "OQTZs B'B;:B;)N>1onyestrue>0noofffalse)T)#rloggingrir`rBretypingrr getLoggerr9r_coreobjectr&r*r7r=rDrEcompile IGNORECASErPrLrRrXrfrurq frozensetrwrxr{rrrrr rsW   + , ' '  83!$\jjBCE==R 7 *-a 23 45   Br