i dZddlZddlmZmZddlmZddlmZmZddl m Z e Z ded dfd Z dd e d eed ee d e fdZd e d e fdZy)u Genesis Persistent Context Architecture — Interceptors Package Story 1.03 — Track B Exports: BaseInterceptor, InterceptorMetadata — abstract base + metadata dataclass InterceptorChain — ordered execution engine GLOBAL_CHAIN — module-level singleton chain register_interceptor() — convenience helper to add to GLOBAL_CHAIN dispatch_to_swarm() — central dispatch function N)datetimetimezone)Optional)BaseInterceptorInterceptorMetadata)InterceptorChain interceptorreturnc.tj|y)zCConvenience helper: add an interceptor to the process-global chain.N) GLOBAL_CHAINregister)r s 3/mnt/e/genesis-system/core/interceptors/__init__.pyregister_interceptorrs+& task_payloadtiercontextcKd|vr ttj|d<tjt j j|d<|||d<|d} tj|d{}t|d{}tj||d{i||ddS7>7-7#t$r/}tj||d{7}|d|dcYd}~Sd}~wwxYww) aCentral dispatch function. Assigns a UUID4 task_id if one is not already present, stamps ``dispatched_at`` in UTC ISO-8601, optionally tags the payload with ``tier``, then runs the interceptor chain pre/post hooks around the internal task executor. Returns a result dict that always includes ``task_id`` and ``status``. On success: ``{"status": "completed", "task_id": ..., ...}`` On error: ``{"status": "error", "task_id": ..., "correction": ...}`` task_id dispatched_atNr completed)rstatuserror)rr correction)struuiduuid4rnowrutc isoformatr execute_pre _execute_task execute_post Exception execute_error)rrrrenrichedresultexcrs rdispatch_to_swarmr*s" $"%djjl"3 Y$,LL$>$H$H$JL! # V9%GQ%11,??$X..''999D&DW DD@.9 Q'55c<HHH "gZPPQsxA%D(CB?CCC1C2 C>D?CCC C=C8'C*( C82C=3D8C==DcVK|jdd|jddddSw)uStub executor — passthrough until real Gemini/Opus dispatch is wired in. Returns the prompt text (if present) as ``output``. Will be replaced by the real execution layer in a later story. runknownpromptr)routputr)get)rs rr#r#As5 ##Iy9""8R0 s'))NN)__doc__rrrtypingrbase_interceptorrrinterceptor_chainr r rdictrr*r#rrr7s  'B/  ! 'o'$'" Q Q 3- Qd^ Q QF d t r