iRUdZddlmZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl mZmZddlmZddlmZmZmZmZmZmZmZddlmZddlmZdd lmZdDd Z ddl!Z!n #e"$rdZ!YnwxYwej#e$Z%hd Z&de'd<dZ(dZ)dEdZ*dFdZ+dGdZ,hdZ-de'd<eGddZ.eGddZ/Gd d!Z0Gd"d#Z1da2d$e'd%<dHd&Z3dIdJd*Z4dKd/Z5 dLdMd8Z6dIdNd9Z7d:Z8dOd<Z9d=Z:dPd?Z;dQdAZ/plugins//`` (shipped with hermes-agent; ``memory/`` and ``context_engine/`` subdirs are excluded — they have their own discovery paths) 2. **User plugins** – ``~/.hermes/plugins//`` 3. **Project plugins** – ``./.hermes/plugins//`` (opt-in via ``HERMES_ENABLE_PROJECT_PLUGINS``) 4. **Pip plugins** – packages that expose the ``hermes_agent.plugins`` entry-point group. Later sources override earlier ones on name collision, so a user or project plugin with the same name as a bundled plugin replaces it. Each directory plugin must contain a ``plugin.yaml`` manifest **and** an ``__init__.py`` with a ``register(ctx)`` function. Lifecycle hooks --------------- Plugins may register callbacks for any of the hooks in ``VALID_HOOKS``. The agent core calls ``invoke_hook(name, **kwargs)`` at the appropriate points. Tool registration ----------------- ``PluginContext.register_tool()`` delegates to ``tools.registry.register()`` so plugin-defined tools appear alongside the built-in tools. ) annotationsN) dataclassfield)Path)AnyCallableDictListOptionalSetUnion)get_hermes_homeenv_var_enabled)cfg_getreturnrctjd}|rt|Sttjjdz S)zLocate the bundled ``plugins/`` directory. Honours ``HERMES_BUNDLED_PLUGINS`` (set by the Nix wrapper / packaged installs) so read-only store paths are consulted first. Falls back to the in-repo path used during development. HERMES_BUNDLED_PLUGINSplugins)osgetenvr__file__resolveparent) env_overrides 7/home/ubuntu/.hermes/hermes-agent/hermes_cli/plugins.pyget_bundled_plugins_dirr7sM9566L"L!!! >> ! ! # # * 1I ==> pre_llm_call post_llm_call pre_tool_call subagent_stopon_session_endpost_tool_callpre_api_requeston_session_reseton_session_startpost_api_requeston_session_finalizepre_approval_requestpre_gateway_dispatchtransform_tool_resultpost_approval_responsetransform_terminal_outputzSet[str] VALID_HOOKSzhermes_agent.pluginshermes_pluginsnamestrboolc t|S)zr6r?)r9r@ plugins_cfgrDs r_get_enabled_pluginsrHs 111111jj++ +t,, 4 K ' '4//),,'4(( 47|| tts":A?A?*A?0A?? B  B >backendplatform exclusive standalone_VALID_PLUGIN_KINDSceZdZUdZded<dZded<dZded<dZded<ee Z d ed <ee Z d ed <ee Z d ed <dZ ded<dZded<dZded<dZded<dS)PluginManifestz0Parsed representation of a plugin.yaml manifest.r2r1version descriptionauthordefault_factoryz List[Union[str, Dict[str, Any]]] requires_env List[str]provides_toolsprovides_hookssourceN Optional[str]pathrLkindkey)__name__ __module__ __qualname____doc____annotations__rQrRrSrr>rVrXrYrZr\r]r^rrrOrOs:: IIIGKF5:U45P5P5PLPPPP %d ; ; ;N;;;; %d ; ; ;N;;;;FD D CMMMMMMrrOceZdZUdZded<dZded<eeZded <eeZ ded <eeZ ded <d Z d ed<dZ ded<dS) LoadedPluginz)Runtime state for a single loaded plugin.rOmanifestNzOptional[types.ModuleType]modulerTrWtools_registeredhooks_registeredcommands_registeredFr3rDr[error) r_r`rarbrcrhrr>rirjrkrDrlrdrrrfrfs33)-F----"'%"="="====="'%"="="=====%*U4%@%@%@@@@@GErrfceZdZdZd9dZ d:d;dZdd?d#Z d@dAd%ZdBd(Z dCd)Z dCd*Z dDdEd2Z dFd5Z dGdHd8ZdS)I PluginContextz=Facade given to plugins so they can register tools and hooks.rgrOmanager'PluginManager'c"||_||_dSN)rg_manager)selfrgros r__init__zPluginContext.__init__s   rNFrPr1r2toolsetschemarFhandlerrcheck_fnCallable | NonerV list | Noneis_asyncr3rRemojirNonec ddlm} | |||||||||  |jj|t d|jj |dS)zKRegister a tool in the global registry **and** track it as plugin-provided.rregistry) r1rvrwrxryrVr|rRr}zPlugin %s registered tool: %sN) tools.registryrregisterrs_plugin_tool_namesaddloggerdebugrgr1) rtr1rvrwrxryrVr|rRr}rs r register_toolzPluginContext.register_tools ,+++++%#   (,,T222 4dm6H$OOOOOrusercontentrolec|jj}|tddS|dkr|nd|d|}t |ddr|j|n|j|dS) aInject a message into the active conversation. If the agent is idle (waiting for user input), this starts a new turn. If the agent is running, this interrupts and injects the message. This enables plugins (e.g. remote control viewers, messaging bridges) to send messages into the conversation from external sources. Returns True if the message was queued successfully. Nz@inject_message: no CLI reference (not available in gateway mode)Fr[z] _agent_runningT)rs_cli_refrwarninggetattr_interrupt_queueput_pending_input)rtrrclimsgs rinject_messagezPluginContext.inject_messagesm$ ; NN] ^ ^ ^5gg-B-B-B-B-B 3(% 0 0 (  $ $S ) ) ) )   " "3 ' ' 'trhelpsetup_fn handler_fnc||||||jjd|jj|<td|jj|dS)aRegister a CLI subcommand (e.g. ``hermes honcho ...``). The *setup_fn* receives an argparse subparser and should add any arguments/sub-subparsers. If *handler_fn* is provided it is set as the default dispatch function via ``set_defaults(func=...)``.)r1rrRrrpluginz$Plugin %s registered CLI command: %sN)rgr1rs _cli_commandsrr)rtr1rrrrRs rregister_cli_commandz"PluginContext.register_cli_command-sV& $m( - -  #D)  ;T]=OQUVVVVVr args_hintc<|ddd}|s'td|jjdS ddlm }||(td|jj|dSn#t$rYnwxYw||pd |jj|pd d |j j |<t d |jj|dS) uRegister a slash command (e.g. ``/lcm``) available in CLI and gateway sessions. The handler signature is ``fn(raw_args: str) -> str | None``. It may also be an async callable — the gateway dispatch handles both. Unlike ``register_cli_command()`` (which creates ``hermes `` terminal commands), this registers in-session slash commands that users invoke during a conversation. ``args_hint`` is an optional short string (e.g. ``""`` or ``"dias:7 formato:json"``) used by gateway adapters to surface the command with an argument field — for example Discord's native slash command picker. Plugin commands without ``args_hint`` register as parameterless in Discord and still accept trailing text when invoked as free-form chat. Names conflicting with built-in commands are rejected with a warning. / -z;Plugin '%s' tried to register a command with an empty name.Nr)resolve_commandz^Plugin '%s' tried to register command '/%s' which conflicts with a built-in command. Skipping.zPlugin commandrP)rxrRrrz!Plugin %s registered command: /%s)lowerstriplstripreplacerrrgr1hermes_cli.commandsrr?rs_plugin_commandsr)rtr1rxrRrcleanrs rregister_commandzPluginContext.register_commandFsH2 ""$$++C0088cBB  NNM "    F  ; ; ; ; ; ;u%%19M&  2    D &:*:m(#/r0022 1 1  &u-  8$-:LeTTTTTs87B22 B?>B? tool_nameargsc ddlm}d|vr(|jj}|rt |ddnd}|||d<|j||fi|S)uDispatch a tool call through the registry, with parent agent context. This is the public interface for plugin slash commands that need to call tools like ``delegate_task`` without reaching into framework internals. The parent agent (if available) is resolved automatically — plugins never need to access the agent directly. Args: tool_name: Registry name of the tool (e.g. ``"delegate_task"``). args: Tool arguments dict (same as what the model would pass). **kwargs: Extra keyword args forwarded to the registry dispatch. Returns: JSON string from the tool handler (same format as model tool calls). rr parent_agentagentN)rrrsrrdispatch)rtrrkwargsrrrs r dispatch_toolzPluginContext.dispatch_tool~su ,+++++  ' '-(C36@GC$///DE ).~& x D;;F;;;rcT|jj'td|jjdSddlm}t||s'td|jjdS||j_t d|jj|jdS)a%Register a context engine to replace the built-in ContextCompressor. Only one context engine plugin is allowed. If a second plugin tries to register one, it is rejected with a warning. The engine must be an instance of ``agent.context_engine.ContextEngine``. NzyPlugin '%s' tried to register a context engine, but one is already registered. Only one context engine plugin is allowed.r) ContextEnginezbPlugin '%s' tried to register a context engine that does not inherit from ContextEngine. Ignoring.z)Plugin '%s' registered context engine: %s) rs_context_enginerrrgr1agent.context_enginerr=info)rtenginers rregister_context_enginez%PluginContext.register_context_engines = ( 4 NNQ "    F666666&-00  NN8 "    F(. % 7 M       rcddlm}ddlm}t ||s't d|jjdS||t d|jj|jdS)a=Register an image generation backend. ``provider`` must be an instance of :class:`agent.image_gen_provider.ImageGenProvider`. The ``provider.name`` attribute is what ``image_gen.provider`` in ``config.yaml`` matches against when routing ``image_generate`` tool calls. r)ImageGenProvider)register_providerzjPlugin '%s' tried to register an image_gen provider that does not inherit from ImageGenProvider. Ignoring.Nz-Plugin '%s' registered image_gen provider: %s) agent.image_gen_providerragent.image_gen_registryrr=rrrgr1r)rtproviderrrs rregister_image_gen_providerz)PluginContext.register_image_gen_providers >=====>>>>>>($455  NN? "    F(### ; M       rlabeladapter_factoryvalidate_config required_env install_hint entry_kwargsrc 0ddlm} m} |d|jj| d||||||pg|dd|} | | |jj |t d|jj|dS) u Register a gateway platform adapter. The adapter_factory receives a ``PlatformConfig`` and returns a ``BasePlatformAdapter`` subclass instance. The gateway calls ``check_fn()`` before instantiation to verify dependencies. Extra keyword arguments are forwarded to ``PlatformEntry`` (e.g. ``setup_fn``, ``emoji``, ``allowed_users_env``, ``platform_hint``). Unknown keys raise TypeError from the dataclass constructor. Example:: ctx.register_platform( name="irc", label="IRC", adapter_factory=lambda cfg: IRCAdapter(cfg), check_fn=lambda: True, emoji="💬", setup_fn=irc_interactive_setup, ) r)platform_registry PlatformEntry plugin_namer)r1rrryrrrrZz!Plugin %s registered platform: %sNrd) gateway.platform_registryrr setdefaultrgr1rrs_plugin_platform_namesrrr) rtr1rrryrrrrrrentrys rregister_platformzPluginContext.register_platforms@ ONNNNNNN t}/ABBB  ++%+%       ""5))) ,00666 / M       r hook_namecallbackc b|tvrLtd|jj|dt t|jj |g |t d|jj|dS)zRegister a lifecycle hook callback. Unknown hook names produce a warning but are still stored so forward-compatible plugins don't break. z4Plugin '%s' registered unknown hook '%s' (valid: %s), zPlugin %s registered hook: %sN) r/rrrgr1joinsortedrs_hooksrappendr)rtrrs r register_hookzPluginContext.register_hooks K ' ' NN " &--..     '' 266==hGGG 4dm6H)TTTTTrr\rcddlm}d|vr td|d|jjd|r||std|d|std ||jjd|}||jj||d |jj |<t d |jj|d S) uRegister a read-only skill provided by this plugin. The skill becomes resolvable as ``':'`` via ``skill_view()``. It does **not** enter the flat ``~/.hermes/skills/`` tree and is **not** listed in the system prompt's ```` index — plugin skills are opt-in explicit loads only. Raises: ValueError: if *name* contains ``':'`` or invalid characters. FileNotFoundError: if *path* does not exist. r) _NAMESPACE_RE:z Skill name 'zG' must not contain ':' (the namespace is derived from the plugin name 'z' automatically).zInvalid skill name 'z'. Must match [a-zA-Z0-9_-]+.zSKILL.md not found at )r\r bare_namerRzPlugin %s registered skill: %sN) agent.skill_utilsr ValueErrorrgr1matchexistsFileNotFoundErrorrs_plugin_skillsrr)rtr1r\rRr qualifieds rregister_skillzPluginContext.register_skill#s0$ 433333 $;;:t::M&:::   =..t44 JtJJJ {{}} E#$CT$C$CDD D})22D22 m(& 3 3  $Y/  , M       r)rgrOrorp)NNFrPrP)r1r2rvr2rwrFrxrryrzrVr{r|r3rRr2r}r2rr~)r)rr2rr2rr3)NrP) r1r2rr2rrrrzrRr2rr~)rPrP) r1r2rxrrRr2rr2rr~)rr2rrFrr2rr~)NNrP)r1r2rr2rrryrrrzrr{rr2rrrr~)rr2rrrr~)rP)r1r2r\rrRr2rr~)r_r`rarbrurrrrrrrrrrrdrrrnrns]GG    %)$(PPPPP>B'+ WWWWW: 4U4U4U4U4Up<<<<>    @    B,0$(4 4 4 4 4 pUUUU. + + + + + + + rrnceZdZdZd/dZd0d1dZ d2d3dZd4dZd5dZd6dZ d7dZ d8dZ d8d Z d9d%Z d:d'Zd;d*Zd PluginManagerz;Central manager that discovers, loads, and invokes plugins.rr~ci|_i|_t|_t|_i|_d|_i|_d|_d|_ i|_ dS)NF) _pluginsrr6rrrrr _discoveredrr)rts rruzPluginManager.__init__Xs]13 13 ,/EE03#.0#13!& 9;rFforcer3c |jr|sdS|r|j|j|j|j|j|jd|_d|_g}t}| | |dhd| | |dz dtdz }| | |d td rCtjd z dz }| | |d | |t#}t%}i}|D]} | || jp| j<|D]I} | jp| j} | |vs | j|vr>t-| d } d| _| |j| <t0d| \| jdkr>t-| d } d| _| |j| <t0d| | jdkr| jdvr|| |duo | |vp| j|v} | sRt-| d } d| | _| |j| <t0d| 4|| K|r^t0dt?|jtAd|jDdSdS)aScan all plugin sources and load each plugin found. When ``force`` is true, clear cached discovery state first so config changes or newly-added bundled backends become visible in long-lived sessions without requiring a full agent restart. NTbundled>memory platformscontext_engine)rZ skip_namesr)rZrrHERMES_ENABLE_PROJECT_PLUGINSz.hermesprojectF)rgrDzdisabled via configzSkipping disabled plugin '%s'rKu<exclusive plugin — activate via .provider configz8Skipping '%s' (exclusive, handled by category discovery))rIrJzBnot enabled in config (run `hermes plugins enable {}` to activate)z&Skipping '%s' (not in plugins.enabled)z/Plugin discovery complete: %d found, %d enabledc3(K|] }|j dVdS)N)rD).0ps r z2PluginManager.discover_and_load..s)CC!CACCCCCCr)!rrclearrrrrrrrextend_scan_directoryrr5rcwd_scan_entry_pointsrArHr^r1valuesrfrlrrr]rZ _load_pluginformatrlensum) rtr manifests repo_pluginsuser_dir project_dirr:rDwinnersrg lookup_keyloaded is_enableds rdiscover_and_loadzPluginManager.discover_and_loadis7   E  F  ( M   ! ! ! K       # ) ) + + +   $ $ & & &  ! ' ' ) ) )   % % ' ' '#'D *, /00    DDD !         !;I N N   #$$y0--hv-FFGGG 7 8 8 R(**y09 >H5=GHL1HM 2 2((: (: (H!6JX%%()B)B%xGGG4 ,2 j) //plugin.yaml``. Key is ```` (e.g. ``disk-cleanup``). * **Category** — ``///plugin.yaml``, where the ```` directory itself has no ``plugin.yaml``. Key is ``/`` (e.g. ``image_gen/openai``). Depth is capped at two segments. *skip_names* is an optional allow-list of names to ignore at the top level (kept for back-compat; the current call sites no longer pass it now that categories are first-class). rPrrprefixdepth)_scan_directory_level)rtr\rZrs rrzPluginManager._scan_directorys,*)) &Z!*   rrrintc ^g}|s|St|D]}|s|dkr |r |j|vr)|dz }|s|dz }|r0|||||} | || |dkrtd||r |d|jn|j} | | ||d| |dz|S) aRecursive implementation of :meth:`_scan_directory`. ``prefix`` is the category path already accumulated ("" at root, "image_gen" one level in). ``depth`` is the recursion depth; we cap at 2 so ``/a/b/c/`` is ignored. rz plugin.yamlz plugin.ymlNrz/Skipping %s (no plugin.yaml, depth cap reached)rr) is_dirriterdirr1r_parse_manifestrrrrr) rtr\rZrrrrchild manifest_filerg sub_prefixs rrz#PluginManager._scan_directory_level s{+- {{}}  DLLNN++! ! E<<>> zzjzUZ:-E-E!M1M '')) 5 % 4 ##%% //!5&&'$$X... zz NPUVVV5;KF11UZ111J   **#%!) +    rr plugin_dirOptional[PluginManifest]c  ttd|dStj|pi}|d|j}|r |d|jn|}|dd}t|tsd}| } | tvrDtd||d ttd} | dkrrd|vrn|d z } | rU | d dd } d | vsd| vrd} td|n#t $rYnwxYwt#|t|dd|dd|dd|dg|dg|dg|t|| | S#t $r'} td|| Yd} ~ dSd} ~ wwxYw)zParse a single ``plugin.yaml`` into a :class:`PluginManifest`. Returns ``None`` on parse failure (logs a warning). Nu'PyYAML not installed – cannot load %sr1rr]rLzBPlugin %s: unknown kind '%s' (valid: %s); treating as 'standalone'r __init__.pyr)errorsi register_memory_providerMemoryProviderrKzAPlugin %s: detected memory provider, treating as kind='exclusive'rQrPrRrSrVrXrY) r1rQrRrSrVrXrYrZr\r]r^zFailed to parse %s: %s)yamlrr safe_load read_textrEr1r=r2rrrMrrrrr?rO) rtrrrZrdatar1r^raw_kindr] init_file source_textexcs rrzPluginManager._parse_manifestEs; |H-XXXt>-"9"9";";<<BD88FJO44D39CV//jo///tCxx 55Hh,, ('>>##))++D...X499V4G-H-H#I#I$|##d(:(:&6 ##%% &/&9&9&9&K&KETE&R 6+EE/;>>#.D"LL!? # %"DHHY3344 HH]B77xx"--!XXnb99#xx(8"==#xx(8"==__        NN3]C H H H44444 sC"H=DH==AFH= F H= FB.H== I.I))I.cg} tj}t|dr|t }n=t |tr|t g}n d|D}|D]9}t|j d|j |j }| |:n2#t$r%}td|Yd}~nd}~wwxYw|S)z7Check ``importlib.metadata`` for pip-installed plugins.selectgroupc2g|]}|jtk|Srdr/ENTRY_POINTS_GROUPreps r z4PluginManager._scan_entry_points..s%PPPB=O1O1OR1O1O1Or entrypoint)r1rZr\r^zEntry-point scan failed: %sN) importlibmetadata entry_pointshasattrr-r2r=rFrErOr1valuerr?rr)rtreps group_epsr4rgr+s rrz PluginManager._scan_entry_pointss%*,  =$1133CsH%% QJJ-?J@@ C&& QGG$6;; PP#PPP  + +)'    **** + = = = LL6 < < < < < < < < =sCC C7C22C7rgrOc6t} jdvr}n}||_t |dd}|(d|_tdj nt}||fdj D|_ tdjDd jDz |_fd jD|_d |_nL#t*$r?}t-||_td j |Yd}~nd}~wwxYw|jjpj <dS) z?Import a plugin module and call its ``register(ctx)`` function.)rg)rrrrNzno register() functionz&Plugin '%s' has no register() functionc^g|])}|djDv'|*S)c,h|]\}}|jD]}|Srd)ri)rr1rns r z8PluginManager._load_plugin...sF!!!#D!!"!3!!!!!!r)ritems)rtrts rr5z.PluginManager._load_plugin..s`+++!!'+}':':'<'<!!!rch|] \}}|| Srdrd)rhcbss rrBz-PluginManager._load_plugin..s2"Asrc,h|]\}}|jD]}|Srd)rj)rr1rrFs rrBz-PluginManager._load_plugin..sF#D!!"!3rcfg|]-}j|djk+|.S)r)rrEr1)rcrgrts rr5z.PluginManager._load_plugin..sF...,Q/33H==NNNNNrTzFailed to load plugin '%s': %s)rfrZ_load_directory_module_load_entrypoint_modulerhrrlrrr1rnrrir>rrCrrjrrkrDr?r2r^)rtrgr rh register_fnctxr+s`` rrzPluginManager._load_pluginsx000, Q"@@@44X>>55h??"FM"&*d;;K"7 GWWWW#Hd33 C   ++++#6+++'+/&*k&7&7&9&9 '+}':':'<'<  + +'.....#4...*"& Q Q Qs88FL NN;X]C P P P P P P P P Q8> hl3hm444sD"D77 F5E;;Ftypes.ModuleTypect|j}|dz }|std|tt jvr@tjt}g|_ t|_ |t jt<|j p|j }| dd dd}td|}tj||t#|g}||jt'd |tj|} || _ t#|g| _ | t j|<|j| | S) a/Import a directory-based plugin as ``hermes_plugins.``. The module slug is derived from ``manifest.key`` so category-namespaced plugins (``image_gen/openai``) import as ``hermes_plugins.image_gen__openai`` without colliding with any future ``tts/openai``. r zNo __init__.py in r__r_.)submodule_search_locationsNzCannot create module spec for )rr\rr _NS_PARENTsysmodulestypes ModuleType__path__ __package__r^r1rr7utilspec_from_file_locationr2loader ImportErrormodule_from_spec exec_module) rtrgrr)ns_pkgr^slug module_namespecrhs rrKz$PluginManager._load_directory_modulesn(-(( . !! G#$E$E$EFF F S[ ( (%j11F FO!+F &,CK #l+hm{{3%%--c377#,,d,, ~55  (+J'86   <4;.JyJJKK K0066(z??+#) K  ''' rctj}t|dr|t }n=t |tr|t g}n d|D}|D](}|j |j kr| cS)td|j dt d)z:Load a pip-installed plugin via its entry-point reference.r-r.c2g|]}|jtk|Srdr1r3s rr5z9PluginManager._load_entrypoint_module..s%LLLRX9K-K-K-K-K-Krz Entry point 'z' not found in group '') r7r8r9r:r-r2r=rFrEr1loadr_)rtrgr<r=r4s rrLz%PluginManager._load_entrypoint_module s --// 3 ! ! M ); <$o4%~ !899 !899 #F$> ? ?#\       rqualified_nameOptional[Path]cN|j|}|r|dndS)z>Return the ``Path`` to a plugin skill's SKILL.md, or ``None``.r\N)rrE)rtryrs rfind_plugin_skillzPluginManager.find_plugin_skill`s+#''77 %/uV}}4/rrrWcr|dtfd|jDS)zCReturn sorted bare names of all skills registered by *plugin_name*.rc3XK|]$\}}||dV%dS)rN) startswith)rqners rrz3PluginManager.list_plugin_skills..hsQ  A}}V$$ kN      r)rrrC)rtrrs @rlist_plugin_skillsz PluginManager.list_plugin_skillsesX"""    ,2244      rc<|j|ddS)z>Remove a stale registry entry (silently ignores missing keys).N)rpop)rtrys rremove_plugin_skillz!PluginManager.remove_plugin_skillns! 55555rrFrr3rr~rr)r\rrZr2rrrr) r\rrZr2rrrr2rrrr) rrrrrZr2rr2rr)rr)rgrOrr~)rgrOrrOrr2rrrrj)rrr)ryr2rrz)rr2rrW)ryr2rr~)r_r`rarbrur rrrrrrKrLrqrxr|rrrdrrrrUsPEE < < < <"EEEEE^*.      26666pFFFFX<2>2>2>2>h$$$$L    ,""""P20000     666666rrzOptional[PluginManager]_plugin_managerc:ttatS)z>Return (and lazily create) the global PluginManager singleton.)rrrdrrget_plugin_managerrzs'// rFrr~cJt|dS)zDiscover and load all plugins. Default behavior is idempotent. Pass ``force=True`` to rescan plugin manifests and reload state in the current process. rNrr rs rdiscover_pluginsrs' ***77777rrrrrjc 6tj|fi|S)z|Invoke a lifecycle hook on all loaded plugins. Returns a list of non-``None`` return values from plugin callbacks. )rrq)rrs rrqrqs& ,    +I @ @ @ @@rrPrrOptional[Dict[str, Any]]task_id session_id tool_call_idr[c(td|t|tr|ni|||}|D]b}t|ts|ddkr2|d}t|tr|r|cScdS)aCheck ``pre_tool_call`` hooks for a blocking directive. Plugins that need to enforce policy (rate limiting, security restrictions, approval workflows) can return:: {"action": "block", "message": "Reason the tool was blocked"} from their ``pre_tool_call`` callback. The first valid block directive wins. Invalid or irrelevant hook return values are silently ignored so existing observer-only hooks are unaffected. r!)rrrrractionblockmessageN)rqr=rFrEr2)rrrrr hook_resultsrwrs rget_pre_tool_call_block_messagers$d++ 3TT! L&$''   ::h  7 * * **Y'' gs # #  NNN 4rcNt}|||S)zReturn the global manager after ensuring plugin discovery has run. Pass ``force=True`` to rescan in the current process. rr)rros r_ensure_plugins_discoveredrs+ !""G E*** Nrc(tjS)z5Return the plugin-registered context engine, or None.)rrrdrrget_plugin_context_enginers % ' ' 77rOptional[Callable]cftj|}|r|dndS)zFReturn the handler for a plugin-registered slash command, or ``None``.rxN)rrrE)r1rs rget_plugin_command_handlerrs3 & ( ( 9 = =d C CE$ .5  $.rg>@rwctjsS tjn$#t$rtjcYSwxYwiit jd fd }t j|dd}|  tstdtd d d vrd  d S)aResolve a plugin command return value, awaiting async handlers when needed. Sync CLI/TUI dispatch sites call plugin handlers from plain functions. If a handler is async, await it directly when no loop is running; if we're already inside an active loop, run it in a helper thread with its own loop so the caller still gets a concrete result synchronously. The threaded path is bounded by a 30s timeout so a hung async handler cannot wedge the terminal indefinitely. rr~c tjd<n#t$r}|d<Yd}~nd}~wwxYwdS#wxYw)Nr;r+)asynciorun BaseExceptionr6)r+donefailureoutcomerws r_runnerz.resolve_plugin_command_result.._runnersv &{622GG   ! ! ! GENNNNNN ! HHJJJJJDHHJJJJs%A 4/A 4A A#zhermes-plugin-command-awaitT)targetr1daemon)timeoutz5Plugin command async handler did not complete within z.0fsr+r;r)inspect isawaitablerget_running_loop RuntimeErrorr threadingEventThreadstartwait"_PLUGIN_COMMAND_AWAIT_TIMEOUT_SECS TimeoutErrorrE)rwrthreadrrrs` @@@rresolve_plugin_command_resultrsK  v & & # """" ###{6"""""#!G(*G ?  D  *F  LLNNN 99?9 @ @  91 8 9 9 9    en ;;w  s0AADict[str, dict]c(tjS)uReturn the full plugin commands dict (name → {handler, description, plugin}). Triggers idempotent plugin discovery so callers can use plugin commands before any explicit discover_plugins() call. )rrrdrrget_plugin_commandsrs & ' ' 88r List[tuple]cDt}|jsgS ddlm}n#t$rgcYSwxYwi}i}|jD]O}||}|s|j}||g|j P|j D]J\}}|j D]=}||}|r$|j|vr||j|>Kg} t|D]} || } d| dd} | r| jjr | jj} n(dt|| } | | | | f| S)zReturn plugin toolsets as ``(key, label, description)`` tuples. Used by the ``hermes tools`` TUI so plugin-provided toolsets appear alongside the built-in ones and can be toggled on/off per platform. rru🔌 rRrr)rrrrr? get_entryrvrrr1rrCrirrErtitlergrRr)ror toolset_toolstoolset_pluginrrts_namer rwts_keyrrdescs rget_plugin_toolsetsr s !""G  % +++++++  +-M.0N/<< ""9--   ]  R((// ;;;;!)//11AA v0 A AI&&y11E A-77))%-@@@ A F''--##F++:sC006688::  rb __future__rrr7importlib.metadataimportlib.utilrloggingrrVrrX dataclassesrrpathlibrtypingrrr r r r r hermes_constantsrutilsrr<rrr$r_ getLoggerr_rr/rcr2rUr5rArHrMrOrfrnrrrrrqrrrrrrrrrdrrrsB#"""""  ((((((((BBBBBBBBBBBBBBBBBB,,,,,,!!!!!!%%%%%% > > > >KKKK DDD  8 $ $ $$$ $$$$L,  !!!!     D!S R RRRRR !!!!!!! !H            e e e e e e e e X [6[6[6[6[6[6[6[6D,0////88888AAAA $$$$$N888 //// &*"+ + + + \9999******s)A..A87A8