eitlUdZddlZddlZddlZddlZddlZddlmZmZm Z m Z m Z ddl m Z mZddlmZmZejeZdaejZejZdZdZdZe  dd lmZen(#e$r Z e!d e YdZ [ ndZ [ wwxYw dd l"m#Z#e#n(#e$r Z e!d e YdZ [ ndZ [ wwxYwej$Z%ee&e&fe'd <ej(Z)ee&e*fe'd<ga+e e&e'd<ddgdgdgdgdggdgddggdgddgd Z, d?de e&de e&d e-d!e ee&effd"Z.hd#Z/d$d%hZ0d&e&d'ee&efd!ee&effd(Z1d)e&fd*Z2d)e&d+e3fd,Z4d@d)e&d-e-fd.Z5d)e&fd/Z6 dAd0e&d1ee&efd2e e&d3e e&d4e e&d5e e&d6e e e&d7e-d!e&fd8Z7d!e e&fd9Z8d&e&d!e e&fd:Z9d!ee&e*ffd;Z:d!ee&e-ffd<Z;d@d=e-d!e e e&e e*ffd>Z 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)DictAnyListOptionalTuple)discover_builtin_toolsregistry)resolve_toolsetvalidate_toolsetct5ttrtjatcdddS#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_loop-/home/div/.hermes/hermes-agent/model_tools.py_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_localrrrset_event_loopr)rs r_get_worker_loopr<sV ' 6 6D |t~~''|%''t$$$$(! Krc tj}n#t$rd}YnwxYw|r|rddl}|jd}|tj|} | d| dd S#|jj $r| wxYw#| dd wxYwtjtjur#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. The RL paths (agent_loop.py, tool_context.py) also provide outer thread-pool wrapping as defense-in-depth, but each handler is self-protecting via this function. Nr) max_workersi,)timeoutFT)waitcancel_futures)rget_running_loop RuntimeError is_runningconcurrent.futuresfuturesThreadPoolExecutorsubmitrunresultshutdown TimeoutErrorcancel threadingcurrent_thread main_threadrrun_until_completer)coror concurrentpoolfuture worker_loop tool_loops r _run_asyncr8Rsp,'))  ;!! ;!!!!!444CCW[$// ;===-- MMuTM : : : : !.    MMOOO   MMuTM : : : :!!)>)@)@@@&(( --d333  I  ' ' - --s$ %%>B++%CCC,)discover_mcp_toolszMCP tool discovery failed: %s)discover_pluginszPlugin discovery failed: %sTOOL_TO_TOOLSET_MAPTOOLSET_REQUIREMENTS_last_resolved_tool_names web_search web_extractterminalvision_analyzemixture_of_agentsimage_generate) skills_list skill_view skill_manage) browser_navigatebrowser_snapshot browser_click browser_typebrowser_scroll browser_back browser_pressbrowser_get_imagesbrowser_visionbrowser_consolecronjob) rl_list_environmentsrl_select_environmentrl_get_current_configrl_edit_configrl_start_trainingrl_check_statusrl_stop_trainingrl_get_results rl_list_runsrl_test_inference) read_file write_filepatch search_filestext_to_speech) web_toolsterminal_tools vision_tools moa_tools image_tools skills_tools browser_tools cronjob_toolsrl_tools file_tools tts_toolsFenabled_toolsetsdisabled_toolsets quiet_modereturnc f t}||D]}t|rSt|}|||s,t d|d|rd|ndd|t vrMt |}|||s(t d|dd||st d|ϐn?|rdd lm}|D]$}|t|%|D]}t|rSt|}| ||s,t d |d|rd|ndd|t vrMt |}| ||s(t d |dd||st d|n5dd lm}|D]$}|t|%tj || } d | D} d| vrpddl m } m} m} | | z}| || }t!| D]<\}}|diddkr d|d| |<n=ddd}|D]| vr ddlm}t)||}|}n#t*$rd}YnwxYw|$fd| D} | ft!| D]<\}}|didkr d|d| |<n=d| vrddh| z}|st!| D]z\}}|diddkrH|ddd}|dd}di|dd|id| |<n{|sS| rBd| D}t d t1| d!d|nt d"d#| Da dd$lm}|| } n2#t*$r%}t8d%|Yd}~nd}~wwxYw| 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. Returns: Filtered list of OpenAI-format tool definitions. Nu✅ Enabled toolset 'z': z, zno toolsu✅ Enabled legacy toolset 'u⚠️ Unknown toolset: r)get_all_toolsetsu🚫 Disabled toolset 'u🚫 Disabled legacy toolset 'quietc*h|]}|ddSfunctionnamer.0ts r z'get_tool_definitions..s!JJJaAjM&1JJJr execute_code)SANDBOX_ALLOWED_TOOLSbuild_execute_code_schema_get_execution_mode)modervrw)typervget_dynamic_schema_coreget_dynamic_schema_admin)discord discord_admin) discord_toolcng|]1}|didk/|2Sru)get)ryrzdiscord_tool_names r z(get_tool_definitions..6sK"""uuZ,,0088r? descriptionzV For simple information retrieval, prefer web_search or web_extract (faster, cheaper).c*g|]}|ddSrurrxs rrz(get_tool_definitions..Ws!HHHA!J-/HHHru🛠️ Final tool selection (z tools): u<🛠️ No tools selected (all filtered out or unavailable)c*g|]}|ddSrurrxs rrz(get_tool_definitions..]s! O O O1:v!6 O O Or)sanitize_tool_schemaszSchema sanitization skipped: %s)setr r updateprintjoin_LEGACY_TOOLSET_MAPtoolsetsrqdifference_updater get_definitionstools.code_execution_toolr}r~r enumeratertoolsrr Exceptiondiscardreplacelenr=tools.schema_sanitizerrloggerwarning)rlrmrntools_to_include toolset_nameresolved legacy_toolsrqts_namefiltered_toolsavailable_tool_namesr}r~rsandbox_enableddynamic_schemaitd_discord_schema_fns_dt schema_fndynamicweb_tools_availabledesc tool_namesrers @rget_tool_definitionsrs& EE#, F FL -- F*<88 ''111!vt,ttZbCr499XCVCVCVhrttuuu!4442<@  '' 555!eccc$))T`JaJaccddd!FDlDDEEE F >------'')) > >G  # #OG$<$< = = = =- F FL -- F*<88 228<<<!xvLvv\dEtTYYxEXEXEXjtvvwww!4442<@  22<@@@!ge<eeDIIVbLcLceefff!FDlDDEEE F .-----'')) > >G  # #OG$<$< = = = =-.>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 R  RHHHHHJ iC4G4GiiRVR[R[\fRgRgii j j j j P Q Q Q!P O O O O=@@@@@@..~>> ===8!<<<<<<<<= s*&K// K>=K>-Q?? R. R))R.>todomemory delegate_tasksession_searchr\r_ tool_nameargsc|rt|ts|Stj|}|s|S|dpid}|s|S|D]d\}}t|t s||}|s3|d}|sKt||}||ur|||<e|S)aACoerce tool call arguments to match their JSON Schema types. LLMs frequently return numbers as strings (``"42"`` instead of ``42``) and booleans as strings (``"true"`` instead of ``true``). This compares each argument value against the tool's registered JSON Schema and attempts safe coercion when the value is a string but the schema expects a different type. Original values are preserved when coercion fails. Handles ``"type": "integer"``, ``"type": "number"``, ``"type": "boolean"``, and union types (``"type": ["integer", "string"]``). parameters propertiesr) isinstancedictr get_schemaritemsstr _coerce_value) rrschemarkeyvalue prop_schemaexpectedcoerceds rcoerce_tool_argsr~s z$--   + +F  **\**0b55lCCJ  jjll   U%%%   nnS))   ??6**  x00 %  DI Krrc6t|tr|D]}t||}||ur|cS|S|dvrt||dkS|dkrt |S|dkrt |tS|dkrt |t S|S)zAttempt to coerce a string *value* to *expected_type*. Returns the original string when coercion is not applicable or fails. )integernumberr) integer_onlybooleanarrayobject)rlistr_coerce_number_coerce_boolean _coerce_jsonr)r expected_typerzr*s rrrs -&&  A"5!,,FU"" # ---e=I3MOOOO !!u%%%E4(((  E4((( Lrexpected_python_typec tj|}n#ttf$r|cYSwxYwt ||r"t d|j|S|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. z5coerce_tool_args: coerced string to %s via json.loads)jsonloads ValueError TypeErrorrrdebug__name__)rrparseds rrrsE""  " &.// C )    Ls --rc 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)floatr OverflowErrorint)rrfs rrrs %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)striplower)rlows rrrs< ++--    C f}}t g~~u Lr function_name function_argstask_id tool_call_id session_id user_task enabled_toolsskip_pre_tool_call_hookc rt||} |tvrtjd|diS|sKd} ddlm} | |||pd|pd|pd}n#t $rYnwxYw|tjd|id Sn/ dd lm} | d |||pd|pd|pd n#t $rYnwxYw|tvr% dd l m } | |pdn#t $rYnwxYwtj } |dkr$||nt} tj|||| }ntj||||}t!tj | z dz} dd lm} | d||||pd|pd|pd|n#t $rYnwxYw dd lm} | d||||pd|pd|pd|}|D]}t#|t$r|}nn#t $rYnwxYw|S#t $rQ}d|dt%|}t&|tjd|id cYd}~Sd}~wwxYw)a 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. Returns: Function result as a JSON string. errorz" must be handled by the agent loopNr)get_pre_tool_call_block_messager)rrrF) ensure_ascii) invoke_hook pre_tool_call)rrrrr)notify_other_tool_calldefaultr|)rr)rripost_tool_call)rrr*rrr duration_mstransform_tool_resultzError executing z: )r_AGENT_LOOP_TOOLSrdumpshermes_cli.pluginsrrr_READ_SEARCH_TOOLStools.file_toolsrtime monotonicr=r dispatchrrrrr)rrrrrrrr block_messagerrr_dispatch_startrr*r hook_results hook_resultr error_msgs rhandle_function_callr s6%]MBBMvD - - -:w=(\(\(\]^^ ^ ' +/M NNNNNN ? ?!!#Mr)/R!-!3 !!!     (z7M":OOOO) :::::: #+&#Mr)/R!-!3       2 2 2 CCCCCC&&w';)<<<<    .** N * *0=/HmmNgO&}-FF &}#F 4>++o=EFF   6 6 6 6 6 6 K '" 2%+)/R'         D   6 6 6 6 6 6&;''" 2%+)/R'   L ,   k3//(FE    D  DDD@}@@A@@  Yz7I.UCCCCCCCCCDs!GGAG A# G"A##GGB G B-*G,B-- G:C G CGCA>GE:9G: FGFG =G G GGGG H6%AH1+H61H6c(tjS)z!Return all registered tool names.)r get_all_tool_namesrrrrrs  & ( ((rc*tj|S)z%Return the toolset a tool belongs to.)r get_toolset_for_tool)rs rrrs  ( 3 33rc(tjS)z0Return toolset availability info for UI display.)r get_available_toolsetsrrrrrs  * , ,,rc(tjS)z>Return {toolset: available_bool} for every registered toolset.)r check_toolset_requirementsrrrrrs  . 0 00rrsc,tj|S)z.Return (available_toolsets, unavailable_info).rr)r check_tool_availabilityrrs rrrs  +% 8 8 88r)NNF)F)NNNNNF)=__doc__rrloggingr.rtypingrrrrrtools.registryrr rr r getLoggerrrrLockr localrrrr8tools.mcp_toolr9rrrrr:get_tool_to_toolset_mapr;r__annotations__get_toolset_requirementsr<rr=rboolrrrrrrrrrr rrrrrrrrr$s*  33333333333333;;;;;;;;66666666  8 $ $  ).""&y((   ,2.2.2.r5111111555 LL0!4444444453333333333 LL.222222223'Gh&F&H&HT#s(^HHH(I(I(K(Kd39oKKK(*49))) .!l%&%&$%AAA  [GFF"#->#'#'``3i`Cy`` $sCx. ````VJII!>2$$4S>$d38n$$$$N04*  # T    $3""& $#)-$)SDSDSDS>SDc]SD3- SD  SD } SDDI&SD"SD SDSDSDSDt)DI)))) 4C4HSM4444 -S$Y---- 1DdO1111 9949E$s)T$Z:O4P999999s0:B B0B++B04CC* C%%C*