ei~dZddlZddlZddlmZmZmZmZm Z ddl Z ddl m Z e dz Z GddZdS)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. 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 //home/div/.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_hooks1sD&'''rNc ddlm}|jdg||jdddgddd S#t $r}td|d Yd }~d Sd }~wwxYw) z/Register built-in hooks that are always active.r)handlezgateway:startupzboot-mdz(Run ~/.hermes/BOOT.md on gateway startupz (builtin)name descriptioneventspathz.[hooks] Could not load built-in boot-md hook: TflushN)gateway.builtin_hooks.boot_mdrr setdefaultappendr Exceptionprint)rboot_md_handlees r_register_builtin_hooksz$HookRegistry._register_builtin_hooks6s T N N N N N N N % %&7 < < C CN S S S   % %!I,-# ''       T T T F1FFd S S S S S S S S S S TsAA B"A<<Bc Z|tsdSttD]S}|s|dz }|dz }|r|sK t j|d}|rt|tstd|j dd | d |j }| d g}|std|d d tjd ||}||jtd|dd 2tj|}|j|t)|dd} | td|dd |D]0} |j| g| 1|j|| dd|t3|dtd|d|d !#t4$r'} td|j d| d Yd} ~ Md} ~ 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.yamlTr rrz: no events declared hermes_hook_z: could not load handler.pyrz: no 'handle' function foundrrz[hooks] Loaded hook 'z' for events: zooks] Error loading hook z: )r) HOOKS_DIRexistssortediterdiris_diryaml safe_load read_text isinstancedictr&rget importlibutilspec_from_file_locationloadermodule_from_spec exec_modulegetattrrr#r$rstrr%) rhook_dir manifest_path handler_pathmanifest hook_namerspecmodule handle_fneventr(s rdiscover_and_loadzHookRegistry.discover_and_loadEs+ $$&&&!!  Fy0022334 V4 VH??$$ ${2M#l2L '')) 1D1D1F1F * V>-*A*A7*A*S*STTz(D'A'APhmPPPX\]]]]$LL?? !h33MiMMMUYZZZZ!~==.9.. <4;#6TiTTT\`aaaa"88>> ''///#FHd;; $UiUUU]abbbb$KKEN--eR88?? JJJJ"))%#+<< r#B#B$MM ++OiOOvOOW[\\\\\ V V VHHMHHQHHPTUUUUUUUUU Vg4 V4 Vs5"AI7`` 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. NrVrWTr )rSrXrYr$r%r&)rrKrTresultsrZr[r(s 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__rpropertyrr7rr)rJr@rrSrrrr\r_rrr r "sB,,, (d4j(((X( T T T TCVCVCVCVJ C DN    WWSW8DcN3KWW[WWWW8-1$sCx.) c rr )rcrXimportlib.utilr9typingrrrrrr3hermes_cli.configrr.r rerrris*66666666666666 ------ O   ' iiiiiiiiiir