oi]XdZddlZddlmZGddZdefdZdefdZd edefd Z y) u# AIVA RLM Nexus PRD v2 — Story 4.07 Track A: ConversationReplayEngine — Last N Conversations Summary Queries royal_conversations, formats N most recent Kinan<>AIVA conversations into a concise human-readable string for system prompt injection. File: core/memory/conversation_replay.py N)Optionalc:eZdZdZddZd dedefdZdedefdZ y) ConversationReplayEngineu Queries royal_conversations, formats N most recent conversations into a concise summary for system prompt injection. Uses the getconn/putconn pattern against a psycopg2 connection pool. All SQL uses parameterised %s placeholders — never f-strings in SQL. Nc||_y)z Args: postgres_pool: A psycopg2 connection pool (SimpleConnectionPool or ThreadedConnectionPool). If None, get_recent_summary() returns an empty string gracefully. N)_pool)self postgres_pools 8/mnt/e/genesis-system/core/memory/conversation_replay.py__init__z!ConversationReplayEngine.__init__s # nreturncNK|jy|dkryd} |jj}|j||} | |jj ||syg}|D]!}t |}|s|j |#|syddj|zS#t$r1Y|, |jj |y#t$rYywxYwywxYw#t$rYwxYw#|, |jj |w#t$rYwwxYwwxYww)a! Fetches last N royal_conversations where kinan participated. Queries royal_conversations with: participants->>'kinan' = 'true' ORDER BY started_at DESC LIMIT %s Returns a human-readable string such as: RECENT CONTEXT: [2026-02-24] Call (18min): George's Cairns number checked. Action: Follow up. [2026-02-23] Call (6min): Voice widget confirmed live. Kinan happy. Returns empty string (never None) when: - No conversations exist - postgres_pool is None - Any database error occurs Args: n: Number of recent conversations to fetch (default 3, must be >= 1). Returns: Formatted string with RECENT CONTEXT header, or "" if nothing found. NzRECENT CONTEXT:  )rgetconn _fetch_rows Exceptionputconn _format_rowappendjoin)rr connrowslinesrowlines r get_recent_summaryz+ConversationReplayEngine.get_recent_summary(sN0 ::  q5 ::%%'D##D!,DJJ&&t, #Cs#D T" # "TYYu%555+ JJ&&t,    !JJ&&t,  sD%,B&D% C#$D%<*D%& C /C20D%3CD% CD%CD%C  C2# C/,D%.C//D%2D"6DD" DD"DD""D%c &d}|j5}|j||f|jDcgc]}|d }}|jDcgc]}t t ||c}cdddScc}wcc}w#1swYyxYw)a  Execute parameterised SELECT against royal_conversations. Uses LIMIT %s (not Python slice) so the database does the bounding. Returns a list of dict-like rows, each containing: started_at, ended_at, summary, action_items zSELECT started_at, ended_at, summary, action_items FROM royal_conversations WHERE participants->>'kinan' = 'true' ORDER BY started_at DESC LIMIT %srN)cursorexecute descriptionfetchalldictzip)rrr _SQLcurdesccolumnsrs r rz$ConversationReplayEngine._fetch_rowses  [[] Gc KKqd #+.??;4tAw;G;7:||~FDWc*+F G G;F G Gs("B A=BB1B= BB)N)) __name__ __module__ __qualname____doc__r intstrrlistrr r rrs6#76#76c76zG3G4Gr rrcx|y ||z }t|j}|dz}|dS#t$rYywxYw)u Return a human-readable duration string. If ended_at is None → "ongoing" Otherwise → "Xmin" where X is the integer number of minutes (rounded down). ongoing<min)r0 total_secondsr) started_atended_atdeltar8minutess r _format_durationr=~sW:%E//12 2%# s '- 99cN|y|}t|tr-|j}|r|dvry tj|}t|trW|Dcgc]5}t|jst|j7}}|syddj|zSt|tr"t|j}|rd|SdSt|j}|rd|SdS#tj t f$rd|cYSwxYwcc}w)u Format action_items (JSONB array or None) into an inline string. Rules: - None / empty list / empty string → return "" (omit Action part) - JSON string that parses to a list → join with "; " - JSON string that parses to a single string → use as-is - Already a list (psycopg2 native) → join with "; " - Any other type → str() it Returns: " Action: " if there are items, else "". r)z[]nullz{}z Action: z; ) isinstancer1stripjsonloadsJSONDecodeError ValueErrorr2rr%) action_itemsitemsstrippedi non_emptytexts r _format_action_itemsrLs" E,$%%'8';; *JJx(E %-2Ec!fllnSV\\^E ETYYy111%5z!%)4&!1r1 u:   D!%Ytf -2-%$$j1 *xj) ) *FsC>D"6D">DDrc^|jd}|y |jd}|jd}t ||}|jdxsdj }|sd}t |jd }d |d |d ||S#t$rt|dd}YwxYw) z Format a single royal_conversations row into one summary line. Output format: [YYYY-MM-DD] Call (Xmin): Where action_part is either "" or " Action: ". Returns "" if started_at is missing. r9Nrz%Y-%m-%d r:summaryz (no summary)rF[z] Call (z): )getstrftimeAttributeErrorr1r=rArL)rr9date_strr:durationrO action_parts r rrs&J(&&z2 wwz"H H5Hwwy!'R..0G  &sww~'>?K xj #gY{m DD (z?3B'(sBB,+B,) r/rBtypingrrr1r=rLr%rr3r r rXsP eGeGXc&-.#-.`ETEcEr