idZddlZddlZddlZddlZddlZddlZddlZddlm Z ddl m Z ddl m Z mZmZmZmZmZejeZedZe dz ZdZd Zd ZGd d ZdS) a} SQLite State Store for Hermes Agent. Provides persistent session storage with FTS5 full-text search, replacing the per-session JSONL file approach. Stores session metadata, full message history, and model configuration for CLI and gateway sessions. Key design decisions: - WAL mode for concurrent readers + one writer (gateway multi-platform) - FTS5 virtual table for fast text search across all session messages - Compression-triggered session splitting via parent_session_id chains - Batch runner and RL trajectories are NOT stored here (separate systems) - Session source tagging ('cli', 'telegram', 'discord', etc.) for filtering N)Path)get_hermes_home)AnyCallableDictListOptionalTypeVarTzstate.dbaJ CREATE TABLE IF NOT EXISTS schema_version ( version INTEGER NOT NULL ); CREATE TABLE IF NOT EXISTS sessions ( id TEXT PRIMARY KEY, source TEXT NOT NULL, user_id TEXT, model TEXT, model_config TEXT, system_prompt TEXT, parent_session_id TEXT, started_at REAL NOT NULL, ended_at REAL, end_reason TEXT, message_count INTEGER DEFAULT 0, tool_call_count INTEGER DEFAULT 0, input_tokens INTEGER DEFAULT 0, output_tokens INTEGER DEFAULT 0, cache_read_tokens INTEGER DEFAULT 0, cache_write_tokens INTEGER DEFAULT 0, reasoning_tokens INTEGER DEFAULT 0, billing_provider TEXT, billing_base_url TEXT, billing_mode TEXT, estimated_cost_usd REAL, actual_cost_usd REAL, cost_status TEXT, cost_source TEXT, pricing_version TEXT, title TEXT, FOREIGN KEY (parent_session_id) REFERENCES sessions(id) ); CREATE TABLE IF NOT EXISTS messages ( id INTEGER PRIMARY KEY AUTOINCREMENT, session_id TEXT NOT NULL REFERENCES sessions(id), role TEXT NOT NULL, content TEXT, tool_call_id TEXT, tool_calls TEXT, tool_name TEXT, timestamp REAL NOT NULL, token_count INTEGER, finish_reason TEXT, reasoning TEXT, reasoning_details TEXT, codex_reasoning_items TEXT ); CREATE INDEX IF NOT EXISTS idx_sessions_source ON sessions(source); CREATE INDEX IF NOT EXISTS idx_sessions_parent ON sessions(parent_session_id); CREATE INDEX IF NOT EXISTS idx_sessions_started ON sessions(started_at DESC); CREATE INDEX IF NOT EXISTS idx_messages_session ON messages(session_id, timestamp); a CREATE VIRTUAL TABLE IF NOT EXISTS messages_fts USING fts5( content, content=messages, content_rowid=id ); CREATE TRIGGER IF NOT EXISTS messages_fts_insert AFTER INSERT ON messages BEGIN INSERT INTO messages_fts(rowid, content) VALUES (new.id, new.content); END; CREATE TRIGGER IF NOT EXISTS messages_fts_delete AFTER DELETE ON messages BEGIN INSERT INTO messages_fts(messages_fts, rowid, content) VALUES('delete', old.id, old.content); END; CREATE TRIGGER IF NOT EXISTS messages_fts_update AFTER UPDATE ON messages BEGIN INSERT INTO messages_fts(messages_fts, rowid, content) VALUES('delete', old.id, old.content); INSERT INTO messages_fts(rowid, content) VALUES (new.id, new.content); END; c#ZeZdZdZdZdZdZdZd\defdZ d e e j ge fd e fd Zd]d Zd ZdZ d^dedededeeefdededed efdZdeded dfdZded dfdZdeded dfdZ d_dededededed ed!ed"eed#eed$eed%eed&eed'eed(eed)eed*ed df"d+Z d`dededed dfd-Zded eeeeffd.Zd/ed eefd0Z d1Z!e"d2eed eefd3Z#ded2ed efd4Z$ded eefd5Z%d2ed eeeeffd6Z&d2ed eefd7Z'd8ed efd9Z( daded;e)eded e)eeeff d?Z* dbded@edAedBedCedDedEedFedGedHedIed efdJZ+ded e)eeeffdKZ,ded e)eeeffdLZ-e"dMed efdNZ. dcdMedOe)ed;e)edPe)ed>>^%% _   #!     ")  4555 3444 fnreturnc*d}t|jD]f} |j5|jd ||j}|jn:#t $r- |jn#t$rYnwxYwwxYw dddn #1swxYwY|xj dz c_ |j |j zdkr| |cS#tj $rx}t|}d|vsd|vrI|}||jdz kr9t!j|j|j}t)j|Yd}~_d}~wwxYw|ptj d)uExecute a write transaction with BEGIN IMMEDIATE and jitter retry. *fn* receives the connection and should perform INSERT/UPDATE/DELETE statements. The caller must NOT call ``commit()`` — that's handled here after *fn* returns. BEGIN IMMEDIATE acquires the WAL write lock at transaction start (not at commit time), so lock contention surfaces immediately. On ``database is locked``, we release the Python lock, sleep a random 20-150ms, and retry — breaking the convoy pattern that SQLite's built-in deterministic backoff creates. Returns whatever *fn* returns. NzBEGIN IMMEDIATErlockedbusyz$database is locked after max retries)range_WRITE_MAX_RETRIESrr"r%commit BaseExceptionrollback Exceptionr_CHECKPOINT_EVERY_N_WRITES_try_wal_checkpointrOperationalErrorr!lowerrandomuniform_WRITE_RETRY_MIN_S_WRITE_RETRY_MAX_Stimesleep)r'r+last_errattemptresultexcerr_msgjitters r(_execute_writezSessionDB._execute_writes/)-T455  G Z  J&&'8999!#DJ ))++++(! J//1111(!!! D! ,               !!Q&!!$t'FF!KK,,... +   c((..**w&&&G*;*;"H!81!<<._donsa LL60<FDJ|,,,$!%IKK       r*rG) r'rwrxryrzr{r|r}rs ``````` r(create_sessionzSessionDB.create_sessioncs\            C   r* end_reasonc@fd}||dS)zMark a session as ended.c\|dtjfdS)Nz=UPDATE sessions SET ended_at = ?, end_reason = ? WHERE id = ?r%r?)rrrws r(rz"SessionDB.end_session.._dos6 LLOj*5     r*Nr)r'rwrrs `` r( end_sessionzSessionDB.end_session>       C     r*c<fd}||dS)z6Clear ended_at/end_reason so a session can be resumed.c6|dfdS)NzCUPDATE sessions SET ended_at = NULL, end_reason = NULL WHERE id = ?r%rrws r(rz%SessionDB.reopen_session.._dos+ LLU      r*Nrr'rwrs ` r(reopen_sessionzSessionDB.reopen_sessions8      C     r*c@fd}||dS)z0Store the full assembled system prompt snapshot.c8|dfdS)Nz2UPDATE sessions SET system_prompt = ? WHERE id = ?r)rrwr{s r(rz+SessionDB.update_system_prompt.._dos. LLD +     r*Nr)r'rwr{rs `` r(update_system_promptzSessionDB.update_system_promptrr*rF input_tokens output_tokensrUrWrXr]r_r`rarbrYr[r\absolutecr|rdnd||||||| | | | | | ||||ffd}||dS)uUpdate token counters and backfill model if not already set. When *absolute* is False (default), values are **incremented** — use this for per-API-call deltas (CLI path). When *absolute* is True, values are **set directly** — use this when the caller already holds cumulative totals (gateway path, where the cached agent accumulates across messages). a}UPDATE sessions SET input_tokens = ?, output_tokens = ?, cache_read_tokens = ?, cache_write_tokens = ?, reasoning_tokens = ?, estimated_cost_usd = COALESCE(?, 0), actual_cost_usd = CASE WHEN ? IS NULL THEN actual_cost_usd ELSE ? END, cost_status = COALESCE(?, cost_status), cost_source = COALESCE(?, cost_source), pricing_version = COALESCE(?, pricing_version), billing_provider = COALESCE(billing_provider, ?), billing_base_url = COALESCE(billing_base_url, ?), billing_mode = COALESCE(billing_mode, ?), model = COALESCE(model, ?) WHERE id = ?aUPDATE sessions SET input_tokens = input_tokens + ?, output_tokens = output_tokens + ?, cache_read_tokens = cache_read_tokens + ?, cache_write_tokens = cache_write_tokens + ?, reasoning_tokens = reasoning_tokens + ?, estimated_cost_usd = COALESCE(estimated_cost_usd, 0) + COALESCE(?, 0), actual_cost_usd = CASE WHEN ? IS NULL THEN actual_cost_usd ELSE COALESCE(actual_cost_usd, 0) + ? END, cost_status = COALESCE(?, cost_status), cost_source = COALESCE(?, cost_source), pricing_version = COALESCE(?, pricing_version), billing_provider = COALESCE(billing_provider, ?), billing_base_url = COALESCE(billing_base_url, ?), billing_mode = COALESCE(billing_mode, ?), model = COALESCE(model, ?) WHERE id = ?c4|dSNr)rparamssqls r(rz*SessionDB.update_token_counts.._dos LLf % % % % %r*Nr)r'rwrrryrUrWrXr]r_r`rarbrYr[r\rrrrs @@r(update_token_countszSessionDB.update_token_countss8 ' ##CC(#C(                ! $ & & & & & & C     r*unknowncDfd}||dS)a2Ensure a session row exists, creating it with minimal metadata if absent. Used by _flush_messages_to_session_db to recover from a failed create_session() call (e.g. transient SQLite lock at agent startup). INSERT OR IGNORE is safe to call even when the row already exists. c^|dtjfdS)NzxINSERT OR IGNORE INTO sessions (id, source, model, started_at) VALUES (?, ?, ?, ?)r)rryrwrxs r(rz%SessionDB.ensure_session.._dos< LL*VUDIKK8      r*Nr)r'rwrxryrs ``` r(ensure_sessionzSessionDB.ensure_sessionsD        C     r*c|j5|jd|f}|}dddn #1swxYwY|rt |ndS)zGet a session by ID.z#SELECT * FROM sessions WHERE id = ?Nrr"r%rKdictr'rwrgrns r( get_sessionzSessionDB.get_session s Z $ $Z''5 }F//##C  $ $ $ $ $ $ $ $ $ $ $ $ $ $ $  )tCyyyT)1AA  A session_id_or_prefixc||}|r|dS|dddddd}|j5|jd|df}d |D}d d d n #1swxYwYt |d kr|d Sd S) a*Resolve an exact or uniquely prefixed session ID to the full ID. Returns the exact ID when it exists. Otherwise treats the input as a prefix and returns the single matching session ID if the prefix is unambiguous. Returns None for no matches or ambiguous prefixes. id\\\%\%_\_zSSELECT id FROM sessions WHERE id LIKE ? ESCAPE '\' ORDER BY started_at DESC LIMIT 2cg|] }|d S)r.0rns r( z0SessionDB.resolve_session_id..*s>>>Ss4y>>>r*Nr.r)rrlrr"r%fetchalllen)r'rexactescapedrgmatchess r(resolve_session_idzSessionDB.resolve_session_ids'  !566  ;  ! WT6 " " WS% WS%  Z ? ?Z''f F?>FOO,=,=>>>G  ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? w<<1  1: ts%>B//B36B3dtitlecR|sdStjdd|}tjdd|}tjdd|}|sdSt|tjkr-t dt|dtjd |S) aValidate and sanitize a session title. - Strips leading/trailing whitespace - Removes ASCII control characters (0x00-0x1F, 0x7F) and problematic Unicode control chars (zero-width, RTL/LTR overrides, etc.) - Collapses internal whitespace runs to single spaces - Normalizes empty/whitespace-only strings to None - Enforces MAX_TITLE_LENGTH Returns the cleaned title string or None. Raises ValueError if the title exceeds MAX_TITLE_LENGTH after cleaning. Nz [\x00-\x08\x0b\x0c\x0e-\x1f\x7f]zB[\u200b-\u200f\u2028-\u202e\u2060-\u2069\ufeff\ufffc\ufff9-\ufffb]z\s+ zTitle too long (z chars, max ))resubstriprrMAX_TITLE_LENGTH ValueError)rcleaneds r(sanitize_titlezSessionDB.sanitize_title2s 4 &._dogs IJ'"??,,$X%XXQUXX\\< #F? "r*r)rrG)r'rwrrrs `` r(set_session_titlezSessionDB.set_session_title^sV##E** # # # # # #"&&s++!|r*c|j5|jd|f}|}dddn #1swxYwY|r|dndS)z%Get the title for a session, or None.z'SELECT title FROM sessions WHERE id = ?Nrrr"r%rKrs r(get_session_titlezSessionDB.get_session_title{s Z $ $Z''9J=F//##C  $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ #,s7||,rc|j5|jd|f}|}dddn #1swxYwY|rt |ndS)z?Look up a session by exact title. Returns session dict or None.z&SELECT * FROM sessions WHERE title = ?Nr)r'rrgrns r(get_session_by_titlezSessionDB.get_session_by_titles Z $ $Z''85(F//##C  $ $ $ $ $ $ $ $ $ $ $ $ $ $ $  )tCyyyT)rc||}|dddddd}|j5|jd|df}|}d d d n #1swxYwY|r|d d S|r|d Sd S) adResolve a title to a session ID, preferring the latest in a lineage. If the exact title exists, returns that session's ID. If not, searches for "title #N" variants and returns the latest one. If the exact title exists AND numbered variants exist, returns the latest numbered variant (the most recent continuation). rrrrrrzaSELECT id, title, started_at FROM sessions WHERE title LIKE ? ESCAPE '\' ORDER BY started_at DESC #%Nrr)rrlrr"r%r)r'rrrrgnumbereds r(resolve_session_by_titlez"SessionDB.resolve_session_by_titles))%00--f--55c5AAII#uUU Z ) )Z''J"F ((H  ) ) ) ) ) ) ) ) ) ) ) ) ) ) )  A;t$ $  ; ts4BB"B base_titlec Ntjd|}|r|d}n|}|dddddd}|j5|jd ||d f}d |D}d d d n #1swxYwY|s|Sd}|D]I}tjd |} | r0t|t| d}J|d|dzS)uGenerate the next title in a lineage (e.g., "my session" → "my session #2"). Strips any existing " #N" suffix to find the base name, then finds the highest existing number and increments. z^(.*?) #(\d+)$r.rrrrrrzESELECT title FROM sessions WHERE title = ? OR title LIKE ? ESCAPE '\'rcg|] }|d S)rrrs r(rz7SessionDB.get_next_title_in_lineage..sBBBG BBBr*Nz ^.* #(\d+)$z #) rmatchgrouprlrr"r%rmaxint) r'rrbaserrgexistingmax_numtms r(get_next_title_in_lineagez#SessionDB.get_next_title_in_lineages*J77  ;;q>>DDD,,tV,,44S%@@HHeTT Z C CZ''X''FCB0A0ABBBH  C C C C C C C C C C C C C C C K 8 8A++A 8gs1771::77'''A+'''s5?CCCexclude_sourceslimitoffsetinclude_childrencDg}g}|s|d|r*|d|||rMdd|D}|d|d|||rdd|nd } d | d } |||g|j5|j| |} | } d d d n #1swxYwYg} | D]}}t|}|d d  }|r(|d d}|t|dkrdnd z|d<nd |d<| |~| S)aList sessions with preview (first user message) and last active timestamp. Returns dicts with keys: id, source, model, title, started_at, ended_at, message_count, preview (first 60 chars of first user message), last_active (timestamp of last message). Uses a single query with correlated subqueries instead of N+2 queries. By default, child sessions (subagent runs, compression continuations) are excluded. Pass ``include_children=True`` to include them. zs.parent_session_id IS NULLz s.source = ?,c3K|]}dVdS?Nrrrs r( z/SessionDB.list_sessions_rich..s"#A#AAC#A#A#A#A#A#Ar*s.source NOT IN (rzWHERE  AND rah SELECT s.*, COALESCE( (SELECT SUBSTR(REPLACE(REPLACE(m.content, X'0A', ' '), X'0D', ' '), 1, 63) FROM messages m WHERE m.session_id = s.id AND m.role = 'user' AND m.content IS NOT NULL ORDER BY m.timestamp, m.id LIMIT 1), '' ) AS _preview_raw, COALESCE( (SELECT MAX(m2.timestamp) FROM messages m2 WHERE m2.session_id = s.id), s.started_at ) AS last_active FROM sessions s zM ORDER BY s.started_at DESC LIMIT ? OFFSET ? N _preview_raw<z...preview) appendjoinextendrr"r%rrpoprr)r'rxrrrr where_clausesr placeholders where_sqlqueryrgrowssessionsrnsrawtexts r(list_sessions_richzSessionDB.list_sessions_richs)&  @  !> ? ? ?  "   0 0 0 MM& ! ! !  +88#A#A#A#A#AAAL  !D\!D!D!D E E E MM/ * * *>KS:W\\-88:::QS     $  ufo&&& Z % %Z''v66F??$$D % % % % % % % % % % % % % % %  CS A%%++1133C "3B3x#C2 uu2F) !) OOA    s0DDDrolecontent tool_name tool_calls tool_call_id token_count finish_reasonrdrerfc H | rtj| nd| rtj| nd |rtj|ndd|&t|trt |nd  f d} || S)z Append a message to a session. Returns the message row ID. Also increments the session's message_count (and tool_call_count if role is 'tool' or tool_calls is present). Nrr.c |d  tj f }|j}dkr|d fn|d f|S)NaINSERT INTO messages (session_id, role, content, tool_call_id, tool_calls, tool_name, timestamp, token_count, finish_reason, reasoning, reasoning_details, codex_reasoning_items) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)rzUPDATE sessions SET message_count = message_count + 1, tool_call_count = tool_call_count + ? WHERE id = ?zBUPDATE sessions SET message_count = message_count + 1 WHERE id = ?)r%r? lastrowid)rrgmsg_idcodex_items_jsonrr num_tool_callsrdreasoning_details_jsonrrwrrtool_calls_jsonrs r(rz%SessionDB.append_message.._do;s\\B  #IKK!*$  F(%F!! M#Z0  XMMr*)rrrklistrrG)r'rwrrrrrrr rdrerfrrrrrs ```` ```` @@@@r(append_messagezSessionDB.append_messages.! +DJ( ) ) )&*  % /DJ, - - -*. 5?H$*Z000D  !0::t0L0LSS___RSN# # # # # # # # # # # # # # # # J""3'''r*c|j5|jd|f}|}dddn #1swxYwYg}|D]}t |}|drZ t j|d|d<n;#t jtf$r"t dg|d<YnwxYw| ||S)z6Load all messages for a session, ordered by timestamp.zBSELECT * FROM messages WHERE session_id = ? ORDER BY timestamp, idNrzDFailed to deserialize tool_calls in get_messages, falling back to []) rr"r%rrgetrloadsJSONDecodeError TypeErrorrLwarningr)r'rwrgrrCrnmsgs r( get_messageszSessionDB.get_messagesbsG Z % %Z''T F??$$D  % % % % % % % % % % % % % % %   Cs))Cww|$$ ++(, 3|3D(E(EC %%,i8+++NN#ijjj(*C %%%+ MM#     s#1AA  A ;B5CCc|j5|jd|f}|}dddn #1swxYwYg}|D]}|d|dd}|dr |d|d<|dr |d|d<|drZ t j|d|d<n;#tjtf$r"t d g|d<YnwxYw|dd kr|d r |d |d <|d rZ t j|d |d <n;#tjtf$r"t d d|d <YnwxYw|drZ t j|d|d<n;#tjtf$r"t dd|d<YnwxYw| ||S)z Load messages in the OpenAI conversation format (role + content dicts). Used by the gateway to restore conversation history. zSELECT role, content, tool_call_id, tool_calls, tool_name, reasoning, reasoning_details, codex_reasoning_items FROM messages WHERE session_id = ? ORDER BY timestamp, idNrrrrrrrzKFailed to deserialize tool_calls in conversation replay, falling back to [] assistantrdrez=Failed to deserialize reasoning_details, falling back to NonerfzAFailed to deserialize codex_reasoning_items, falling back to None) rr"r%rrrrrrLrr)r'rwrgrmessagesrnrs r(get_messages_as_conversationz&SessionDB.get_messages_as_conversationvs Z % %Z''L F ??$$D % % % % % % % % % % % % % % % ! !Cv;3y>BBC>" :&).&9N#; 4#&{#3K <  ++(, 3|3D(E(EC %%,i8+++NN#pqqq(*C %%%+ 6{k)){#8'*;'7C $*+8837:cBU>V3W3W/00 0)<888'fggg37/0008./<<7;z#F]B^7_7_344 0)<<<<'jkkk7;3444< OOC sG1AA  A B555C-,C-D665E.-E.:F5GGrc<gdtjdtffd }tjd||}tjdd|}tjdd|}tjd d |}tjd d |}tjd d |}tjdd|}t D]\}}|d|d|} |S)aSanitize user input for safe use in FTS5 MATCH queries. FTS5 has its own query syntax where characters like ``"``, ``(``, ``)``, ``+``, ``*``, ``{``, ``}`` and bare boolean operators (``AND``, ``OR``, ``NOT``) have special meaning. Passing raw user input directly to MATCH can cause ``sqlite3.OperationalError``. Strategy: - Preserve properly paired quoted phrases (``"exact phrase"``) - Strip unmatched FTS5-special characters that would cause errors - Wrap unquoted hyphenated and dotted terms in quotes so FTS5 matches them as exact phrases instead of splitting on the hyphen/dot (e.g. ``chat-send``, ``P2.2``, ``my-app.config.ts``) rr,c|ddtdz dS)NrQr.)rrr)r _quoted_partss r(_preserve_quotedz8SessionDB._sanitize_fts5_query.._preserve_quoteds?   , , ,73}--1777 7r*z"[^"]*"z [+{}()\"^]rz\*+*z(^|\s)\*z\1z(?i)^(AND|OR|NOT)\b\s*rz(?i)\s+(AND|OR|NOT)\s*$z\b(\w+(?:[.-]\w+)+)\bz"\1"r#r$)rMatchr!rr enumeraterl)rr& sanitizediquotedr%s @r(_sanitize_fts5_queryzSessionDB._sanitize_fts5_querys-$!  8 8S 8 8 8 8 8 8F:'7?? F=#y99 F63 22 F;y99 F4b)//:K:KLL F5r9??;L;LMM F3WiHH #=11 C CIAv!))/!///6BBII   r* source_filter role_filterc |r|sgS||}|sgSdg}|g}|Mdd|D} |d| d|||Mdd|D} |d| d|||rMdd |D} |d | d||d |} |||gd | d } |j5 |j| |}n##tj $rgcYcdddSwxYwd| D}dddn #1swxYwY|D]} |j5|jd|d|d|df}d| D}dddn #1swxYwY||d<v#t$rg|d<YwxYw|D]}| dd|S)a Full-text search across session messages using FTS5. Supports FTS5 query syntax: - Simple keywords: "docker deployment" - Phrases: '"exact phrase"' - Boolean: "docker OR kubernetes", "python NOT java" - Prefix: "deploy*" Returns matching messages with session metadata, content snippet, and surrounding context (1 message before and after the match). zmessages_fts MATCH ?Nrc3K|]}dVdSrrrs r(rz,SessionDB.search_messages..s"*F*F13*F*F*F*F*F*Fr*z s.source IN (rc3K|]}dVdSrrrs r(rz,SessionDB.search_messages..s"+I+IAC+I+I+I+I+I+Ir*rc3K|]}dVdSrrrs r(rz,SessionDB.search_messages.. s"(B(B(B(B(B(B(B(Br*z m.role IN (ra SELECT m.id, m.session_id, m.role, snippet(messages_fts, 0, '>>>', '<<<', '...', 40) AS snippet, m.content, m.timestamp, m.tool_name, s.source, s.model, s.started_at AS session_started FROM messages_fts JOIN messages m ON m.id = messages_fts.rowid JOIN sessions s ON s.id = m.session_id WHERE z@ ORDER BY rank LIMIT ? OFFSET ? c,g|]}t|Srrrs r(rz-SessionDB.search_messages..*s>>>StCyy>>>r*zSELECT role, content FROM messages WHERE session_id = ? AND id >= ? - 1 AND id <= ? + 1 ORDER BY idrwrcDg|]}|d|dpddddS)rrrNrr)rrs r(rz-SessionDB.search_messages..7sF$$$"#6) 8JDSD7QRR$$$r*contextr) rr-rrrrr"r%rr9rr6r)r'rr.rr/rrrrsource_placeholdersexclude_placeholdersrole_placeholdersrrrgrr ctx_cursor context_msgss r(search_messageszSessionDB.search_messagess* EKKMM I))%00 I00 w  $"%((*F*F *F*F*F"F"F   !G1D!G!G!G H H H MM- ( ( (  &#&88+I+I+I+I+I#I#I  !L5I!L!L!L M M M MM/ * * *  ' #(B(Bk(B(B(B B B   !C/@!C!C!C D D D MM+ & & &LL//  ufo&&&    (Z ? ? ++C88+     ? ? ? ? ? ? ? ? ?>FOO,=,=>>>G  ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? & &E &Z  !%!3!3*|,eDk5;G ""J $$!+!4!4!6!6$$$L               $0i   & & &#%i    & ' 'E IIi & & & &smG  E<;G <F G F!G  G G I  AH;/ I ;H? ?I H? I  IIc|j5|r|jd|||f}n|jd||f}d|DcdddS#1swxYwYdS)z-List sessions, optionally filtered by source.zQSELECT * FROM sessions WHERE source = ? ORDER BY started_at DESC LIMIT ? OFFSET ?z@SELECT * FROM sessions ORDER BY started_at DESC LIMIT ? OFFSET ?c,g|]}t|Srr5rs r(rz-SessionDB.search_sessions..Ws;;;#DII;;;r*N)rr"r%r)r'rxrrrgs r(search_sessionszSessionDB.search_sessionsEsZ < < ++gUF+ ++VFO<;):):;;; < < < < < < < < < < < < < < < < <  >G((77H NN._dosJ LL;j]    LLY      r*Nrrs ` r(clear_messageszSessionDB.clear_messagess8      C     r*c8fd}||S)zDelete a session and all its messages. Child sessions are orphaned (parent_session_id set to NULL) rather than cascade-deleted, so they remain accessible independently. Returns True if the session was found and deleted. c|df}|ddkrdS|df|df|dfdS)Nz*SELECT COUNT(*) FROM sessions WHERE id = ?rFzHUPDATE sessions SET parent_session_id = NULL WHERE parent_session_id = ?rP!DELETE FROM sessions WHERE id = ?T)r%rK)rrgrws r(rz%SessionDB.delete_session.._dos\\._do..s&EECc$iEEEEEEr*rrrzIUPDATE sessions SET parent_session_id = NULL WHERE parent_session_id IN (rrPrT)r%setrrrr)rrg session_idsrsidcutoffrxs r(rz%SessionDB.prune_sessions.._dos* WV$ [IEE6??3D3DEEEEEK q88C#k*:*:$:;;L LL?/;???[!!    # J J H3&QQQ @3&IIII{## #r*)r?rG)r'rWrxrr^s ` @r(prune_sessionszSessionDB.prune_sessionssO% 78 $ $ $ $ $ $<""3'''r*r)r,N)NNNNN)rrNrrrNNNNNNNNF)rN)NNrrF) NNNNNNNNN)NNNrr)Nrr)rVN)8__name__ __module__ __qualname____doc__r2r=r>r7rr)rr Connectionr rGr8rOr&r!rrrrrrrr floatboolrrrrr staticmethodrrrrrrrrrrr r-r?rBrDrGrJrMrQrUr_rr*r(rrssW !#42 7+=*>*A!B2 q2 2 2 2 h* " " "aaaV'+!!%  38n    <!c!s!t!!!!!!!!!!!s!3!4!!!!!""# !.2+/%)%))-*.*.&*#X!X!X!X! X!  X!  X! X!X!%UOX!"%X!c]X!c]X!"#X!#3-X!#3-X! sm!X!"#X!$ %X!X!X!X!z  !!!! !  !!!!**c*htCH~.F****sx}8)hsm) )))\)VC:-C-HSM----*#*(4S>2J****chsm:!(C!(C!(!(!(!(J%)!& DDDcD D  D  D d38n DDDD\ !!%%)I(I(I(I( I(  I(  I(I(I(I(I(I( #I( I(I(I(I(VstDcN/C(-s-tDcN?S----f2!C2!C2!2!2!\2!n$(%)!%eeeCyec e #Y e  ee d38n eeeeR <<<< < d38n  <<<<0 ( (C (3 ( ( ( ( ( ( (s ( ( ( (11$sCx.1I1111   T#s(^0D     ! ! ! ! ! !((((((0'('(c'('(s'('('('('('(r*r)rcrloggingr;rrrr?pathlibrhermes_constantsrtypingrrrrr r getLoggerr`rLr rrjrirmrrr*r(rms(     ,,,,,,????????????????  8 $ $ GCLL!/##j07 r ,c(c(c(c(c(c(c(c(c(c(r*