iUdZddlmZddlZddlZddlmZmZddlm Z e e Z GddZ e eefZGdd Zdad ed <dd Zddd Zy)uG utils/event_hooks.py — 이벤트 훅 시스템 이벤트를 emit하면 등록된 핸들러를 순서대로 호출한다. - 동기/비동기 핸들러 자동 감지 - 와일드카드 매칭 (dispatch:* → dispatch:start, dispatch:end …) - 핸들러 예외 격리 (catch + log, 메인 파이프라인 블록 안 함) - 디렉토리 기반 동적 로드 (HOOK.yaml + handler.py) Usage: from utils.event_hooks import Event, get_registry, emit reg = get_registry() reg.register(Event.DISPATCH_START, my_handler) await emit(Event.DISPATCH_START, {"key": "value"}) ) annotationsN)AnyCallable) get_loggerceZdZUdZdZded<dZded<dZded<d Zded <d Z ded <d Z ded<dZ ded<dZ ded<dZ ded<y)Eventu이벤트 타입 상수 모음.zdispatch:startstrDISPATCH_STARTz dispatch:end DISPATCH_ENDzdispatch:errorDISPATCH_ERRORz session:start SESSION_STARTz session:end SESSION_ENDz agent:step AGENT_STEPzsecurity:blockSECURITY_BLOCKz security:warn SECURITY_WARNz skill:install SKILL_INSTALLN)__name__ __module__ __qualname____doc__r __annotations__r r r rrrrrB/home/jay/workspace/.worktrees/task-2116-dev1/utils/event_hooks.pyrr"s_)*NC*&L#&*NC*(M3($K$"J"*NC*(M3((M3(rrcFeZdZdZd dZd d dZd dZd ddZd ddZddZ y) HookRegistryu$이벤트 핸들러 레지스트리.ci|_yN) _handlers)selfs r__init__zHookRegistry.__init__:s 8:rc||jvrg|j|<||xst|dt|d}|j|j|tj d|d|y)ua핸들러를 이벤트 타입에 등록한다 (와일드카드 포함 가능, e.g. "dispatch:*").r)fnnamez&Registered handler '%s' for event '%s'r$N)rgetattrreprappendloggerdebug)r event_typehandlerr$infos rregisterzHookRegistry.registerBsg T^^ +)+DNN: &$+T5hWWjZ^_fZg=hi z"))$/ =tF|ZXrcg}|jjD]2\}}||k(stj||s"|j|4|S)u^event_type에 매칭되는 모든 핸들러를 반환한다 (정확 매칭 + 와일드카드).)ritemsfnmatchextend)r r*resultpatternhandlerss r_matching_handlerszHookRegistry._matching_handlersNsP%'!%!5!5!7 ( GX*$ G(L h' ( rNc K|j|D];}|d}|d} tj|r||d{n||=y7#t$r$}tj d|||dYd}~id}~wwxYww)uZ비동기 이벤트를 발생시킨다. 핸들러 예외는 격리되어 log만 남긴다.r#r$Nz8Hook handler '%s' for event '%s' raised an exception: %sTexc_info)r5asyncioiscoroutinefunction Exceptionr(warning)r r*contextr,r# handler_nameexcs remitzHookRegistry.emitZs++J7 DdBr?s r emit_synczHookRegistry.emit_syncqs  ++-D   1// ; $Z#F|  2226--bkE7  $ KK *g6 7/ D !NNQ$"!% #s)B+;B<+ B98B9< C)C$$C)c"ddlm}|||y)u 디렉토리를 순회하여 HOOK.yaml + handler.py 기반 훅을 동적으로 로드한다. 실제 로직은 utils.event_hooks_loader.discover_hooks에 위임한다. Args: hooks_dir: 훅 서브디렉토리들이 위치한 상위 디렉토리 경로 r)discover_hooksN)utils.event_hooks_loaderrJ)r hooks_dirrJs rdiscover_and_loadzHookRegistry.discover_and_loads <tY'r)returnNone))r*r r+zCallable[..., Any]r$r rNrO)r*r rNzlist[_HandlerInfo]rr*r r=rrNrO)rLr rNrO) rrrrr!r-r5r@rHrMrrrrr7s%.;Y.8H (rrzHookRegistry | None _registryc.t tatS)u;프로세스 전역 싱글턴 HookRegistry를 반환한다.)rRrrrr get_registryrTs N rcTKtj||d{y7w)uV전역 싱글턴 레지스트리를 통해 이벤트를 발생시키는 편의 함수.N)rTr@)r*r=s rr@r@s .  j' 222s (&()rNrrrQ)r __future__rr9r0typingrr utils.loggerrrr(rdictr _HandlerInforrRrrTr@rrrr[sb"# # H  ) )$CH~ h(h(^"& %3r