"iY-dZddlZddlZddlZddlZddlZddlmZmZddlm Z ddl m Z ddl Z ejeZdZe dZdZd ZGd d Zy) uRLMCaptureAgent — async agent loop for capturing call transcripts. Story 3.05 — AIVA RLM Nexus PRD v2 — Track A Story 3.06 — Transcript Fetch + Speaker Labeling (extends 3.05) N)datetimetimezone)Path)Optionalz'https://api.telnyx.com/v2/ai/assistantsz(/mnt/e/genesis-system/data/observabilityic eZdZdZ ddedededdfdZddZdefd Zdd Z de e fd Z dd Z dd ede e ddfdZy)RLMCaptureAgentu Async capture loop that polls for call-ended signal. Designed to run as a background asyncio task during active calls. The agent polls Redis every POLL_INTERVAL_SECONDS seconds looking for the key ``aiva:state:{session_id}`` to contain ``{"status": "ended"}``. When detected — or when MAX_RUNTIME_SECONDS elapses — the loop exits cleanly and logs a stop event. Any Redis failure is treated as fail-safe: the agent keeps running (returns False from _is_call_ended). N session_idcall_control_idcall_directionreturnc||_||_||_||_d|_d|_d|_d|_d|_y)NTr) r r _redisr _running _started_at_consecutive_failures _chunk_index_last_transcript_text)selfr r redis_clientr s 6/mnt/e/genesis-system/core/agents/rlm_capture_agent.py__init__zRLMCaptureAgent.__init__&sI%." ," ,0*+"!"*,"cVKtj|_|jd|jrtj|jz }|t k\r|jdd|inp|j d{r|jdnF|jd{tjtd{|jrd|_|jddtj|jz iy77o7Pw) u_ Main loop. Runs until call ended or max runtime exceeded. - Polls every POLL_INTERVAL_SECONDS (30 s) - Checks Redis ``aiva:state:{session_id}`` for ``{"status": "ended"}`` to stop - Max runtime: MAX_RUNTIME_SECONDS (3600 s) — zombie guard - Returns normally (no exception) after stopping agent_startedzombie_guard_triggeredelapsed_secondsNcall_ended_detectedF agent_stopped total_seconds) time monotonicr _log_eventrMAX_RUNTIME_SECONDS_is_call_ended_capture_cycleasynciosleepPOLL_INTERVAL_SECONDS)relapseds rrunzRLMCaptureAgent.run8s >>+ (mmnn&)9)99G-- 8;Lg:VW((*** 56%%' ' '-- 56 6 6!mm$    dnn.1A1AA B + ( 7s<B D) D# )D)5D%6 D)D'D)(clientr^payloadexcrDrElatestrGrRtranscript_textrQchunks r_fetch_and_label_chunkz&RLMCaptureAgent._fetch_and_label_chunkss***..!126q 1*4+?+?*@ B 'wi0.   ((6 * *&!'C!AA))+"--/ * *(1 ;;vw/D0:$/Etxx +4HJx63x=1;L!"zz&&1zz)R03=T42HDHH\2.b '&t111)-D &{" $$ 2!$YY["#00 E    " LC *A * * * *%%  OOOeS\ :$$  OO" # 8 8E   OOME3< 8 l  OO/ 0 sA J!G2(G)G2,GG$G( G23G4G29B%JJ!J%J!&J5J!6AJJ!G2GG2G/"G% #G/*G22'I>J!I>-)IJ! I>;J!=I>>J!JJ!JJ!c8K |jd{}|yd|j } |jj|tj|d{d|_y7V#t$r}|xjdz c_tj d|j |j||jdk\r+tj d|j |jYd}~yd}~wwxYw7#t$r}|xjdz c_tj d||j |j||jdk\r0tj d|j |jYd}~yYd}~yd}~wwxYww) u One capture cycle called every 30 s from the run() loop. 1. Call _fetch_and_label_chunk() to get the latest transcript chunk. 2. If a chunk is returned: RPUSH it (as JSON) to ``aiva:transcript:{session_id}`` in Redis. 3. If _fetch_and_label_chunk() returns None: no-op (normal — no new content). 4. Any exception (from fetch OR from Redis RPUSH) is caught, logged as a warning, and the agent continues running — NEVER raises. 5. After 3 consecutive failed cycles: log at ERROR level (escalation signal). 6. A successful cycle resets the consecutive-failure counter to 0. NrTzUrlm_capture: _fetch_and_label_chunk raised unexpectedly (session=%s, failures=%d): %suTrlm_capture: 3+ consecutive failures (session=%s, failures=%d) — escalation signalzaiva:transcript:rzHrlm_capture: Redis RPUSH failed for key=%s (session=%s, failures=%d): %s) rjr3rloggerwarningr errorrrpushr1dumps)rrirf redis_keys rr'zRLMCaptureAgent._capture_cycless 5577E( = 't&78  ++##Itzz%/@A A A)*D &;8   & &! + & NN0**  ))Q. (OO..  # 4 B   & &! + & NN0**  ))Q. (OO.. / szFA0A.A0F2D!D" D-F.A00 C>9A;C94F9C>>FD F A137 21 5)D01 2 2 2   s0B C (B=4C =CC C CC)Ninbound)r N)N)__name__ __module__ __qualname____doc__strrr,boolr&r8rr`rjr'r$rrr r s ' ---  -  -$# Jd$ehtneN<|S$4rr )rr(r1loggingrVr"rrpathlibrtypingrrY getLoggerrrmrXr|r%r*r rrrrsa   '   8 $; < = MMr