yj #dZddlZddlZddlZddlmZmZmZm Z m Z ddl Z ddl m Z e dz ZGddZdS)a  Event Hook System A lightweight event-driven system that fires handlers at key lifecycle points. Hooks are discovered from ~/.hermes/hooks/ directories, each containing: - HOOK.yaml (metadata: name, description, events list) - handler.py (Python handler with async def handle(event_type, context)) Events: - gateway:startup -- Gateway process starts - session:start -- New session created (first message of a new session) - session:end -- Session ends (user ran /new or /reset) - session:reset -- Session reset completed (new session entry created) - agent:start -- Agent begins processing a message - agent:step -- Each turn in the tool-calling loop - agent:end -- Agent finishes processing - command:* -- Any slash command executed (wildcard match) Errors in hooks are caught and logged but never block the main pipeline. Context dict passed to ``agent:start`` / ``agent:end`` handlers: platform -- source platform name (e.g. "telegram", "matrix", "slack") user_id -- platform user id of the sender chat_id -- platform chat id (group/DM identifier) thread_id -- Telegram forum-topic id / thread root id (string; empty when not in a thread / topic) chat_type -- "dm" | "group" | "forum" (empty if unknown) session_id -- Hermes session id message -- inbound message text (truncated to 500 chars) ``agent:end`` adds: response -- agent response text (truncated to 500 chars) model -- model name that handled the turn provider -- provider that handled the turn Handlers posting a follow-up into the same Telegram forum-topic should include ``message_thread_id=int(thread_id)`` when ``chat_type == "forum"`` and ``thread_id`` is non-empty. N)AnyCallableDictListOptional)get_hermes_homehooksceZdZdZdZedeefdZd dZ d dZ de dee fd Z dde d eee efddfd Z dde d eee efdeefd ZdS) HookRegistryz Discovers, loads, and fires event hooks. Usage: registry = HookRegistry() registry.discover_and_load() await registry.emit("agent:start", {"platform": "telegram", ...}) c"i|_g|_dSN) _handlers _loaded_hooksselfs 3/home/ragecks/.hermes/hermes-agent/gateway/hooks.py__init__zHookRegistry.__init__@s46)+returnc*t|jS)z'Return metadata about all loaded hooks.)listrrs r loaded_hookszHookRegistry.loaded_hooksEsD&'''rNcdS)uRegister built-in hooks that are always active. Currently empty — no shipped built-in hooks. Kept as the extension point for future always-on gateway hooks so they drop in without re-plumbing discover_and_load(). Nrs r_register_builtin_hooksz$HookRegistry._register_builtin_hooksJs  rc |tsdSttD]}|s|dz }|dz }|r|sK t j|d}|rt|tstd|j dd | d |j }| d g}|std|d d d |}tj||}||jtd|dd 4tj|} | t&j|< |j| n/#t,$r"t&j|dwxYwt1| dd} | td|dd |D]0} |j| g| 1|j|| dd|t;|dtd|d|d c#t,$r'} td|j d| d Yd} ~ d} ~ wwxYwdS)aI Scan the hooks directory for hook directories and load their handlers. Also registers built-in hooks that are always active. Each hook directory must contain: - HOOK.yaml with at least 'name' and 'events' keys - handler.py with a top-level 'handle' function (sync or async) Nz HOOK.yamlz handler.pyzutf-8)encodingz[hooks] Skipping z: invalid HOOK.yamlTflushnameeventsz: no events declared hermes_hook_z: could not load handler.pyhandlez: no 'handle' function found description)r r$r!pathz[hooks] Loaded hook 'z' for events: zooks] Error loading hook z: )r HOOKS_DIRexistssortediterdiris_diryaml safe_load read_text isinstancedictprintr get importlibutilspec_from_file_locationloadermodule_from_specsysmodules exec_module Exceptionpopgetattrr setdefaultappendrstr) rhook_dir manifest_path handler_pathmanifest hook_namer! module_namespecmodule handle_fneventes rdiscover_and_loadzHookRegistry.discover_and_loadSs~ $$&&&!!  Fy002233@ V@ VH??$$ ${2M#l2L '')) 1D1D1F1F 6 V>-*A*A7*A*S*STTz(D'A'APhmPPPX\]]]]$LL?? !h33MiMMMUYZZZZ9Y88  ~==<4;#6TiTTT\`aaaa"88>>+1 K(K++F3333 KOOK666$FHd;; $UiUUU]abbbb$KKEN--eR88?? JJJJ"))%#+<< r#B#B$MM ++OiOOvOOW[\\\\\ V V VHHMHHQHHPTUUUUUUUUU V@ V@ VsL"AJ9`` policies that want to allow/deny/rewrite the command before normal dispatch). Exceptions from individual handlers are logged but do not abort the remaining handlers. NrXrYTr)rUrZr[r?r;r1)rrMrVresultsr\r]rKs r emit_collectzHookRegistry.emit_collects ?G((44 W WB WJ00&v..*#)\\\\\\F%NN6*** W W WIzIIaIIQUVVVVVVVVV Ws?A!! B +BB )rNr )__name__ __module__ __qualname____doc__rpropertyrr0rrrLr@rrUrrrr^rarrrr r 6s>,,, (d4j(((X(OVOVOVOVb C DN    WWSW8DcN3KWW[WWWW8-1$sCx.) c rr )rerZimportlib.utilr3r8typingrrrrrr,hermes_cli.configrr'r rrrrjs&&P 66666666666666 ------ O   ' oooooooooor