+ lHj:~Rt^RIHt^RIt^RIt^RIt^RIt^RIHt^RI H t H t ^RI H t HtHtHtHt^RItRtRtRt]!]]]04tR t] !R R 44t]P4!R 4t]P8!4t]P<!R R7RRl4tRRlt RRlt!RRlt"RRlt#R6RRllt$RRlt%RRlt&R7RR llt'](])]*,]+],]-]*3,]*3,t.R!R"lt/R#R$lt0R%t1^t2R&R'lt3R8R(R/R)R*lllt4]P4!R+4t5R9R,R-llt6R.R/lt7R0R1lt8R2R3/R4R5llt9R#):zDeferred-tool catalog for tool search: BM25 retrieval over deferrable tool defs plus the budgeted, byte-stable catalog listing embedded in the bridge.) annotationsN)Counter) dataclassfield)AnyDictListOptionalTuple tool_search tool_describe tool_callg@cj]tRt^t$RtR]R&R]R&R]R&R]R&R]R&]!]R 7tR ]R &R t R #) CatalogEntryzEOne deferrable tool, in a form the bridge tools can search and serve.strname descriptiondict[str, Any]schemasource source_name)default_factory list[str]_tokensN) __name__ __module__ __qualname____firstlineno____doc____annotations__rlistr__static_attributes__r>/home/ubuntu/.hermes/hermes-agent/tools/tool_search_catalog.pyrrs0O I  Kt4GY4r#rz [A-Za-z0-9]+i@)maxsizec V^8dQhRRRR/#)tokenrreturnr)formats"r$ __annotate__r++s1111r#c\\RR4f \P!R4\n\PP V4#)zStem one token, memoized across stateless catalog rebuilds. Snowball stemmers carry mutable parsing state and bridge dispatch runs on parallel tool-call threads, so the stemmer is one-per-thread, created lazily.stemmerNenglish)getattr _thread_localsnowballstemmerr-stemWord)r(s&r$_stemr3*s= }i.6 / 7 7 B   ) )% 00r#c V^8dQhRRRR/#)r'textrr)rr)r*s"r$r+r+4sWWCWIWr#cV'd=\PV4Uu.uFp\VP44NK up#.#uupi)zLowercase alphanumeric tokens, Snowball-stemmed (English); shared by the index and query paths so "issues" matches ``create_issue``.) _TOKEN_REfindallr3lower)r5r(s& r$ _tokenizer:4s>KOi.?.?.E F.EUE%++- .E FVTVV Fs"Ac V^8dQhRRRR/#)r'tdrr)r)r*s"r$r+r+:s$$N$~$r#c8VPR4;'g/#)z?The ``function`` block of a tool-def (``{}`` when absent/None).function)get)r<s&r$_fnr@:s 66*  # ##r#c V^8dQhRRRR/#)r'rrr)rr)r*s"r$r+r+?s##r#cV^RIHpVPV4# \dR#i;i)zRegistry entry for ``name``; None when unregistered OR the registry raises (lookup failures must never fail a bridge call). Lazy import: tests patch the registry.registryN)tools.registryrD get_entry Exception)rrDs& r$_registry_entryrH?s-+!!$'' s  ((c V^8dQhRRRR/#)r'rrr) Optional[str]r)r*s"r$r+r+Is99C9M9r#cb\\V4RR4p\V\4'dV#R#)zSToolset of a registered tool; None when unregistered or malformed (no str toolset).toolsetN)r/rH isinstancerrrLs& r$_registry_toolsetrOIs,od+Y=G #..78D8r#c$V^8dQhRRRRRR/#)r'r<r source_labelrr)r)r*s"r$r+r+Os& S S> S Sc Sr#c\V4pVPRR4pVPR4p\P!RRV4pV'dWP 49dTMRpRP VPR4;'g/PR4;'g/P44pT RT RVPRR4;'gR RV 2#) uASearch-text blob: split name words + source label + description + top-level parameter names (schema bodies are noise with no recall gain). The ``mcp__`` prefix is dropped — it is in every MCP document, so its IDF is ~0. The source label lets a service-name query ("linear") reach a tool whose own name omits the vendor.rmcp__z[_.:-] parameters propertiesr)r@r? removeprefixresubsplitjoinkeys)r<rQfnr name_wordsextra param_namess&& r$_entry_search_textrbOs RB 66&" D   W %D 3-J(\AQAQAS-SLY[E((RVVL177R<<\JPPbVVXYK\5'266-#<#B#B"C1[M RRr#c V^8dQhRRRR/#)r'rrr)ztuple[str, str]r)r*s"r$r+r+]sHH3H?Hr#cb\V4pVfR#VPR4'dRV3#RV3#)z=Return (source_kind, source_name) for a registered tool name.mcp-mcpplugin)otherrS)rO startswithrNs& r$_classify_sourcerj]s<%G''//Ew GGXw GGr#c V^8dQhRRRR/#)r' tool_defslist[dict[str, Any]]r)list[CatalogEntry]r)r*s"r$r+r+es16Hr#cB.pVFp\V4pVPRR4pV'gK*\V4wrVV'd \V4MRpTP \ YCPRR4;'gRW%V\ \W'44R74K V#)zHBuild the deferred-tool catalog from the deferrable subset of tool-defs.rrSr)rrrrrr)r@r?rj_listing_group_labelappendrr:rb)rlcatalogr<r^rrrrQs& r$ build_catalogrses"$G Wvvfb! .t4 _corpus_stats..s"Nu3u}};MCs;Mss*,)rrsumrrdict)rrrrwrxrzs& r$ _corpus_statsrsd3:;7%3u}}%7K;  C $4a 8 8FNNNH XG <<'3'SV'r#c2aaRVV3Rllp\WR7#)aGThe query token with the highest IDF: the word that names the intent. ``send``, ``read``, ``create`` sit in dozens of tool documents and separate nothing; ``gmail``, ``github``, ``incident`` sit in a few and separate everything. A document without this token answered a different question, however many common tokens it shares.c V^8dQhRRRR/#)r'r(rr)ryr)r*s"r$r+!_gate_token..__annotate__s>>C>E>r#c<SPV^4p\P!^SV, R,VR,, ,4#)r)r?rr)r(rrzr|s& r$_idf_gate_token.._idfs9 \\% #xxVb[3.28<<==r#key)r)rurzr|rs&ff r$ _gate_tokenrs >> | &&r#rc V^8dQhRRRR/#)r'answerable_term_countr}r)r)r*s"r$r+r+sFF3F3Fr#c^V\8d^#\P!V\,4#)zHow many of a query's ANSWERABLE unique terms a document must match to be offered: one below the engagement floor, else at least half, rounded up.)!MIN_ANSWERABLE_TERMS_FOR_COVERAGErceilMIN_QUERY_TERM_COVERAGE)rs&r$_required_term_coveragers&@@ 99*-DD EEr# corpus_statsc ,V^8dQhRRRRRRRRR R/#) r'rrrnqueryrlimitr}rzOptional[_CorpusStats]r)r)r*s"r$r+r+s2 * *. *s *3 *!7 *CU *r#ca a aaV'dV^8d \V4M.pV'g.#T;'g \V4pV^,p\WEV^,4oVUu0uFqePV^4^8gKVkK upo \ \ S 44oVP 4P4o RV V VV3RllpVUu.uFUq!V4'gKVPP4S 8Xd \R4M\WHP.VO5!V3NKW p pV PRRR7V RVU U u.uFwrV NK up p #uupiuupiuup p i)agTop-``limit`` catalog entries for ``query`` by BM25 (exact name match ranks first). Admission is by the query's rarest token (:func:`_gate_token`), not by ``score > 0``: BM25 is additive over the tokens a document shares with the query, so on a large catalog ``score > 0`` admits one-token matches and fills every slot with them (measured: "send gmail email" returned 5 incident tools that only shared ``email``). A token no document carries admits nothing; the caller's empty-group hint tells the model to retry without it. Long queries additionally need :func:`_required_term_coverage` of their answerable terms.c V^8dQhRRRR/#)r'rrr)boolr)r*s"r$r+$search_catalog..__annotate__s^^^$^r#c<aVPP4S8XdR#\VP4oSS9;'d\ V3RlS44S8#)zRCarries the intent word AND enough of the answerable terms (exact name is exempt).Tc38<"TFqS9gK ^xK R#5i)Nr)rttokenss& r$r4search_catalog.._admitted..s%KAF{aas )rr9rrr)rr answerable exact_namegaterequired_termss&@r$ _admitted!search_catalog.._admittedsK ::    +U]]#v~]]#%K%K"K~"]]r#infcV^,#)rr)xs&r$ search_catalog..sadr#T)rreverseN) r:rrr?rrstripr9rryrrsort)rrrrrrurzrrrscored_errrrs&&&$ @@@@r$search_catalogrs>(/5199U#"L  99=#9LAH ||A ?D)D\\\!Q-?!-C!!\DJ,S_=N$$&J^^2E % 0 N))+z9u, E Eu N 2 KKNDK1 %. ).$!A. ))!E2 *s E=EEAE Ez-(?DD 4yI :IG+.'>gnnS!$Q'wG >>& !E ))r#c V^8dQhRRRR/#)r'rrr)r)r*s"r$r+r+s&&c&c&r#c<T;'gRpVPR4#)zLHuman-facing group heading for a toolset, e.g. ``mcp-github`` -> ``github``.rhre)rX)rlabels& r$rprps  " "7E   f %%r#cV^8dQhRR/#)r'r)rmr)r*s"r$r+r+s!5r#c F^RIHp^RIHp^RIHp/pVP 4FXpVPPR4'gK&VPVPR,.4PV4KZ .p\V4FpVPV4fKW6,p\;QJdRV4F 'gK RM RM !RV44'dK\V!V4pVfKjVwrp VPR VR \V4R V /4K V#) zNReturn deterministic summaries for declared MCP servers hidden by their check.) declaration)unavailable_detailsrCre:NNc3~"TF3qPRJ;'g\VP44xK5 R#5ir)check_fnr)rrs& r$r*hidden_declared_sources..s.UWE~~%??enn.>)??Ws="=TFr tool_count unavailable)hermes_platformrtools.mcp_livenessrrErDget_all_entriesrLri setdefaultrqsortedlookupanyr) rrrDgroupedrrows server_nameentriesdetails_decl_currentsentences r$hidden_declared_sourcesrs+6'$&G))+ == # #F + +   u}}R0" 5 < text is None). Ordering is deterministic (sorted groups and tools) so the block is byte-stable — the request prefix stays cacheable. Degradation is PER SERVER, largest first: one huge server must not cost a small one its listing.rrSrc$V^8dQhRRRRRR/#)r'rrmoder)r)r*s"r$r+5build_catalog_listing_with_form..__annotate__s!   C  s  s  r#c:<\SV,4pVR8XdV R\V4 R\ R2#V R\V4 R2.pVR8XdVPRV44M'VP R P R V444R P V4#) z>Render one server's block. mode: 'full' | 'names' | 'summary'.summary (u+ tools — names not listed; discover via `z`)z tools (z):fullc3P"TFwrV'd RV RV 2MRV 2xK R#5i)z- z: Nr)rrdescs& r$rHbuild_catalog_listing_with_form..render_group.. s.^X]*$2dV2dV,Btf+EX]s$&z, c3*"TF wrVxK R#5irr)rrrs& r$rr"s"=uGD4u )rrTOOL_SEARCH_NAMEextendrqr\)rrtoolslinesgroupss&& r$ render_group5build_catalog_listing_with_form..render_groupsve}% 9 gRE |,%%5$6b: ;7(3u:,b12 6> LL^X]^ ^ LL"=u"== >yyr#z)Deferred tool catalog (call schemas via `z`, invoke via `z`):c V^8dQhRRRR/#)r'modeszdict[str, str]r)rJr)r*s"r$r+r(sVVV=Vr#c <SUu/uFqS !WV,4bK ppS Uu/uFTpVR,VPR4e!VR, RVR, RVR, R2MVR, RVR, R2bKV pp\W$,4Uu.uFpW9d W!,MWA,NK ppRPS.V,4p\P!\ V4\ , 4S 8:dV#R#uupiuupiuupi) rrNrz tools unavailable: r)z (tools unavailable: r)r?rr\rrrCHARS_PER_TOKEN) rravailable_blocksrowunavailable_blocksblocksr5r headerrr rs & r$assemble_if_fits9build_catalog_listing_with_form..assemble_if_fits(s3RXYRX<U|#DDRXY#  # K77<(4v;-r#l"3!44H]I[H\\]^F }$9#m:L9MQO P #   0 EF F(-'@  #FXF_ _F  yy&F*+yyT_!<=KtUQUUZ  sDADD c.<\S!VR44)V3#)names)r)lblr s&r$r1build_catalog_listing_with_form..?sLg4N0O/OQT.Ur#rrc3*"TF qR8HxK R#5i)rNr)rrs& r$r2build_catalog_listing_with_form..Cs(PAirFTr mixed)Nnone)rr) r@r?rprjrrqrrTOOL_DESCRIBE_NAMETOOL_CALL_NAMErallvalues)rrr<r^rrrrrrr5r rr rs&d @@@@r$build_catalog_listing_with_formr&st02F Wvvfb! 4()9$)?)BCE   eR ( / /{266-Y[C\7]0^ _ *+K +   $%_^4DCIFVV""&,-fsdf-&  :  " f"UVc &  SS(P(PSSS(P(P%P%P] ]V]] ] W .s F )rS)g?g?))<):r __future__r functoolsrrY threading collectionsr dataclassesrrtypingrrrr r r1rr"r# frozensetBRIDGE_TOOL_NAMESrrcompiler7localr0 lru_cacher3r:r@rHrOrbrjrsrtupler!r}ryrrrrrrrrrrrrprr&rr#r$r5s^O# (33!$/1C^TU 55 5 JJ ' !  U#1$1W $ 9 SH"  T#YtCH~s:; ='&$%!F *:> * *H::NO *& 2@;?@@r#