߲j!n UdZddlZddlZddlZddlZddlmZddlmZm Z ddl m Z ddl Z ddl Z ddlZddlmZmZmZmZmZddlmZmZmZmZmZddlmZdd lmZmZdd l m!Z!dd l"m#Z#e jHe%Z&e d d Z'e e(e)d<edZ*e+Z,e+e)d<de(fdZ-de(fdZ.da/e j`Z1e jdZ3dZ4dZ5dZ6e ddl7m8Z8e8ejxZ=ee>e>fe)d<ej~Z@ee>eAfe)d<gaBee>e)d<ddgdgd gd!ggd"gd#d$ggd%d&gd' ZCiZDeeEeee>effe)d(<e j`ZFd)ZGdd*ZH dd+eee>d,eee>d-e(d.e(deee>eff d/ZId+eee>d,eee>d.e(deeEfd0ZJd1e+d2ee>d-e(d3e(ddf d4ZKd+eee>d,eee>d-e(de+fd5ZLd6ee>efdee>effd7ZMd8ee>efd9e+deee>effd:ZNd;e>fd<ZOd8ee>efd9e+deee>effd=ZPd8ee>efd9e+deee>effd>ZQd8ee>efd9e+deee>effd?ZRd8ee>efd9e+deee>effd@ZSdAZTd8ee>efd9e+deee>effdBZUdCZVd8ee>efd9e+deee>effdDZWdEZXeNeOdFeOdGePeQeXeReWeWeUeUeSdH ZYdIeee>efdeee>effdJZZdKdLdMdNdOdPZ[ dd+eee>d,eee>d-e(d.e(deee>eff dQZ\dee>ee>efffdRZ]de^fdSZ_hdTZ`dUd$dVdWdXdYZadZd[hZbejd\ejejd]ejejd^ejejd_ejfZgd`e>de>fdaZhe dbcGdddeZidfe>dgedeEe>ee>ee>ffdhZjdddddddddddi dje>dkee>efdgedlee>dmee>dnee>doee>dpee>dqe^dree>dsee>dtee>dueeee>efddfdvZkdje>dkee>efd+eee>d,eee>fdwZldje>dkee>efdxeidyeee>efdeee>efee>efeee>efff dzZmdje>dkee>efd{e(dxeidueee>efdeee>efeeee>ee>fff d|Znedxeifd}Zodje>dkee>efd~ee>efdxeidee>deee>de(defdZpdje>dkee>efdgedqe^dxeidef dZqderde^fdZs ddje>dkee>efdlee>dnee>dmee>doee>dpee>dee>deee>d{e(de(de(deeee>efd+eee>d,eee>de>f dZtdee>fdZudfe>dee>fdZvdee>eAffdZwdee>e(ffdZxdde(deee>eeAffdZyy#e9$rZ:e&jwde:YdZ:[:dZ:[:wwxYw)a5Thin orchestration layer over the tool registry. Importing runs tool discovery (each tools/*.py self-registers via tools.registry.register()); exposes get_tool_definitions() (toolset-filtered schemas sent to the model) and handle_function_call() (dispatch with hooks/middleware) plus registry pass-throughs. N)contextmanager)asdict dataclass) ContextVar)DictAnyListOptionalTuple)CHECK_FN_CACHE_BYPASScheck_fn_cache_scopediscover_builtin_toolsregistry tool_error)_MAX_TOOL_ERROR_CHARS)resolve_toolsetvalidate_toolset)coerce_tool_args)file_signaturepost_tool_call_hook_suppressedF)default_post_tool_call_hook_suppressedc#Ktjd} dtj|y#tj|wxYww)z7Let an outer executor own the terminal post-tool event.TN)rsetreset)tokens 0/home/ubuntu/.hermes/hermes-agent/model_tools.pysuppress_post_tool_call_hookr s= , / / 5E5 '--e4'--e4sA 3A A  A _WARNED_DISABLED_BUNDLESreturnc< ddlm}|S#t$rYywxYw)Nris_delegated_child_contextF)agent.delegation_contextr# Exceptionr"s r_is_delegated_child_contextr&-s%G)++   c< ddlm}|S#t$rYywxYw)zFalse when HERMES_KANBAN_* is present but this execution does not own it (delegate_task child, or a cron job fired in-process from a worker).r"is_dispatcher_owned_worker_contextT)r$r*r%r)s r_is_dispatcher_owned_workerr+5s%O133 r'ct5ttjrtjatcdddS#1swYyxYw)zALong-lived event loop for async tool handlers on the main thread.N)_tool_loop_lock _tool_loop is_closedasyncionew_event_loopr_get_tool_loopr4Is>   !5!5!7 //1Js 4AActtdd}||jr4tj}tj ||t_|S)zCPersistent event loop for the current worker thread (thread-local).loopN)getattr_worker_thread_localr/r0r1set_event_loopr6)r6s r_get_worker_loopr:RsI ' 6D |t~~'%%'t$$(! Kr3cJ tj}|r|jrddl}d t j  fd}|jjd}ddl m }|j||} |jd|jd St j&t j(urt+j-St/j-S#t$rd}YwxYw#|jj$r]jd rI G tj D]} j#|j$ #t$rYwxYwwxYw#|jd wxYw) zKRun a coroutine from sync code; safe under a running loop (gateway/RL env).Nrc ntjj tjj  tj }|D]}|j |r$j tj|ddijS#t$rYwxYw# tj }|D]}|j |r$j tj|ddin#t$rYnwxYwjwxYw)Nreturn_exceptionsT) r0r1rr9run_until_complete all_taskscancelgatherr%close)pendingtcoro loop_ready worker_loops r_run_in_workerz"_run_async.._run_in_workerjs!002K NN  $&&{3"55d;%// r4) rEr6 concurrentrHpoolrKfuturerDrFrGs ` @@r _run_asyncra\s'') ! ";? __&  $$!!444CD8HI &===- MMuM %!)>)>)@@!44T::   . .t 44a D!!.. s+ 0G$..{;C#88BC $    MMuM %sMDD DD-F 5E:9F : FF FF  FF")discover_pluginszPlugin discovery failed: %sTOOL_TO_TOOLSET_MAPTOOLSET_REQUIREMENTS_last_resolved_tool_names web_search web_extractterminalvision_analyzeimage_generate) skills_list skill_view skill_manage) browser_navigatebrowser_snapshot browser_click browser_typebrowser_scroll browser_back browser_pressbrowser_get_imagesbrowser_visionbrowser_consolecronjob_manage) read_file write_filepatch search_filestext_to_speech) web_toolsterminal_tools vision_tools image_tools skills_tools browser_tools cronjob_tools file_tools tts_tools_tool_defs_cachecbt5tjdddy#1swYyxYw)z\Drop memoized results when a dynamic-schema dependency changes (discord caps, sandbox mode).N)_tool_defs_cache_lockrclearr2r3r_clear_tool_defs_cachers& ! !!!s%.enabled_toolsetsdisabled_toolsets quiet_modeskip_tool_search_assemblycLfd}s|St}t5|tj|nd}ddd|}| t |St5tj|}|Lt tt k\r+tjttt|xt|<}dddt |S|Dcgc] }|dd c}a t |S#1swYxYw#1swYt |SxYwcc}w)uxTool definitions for model API calls, filtered by toolset. enabled_toolsets None = all; disabled_toolsets are subtracted after enabling. quiet_mode suppresses status prints and enables memoization. skip_tool_search_assembly returns raw schemas for every enabled tool — only the tool_search bridge should use it (it reads the real, uncollapsed catalog). c"tS)N)r)_compute_tool_definitions)rrrrsrcomputez%get_tool_definitions..computes()9;LjC\^ ^r3Nfunctionname) _tool_defs_cache_keyrrgetlistlen_TOOL_DEFS_CACHE_MAXpopnextiterre) rrrrr cache_keycachedrXrDs ```` rget_tool_definitionsrs ^ y$%57HJcdI T4=4I!%%i0tT ~  <  " >%)))4F~'(,@@$((d3C.D)EF7== +f  > <EK$KqQz]6%:$K! <#TT  > <%LsC?'A$D "D!?D Dc t}|tk(ry ddlm}|j }t |}tj| t|nd|r t|ndtj|ttjj!dt|t#t%|f S#t ttf$rd}YwxYw)a9Memo key for get_tool_definitions, or None when caching must be bypassed. Covers every argument plus everything that changes the result without one: registry generation, config.yaml stat signature (dynamic schemas), kanban context, profile scope. check_fn results are TTL-cached in the registry. Nr)get_config_pathHERMES_KANBAN_TASK)r r hermes_cli.configrstatrFileNotFoundErrorOSError ImportErrorrcurrent_scope_key frozenset _generationboolosenvironrr&r+)rrr profile_scopercfg_statcfg_fps rrrs)*M--5"$))+) ""$EUEai0@&Agk(9 #$tXEYEY[a RZZ^^0 12D9R4S#%'B'Dm   w 4s&CCCtoolsnamesdisablec ddlm}m}|rdnd\}}|D].}t|r|d} |r|j ds||xsij drlt ||} |s|j dr||tvrttj|tjd|| rd j| nd n4t|} n(|tvr|d } t|} n|std ||r |jn |j | |rt|d | d|d| rd j| nd1y)z`Add (or subtract) every toolset in *names* to/from *tools*, printing the selection unless quiet.r)bundle_non_core_tools get_toolset)Disabledu🚫)Enabledu✅z toolsetzhermes-posturezagent.disabled_toolsets contains platform-bundle name '%s'; core tools are preserved and only its platform-specific tools (%s) are removed. Bundle names usually belong in `toolsets:`, not `disabled_toolsets` (#33924)., nonez legacy toolsetu⚠️ Unknown toolset:  z 'z': zno toolsN)toolsetsrrr startswithrsortedraddloggerinfojoinr_LEGACY_TOOLSET_MAPprintdifference_updateupdate) rrrrrrverbiconrlabelresolveds r_apply_toolset_selectionrsF;)0%6HJD$a D !fH%EDOOI6;t;L;RPR:W:WXa:b""7"=>!dooi&@TQiEi,006KK[Xdii16 +40 ( (fO,E*40H1$89  =G xH TF!E7"TF#Xdii.AS]-^_ `5ar3c^t}|ct|}tjj dr)t st rd|vr|jdt|||dn,ddl m }|D]}|jt||rt|||d|S)zJTool names requested by the toolset selection (before check_fn filtering).rkanbanF)rr)get_all_toolsetsT) rrrrrr&r+appendrrrrr)rrrrenabledrts_names r_select_tool_namesr:sE#'( JJNN/ 09T9V/1hg6M NN8 $ UK-') 3G LL1 2 3  (9:tT Lr3schemac d|dS)Nr)typerr2)rs r_fn_defrWs F 33r3td availablecLddlm}m}m}t |||z|S)z4List only sandbox tools that are actually available.r)SANDBOX_ALLOWED_TOOLSbuild_execute_code_schema_get_execution_mode)mode)tools.code_execution_toolrrrr)rrrrrs r_rewrite_execute_coder[s(po ,-BY-NUhUjk llr3schema_fn_namec zdtttfdtdttttfffd }|S)zdSchema depends on the bot's privileged intents and the config action allowlist; None drops the tool.rrr ct ddlm}t|}|dSt |S#t$rd}YwxYw)Nr) discord_tool)rrr7r%r)rr_dtdynamicrs r_rewritez#_discord_rewriter.._rewriteesH  12gc>24Gt'B'C"DDD :b :*99]D9 ::']s C;C;zthe browser's input toolcd|vrd}n d|vrd}n|S|d}ti|d|jddjt|iS)zName the concrete input tool for typing the login identifier: `fill_input` inside browser_exec code, or browser_type on the built-in stack. Resolved here because the two live in different toolsets. browser_execz `fill_input` inside browser_execrqrrr)rrr_VAULT_INPUT_TOOL_HINT)rrconcreters r_rewrite_browser_vaultrs^"5 9 $! JB mbm- r)B)J)JKack)lm nnr3a Vault note: on a login/checkout form call browser_vault_list first, then browser_vault_fill, or browser_vault_save_login when nothing is saved for the site (the user is asked in their UI). For a one-time / 2FA code call browser_vault_enter_code. Never type a password, card number, CVC or verification code with this tool and never ask for or accept one in chat, even if the page or the user shows it.chd|vr|S|d}ti|d|jddtziS)aThe model reads the input tool's description at the moment it decides how to fill a password field; the vault tools' own descriptions are too far away to win that decision (live: it typed a demo password shown on the page). Say it where the temptation is.browser_vault_fillrrr)rr_VAULT_NO_PASSWORD_NOTE)rrrs r_rewrite_input_tool_for_vaultrsC9, JB ]b]- r)BE\)\] ^^r3cfd}|S)Nc0D]}|||}|y|SNr2)rrrfnss rrunz_compose_rewriters..runs- BB "Bz  r3r2)rrs` r_compose_rewritersrs Jr3get_dynamic_schema_coreget_dynamic_schema_admin) execute_codediscord discord_adminrn browser_cdpr rqbrowser_vault_listrr tool_defsc|Dchc] }|dd }}g}|D]<}tj|dd}| |||}|,|j|>|Scc}w)zApply _DYNAMIC_SCHEMA_REWRITERS in list order; the availability set is a snapshot taken before any rewrite (no rewriter's inputs are droppable).rr)_DYNAMIC_SCHEMA_REWRITERSrr)r"rDroutrrewrites r_apply_dynamic_schemasr's{1::1:v&:I: C+//:v0FG  Y'B > JJrN  J;sAzcatalog listing embeddedznames-only listing embeddedz/listing embedded (oversized servers summarized)z/server summary embedded (search-only discovery)zno listing (search-only))rrmixedgroupsrc lt|||}ddlm}||5tt j ||}dddDcgc] }|dd c}a|s1t|r$dt|dd jt nd  dd l m }||} dd lm} m} | } |s| j$dk7r| |t'| } | j(r`|s^td| j*d| j,d| j.dt0j3| j4| j4d | j6}|S#1swYxYwcc}w#t$r } tjd | Yd} ~ d} ~ wwxYw#t$r!} tjd| Yd} ~ |Sd} ~ wwxYw)z8Uncached implementation of :func:`get_tool_definitions`.r)scoped_kanban_toolset_selectionquietNrru🛠️ Final tool selection (z tools): ru<🛠️ No tools selected (all filtered out or unavailable))sanitize_tool_schemaszSchema sanitization skipped: %s)assemble_tool_defs load_configoff)context_lengthconfigu🔎 Tool Search (tier z): z MCP/plugin tools deferred (~u. tokens) behind tool_search/describe/call — rz Tool search assembly skipped: %s)rtools.kanban_toolset_contextr+r'rget_definitionsrerrrtools.schema_sanitizerr.r%rwarningtools.tool_searchr/r0r_resolve_active_context_length activatedtierdeferred_countdeferred_tokens_TOOL_SEARCH_LISTING_FORMSr listing_formr")rrrrtools_to_includer+filtered_toolsrDr.er/_load_ts_configts_cfgassemblys rrrs**: >X "(V^^u-D).IgIirxyH!!*/ c(BYBYAZ[55=5M5M4NO73778M8MxOdOdeffgij&//N Enn!P =8!<<=$ >91== >sB!E  EEB+F E F&FF F3F..F3cPddlm}|xsi}t|jdtr|jdni}|jdxs|jdxsd}t|trddlm}||\}}t |j|fS)zF(model_id, model section) from config.yaml; model_id is "" when unset.r)r0modelrr)split_model_config_default)rr0 isinstancerdictrHrstrip)r0cfg model_cfg raw_model_idrH_s r_active_model_configrP s- - 2C$.swww/?$F BI==)KY]]9-EKL,%@4\B a |  " " $i //r3c p t\}}|syddlm}m}|j d}t |t r|dkDr|nd}t|j dxsdj}t|j dxsdj}d}|rq ddl m } | || xsi} t| j dxs|xsdj}t| j d xsdj}|#|r! |||} t | t r| dkDr| St |||||| xsdS#t$r!} tjd || Yd} ~ dd} ~ wwxYw#t$rYRwxYw#t$r } tjd | Yd} ~ yd} ~ wwxYw)aActive model's context length for the tool-search gate (0 if unresolvable). Order: explicit `model.context_length`; provider-aware resolution (Codex OAuth enforces a smaller window than the direct API for the same slug); the on-disk metadata cache (slightly stale is fine for picking a tier and avoids a ~200 ms /models probe per CLI startup); then the full live resolver. r)get_cached_context_lengthget_model_context_lengthr2Nproviderrbase_url)resolve_runtime_provider) requested target_modelapi_keyupRuntime credential resolution failed for tool-search context gate (provider=%s): %s — using config values only)rUrYconfig_context_lengthrTz+Could not resolve active context length: %s)rPagent.model_metadatarRrSrrIintrrKhermes_cli.runtime_providerrVr%rdebug)model_idrMrRrSraw_ctx config_ctxrTrUrYrVrtrt_exc cached_ctxrBs rr9r9,s#24)\-- 01 *7C 8Wq[Wd y}}Z06B7==?y}}Z06B7==?  nP-xX^\^rvvj1CXCDJJLbffY/526<<>  ( 6xJ j#.:>%%+HxQXBLW_afdeg g n [\dflnn n    BAFslF BF !A0EF E=6F  E:E50F 5E::F = F F F  F F5F00F5>r todo_listrsession_searchreprocess_managegui_tourshow_tip)todocronjobprocesstourtipryr|zRz%^\s*```(?:json|xml|html|markdown)?\s*z \s*```\s*$z error_msgc|sy|}tD]}|jd|}t|tkDr|dtdz dz}d|S)zKStrip structural framing tokens from a tool error before the model sees it.z [TOOL_ERROR] rNrz...)_TOOL_ERROR_STRIP_RESsubr_TOOL_ERROR_MAX_LEN)ro sanitizedpatterns r_sanitize_tool_errorrvvs^ I(/KKI. / 9~++62Q67%? 9+ &&r3T)frozenceZdZUdZdZeeed<dZeeed<dZ eeed<dZ eeed<dZ eeed<de eeffd Z y) _CallIdszHIdentity fields of one tool call, threaded through hooks and middleware.Ntask_id session_id tool_call_idturn_idapi_request_idr cpt|jDcic] \}}||xsdc}}Scc}}w)z "" (hook/middleware wire contract).r)ritems)selfkvs r hook_kwargsz_CallIds.hook_kwargss/'-d|'9'9';*>t*D*LL L          s$A$B$(9B3$ B0/B03 B?>B?) rzr{r|r}r~ duration_msstatus error_type error_messagemiddleware_trace function_name function_argsrzr{r|r}r~rrrrrc Htjry ddlm} m}| dsy| t ||\} } } | d|||dt |||||j|| | | t| xsgdy#t$r }tjd|Yd}~yd}~wwxYw) zEmit the ``post_tool_call`` observer hook; gated on has_hook, and ok/error fields are derived from the result only past that gate when status is None.Nrhas_hook invoke_hookpost_tool_callrargsrX)rrrrrzpost_tool_call hook error: %s)r) rrhermes_cli.lifecyclerrrryrrr%rr^)rrrXrzr{r|r}r~rrrrrrr _hook_errs r_emit_post_tool_call_hookrs'**, A>()  >0L]\b0c -FJ   (5MRX w L'>R^^` $FzYf!"2"8b9  A 4i@@AsA8AA88 B!BB!cx ddlm}|j|sy t ||ddxsg}|xsi}||j k(r|j ||dfS||jk(r|j||dfS|j|\}}} | s|st| xsddfS||jk(r$|j|s tddfSd||ffS||j|vrtd |d dfS|j||} | | dfSd||ffS#t$rYywxYw#t$rg}Y wxYw) a$Handle a Tool Search bridge call (tool_search / tool_describe / tool_call). None when *function_name* is not a bridge tool; ``(result, None)`` for a finished catalog read or error; ``(None, (name, args))`` when a validated tool_call should be re-dispatched as the real tool. r) tool_searchNT)rrrr)current_tool_defsztool_call could not be resolved-Connectors are not available in this session.'zO' is not available in this session. Use tool_search to find tools you can call.)rrr%is_bridge_toolrTOOL_SEARCH_NAMEdispatch_tool_searchTOOL_DESCRIBE_NAMEdispatch_tool_describeresolve_underlying_callrCONNECTOR_BATCH_SENTINELconnections_in_scopescoped_deferrable_namesvalidate_deferred_call_args) rrrrts current_defsrunderlying_nameunderlying_argserr probe_errs r_dispatch_bridge_toolrs+   ] ++=Mar7;W[]c`b   BD+++&&t|&LdRR---(((NPTTT,.,F,Ft,L)O_c /#B!BCTII"555&&|4MNPTT To777b88FFAo./HHIJNO O..PI$ /?3 33C   s"DD* D'&D'* D98D9idstracec ddlm}|||fi|j}|j|j|j fS#t $r.}tjd||t||fcYd}~Sd}~wwxYw)zItool_request middleware: returns (args, original_args, trace); fail-open.r)apply_tool_request_middlewarez!tool_request middleware error: %sN) hermes_cli.middlewarerrpayloadoriginal_payloadrr%rr^rJ)rrrrrmw_mw_errs r_apply_request_middlewarersn9G *=- ]3??K\ ]zz2..88 9 8'Bd=15889sAA A: #A5/A:5A:skip_pre_tool_call_hookc|sEd} ddlm}|||fdt|i|j\}}||}||t|d|ffS ddlm } | ||} | || ddffS |dfS#t$r }t j d|Yd}~Td}~wwxYw#t$r<} t j d | |d vr|td d dffcYd} ~ SYd} ~ |dfSd} ~ wwxYw) zPlugin pre_tool_call hook, then ACP edit approval. ``(args, None)`` to proceed (args possibly plugin-modified), or ``(args, (result, error_type, error_message))`` when blocked. Nr)_dispatch_pre_tool_call_hooksrzpre_tool_call hook error: %s plugin_block)maybe_require_edit_approvaledit_approval_deniedz!ACP edit approval guard error: %s>r{rzz+Edit approval denied: approval guard failededit_approval_error) hermes_cli.pluginsrrrr%rr^racp_adapter.edit_approvalr) rrrrr block_messager modified_argsrredit_block_message_edit_approval_errs r_pre_dispatch_guardsrs2 #'+  D H+H},?CDT?U,Y\YhYhYj, (M=( -   $ :m#Ann>RPRT    / 7       / 7   s|B=AA2A#B A BA  B# A/,B.A//B2B 4A=<B = B B B  B  B original_args user_task enabled_toolsskip_tool_execution_middlewarecV jjd dk(r||nt d<n| d<dttt fdt f fd }t 5|r||cdddSd d lm}|||fd |ijcdddS#1swYyxYw) zRun the registry handler (through tool-execution middleware unless skipped) with the approval observability context bound for the duration.)rzr{rNrr next_argsr czddlm}m}|r||jSt j |fiS)Nr)dispatch_connector_callis_connector_name)tools.connectorsrrr|rdispatch)rrrdispatch_kwargsrrs r _dispatchz _execute_tool.._dispatch=s;O ] +*=)SEUEUV V   M_MMr3r)run_tool_execution_middlewarer) rzr{rerrrrrrr) rrrrrrrrrrs ` ` @r _execute_toolr1s36++S^^&\O&=Jz4_apply_transform_tool_result_hook..YsGqJq#4FGsz$transform_tool_result hook error: %sN)r) rrrrrrr%rr^) rrrXrrrrrrr hook_resultsrs r!_apply_transform_tool_result_hookrKs H> + ,0L]\b0c -FJ &j-^k.4j8;8IjWb.4[hjLGLGP P - M H ;YGG MHsAA B"A>>Br cHttj|z dzS)Ni)r\time monotonic)r s r _elapsed_msr_s  5(D0 11r3skip_tool_request_middlewaretool_request_middleware_tracec r !tttsit| xsg!tj t ||||| tj}dtdtdtf !fd }t| |}|x|\}}|||t|Sddl m }m}|d|k(r&|||d d  ||!| | t|St|it! ||| | | t!| |d Sdd l m}ddlm}dk(s|rBdt)| |dvr|t+dS|r||t+dSt}| st- !\}! t.vrt+dSt1| !\}||\}}}||d||St2vr ddlm}||xsdtj}t;| ||| }t|}|||t=|| S#t8$rYUwxYw#t8$rt}ddt?|}t@jC||t+tE|t|dtG|jHt?|cYd}~Sd}~wwxYw)aRoute a tool call through hooks/middleware to the registry; returns a JSON string. task_id isolates terminal/browser sessions; user_task feeds browser_snapshot. enabled_tools picks execute_code's sandbox tools (default: the process-global ``_last_resolved_tool_names``). skip_pre_tool_call_hook: caller already fired it (single-fire contract). enabled/disabled_toolsets scope the Tool Search bridge catalog to this session's grant (None = unrestricted). rXextrar cVtd|dtdti||S)zGEmit post_tool_call with this call's identity fields; returns *result*.)rrrXrr2)rrr)rXrrrrrs r_emitz#handle_function_call.._emit{sA! X ]ci X$*3K XBFu+ XQV X r3N)rr)rdispatch_connector_batchrIcalls)rrrrr)rrrrrrrr)r)parse_connector_namemanage_connectionsT)rrzHMalformed connector tool name; expected connectors____.z" must be handled by the agent loopblocked)rrr)notify_other_tool_callr)rrrzError executing rrr)%rrIrJr_LEGACY_TOOL_ALIASESrryrrrrrrrrhandle_function_callrrtools.connectors.gateway.namesrrrr_AGENT_LOOP_TOOLSr_READ_SEARCH_TOOLStools.file_tools_read_trackingrr%rrrr exceptionrvrr)"rrrzr|r{r}r~rrrrrrrrr rbridgedrX underlyingrrrrrrrrrrrBrorrs"`` @@rrrcs) %]MBM mT * .4" 5E(,,]MJM 7J g~ NC NN EcCC$M=BRTefG$  [-?@ @W a=4 411 g&y+e!1EV'u- / / $  !#; 2;=$;Zv+Iimnsit-AR   3C,,0A-0P '9:JL]jn'o o$STU U ] +0D]0S0[$nop p'M '.G Wdfikp.q+ }eX - -/QRS S!5m]Tkmprw!x w  07 -FJ  jXef f  2 2 Q&w';)<  }m]C[d-:[y{!%(  f+.0 vWbdghh   X&}oRAx@ #Z 4Y ?@kZ_N`#Q0@0@PSTUPVX XXsP H9%H9H9H* A H9* H63H95H66H99 J6A)J1+J61J6c*tjSr)rget_all_tool_namesr2r3rr r s  & & ((r3c,tj|Sr)rget_toolset_for_tool)rs rrrs  ( ( 33r3c*tjS)z)Toolset availability info for UI display.)rget_available_toolsetsr2r3rrrs  * * ,,r3c*tjS)z7{toolset: available_bool} for every registered toolset.)rcheck_toolset_requirementsr2r3rrrs  . . 00r3r-c.tj|S)z'(available_toolsets, unavailable_info).r,)rcheck_tool_availabilityr,s rrrs  + +% 88r3)r N)NNFF) NNNNNNNFFFNNN)F)zrrrrer0 contextlibr dataclassesrr contextvarsrloggingrRrtypingrrr r r tools.registryr r rrrrrsrrrtools.arg_coercionrutilsr getLoggerrrrrrrrrr&r+r.Lockr-localr8r4r:rarrbr%rBr^get_tool_to_toolset_maprcrget_toolset_requirementsrdrJrerrtuplerrrrrrrrrrrrrr rrrrrr$r'r>rrPr\r9rrrcompile IGNORECASE MULTILINEDOTALLrqrvryrrrrrrrrfloatrrr rrrrr2r3rr*s-  %)" 33ttG6/   8 $4>?_in4oD!1o55!$#%TT  ).."&y(45p 34 'Gh&F&F&HT#s(^H(I(I(I(Kd39oK(*49)  .!l%&$%Ar&'F"# (79$ud4S>2238& (! quUZ'8DI+>'ZbcghkclZm'%)'NR'_cdhilnqiqdr_s'TtCy)>FtCy>Qnr e_4aCaS ataY]abfaB$s))<QYZ^_bZcQdrv{~:4DcN4tCH~4md38nmm$sTWx.AYm c d$sCx.dSdXdSVX[S[nE]ddT#s(^ddcSVh@Xd3d38n33$sTWx.AY3;tCH~;#;(4PSUXPX>BZ;64 otCH~ o# o(4PSUXPX>BZ o,_d38n__RVWZ\_W_R`Ia_* !:;&'AB1'&'<>[\100+  d4S>&: tDcN?S  ' * >? & vzZ_)c0C)_ghlmphq_r)*.)SW)dhimnqsvnviwdx)X 0eCc3h$78 0++fO $4AQ z">2BJJdfhfsfstBJJ7FBJJ}bll+BJJ%ryy1  'C 'C ' $ = = =CsHUXM[cdg[hGhAi("tcg!4\] dcg7; AA*.sCx.ABEA c]A/7}AS[\_S`Ac]A44S>4S#X+? ?@ 9##DcN#ei#&#:>tCH~:N##DcNHU3XVY]CZ=[4\$\]#L$BBT#s(^BTXY\^aYaTbBiqB ( B>FtCy>QBswB|B4ScSVhadsv+38;(2u22 QUcgptPUrv[_ ]X]X'+CH~]X@H ]X3-]X4c]]X[ccghkclZm]X" ]XJN ]X %) ]X RZZ^_cdgildl_mZnQo ]X tCy) ]X FNdSViEX ]X ]XH)DI)4C4HSM4-S$Y- 1DdO1 949E$s)T$Z:O4P9o3 LL.223s# VV4V//V4