i dZddlZejjddddlZddlZddlZddlmZddl m Z ddl m Z ejeZedZ dded ed ed efd Zded ed ed dfdZy)u AIVA RLM Nexus — pre_call_hook Standalone async function called on every call.initiated webhook event. Triggers BinduHydrator and returns the context envelope. Story 4.06 — Track A File: core/hydrators/pre_call_hook.py Nz/mnt/e/genesis-system)Path)Optional) BinduHydratorz5/mnt/e/genesis-system/data/observability/events.jsonl session_idcall_id caller_numberreturncKtj}|6 |jd|d|d{tj d||t|||}|j||d{|j||d{} tj|z dz} t||| tjd||| | S7#t $r!}tj d||Yd}~d}~wwxYw77vw) a! Called on every call.initiated webhook. Steps: 1. Stores caller_number in Redis aiva:state:{session_id} via HSET 2. Instantiates BinduHydrator with injected clients (never a singleton) 3. Calls start_hydration(session_id, call_id) 4. Calls gather_and_assemble(session_id, call_id) 5. Logs timing to data/observability/events.jsonl 6. Returns the ROYAL_CHAMBER_CONTEXT XML envelope string All clients are injected as parameters so the function is fully testable without real infrastructure. Args: session_id: Unique identifier for this hydration cycle. call_id: Telnyx call_control_id (or internal call UUID). caller_number: E.164 phone number of the incoming caller. redis_client: Optional async Redis client (must support hset/setex/get). postgres_client: Optional psycopg2 connection pool (getconn/putconn). qdrant_client: Optional async Qdrant client. Returns: ROYAL_CHAMBER_CONTEXT XML envelope as a string. Nz aiva:state:rz9pre_call_hook: stored caller_number '%s' in aiva:state:%suDpre_call_hook: Redis HSET failed for session '%s': %s — proceeding) redis_clientpostgres_client qdrant_clientiz5pre_call_hook: session=%s call=%s completed in %.1fms) time monotonichsetloggerdebug Exceptionerrorrstart_hydrationgather_and_assemble _log_timinginfo) rrrr r r startexchydrator xml_envelope elapsed_mss 5/mnt/e/genesis-system/core/hydrators/pre_call_hook.py pre_call_hookrs'B NN E ##j\*   LLK !'#H  " ":w 777"55j'JJL.."U*d2J GZ0 KK?  W   LLV    8Ks]DCCC#D2D3D D ADC C>C94D9C>>DDrcd||t|dd} tjjddtj dd5}|j t j|d zd d d tjd |ty #1swY%xYw#t$r }tjd |Yd }~y d }~wwxYw) uV Append a JSON timing event to EVENTS_PATH (data/observability/events.jsonl). Each line is a valid JSON object: { "event": "pre_call_hook_complete", "session_id": "...", "call_id": "...", "elapsed_ms": 123.4 } File I/O failure is NON-FATAL — a timing log should never crash a call. pre_call_hook_complete)eventrrrT)parentsexist_okazutf-8)encoding Nz1_log_timing: appended timing event (%.1fms) to %suH_log_timing: failed to write events.jsonl: %s — timing event discarded) round EVENTS_PATHparentmkdiropenwritejsondumpsrrrr)rrrr#fhrs rrrms* J*  E     =   cG  4 / HHTZZ&- . / ?    / /   V    s/8B# (B3#B#B B## C ,CC )NNN)__doc__syspathinsertr/loggingrpathlibrtypingrcore.hydrators.bindu_hydratorr getLogger__name__rr*strrfloatrrr@s *+  7   8 $JK  QQ QQ Qh! C! #! 5! T! r?