sj!"!UdZddlZddlZddlZddlZddlmZddlmZddl Z ddl Z ddl Z ddl m Z mZmZmZmZddlmZmZmZmZmZddlmZmZe jeZedd Zeee d <ed Z!e"Z#e"e d <defdZ$defdZ%da&e j'Z(e j)Z*dZ+dZ,dZ-e ddl.m/Z/e/n(#e0$r Z1e2de1YdZ1[1ndZ1[1wwxYwej3Z4e e5e5fe d<ej6Z7e e5e8fe d<ga9ee5e d<ddgdgdgdggdgdd ggd!d"gd# Z:iZ;e eddd&Z? ded'eee5d(eee5d)ed*edee e5eff d+Z@ ded'eee5d(eee5d)ed*edee e5eff d,ZAdeBfd-ZChd.ZDd/d0hZEejFd1ejGZHejFd2ejIZJejFd3ejIZKejFd4ejLZMdd5lmNZOd6e5de5fd7ZPd8e5d9e e5efde e5effd:ZQd;eded;edefd?ZSdfd>e5d;e8dzfd@ZTd;e8dzdefdAZUd>e5dBeVfdCZWdgd>e5dDefdEZXd>e5fdFZYd8e5dGede list handle_function_call(function_name, function_args, task_id, user_task) -> str TOOL_TO_TOOLSET_MAP: dict (for batch_runner.py) TOOLSET_REQUIREMENTS: dict (for cli.py, doctor.py) get_all_tool_names() -> list get_toolset_for_tool(name) -> str get_available_toolsets() -> dict check_toolset_requirements() -> dict check_tool_availability(quiet) -> tuple N)contextmanager) ContextVar)DictAnyListOptionalTuple)CHECK_FN_CACHE_BYPASScheck_fn_cache_scopediscover_builtin_toolsregistry tool_error)resolve_toolsetvalidate_toolsetpost_tool_call_hook_suppressedF)default_post_tool_call_hook_suppressedc#Ktd} dVt|dS#t|wxYw)z7Let an outer executor own the terminal post-tool event.TN)rsetreset)tokens //home/agent/.hermes/hermes-agent/model_tools.pysuppress_post_tool_call_hookr2s^ , / / 5 5E5 '--e44444'--e4444s >A_WARNED_DISABLED_BUNDLESreturncF ddlm}|S#t$rYdSwxYw)Nris_delegated_child_contextF)agent.delegation_contextr Exceptionrs r_is_delegated_child_contextr!@sJGGGGGG))+++ uu   cF ddlm}|S#t$rYdSwxYw)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)rr%r r$s r_is_dispatcher_owned_workerr&IsJOOOOOO11333 ttr"ct5ttrtjatcdddS#1swxYwYdS)a^Return a long-lived event loop for running async tool handlers. Using a persistent loop (instead of asyncio.run() which creates and *closes* a fresh loop every time) prevents "Event loop is closed" errors that occur when cached httpx/AsyncOpenAI clients attempt to close their transport on a dead loop during garbage collection. N)_tool_loop_lock _tool_loop is_closedasyncionew_event_loopr_get_tool_loopr/]s   !5!5!7!7  /11Js:AAActtdd}||r3tj}tj||t_|S)uReturn a persistent event loop for the current worker thread. Each worker thread (e.g., delegate_task's ThreadPoolExecutor threads) gets its own long-lived loop stored in thread-local storage. This prevents the "Event loop is closed" errors that occurred when asyncio.run() was used per-call: asyncio.run() creates a loop, runs the coroutine, then *closes* the loop — but cached httpx/AsyncOpenAI clients remain bound to that now-dead loop and raise RuntimeError during garbage collection or subsequent use. By keeping the loop alive for the thread's lifetime, cached clients stay valid and their cleanup runs on a live loop. loopN)getattr_worker_thread_localr*r+r,set_event_loopr1)r1s r_get_worker_loopr5lsV ' 6 6D |t~~''|%''t$$$$(! Kr.c tj}n#t$rd}YnwxYw|r+|rddl}d t j fd}|jd}ddl m }| ||} | d| d S#|jj$r] d rE C tj D]} |jn#t$rYnwxYwwxYw#| d wxYwt jt jur#t+ St/}|S) aRun an async coroutine from a sync context. If the current thread already has a running event loop (e.g., inside the gateway's async stack or Atropos's event loop), we spin up a disposable thread so asyncio.run() can create its own loop without conflicting. For the common CLI path (no running loop), we use a persistent event loop so that cached async clients (httpx / AsyncOpenAI) remain bound to a live loop and don't trigger "Event loop is closed" on GC. When called from a worker thread (parallel tool execution), we use a per-thread persistent loop to avoid both contention with the main thread's shared loop AND the "Event loop is closed" errors caused by asyncio.run()'s create-and-destroy lifecycle. This is the single source of truth for sync->async bridging in tool handlers. Each handler is self-protecting via this function. Nrc tj tj tj}|D]}||r$tj|ddin#t$rYnwxYw S# tj}|D]}||r$tj|ddin#t$rYnwxYw wxYw)Nreturn_exceptionsT) r+r,rr4run_until_complete all_taskscancelgatherr close)pendingtcoro loop_ready worker_loops r_run_in_workerz"_run_async.._run_in_workers!022K NN    $&{333"55d;; &/ <)@)@@@&(( --d333  I  ' ' - --sH ((#C'D;71D)(D;) D63D;5D66D;;D>>E)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) 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_cachecxt5tddddS#1swxYwYdS)zDrop memoized get_tool_definitions() results. Called when dynamic schema dependencies change (e.g. discord capability cache reset, execute_code sandbox reconfigured).N)_tool_defs_cache_lockrclearr-r.r_clear_tool_defs_cacher;s !!   !!!!!!!!!!!!!!!!!!s /33enabled_toolsetsdisabled_toolsets quiet_modeskip_tool_search_assemblyc td}|r^ ddlm}|}|}|j|jf}n#t t tf$rd}YnwxYwt} | tkrtj |t|nd|rt|ndtj |ttjdt|t%t'| f }t(5|t*|nd} dddn #1swxYwY| d| Dat/| St1||||} |r|t(5t*|} | bt3t*t4kr9t*t9t;t*| t*|<| } dddn #1swxYwYt/| S|rt/| S| S)a Get tool definitions for model API calls with toolset-based filtering. All tools must be part of a toolset to be accessible. Args: enabled_toolsets: Only include tools from these toolsets. disabled_toolsets: Exclude tools from these toolsets (if enabled_toolsets is None). quiet_mode: Suppress status prints. skip_tool_search_assembly: When True, return the pre-assembly tool list (raw schemas for every enabled tool). Used internally by the tool_search / tool_describe bridge handlers so they can read the real catalog, not the already-collapsed one. Public callers should leave this False. Returns: Filtered list of OpenAI-format tool definitions. Nr)get_config_pathHERMES_KANBAN_TASKc*g|]}|ddSfunctionnamer-.0r?s r z(get_tool_definitions..s!(O(O(O1:v)>(O(O(Or.)r)hermes_cli.configrstat st_mtime_nsst_sizeFileNotFoundErrorOSError ImportErrorr r r current_scope_key frozenset _generationboolosenvirongetr!r&rrralist_compute_tool_definitionslen_TOOL_DEFS_CACHE_MAXpopnextiter) rrrr cache_keyrcfg_pathcfg_statcfg_fp profile_scopecachedrSs rget_tool_definitionsrCs@I   9 9 9 9 9 9&((H}}H*H,<=FF!7K8   FFF ,.. 1 1 1*,,/?/K *+++QU0AK +,,,t$RZ^^$899::.//+--+-- I# X X8A8M%)))444SWF X X X X X X X X X X X X X X X  )P(O(O(O(O %<<  &'79JJAZ\\\Fi+#  &)))44F~'((,@@@$((d3C.D.D)E)EFFF.4 +               F||F|| Ms42:AAD<<EEA?H  HHc p &t}|5t|}tjdr5t s't rd|vr|d|D]}t|rSt|}| ||s,td|d|rd |ndd|tvrMt|}| ||s(td|dd ||std |n5d d lm} | D]$} | t| %|r|D]}t|r.d d lm} m} |d s | |pidr| |} || t)| }|sk|d rV|t*vrMt*|t.d||rd |ndn$t|}|||s,td|d|rd |ndA|tvrNt|}|||s(td|dd ||std |t3j||}d|D}d|vrpd dlm}m}m}||z}|||}t?|D]<\}}|diddkr d|d||<n=ddd}|D]&&|vr d dl m!}tE||&}|}n#tF$rd}YnwxYw|$&fd|D}|$&ft?|D]<\}}|did&kr d|d||<n=d |vrd!d"h|z}|st?|D]z\}}|didd krH|dd#d$}|%d%d$}di|dd#|id||<n{d&|vr%d'|vr!d(|D}|$d&|sS|rBd)|D}td*tM|d+d |ntd,d-|Da' d d.l(m)}||}n2#tF$r%}t.*d/|Yd}~nd}~wwxYw d d0l+m,} m-}!|!}"|s|"j.d1kr}t_}#| ||#|"2}$|$j0rS|sQd3d4d5d6d7d8}%td9|$j1d:|$j2d;|$j3d<|%|$j4|$j4d= |$j5}n2#tF$r%}t.*d>|Yd}~nd}~wwxYw|S)?z8Uncached implementation of :func:`get_tool_definitions`.Nrkanbanu✅ Enabled toolset 'z': z, zno toolsu✅ Enabled legacy toolset 'u⚠️ Unknown toolset: r)get_all_toolsets)bundle_non_core_tools get_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).noneu🚫 Disabled toolset 'u🚫 Disabled legacy toolset 'quietc*h|]}|ddSrr-rs r z,_compute_tool_definitions..s!JJJaAjM&1JJJr. execute_code)SANDBOX_ALLOWED_TOOLSbuild_execute_code_schema_get_execution_mode)moderr)typerget_dynamic_schema_coreget_dynamic_schema_admin)discord discord_admin) discord_toolcng|]1}|didk/|2Srr)rr?discord_tool_names rrz-_compute_tool_definitions..%sK"""uuZ,,0088.MsI   vvj"%%))&11^CC CCCr.c*g|]}|ddSrr-rs rrz-_compute_tool_definitions..Us!HHHA!J-/HHHr.u🛠️ Final tool selection (z tools): u<🛠️ No tools selected (all filtered out or unavailable)c*g|]}|ddSrr-rs rrz-_compute_tool_definitions..[s! O O O1:v!6 O O Or.)sanitize_tool_schemaszSchema sanitization skipped: %s)assemble_tool_defs load_configoff)context_lengthconfigzcatalog listing embeddedznames-only listing embeddedz/listing embedded (oversized servers summarized)z/server summary embedded (search-only discovery)zno listing (search-only))fullnamesmixedgroupsru🔎 Tool Search (tier z): z MCP/plugin tools deferred (~u. tokens) behind tool_search/describe/call — .z Tool search assembly skipped: %s)6rrrrrr!r&appendrrupdateprintjoin_LEGACY_TOOLSET_MAPtoolsetsrrr startswithdifference_updatesortedraddloggerinfor get_definitionstools.code_execution_toolrrr enumeratetoolsrr2r discardreplacerratools.schema_sanitizerrwarningtools.tool_searchrrenabled_resolve_active_context_length activatedtierdeferred_countdeferred_tokens listing_form tool_defs)'rrrrtools_to_includeeffective_enabled_toolsets toolset_nameresolved legacy_toolsrts_namerr to_removefiltered_toolsavailable_tool_namesrrrsandbox_enableddynamic_schemair_discord_schema_fns_dt schema_fndynamicweb_tools_availabledesc tool_namesrer_load_ts_configts_cfgrassembly_formsrs' @rrrsz  EE#%)*:%;%;" JNN/ 0 0 8/11 8,-- 8 ::: ' - -h 7 7 76 B BL -- B*<88 ''111!vt,ttZbCr499XCVCVCVhrttuuu!4442<@  '' 555!eccc$))T`JaJaccddd B@,@@AAA B .-----'')) > >G  # #OG$<$< = = = = %B-$ B$ BL --# BGGGGGGGG**955A++l:S:S:YWY9^9^_h9i9iA!6 5l C CI$66yAAA%i00H& <+B+B9+M+M  ,4L L L044\BBB < )3;GDIIh/// /|<jQQQN KJ>JJJ ---ssssssssss/2FF22?I\I\I^I^___~..  EArvvj"%%))&11^CC-7^$T$Tq!D-31  4 4 4 555555#C)<=N)OPP #)++    """"-"""%,,->????&~66EArvvj"--11&99=NNN5?W,U,Uq)O111+];>RR" ">22  266*b))--f559KKKj>--mR@@D<<pD !+$Kr*~$K}d$K$K))N1%EL(---*DX2X2X  '    $$^444 R  RHHHHHJ iC4G4GiiRVR[R[\fRgRgii j j j j P Q Q Q!P O O O O=@@@@@@..~>> ===8!<<<<<<<<=>XXXXXXXX ""( 0V^u-D-D;==N))-H ! * "<#@#T$U"< >> qhmqq@Wqq3;3Kqq5;ZZ@UW_Wl5m5mqqq &/N >>>91========> sC&O;; P  P "V44 W#>WW#'BZ Z3Z..Z3c  ddlm}|pi}t|dtr|dni}t|tsi}|dp|dpd}t|trddlm}||\}}t |}|sdSddlm }|d}t|tr|dkr|nd } t |d pd} t |d pd} d} | r dd l m } | | | pi}t |d p| pd} t |dpd} n3#t$r&}td| |Yd }~nd }~wwxYw| C| rA ddlm}||| }t|tr|dkr|Sn#t$rYnwxYwt||| | | | pdS#t$r&}td|Yd }~dSd }~wwxYw)uLook up the active model's context length for the tool-search gate. Returns 0 when the model can't be resolved — ``should_activate`` falls back to a fixed token cutoff in that case. r)rmodelrr)split_model_config_default)get_model_context_lengthrNproviderbase_url)resolve_runtime_provider) requested target_modelapi_keyupRuntime credential resolution failed for tool-search context gate (provider=%s): %s — using config values only)get_cached_context_length)rrconfig_context_lengthrz+Could not resolve active context length: %s)rr isinstancerdictrstrstripagent.model_metadatarinthermes_cli.runtime_providerrr rdebugr)_loadcfg model_cfg _raw_model_idr_model_idrraw_ctx config_ctxrrrrrtrt_excr cached_ctxrs rrrs G::::::eggm(237773C3CT(J(JRCGGG$$$PR )T** I! g..P)-- 2J2JPb mT * * I D D D D D D99-HH M1}%%++-- 1AAAAAA -- 011 *7C 8 8RWq[[WWd y}}Z006B77==??y}}Z006B77==??   PPPPPP--&Xrvvj11CXCDDJJLLbffY//5266<<>>    Rf   (  JJJJJJ66xJJ j#..&:>>%%    ++ ",         BAFFFqqqqqsnC J*$B*J*BHJ* IH>9J*>IJ* .I;:J*; JJ*J!J** K4KK>todomemory delegate_tasksession_searchrurxzRz%^\s*```(?:json|xml|html|markdown)?\s*z \s*```\s*$z)_MAX_TOOL_ERROR_CHARS error_msgcF|sdStd|}td|}td|}td|}t |t kr|dt dz dz}d|S)zStrip structural framing tokens from a tool error before showing it to the model. See _TOOL_ERROR_ROLE_TAG_RE docstring above for rationale. z [TOOL_ERROR] rNz...)_TOOL_ERROR_ROLE_TAG_REsub_TOOL_ERROR_FENCE_OPEN_RE_TOOL_ERROR_FENCE_CLOSE_RE_TOOL_ERROR_CDATA_REr_TOOL_ERROR_MAX_LEN)r7 sanitizeds r_sanitize_tool_errorrA s '++B ::I)--b)<ukRRS X%%*UD*A*A%>ukRRS   3K @ @  x DDD %  DI'D%#677 U>w TTS Ks!%B BBrJkindc<t|tsdS|d}|kst|tr|vrdSdD]J}||}t|trt fd|DrdSKdS)uReturn True when *schema* permits a value of JSON type *kind*. Looks at ``type`` (string or list) and recurses through ``anyOf``/``oneOf``/``allOf`` branches — matching the JSON-Schema shapes open-weight models emit against. ``kind`` is ``"array"`` or ``"object"``. FrT)anyOfoneOfallOfc38K|]}t|VdSN)_schema_accepts_kind)rbrZs r z'_schema_accepts_kind..s?. . ./ D ) ). . . . . . r.)rr rrany)rJrZr? union_keybranchess ` rraras fd # #u 6ADyyZ4((yTQYYt0 ::i(( h % % #. . . . 3;. . . + +  44 5r.rUcLt|ts|St|tr|}t |d}t |d}|r|ds|rz|dre t j|}n#ttf$r|cYSwxYwt|tr|r|}nt|tr|r|}n|S|St|trf| d}t|ts|Sd}g}|D]-} t| |} |p| | u}| | .|r|n|St|tr| d} t| ts|Sd}t|}| D]F\} } | |vst| tst|| | } | || ur| || <d}G|r|n|S|S) uRecursively parse JSON-encoded string values that a schema expects to be arrays or objects, including nested array items and object properties. Open-weight models (DeepSeek, Qwen, GLM, and others) sometimes emit a structured field — or an *element* of a structured field — as a JSON-encoded string instead of a native value. The top-level :func:`coerce_tool_args` pass repairs the outermost value; this helper walks the rest of the tree so cases like:: {"todos": ["{\"id\": \"1\", \"content\": \"x\"}"]} (a list whose elements are JSON strings) and nested object sub-fields are repaired too. Parsing is schema-guided: a string is only parsed when the matching schema position actually expects an array or object, so legitimate JSON-looking string fields (``type: string``) are preserved. Ported from cline/cline#11803, adapted to hermes-agent's coercion layer. Returns the original value object when nothing changed (identity preserved so callers can cheaply detect no-ops). rHrLrK{rNFrFT)rr r!r"rarjsonloads ValueError TypeErrorrrrRrrN)rUrJtrimmed expects_arrayexpects_objectparsed items_schemachangedoutitemnxtpropskrVs rrRrRsv* fd # # %++--,VW== -fh??  g0055   &11#66  G,, *     &$'' M FD)) n  L% )zz'** ,-- L  D4T<HHC2#T/G JJsOOOO(ss5(% ) <((%&& L5kk#kkmm  NA{~~Z T%B%B~4U1X{KKC%(""A(ss5( LsB%%B;:B;ct|r,|dkrdSt|tr!|D]}t |||}||ur|cS|S|dvrt ||dkS|dkrt|S|dkrt|tS|d krt|tS|dkr,|dkrdS|S) zAttempt to coerce a string *value* to *expected_type*. Returns the original string when coercion is not applicable or fails. nullNrI>numberintegerr{) integer_onlybooleanrHrL) rSr"lowerrrrP_coerce_number_coerce_boolean _coerce_jsonr )rU expected_typerJr?rSs rrPrPs0 6""u{{}}':':'<'<'F'Ft-&&  A"5!F;;;FU"" # ---e=I3MOOOO !!u%%%E4(((  E4(((5;;==#6#6#8#8F#B#Bt Lr.ct|tsdS|d}|dkrdSt|trd|vrdS|ddurdSdD]d}||}t|ts-|D]4}t|tr|ddkrdS5edS)z@Return True when a JSON Schema fragment explicitly permits null.FrryTnullable)r\r])rr rr)rJ schema_typerevariantsvariants rrSrSs fd # #u**V$$Kft+t$$;)>)>t zz*%%t' ::i(((D))    G'4(( W[[-@-@F-J-Jttt  5r.expected_python_typec~ tj|}nA#ttf$r-}td|j||cYd}~Sd}~wwxYwt||r"td|j|Stdt|j|j|S)aJParse *value* as JSON when the schema expects an array or object. Handles model output drift where a complex oneOf/discriminated-union schema causes the LLM to emit the array/object as a JSON string instead of a native structure. Returns the original string if parsing fails or yields the wrong Python type. zIcoerce_tool_args: failed to parse string as JSON for expected type %s: %sNz5coerce_tool_args: coerced string to %s via json.loadsuLcoerce_tool_args: JSON-parsed value is %s, expected %s — skipping coercion) rirjrkrlrrrQrr&r)rUrrpexcs rrr sE""  " W )     &.// C )     NNV V % LsA"A AAr|c t|}n#ttf$r|cYSwxYw||ks&|tdks|tdkr|S|t|krt|S|r|S|S)zFTry to parse *value* as a number. Returns original string on failure.infz-inf)floatrk OverflowErrorr$)rUr|fs rrr?s %LL  &  AvveEll""a5==&8&8 CFF{{1vv  Hs ((cr|}|dkrdS|dkrdS|S)zGTry to parse *value* as a boolean. Returns original string on failure.trueTfalseF)r"r~)rUlows rrrQs< ++--    C f}}t g~~u Lr.rSc t|trtj|n|}t|tr:|dr%ddt|dfSn#t $rYnwxYw ddlm}|||\}}|r,dd| dpdfSn#t $rYnwxYwdS)Nerrorrr)_detect_tool_failurez[])okNN) rr!rirjr rr agent.displayrr")rBrS parsed_resultrfailedsuffixs r_tool_result_observer_fieldsr[s! .8.E.EQ 6***6 mT * * J}/@/@/I/I JL#m.?.?.H.H*I*II I       666666--i@@  ML&,,..*>*>t*D*D*LL L M       s%A9A== B  B AC CC) task_id session_id tool_call_idturn_idapi_request_id duration_msstatus error_type error_messagemiddleware_trace function_name function_argsrrrrrrrrrrc ^trdS ddlm} m}| dsdS| t ||\} } } |d||||pd|pd|pd|pd|pd|| | | t | pgdS#t$r&}t d|Yd}~dSd}~wwxYw)uEmit the ``post_tool_call`` observer hook. No-ops cheaply when no plugin has registered for ``post_tool_call`` — the ``has_hook`` gate skips both the result-field derivation and the payload dispatch so the no-listener path costs one dict lookup. When ``status`` is not supplied, the ok/error fields are derived from the result *after* the gate (parsing the result is only worth it when a listener will actually consume it). Nrhas_hook invoke_hookpost_tool_callr) rBrCrSrrrrrrrrrrzpost_tool_call hook error: %s) rrhermes_cli.lifecyclerrrrr rr&)rrrSrrrrrrrrrrrr _hook_errs r_emit_post_tool_call_hookrps42'**,,A>>>>>>>>x())  F >0L11 -FJ   #Mr!'R%+Mr)/R#!'!"2"8b99      AAA 4i@@@@@@@@@AsA<AA<< B,B''B, user_task enabled_toolsskip_pre_tool_call_hookskip_tool_request_middlewareskip_tool_execution_middlewaretool_request_middleware_tracec 345tttsit| pg4t j3dt dt f34f d }d} ddlm}n#t$rd}YnwxYw|`| rJ t| |ddpg}n#t$rg}YnwxYw|j kr"|| pi| S|jkr"||pi| S|jkr|pi\}}}|s|s|t%|pd S||}||vr|t%d |d S|||}| ||St+|||| | | t4| | St}| sk ddlm}|pdpdpdpdpd}|j|j}|j4n2#t$r%}t6d|Yd}~nd}~wwxYw t:vrt%dS| sd} ddlm}|pdpdpdpdpdt4\}}||n2#t$r%}t6d|Yd}~nd}~wwxYw|9t%|}tA|dd|t4 |S ddl!m"} | }!|!)tA|!ddt4 |!Sns#t$rf}"t6d|"dvr=t%d}tA|ddt4 |cYd}"~"SYd}"~"nd}"~"wwxYwtFvr% dd l$m%}#|#pd!n#t$rYnwxYwt j3d}$ dd"l&m'}%m(}&|&pdpdpd#}$n#t$rd}%YnwxYw d$kr5||ntR5d%tTtVt fdt f5fd& }'n)d%tTtVt fdt ffd' }'| r |'}n$dd(lm,}(|(|'|pdpdpdpdpd) }|$|% |%|$n8#t$rYn,wxYwn'#|$|% |%|$w#t$rYwwxYwwwxYwt[t j3z d*z})tA||)t4+  dd,l.m/}*m0}+|*d-rTtc|\},}-}.|+d-|pdpdpdpdpd|)|,|-|.. }/|/D]}0t|0tVr|0}nn2#t$r%}t6d/|Yd}~nd}~wwxYw|S#t$r}1d0d1tW|1}2t62|2t%tg|2}3&t[t j3z d*znd})tA||)d2ti|1j5tW|1t43 |cYd}1~1Sd}1~1wwxYw)4a Main function call dispatcher that routes calls to the tool registry. Args: function_name: Name of the function to call. function_args: Arguments for the function. task_id: Unique identifier for terminal/browser session isolation. user_task: The user's original task (for browser_snapshot context). enabled_tools: Tool names enabled for this session. When provided, execute_code uses this list to determine which sandbox tools to generate. Falls back to the process-global ``_last_resolved_tool_names`` for backward compat. enabled_toolsets: The session's enabled toolsets. Used to scope the Tool Search bridge catalog so ``tool_search`` / ``tool_describe`` / ``tool_call`` only see and invoke tools the session was actually granted. ``None`` means "no restriction" (the caller scopes to every toolset), matching ``get_tool_definitions`` semantics. disabled_toolsets: The session's disabled toolsets, applied as a subtraction when scoping the bridge catalog. Returns: Function result as a JSON string. rSrc t| ttjz dzt  |S)N rrrSrrrrrrr)rr$time monotonicr) rS_dispatch_start_tool_middleware_tracerrrrrrrs r_return_bridge_resultz3handle_function_call.._return_bridge_resultsb!''!%)T^--?4GHH!"899  r.Nr) tool_searchT)rrrr)current_tool_defsztool_call could not be resolved'zO' is not available in this session. Use tool_search to find tools you can call.)rrrrrrrrrrrrrrr)apply_tool_request_middlewarer)rrrrrz!tool_request middleware error: %sz" must be handled by the agent loop)_dispatch_pre_tool_call_hooks)rrrrrrzpre_tool_call hook error: %sblocked plugin_block) rrrSrrrrrrrrr)maybe_require_edit_approvaledit_approval_denied) rrrSrrrrrrrrz!ACP edit approval guard error: %s>rwrvz+Edit approval denied: approval guard failededit_approval_error)notify_other_tool_callr)#reset_current_observability_context!set_current_observability_context)rrrr next_argsc6tj|S)N)rrrr dispatch)rrrrrs r _dispatchz'handle_function_call.._dispatchs+#,%y '#-&5 r.c6tj|S)N)rrrr)rrrrrs rrz'handle_function_call.._dispatchs+#,%y '#-"+ r.)run_tool_execution_middleware) original_argsrrrrrrrrtransform_tool_result) rBrCrSrrrrrrrrrz$transform_tool_result hook error: %szError executing z: r) rrrSrrrrrrrrrr)6rYrr rrrrrrr is_bridge_toolrTOOL_SEARCH_NAMEdispatch_tool_searchTOOL_DESCRIBE_NAMEdispatch_tool_describeTOOL_CALL_NAMEresolve_underlying_callrscoped_deferrable_namesvalidate_deferred_call_argshandle_function_callhermes_cli.middlewarerpayloadoriginal_payloadtracerr&_AGENT_LOOP_TOOLShermes_cli.pluginsrracp_adapter.edit_approvalr_READ_SEARCH_TOOLStools.file_toolsrtools.approvalrrrarr!rr$rrrr exceptionrArrQ)6rrrrrrrrrrrrrrrr_ts_mod current_defsunderlying_nameunderlying_argserr_scoped_deferrable _probe_err_tool_original_argsr_tool_request_mw_mw_err block_messager modified_argsrrSredit_block_message_edit_approval_errr_approval_tokensrrrrrrrrrr hook_results hook_resultrr7rrrs6```````` @@@rrrs T%]MBBM mT * * !"?"E2FFn&&O c c              G0000000 w55mDD 0!1"34 L    LLL  G4 4 4((,,!'R&2-  G6 6 6((..!'R&2/  G2 2 24;4S4STaTgeg4h4h 1O_c / ,,sG&GHH")!@!@!N!N &888,,FOFFF!<<_o^^J%,,Z888(--)%-#+(?-I/M.23I.J.J!1"3 $}-- 'G G K K K K K K<< 2%+)/R 2-3    -4M"2"C %5%; " " G G G LLP Q Q Q 777#$QRR)"/"/!#)!-##1$4%)*@%A%A     87777 *  2 2 2 CCCCCC&&w';)<<<<    .** 7         A@ 2)/R%+       7 7 726 / / / 7) ..4A3L--Rkc3hCc3hC. "=11OOOOOO66!!"5#Mr)/R!-!3#Mr#1#7R    +0S0_778HIIII D +0S0_778HIIII D,0_ 4>++o=EFF !''!%)#!"899 * L B B B B B B B Bx/00 4P!551 M +{++&!#Mr)/R!-!3#Mr#1#7R +!)"/    $0K!+s33!, L L L LL? K K K K K K K K L @}@@A@@ ###0;;<<* !!O3t; < < <  "''!%)#Aww'a&&!"899     1s6A== B  B )B?? C C7H<< I+I&&I+/X" X"7KX" K6K1,X"1K66=X"5[0*[50[5c(tjS)z!Return all registered tool names.)r get_all_tool_namesr-r.rrrSs  & ( ((r.c*tj|S)z%Return the toolset a tool belongs to.)r get_toolset_for_tool)rBs rrrXs  ( 3 33r.c(tjS)z0Return toolset availability info for UI display.)r get_available_toolsetsr-r.rrr]s  * , ,,r.c(tjS)z>Return {toolset: available_bool} for every registered toolset.)r check_toolset_requirementsr-r.rrrbs  . 0 00r.rc,tj|S)z.Return (available_toolsets, unavailable_info).r)r check_tool_availabilityrs rrrgs  +% 8 8 88r.)rN)NNFFr`)F) NNNNNNNFFFNNN)b__doc__rrirer+ contextlibr contextvarsrloggingrMrtypingrrrrr tools.registryr r r r rrrr getLoggerrQrrr__annotations__rrrr!r&r)Lockr(localr3r/r5r]rr^r rr&get_tool_to_toolset_mapr_r!get_toolset_requirementsr`r rarrrOrrrrrr$rrrcompile IGNORECASEr: MULTILINEr<r=DOTALLr>r6r?rArYrarRrPrSrrrrrrrrrrrrr-r.rrs% * %%%%%%"""""" 3333333333333376666666  8 $ $4>J$e555D!1 555!$#%%%TT  ).""&y((   ,].].].H 3333333333 LL.222222223'Gh&F&H&HT#s(^HHH(I(I(K(Kd39oKKK(*49))) .!l%&$%AAA  [FFF"#B79$ud4S>223888& ((!!!!-1-1&+ [[tCy)[S *[[ $ [  $sCx. [[[[~-1-1&+ kktCy)kS *kk $ k  $sCx. kkkk\MMMMMpJII!>2&%"*YM'BJ'OQSQ]^^'RZ r|DD!rz"8")DD HGGGGG 'C 'C ' ' ' '(ii4S>id38niiiiXCD*JcJ3J3JJJJZTD[:t 04>  # T    $3  3 x} ,-4" $"&!$( $#'7;5A5A5A5AS>5A  5A c] 5A  5A3-5Ac]5ASM5A5A SM5A 5AC=5AtDcN345A 5A5A5A5Av""& $!$(#)-$)).+0DH,0-1dddS>dc]d3- d  d c] dSMd}dDI&d"d#'d%)d$,Dc3h,@#AdtCy)d S *d  !ddddV )DI)))) 4C4HSM4444 -S$Y---- 1DdO1111 9949E$s)T$Z:O4P999999sC##D(DD