§ žsˆjHãóÜ—UdZddlZddlZddlZddlmZmZddlmZddl m Z mZmZm Z mZmZmZmZmZmZmZmZmZejd¦«Zdaeeed<defd „ZGd „d¦«ZdS)uäSchema creation, column reconciliation, and FTS DDL management for SessionDB. Mixin contract: this is a plain mixin class consumed by ``hermes_state.SessionDB``. It defines no ``__init__`` and no state of its own; methods access the host's attributes (``self._conn``, ``self.db_path``, ``self._execute_write`` and other SessionDB methods) established by ``SessionDB.__init__``. It must never import hermes_state (cycle) â€” shared module-level constants live in hermes_state_common. éN)ÚDictÚOptional©Úget_hermes_home) ÚDEFERRED_INDEX_SQLÚFTS_CJK_STALE_KEYÚ FTS_STALE_KEYÚFTS_SQLÚFTS_STORAGE_VERSIONÚFTS_TRIGRAM_SQLÚLEGACY_FTS_SQLÚLEGACY_FTS_TRIGRAM_SQLÚ SCHEMA_SQLÚSCHEMA_VERSIONÚ_FTS_CJK_TRIGGERSÚ _FTS_TRIGGERSÚ_ephemeral_child_sqlÚhermes_stateÚ_READ_PROBE_STATEMENTSÚreturncóÌ—t€Wt t¦«}t d„t| ¦«¦«D¦«¦«atS)udSELECT statements that fail iff a live store is behind SCHEMA_SQL. Read-only opens skip ``_reconcile_columns()`` by design (no DDL against another profile's live DB), so a store created before a schema addition keeps 500ing on read paths until something opens it writable. Callers that heal on staleness (see ``_open_session_db_at_path`` in ``hermes_cli/web_server.py``) run these probes right after a read-only open: any missing table raises "no such table" and any missing column raises "no such column", both at prepare time. Derived from SCHEMA_SQL â€” the same source of truth the writable reconciler diffs against â€” so a column added there is covered here automatically. A hand-maintained probe list went stale within days of shipping (it never learned ``sessions.last_activity_at``, so the sidebar served an empty session list after `hermes update` until the user's first message forced a writable open). Each statement is ``LIMIT 0``: column resolution happens at prepare time, so the probe reads zero rows. Column references are qualified with the table name â€” an unqualified double-quoted identifier that fails to resolve silently degrades to a string literal (SQLite's double-quoted-string misfeature), which would make the probe pass on exactly the stale store it exists to catch. Nc3ó°‡K—|]P\Š}d d ˆfd„|D¦«¦«‰ dd¦«¦«V—ŒQdS)zSELECT {} FROM "{}" LIMIT 0ú, c3ó”•K—|]B}d ‰ dd¦«| dd¦«¦«V—ŒCdS)z "{}"."{}"ú"ú""N)ÚformatÚreplace)Ú.0ÚcolÚtables €ú7/home/agent/.hermes/hermes-agent/hermes_state_schema.pyú z9schema_read_probe_statements...Hsjøèè€ðððð ×&Ò&ØŸ š c¨4Ñ0Ô0°#·+²+¸cÀ4Ñ2HÔ2HñôððððððórrN)rÚjoinr)rÚcolsr!s @r"r#z/schema_read_probe_statements..Fs™øèè€ð' ð' ñtð *×0Ò0Ø— ’ ððððð $ð ñôñôð— ’ ˜c 4Ñ(Ô(ñ ô ð' ð' ð' ð' ð' ð' r$)rÚSessionSchemaMixinÚ_parse_schema_columnsrÚtupleÚsortedÚitems)Útabless r"Úschema_read_probe_statementsr-*sc€õ4Ð%Ý#×9Ò9½*ÑEÔEˆÝ!&ð' ð' õ & f§l¢l¡n¤nÑ5Ô5ð' ñ' ô' ñ" ô" Ðõ"Ð!r$c ób—eZdZdZdejddfd„Zdejdefd„Zdejddfd„Z e dejdefd„¦«Ze d e edefd „¦«Zdejdefd„Zdejdefd„Zdejddfd „Ze ddœdejdeddfd„¦«Ze ddœdejdeddfd„¦«Zdejdede efd„Zdejdedefd„Ze dedeeeeefffd„¦«Zdejddfd„Zdejddfd„Zdejddfd„Zd„Zdejddfd„ZdS)r'u>See module docstring â€” mixin for SessionDB (Schema cluster).ÚcursorrNcó— | d¦« ¦«}n#tj$rYdSwxYw|D]¾}t |tj¦«r|dn|d}t |tj¦«r|dn|d} | ||¦«}| d||f¦«Œ†#tj$r'}t d|¦«Yd}~dSd}~wwxYwdS) u·Move inline prompt snapshots into the shared content-addressed table. Contention-safe by design: a ``database is locked`` (or any other ``OperationalError``) mid-loop returns instead of raising. Partial migration is safe â€” the legacy ``system_prompt`` column is kept as a read fallback for unmigrated rows, and the next schema init picks up the remainder. Letting the error propagate aborted schema init entirely, left the version below 25, and made every subsequent ``SessionDB.__init__`` re-enter this migration against the same contended DB (enterprise field report, 2026-08-14: gateway watchdog crash loop). zFSELECT id, system_prompt FROM sessions WHERE system_prompt IS NOT NULLNÚidrÚ system_promptézMUPDATE sessions SET system_prompt_hash = ?, system_prompt = NULL WHERE id = ?zv25 prompt dedupe paused after contention (%s); unmigrated rows keep the legacy inline prompt and the next schema init resumes the migration.) ÚexecuteÚfetchallÚsqlite3ÚOperationalErrorÚ isinstanceÚRowÚ_store_system_promptÚloggerÚwarning)Úselfr/ÚrowsÚrowÚ session_idÚpromptÚprompt_hashÚexcs r"Ú_dedupe_legacy_system_promptsz0SessionSchemaMixin._dedupe_legacy_system_promptsXsQ€ð Ø—>’>ð2ñô÷Šh‰jŒjð ˆDøõÔ'ð ð ð ØˆFˆFð øøøðð ð ˆCÝ&0°µg´kÑ&BÔ&BÐN˜˜Tœ˜ÈÈAÌˆJÝ-7¸½W¼[Ñ-IÔ-IÐUS˜Ô)Ð)ÈsÐSTÌvˆFð Ø"×7Ò7¸ÀÑGÔGØ—’ð#ð! *Ð-ñ ôððøõÔ+ð ð ð Ý—’ð>ðñ ôððøøøøð øøøð ð s$‚'*ª=¼=Â.CÃC>ÃC9Ã9C>cóì— | d¦«| d¦«dS#tj$r6}| |¦«s‚| |¦«Yd}~dSd}~wwxYw)Nz:CREATE VIRTUAL TABLE temp._hermes_fts5_probe USING fts5(x)z"DROP TABLE temp._hermes_fts5_probeTF)r4r6r7Ú_is_fts5_unavailable_errorÚ_warn_fts5_unavailable)r=r/rCs r"Ú_sqlite_supports_fts5z(SessionSchemaMixin._sqlite_supports_fts5sŽ€ð ØNŠNÐWÑXÔXÐXØNŠNÐ?Ñ@Ô@Ð@Ø4øÝÔ'ð ð ð Ø×2Ò2°3Ñ7Ô7ð ØØ×'Ò'¨Ñ,Ô,Ð,Ø55555øøøøð øøøs‚*.®A3½+A.Á.A3có —| |¦«tD]0} | d|›¦«Œ#tj$rYŒ-wxYwdS)NúDROP TRIGGER IF EXISTS )Ú_drop_fts_triggersrr4r6r7)r=r/Útriggers r"Ú_drop_all_fts_triggersz)SessionSchemaMixin._drop_all_fts_triggersŒsu€Ø×Ò Ñ'Ô'Ð'Ý(ð ð ˆGð Ø—’ÐB¸ÐBÐBÑCÔCÐCÐCøÝÔ+ð ð ð Øð øøøð ð s 9¹AÁ Acó—d d„tD¦«¦«}| d|›dt¦« ¦«}t t|tj¦«s|dn|d¦«S)NÚ,c3óK—|]}dV—ŒdS©ú?N©©rÚ_s r"r#z8SessionSchemaMixin._fts_trigger_count..–s"èè€Ð;Ð;¨ Ð;Ð;Ð;Ð;Ð;Ð;r$zGSELECT COUNT(*) FROM sqlite_master WHERE type = 'trigger' AND name IN (ú)r)r%rr4ÚfetchoneÚintr8r6r9)r/Úplaceholdersr?s r"Ú_fts_trigger_countz%SessionSchemaMixin._fts_trigger_count”sŽ€à—x’xÐ;Ð;]Ð;Ñ;Ô;Ñ;Ô;ˆØnŠnð CØ3?ð Cð Cð Cåñ ô ÷Š(‰*Œ*ð õ ¥¨Cµ´Ñ!=Ô!=ÐI3q”66À3ÀqÄ6ÑJÔJÐJr$Úsqlcó—|sdSd | ¦«¦« ¦«}d|vrdSd|vS)z?True when trigger SQL is missing AFTER UPDATE OF (still broad).FÚ zAFTER UPDATE OF zAFTER UPDATE ON )r%ÚsplitÚupper)r[Úcompacts r"Ú#_fts_update_trigger_needs_narrowingz6SessionSchemaMixin._fts_update_trigger_needs_narrowingŸsQ€ðð Ø5à—(’(˜3Ÿ9š9™;œ;Ñ'Ô'×-Ò-Ñ/Ô/ˆà Ð(Ð(Ø5à! WÐ,Ð,r$cóÎ—| |¦«}d}|st|d¦«r|dz }d d„|D¦«¦«}| d|›d|¦« ¦«}g}|D]€}t|tj¦«s|dn|d }t|tj¦«s|d n|d} | | ¦«r| |¦«Œ|sdS|D]}| d|›¦«Œ|r9| |d t¦«| |dt¦«nÕ| |d t¦«| |dt¦«d|vr™ | |¦«n>#t $r1| |¦«t$ d¦«‚wxYw| |¦«s/| |¦«t$ d¦«t$ dt/|¦«¦«t/|¦«S)a¤Replace broad AFTER UPDATE FTS triggers with AFTER UPDATE OF variants. ``CREATE TRIGGER IF NOT EXISTS`` will not replace an existing broad trigger, so installs that already created ``AFTER UPDATE ON messages`` would keep firing on every messages row touch (status/compaction writes included). Inspect ``sqlite_master``, drop any still-broad UPDATE triggers, and re-apply the current DDL constants. No FTS rebuild: content correctness was already gated by WHEN clauses on modern installs; OF only skips unnecessary trigger evaluation. Returns the number of triggers dropped (0 when already converged). )Úmessages_fts_updateÚmessages_fts_trigram_updateÚ_ensure_fts_cjk_schema©Úmessages_fts_cjk_updaterc3óK—|]}dV—ŒdSrQrSrTs r"r#zHSessionSchemaMixin._migrate_broad_fts_update_triggers..Äs"èè€Ð ;Ð ;¨ Ð ;Ð ;Ð ;Ð ;Ð ;Ð ;r$zHSELECT name, sql FROM sqlite_master WHERE type = 'trigger' AND name IN (rVrÚnamer3r[rJÚmessages_ftsÚmessages_fts_trigramrgz2CJK FTS re-ensure after UPDATE OF migration failedzeCJK FTS UPDATE trigger missing or still broad after UPDATE OF migration; marked stale and unavailablezPMigrated %d broad FTS UPDATE trigger(s) to AFTER UPDATE OF (no rebuild required))Ú_db_has_legacy_inline_ftsÚhasattrr%r4r5r8r6r9raÚappendÚ_ensure_fts_schemar rr rreÚ ExceptionÚ)_quarantine_cjk_after_update_of_migrationr;Ú exceptionÚ_cjk_update_trigger_is_narrowedr<ÚinfoÚlen) r=r/Ú legacy_layoutÚupdate_namesrYr>Úto_dropr?rir[s r"Ú"_migrate_broad_fts_update_triggersz5SessionSchemaMixin._migrate_broad_fts_update_triggers¬sÙ€ð"×6Ò6°vÑ>Ô>ˆ ð ˆðð 9¥¨Ð/GÑ!HÔ!Hð 9ØÐ8Ñ8ˆLØ—y’yÐ ;Ð ;¨lÐ ;Ñ ;Ô ;Ñ;Ô;ˆØ~Š~ð CØ3?ð Cð Cð Càñ ô ÷Š(‰*Œ*ð ð ˆØð %ð %ˆCÝ!+¨Cµ´Ñ!=Ô!=ÐN3q”66À3ÀvÄ;ˆDÝ *¨3µ´Ñ <Ô <ÐL#a”&&À#ÀeÄ*ˆCØ×7Ò7¸Ñ<Ô<ð %Ø—’˜tÑ$Ô$Ð$øØð Ø1àð =ð =ˆDð NŠNÐ;°TÐ;Ð;Ñ<Ô<Ð<Ð<ðð Ø×#Ò# F¨N½NÑKÔKÐKØ×#Ò#ØÐ.Õ0Fñ ô ð ð ð ×#Ò# F¨N½GÑDÔDÐDØ×#Ò#ØÐ.µñ ô ð ð)¨GÐ3Ð3ðØ×/Ò/°Ñ7Ô7Ð7Ð7øÝ ðððØ×BÒBÀ6ÑJÔJÐJÝ×$Ò$ØLñôðððøøøð×;Ò;¸FÑCÔCðØ×BÒBÀ6ÑJÔJÐJÝ—N’NðLñôðõ Šð $å‰LŒLñ ô ð õ 7‰|Œ|ÐsÆF.Æ.;G)cóÚ—| dd¦« ¦«}|sdSt|tj¦«s|dn|d}| |¦«S)z>True when messages_fts_cjk_update exists with AFTER UPDATE OF.zASELECT sql FROM sqlite_master WHERE type = 'trigger' AND name = ?rfFrr[)r4rWr8r6r9ra)r=r/r?r[s r"rsz2SessionSchemaMixin._cjk_update_trigger_is_narrowedss€ànŠnð 2à(ñ ô ÷Š(‰*Œ*ð ð ð Ø5Ý& sG¬KÑ8Ô8ÐHˆc!Œfˆf¸cÀ%¼jˆØ×;Ò;¸CÑ@Ô@Ð@Ð@r$có0—d|_ | td|¬¦«n,#t$rt dd¬¦«YnwxYw | d¦«d S#t$r t dd¬¦«Yd SwxYw) aFail-closed after dropping CJK UPDATE during OF migration. Clears availability, persists ``fts_cjk_stale``, and drops any residual broad/partial CJK UPDATE trigger so a later open cannot ``CREATE TRIGGER IF NOT EXISTS`` a gap without rebuild. FÚ1©r/z*Could not persist CJK FTS stale breadcrumbT)Úexc_infoz.DROP TRIGGER IF EXISTS messages_fts_cjk_updatez;Could not drop residual CJK UPDATE trigger after quarantineN)Ú_fts_cjk_availableÚset_metarrpr;Údebugr4)r=r/s r"rqzsy€ð ŠÐ1Ñ2Ô2Ð2ØŠð ñ ô ð ðð ØˆFØŠÐ9Ñ:Ô:Ð:ØŠð ñ ô ð ð ð r$Ú table_namecór— | d|›d¦«dS#tj$rŠ}| |¦«rF| |¦«r| |¦«n| |¦«Yd}~dSdt|¦« ¦«vrYd}~dS‚d}~wwxYw)NzSELECT * FROM z LIMIT 0Tz no such tableF) r4r6r7rFÚ_is_trigram_unavailable_errorÚ_warn_trigram_unavailablerGÚstrÚlower)r=r/rŠrCs r"Ú_fts_table_probez#SessionSchemaMixin._fts_table_probe`sÝ€ð ØNŠNÐ@¨JÐ@Ð@Ð@ÑAÔAÐAØ4øÝÔ'ð ð ð Ø×.Ò.¨sÑ3Ô3ð ð×5Ò5°cÑ:Ô:ð5Ø×2Ò2°3Ñ7Ô7Ð7Ð7à×/Ò/°Ñ4Ô4Ð4ØtttttØ¥# c¡(¤(§.¢.Ñ"2Ô"2Ð2Ð2ØuuuuuØøøøøð øøøs!‚B6¬AB1Â#B1Â0B1Â1B6ÚlegacycóH— | |d¦«}n#tj$rd}YnwxYw|du}d d„tD¦«¦«}|r|dz }|dz }|dz }|r t }|r |tz }|dz}|r|d z }n$t}|r |tz }|d z}|r|dz }|dz }d |z|zdt›dzdz} | |¦«n–#tj$r„} |j ¦«n#tj $rYnwxYw| |¦«|j ¦«t d| ¦«Yd} ~ dSd} ~ wwxYwd|_d|_||_t d¦«dS)zAAtomically rebuild stale base/trigram indexes and resume syncing.rkTÚc3ó"K—|] }d|›dV—ŒdS)rJú;NrS)rrLs r"r#z8SessionSchemaMixin._recover_stale_fts..{s?èè€ð ð Ø5<Ð0 gÐ0Ð0Ð0ð ð ð ð ð ð r$z*DROP TABLE IF EXISTS messages_fts_trigram;z-DROP VIEW IF EXISTS messages_fts_trigram_src;z"DROP TABLE IF EXISTS messages_fts;a INSERT INTO messages_fts(rowid, content) SELECT id, COALESCE(content, '') || ' ' || COALESCE(tool_name, '') || ' ' || COALESCE(tool_calls, '') FROM messages; az DELETE FROM messages_fts_trigram; INSERT INTO messages_fts_trigram(rowid, content) SELECT id, COALESCE(content, '') || ' ' || COALESCE(tool_name, '') || ' ' || COALESCE(tool_calls, '') FROM messages; z9INSERT INTO messages_fts(messages_fts) VALUES('rebuild');zIINSERT INTO messages_fts_trigram(messages_fts_trigram) VALUES('rebuild');zWDELETE FROM state_meta WHERE key IN ('fts_rebuild_high_water', 'fts_rebuild_progress');zBEGIN IMMEDIATE;z$DELETE FROM state_meta WHERE key = 'z';zCOMMIT;zfAutomatic rebuild of stale FTS indexes failed (%s); canonical writes remain enabled with FTS detached.NFzVRebuilt stale state.db FTS indexes from canonical messages and restored sync triggers.)rr6Ú DatabaseErrorr%rr rr rr Ú executescriptÚ_connÚrollbackÚErrorrMÚcommitr;ÚerrorÚ _fts_staleÚ_fts_enabledÚ_trigram_availabler<) r=r/r‘Útrigram_statusrƒÚdrop_sqlÚ schema_sqlÚrebuild_sqlÚrecovery_sqlrCs r"Ú_recover_stale_ftsz%SessionSchemaMixin._recover_stale_ftsqs“€ð "Ø!×2Ò2°6Ð;QÑRÔRˆNˆNøÝÔ$ð "ð "ð "ð"ˆNˆNˆNð "øøøð)¨DÐ0ˆà—7’7ð ð Ý@Mð ñ ô ñ ô ˆðð EØÐDÑDˆHØÐCÑCˆØÐ8Ñ8ˆàð% Ý'ˆJØð 5ØÕ4Ñ4 Ø$ð(ñˆKðð Øð ñøõ!ˆJØð .ØoÑ- Ø$ØKñˆKðð Øð)ñð ðFñ ˆKð Øñ àñ ðGµ]ÐFÐFÐFñ Gðñ ð ð Ø× Ò Ñ.Ô.Ð.Ð.øÝÔ$ð ð ð ð Ø” ×#Ò#Ñ%Ô%Ð%Ð%øÝ”=ð ð ð Øð øøøð ×'Ò'¨Ñ/Ô/Ð/ØŒJ×ÒÑÔÐÝLŠLðEàñ ô ð ð 55555øøøøð øøøð ˆŒØ ˆÔØ"1ˆÔÝŠð &ñ ô ð ðˆtsC‚™-¬-ÃCÃE0Ã-DÄE+ÄDÄE+ÄDÄAE+Å+E0r¢có<—ddl}ddl}d}| | d¦«¦« ¦«} ddlm}|¦«dzdz}| | d¬¦«¦«}t|t¦«rv| d¦«|kr]t| d ¦«t¦«r5|d }td „| ¦«D¦«¦«r|Sn#t$rYnwxYwtjd¦«} | |¦«i} | d¦« ¦«D]µ\} i}| d | ›d¦« ¦«D]~}|d} |dpd}|d}|d}|d}|r|gng}|r|s| d¦«|| d|›¦«d |¦«|| <Œ|| | <Œ¶ | ¦«n#| ¦«wxYw|Á ddl}ddl}|j dd¬¦«| t9|j¦«d¬¦«\}}| |dd¬¦«5}| || dœ|¦«ddd¦«n#1swxYwY| ||¦«n#t$rYnwxYw| S)uExtract expected columns per table from SCHEMA_SQL. Uses an in-memory SQLite database to parse the SQL â€” SQLite itself handles all syntax (DEFAULT expressions with commas, inline REFERENCES, CHECK constraints, etc.) so there are zero regex edge cases. The in-memory DB is opened, the schema DDL is executed, and PRAGMA table_info extracts the column metadata. Adding a column to SCHEMA_SQL is all that's needed; the reconciliation loop picks it up automatically. The parse result is memoized on disk keyed by a hash of the DDL: executing SCHEMA_SQL (FTS5 virtual tables included) in the scratch DB costs ~85ms on every startup, but the output is a pure function of the DDL text, which only changes when the shipped code changes. Reconciliation itself (diffing the LIVE database) still runs every startup â€” only the reference-side parse is cached. A corrupt or stale cache degrades to recomputation. rNúutf-8rÚcachezschema_columns.json©ÚencodingÚschema_hashr,c3ó–K—|]D}t|t¦«o*td„| ¦«D¦«¦«V—ŒEdS)c3ó@K—|]}t|t¦«V—ŒdS©N)r8rŽ)rÚvs r"r#zESessionSchemaMixin._parse_schema_columns...ôs,èè€ÐFÐF°1J q#Ñ.Ô.ÐFÐFÐFÐFÐFÐFr$N)r8ÚdictÚallÚvalues)rr&s r"r#z;SessionSchemaMixin._parse_schema_columns..òsjèè€ðððõ˜t¥TÑ*Ô*ðGÝÐFÐF¸¿º¹ ¼ ÐFÑFÔFÑFÔFððððððr$z:memory:zNSELECT name FROM sqlite_master WHERE type='table' AND name NOT LIKE 'sqlite_%'úPRAGMA table_info("ú")r3ér“ééézNOT NULLzDEFAULT r]T)ÚparentsÚexist_okz.schema_columns.)ÚdirÚprefixÚw)r«r,) ÚhashlibÚjsonÚsha256ÚencodeÚ hexdigestÚhermes_constantsrÚloadsÚ read_textr8r°Úgetr±r²rpr6Úconnectr—r4r5rnr%ÚcloseÚosÚtempfileÚparentÚmkdirÚmkstemprŽÚfdopenÚdumpr)r¢Ú_hashlibÚ_jsonÚ cache_pathr«rÚblobr,ÚrefÚ table_columnsÚtblr&r?Úcol_nameÚcol_typeÚnotnullÚdefaultÚpkÚpartsÚ_osÚ _tempfileÚfdÚtmpÚfhs r"r(z(SessionSchemaMixin._parse_schema_columnsÎsô€ð* #Ð"Ð"Ð"ØÐÐÐàˆ Ø—o’o j×&7Ò&7¸Ñ&@Ô&@ÑAÔA×KÒKÑMÔMˆð Ø8Ð8Ð8Ð8Ð8Ð8Ø(˜Ñ*Ô*¨WÑ4Ð7LÑLˆJØ—;’;˜z×3Ò3¸WÐ3ÑEÔEÑFÔFˆDå˜4¥Ñ&Ô&ð "à—H’H˜]Ñ+Ô+¨{Ò:Ð:Ý˜tŸxšx¨Ñ1Ô1µ4Ñ8Ô8ð;ð˜hœÝððð!'§ ¢ ¡¤ðñôñôð"ð "MøøÝð ð ð ØˆDð øøøõŒo˜jÑ)Ô)ˆð Ø×Ò˜jÑ)Ô)Ð)Ø79ˆMØŸ+š+ðBñô÷Šh‰jŒjð *ð *‘ð(*ØŸ;š;Ø1¨#Ð1Ð1Ð1ñôç’(‘*”*ð5ð5Cð # 1œvHØ" 1œv˜|¨HØ! !œfGØ! !œfGØ˜QœBà*2Ð:˜X˜J˜J¸EØð1 rð1ØŸš ZÑ0Ô0Ð0ØÐ*ØŸšÐ%9°Ð%9Ð%9Ñ:Ô:Ð:Ø%(§X¢X¨e¡_¤_D˜‘NNØ%) ˜cÑ"Ð"ð+ *ð. IŠI‰KŒKˆKˆKøˆCIŠI‰KŒKˆKˆKøøøàÐ!ð Ø Ð Ð Ð Ø,Ð,Ð,Ð,ØÔ!×'Ò'°¸tÐ'ÑDÔDÐDØ#×+Ò+Ý˜JÔ-Ñ.Ô.Ð7Ið,ñô‘Cð—Z’Z C°'ZÑ:Ô:ð¸bØ—J’JØ(3¸}ÐMÐMÈrñôððððñôððððððøøøððððð—’˜C Ñ,Ô,Ð,Ð,øÝð ð ð Øð øøøàÐsWÁC DÄ DÄDÄ6C4IÉIÉA(LËK*ËLË*K.Ë.LË1K.Ë2LÌ LÌLc óX—| t¦«}| ¦«D]y\}} | d|›d¦« ¦«}n#t j$rYŒDwxYwt¦«}|D]C}t|ttf¦«r|dn|d}| |¦«ŒD| ¦«D]È\} } | |vr¿| dd¦«} | d|›d|›d | ›¦«Œ?#t j$rw}t|¦« ¦«} d | vr"t d|| |¦«Yd}~Œ•d | vsd| vr‚t d|| |¦«Yd}~ŒÀd}~wwxYwŒÉŒ{dS)uZEnsure live tables have every column declared in SCHEMA_SQL. Follows the Beets/sqlite-utils pattern: the CREATE TABLE definition in SCHEMA_SQL is the single source of truth for the desired schema. On every startup this method diffs the live columns (via PRAGMA table_info) against the declared columns, and ADDs any that are missing. This makes column additions a declarative operation â€” just add the column to SCHEMA_SQL and it appears on the next startup. Version-gated migration blocks are no longer needed for ADD COLUMN. r³r´r3rirrz ALTER TABLE "z" ADD COLUMN "z" zduplicate columnzreconcile %s.%s: %sNÚlockedÚbusyz;reconcile %s.%s failed; store remains behind SCHEMA_SQL: %s)r(rr+r4r5r6r7Úsetr8r)ÚlistÚaddrrŽrr;rr<)r=r/ÚexpectedrŠÚ declared_colsr>Ú live_colsr?rir×rØÚ safe_namerCÚmessages r"Ú_reconcile_columnsz%SessionSchemaMixin._reconcile_columns)s8€ð×-Ò-jÑ9Ô9ˆØ)1¯ªÑ)9Ô)9ð3 ñ3 Ñ%ˆJ˜ ð Ø—~’~Ø8¨*Ð8Ð8Ð8ñôç’(‘*”*ðøõÔ+ð ð ð Øð øøøå™œˆIØð $ð $å!+¨Cµ%½°Ñ!?Ô!?ÐPs˜1”vvÀSÈÄ[Ø— ’ ˜dÑ#Ô#Ð#Ð#à&3×&9Ò&9Ñ&;Ô&;ð% ð% Ñ"˜(Ø 9Ð,Ð,Ø (× 0Ò 0°°dÑ ;Ô ;Ið"ØŸšØ]¨JÐ]Ð]ÀiÐ]Ð]ÐS[Ð]Ð]ñôððøõ#Ô3ðððÝ"% c¡(¤(§.¢.Ñ"2Ô"2˜Ø-°Ð8Ð8õ#ŸLšLØ 5°zÀ8ÈSñôðð%˜H˜H˜H˜HØ# wÐ.Ð.°&¸GÐ2CÐ2Cð"õ Ÿšð-Ø.8¸(ÀCñôððððððøøøøð7øøøð -ñ% ð3 ð3 s0¶+A"Á"A4Á3A4Ã?DÄF$Ä-AFÅ4&FÆF$cóÞ‡— | d¦« ¦«}n#tj$rYdSwxYw|sdSd„Šˆfd„t ˆfd„|D¦«ˆfd„¬¦«D¦«}|dd gkrdSt d |¦«| d¦«| d¦«| d ¦«| d¦«dS)uÜRebuild ``gateway_routing`` when its PRIMARY KEY predates scoping. Early builds of the routing-index migration (#59203) created the table with ``session_key TEXT PRIMARY KEY`` and no ``scope`` column. ``_reconcile_columns()`` ADDs the missing ``scope`` column on those databases, but SQLite cannot ALTER a primary key, so the shipped composite ``PRIMARY KEY (scope, session_key)`` never lands. On such tables every write path is broken: * ``save_gateway_routing_entry`` fails with "ON CONFLICT clause does not match any PRIMARY KEY or UNIQUE constraint" (its upsert targets the composite key), and * ``replace_gateway_routing_entries`` fails with "UNIQUE constraint failed: gateway_routing.session_key" whenever the same session_key exists under a different scope â€” the exact isolation the composite key exists to provide. Each failed save logs a warning and falls back to sessions.json, so a legacy-shaped table produces endless per-save warning spam. Rebuild it once, preserving rows. On a session_key collision across scopes (possible while the PK was wrong) the newest row wins. z$PRAGMA table_info("gateway_routing")NcóZ—t|ttf¦«r||n||Sr®©r8r)ræ©r?Úidxris r"Ú_colz9SessionSchemaMixin._heal_gateway_routing_pk.._colŒó'€Ý)¨#µµt¨}Ñ=Ô=ÐL3s”88À3ÀtÄ9ÐLr$có*•—g|]}‰|dd¦«‘ŒS)r3rirS©rÚrrós €r"ú z?SessionSchemaMixin._heal_gateway_routing_pk..s7ø€ð ð ð àð ˆDAvÑÔð ð ð r$c3ó6•K—|]}‰|dd¦«¯|V—ŒdS)r¸rÛNrSrös €r"r#z>SessionSchemaMixin._heal_gateway_routing_pk..’s6øèè€Ð5Ð5q D D¨¨A¨tÑ$4Ô$4Ð5Ð5Ð5Ð5Ð5Ð5Ð5r$có•—‰|dd¦«S)Nr¸rÛrS)r÷rós €r"úz=SessionSchemaMixin._heal_gateway_routing_pk..“sø€˜d˜d 1 a¨Ñ.Ô.€r$)ÚkeyÚscopeÚsession_keyz]gateway_routing has legacy primary key %r; rebuilding with composite (scope, session_key) keyz?ALTER TABLE gateway_routing RENAME TO gateway_routing_legacy_pkzÄCREATE TABLE gateway_routing ( scope TEXT NOT NULL DEFAULT '', session_key TEXT NOT NULL, entry_json TEXT NOT NULL, updated_at REAL NOT NULL, PRIMARY KEY (scope, session_key) )zÊINSERT OR REPLACE INTO gateway_routing (scope, session_key, entry_json, updated_at) SELECT COALESCE(scope, ''), session_key, entry_json, updated_at FROM gateway_routing_legacy_pk ORDER BY updated_at ASCz$DROP TABLE gateway_routing_legacy_pk)r4r5r6r7r*r;rt)r=r/r>Úpk_colsrós @r"Ú_heal_gateway_routing_pkz+SessionSchemaMixin._heal_gateway_routing_pklsrø€ð. Ø—>’>Ø6ñôçŠh‰jŒjð ˆDøõÔ'ð ð ð ØˆFˆFð øøøàð ØˆFð Mð Mð Mð ð ð ð åØ5Ð5Ð5Ð5˜DÐ5Ñ5Ô5Ø.Ð.Ð.Ð.ðñôð ñ ô ˆðw Ð.Ò.Ð.ØˆFåŠð 1àñ ô ð ð ŠØMñ ô ð ð Šð ñ ô ð ð Šð Eñ ô ð ð ŠÐ=Ñ>Ô>Ð>Ð>Ð>sƒ'+«>½>có‡— | d¦« ¦«}n#tj$rYdSwxYw|sdSd„Šˆfd„|D¦«}d|vrdSt dt |¦«¦«| d¦« | d¦«| d ¦«| d ¦«| d¦«| d¦«| d ¦«n7#tj$r%}t d|¦«Yd}~nd}~wwxYw| d¦«dS#| d¦«wxYw)u:Rebuild ``session_model_usage`` when its PRIMARY KEY lacks ``task``. Installs whose ``state.db`` reached ``schema_version >= 22`` before the ``task`` dimension was added carry a 5-column PRIMARY KEY ``(session_id, model, billing_provider, billing_base_url, billing_mode)``. ``_reconcile_columns()`` ADDs the ``task`` column as a bare nullable, but SQLite cannot ALTER a primary key, so the shipped composite 6-column key never lands. The version-gated v22 rebuild is unreachable on those installs (``current_version < 22`` is already false), so every upsert in ``_record_model_usage()`` fails with "ON CONFLICT clause does not match any PRIMARY KEY or UNIQUE constraint" â€” aborting the enclosing write transaction and silently zeroing all token *and* cost accounting (#73823). Idempotent; runs unconditionally on every open, same pattern as :meth:`_heal_gateway_routing_pk` above. On healthy databases the PRAGMA check short-circuits and this is a no-op. z(PRAGMA table_info("session_model_usage")NcóZ—t|ttf¦«r||n||Sr®rðrñs r"róz=SessionSchemaMixin._heal_session_model_usage_pk.._colÒrôr$cóD•—h|]}‰|dd¦«¯‰|dd¦«’ŒS)r¸rÛr3rirSrös €r"ú zBSessionSchemaMixin._heal_session_model_usage_pk..ÕsJø€ð ð ð Ø#$°°°Q¸¸4Ñ0@Ô0@ð ØˆDAvÑÔð ð ð r$Útaskzdsession_model_usage has legacy primary key %r (missing task); rebuilding with composite 6-column keyzPRAGMA foreign_keys=OFFzGALTER TABLE session_model_usage RENAME TO session_model_usage_legacy_pka_CREATE TABLE session_model_usage ( session_id TEXT NOT NULL REFERENCES sessions(id) ON DELETE CASCADE, model TEXT NOT NULL, billing_provider TEXT NOT NULL DEFAULT '', billing_base_url TEXT NOT NULL DEFAULT '', billing_mode TEXT NOT NULL DEFAULT '', task TEXT NOT NULL DEFAULT '', api_call_count INTEGER NOT NULL DEFAULT 0, input_tokens INTEGER NOT NULL DEFAULT 0, output_tokens INTEGER NOT NULL DEFAULT 0, cache_read_tokens INTEGER NOT NULL DEFAULT 0, cache_write_tokens INTEGER NOT NULL DEFAULT 0, reasoning_tokens INTEGER NOT NULL DEFAULT 0, estimated_cost_usd REAL NOT NULL DEFAULT 0, actual_cost_usd REAL NOT NULL DEFAULT 0, cost_status TEXT, cost_source TEXT, first_seen REAL, last_seen REAL, PRIMARY KEY (session_id, model, billing_provider, billing_base_url, billing_mode, task) )aINSERT OR IGNORE INTO session_model_usage ( session_id, model, billing_provider, billing_base_url, billing_mode, task, api_call_count, input_tokens, output_tokens, cache_read_tokens, cache_write_tokens, reasoning_tokens, estimated_cost_usd, actual_cost_usd, cost_status, cost_source, first_seen, last_seen ) SELECT session_id, model, COALESCE(billing_provider, ''), COALESCE(billing_base_url, ''), COALESCE(billing_mode, ''), COALESCE(task, ''), api_call_count, input_tokens, output_tokens, cache_read_tokens, cache_write_tokens, reasoning_tokens, estimated_cost_usd, actual_cost_usd, cost_status, cost_source, first_seen, last_seen FROM session_model_usage_legacy_pkz(DROP TABLE session_model_usage_legacy_pkú]CREATE INDEX IF NOT EXISTS idx_session_model_usage_session ON session_model_usage(session_id)úVCREATE INDEX IF NOT EXISTS idx_session_model_usage_model ON session_model_usage(model)z'session_model_usage PK heal skipped: %szPRAGMA foreign_keys=ON)r4r5r6r7r;rtr*r)r=r/r>rÿrCrós @r"Ú_heal_session_model_usage_pkz/SessionSchemaMixin._heal_session_model_usage_pkµsø€ð& Ø—>’>Ø:ñôçŠh‰jŒjð ˆDøõÔ'ð ð ð ØˆFˆFð øøøàð àˆFð Mð Mð Mð ð ð ð Ø(,ð ñ ô ˆðWÐÐàˆFåŠð 5å7‰OŒOñ ô ð ð ŠÐ0Ñ1Ô1Ð1ð? 5ØNŠNð:ñ ô ð ð NŠNðñ ô ð ð6 NŠNð9ñ ô ð ð& NŠNÐEÑFÔFÐFØNŠNð5ñ ô ð ð NŠNð0ñ ô ð ð øõÔ'ð Ið Ið IÝLŠLÐBÀCÑHÔHÐHÐHÐHÐHÐHÐHøøøøð Iøøøð NŠNÐ3Ñ4Ô4Ð4Ð4Ð4øˆFNŠNÐ3Ñ4Ô4Ð4Ð4øøøs=ƒ'+«>½>ÂA>DÄE'ÄE Ä(EÅE'ÅE Å E'Å'E>có²—|j ¦«}| t¦«| |¦«| |¦«| |¦« | d¦«n7#tj $r%}t d|¦«Yd}~nd}~wwxYw| t¦« | d¦«n#tj $rYnwxYw| |¦«}d}| dtf¦« ¦«du|_|jr| |¦«|s| |¦«| d¦«| ¦«}|€| dt&f¦«nvt)|tj¦«r|d n|d }|dkrct&dkrX|rT| |d¦«}|d ur5| |dt0¦«r| d¦«n d }n|€d }nd }|dkrt&dkr |dkrQ | dt3d¦«›¦«| d¦«n#tj $rYnwxYw|dkrI | |¦«n2#t6$r%}t d|¦«Yd}~nd}~wwxYw|dkr, | d¦«n#tj $rYnwxYw|dkræ | d¦« ¦«d }|s~| d¦«| d¦«| d¦«| d¦«| d¦«| d ¦«n7#tj $r%}t d!|¦«Yd}~nd}~wwxYw|dkr/|r-| |¦«r| d"d#|¬$¦«|d%kr| |¦«|r| |¦«s{| d&¦« ¦«€T| |¦«s?| |¦«s*| d'tCtD¦«|¬$¦«|t&kr |r|r| d(t&f¦«d)} | | ¦«n #tj#$r~ | d*¦«t $d+|j%¦«| | ¦«n/#tj&$rt 'd,¦«YnwxYwYntj $rYnwxYw|r½| |¦«} |jrE| (|| ¬-¦«r| )|¦«nMd |_*d |_+d |_,n6| r| -|¦«t]t^¦«k}| |d.t`¦«|_*|j*r<| |dtb¦«}||_+|r| 2||¬/¦«n¤| -|¦«t]t^¦«k}| |d.tf¦«|_*|j*rQ| |dt0¦«}||_+|r| 4||¬/¦«| )|¦«tk|d0d ¦«r| 6|¦«|j 7¦«dS)1aCreate tables and FTS if they don't exist, reconcile columns. Schema management follows the declarative reconciliation pattern (Beets, sqlite-utils): SCHEMA_SQL is the single source of truth. On existing databases, _reconcile_columns() diffs live columns against SCHEMA_SQL and ADDs any missing ones. This eliminates the version-gated migration chain for column additions, making it impossible for reordered or inserted migrations to skip columns. The schema_version table is retained for future data migrations (transforming existing rows) which cannot be handled declaratively. zŠCREATE INDEX IF NOT EXISTS idx_messages_platform_msg_id ON messages(session_id, platform_message_id) WHERE platform_message_id IS NOT NULLz/idx_messages_platform_msg_id create skipped: %sNz3UPDATE messages SET active = 1 WHERE active IS NULLTz.SELECT 1 FROM state_meta WHERE key = ? LIMIT 1z*SELECT version FROM schema_version LIMIT 1z/INSERT INTO schema_version (version) VALUES (?)Úversionré rkFzkINSERT INTO messages_fts_trigram(rowid, content) SELECT id, content FROM messages WHERE content IS NOT NULLééézäUPDATE sessions SET model_config = json_set(COALESCE(model_config, '{}'), '$._delegate_from', parent_session_id) WHERE parent_session_id IS NOT NULL AND json_extract(COALESCE(model_config, '{}'), '$._delegate_from') IS NULL AND ÚsessionsaUPDATE sessions SET model_config = json_set(COALESCE(model_config, '{}'), '$._delegate_from', '__orphaned__') WHERE parent_session_id IS NULL AND json_extract(COALESCE(model_config, '{}'), '$._delegate_from') IS NULL AND json_extract(COALESCE(model_config, '{}'), '$._branched_from') IS NULL AND title IS NULL AND message_count <= 25 AND EXISTS (SELECT 1 FROM messages m WHERE m.session_id = sessions.id AND m.role = 'tool') AND NOT EXISTS (SELECT 1 FROM sessions ch WHERE ch.parent_session_id = sessions.id)éz)v18 gateway metadata backfill skipped: %séaINSERT OR IGNORE INTO session_model_usage ( session_id, model, billing_provider, billing_base_url, billing_mode, api_call_count, input_tokens, output_tokens, cache_read_tokens, cache_write_tokens, reasoning_tokens, estimated_cost_usd, actual_cost_usd, cost_status, cost_source, first_seen, last_seen ) SELECT id, COALESCE(model, 'unknown'), COALESCE(billing_provider, ''), COALESCE(billing_base_url, ''), COALESCE(billing_mode, ''), COALESCE(api_call_count, 0), COALESCE(input_tokens, 0), COALESCE(output_tokens, 0), COALESCE(cache_read_tokens, 0), COALESCE(cache_write_tokens, 0), COALESCE(reasoning_tokens, 0), COALESCE(estimated_cost_usd, 0), COALESCE(actual_cost_usd, 0), cost_status, cost_source, started_at, COALESCE(ended_at, started_at) FROM sessions WHERE COALESCE(input_tokens, 0) + COALESCE(output_tokens, 0) + COALESCE(cache_read_tokens, 0) + COALESCE(cache_write_tokens, 0) + COALESCE(reasoning_tokens, 0) > 0éz\SELECT COUNT(*) FROM pragma_table_info('session_model_usage') WHERE name = 'task' AND pk > 0zAALTER TABLE session_model_usage RENAME TO session_model_usage_v21aËCREATE TABLE session_model_usage ( session_id TEXT NOT NULL REFERENCES sessions(id) ON DELETE CASCADE, model TEXT NOT NULL, billing_provider TEXT NOT NULL DEFAULT '', billing_base_url TEXT NOT NULL DEFAULT '', billing_mode TEXT NOT NULL DEFAULT '', task TEXT NOT NULL DEFAULT '', api_call_count INTEGER NOT NULL DEFAULT 0, input_tokens INTEGER NOT NULL DEFAULT 0, output_tokens INTEGER NOT NULL DEFAULT 0, cache_read_tokens INTEGER NOT NULL DEFAULT 0, cache_write_tokens INTEGER NOT NULL DEFAULT 0, reasoning_tokens INTEGER NOT NULL DEFAULT 0, estimated_cost_usd REAL NOT NULL DEFAULT 0, actual_cost_usd REAL NOT NULL DEFAULT 0, cost_status TEXT, cost_source TEXT, first_seen REAL, last_seen REAL, PRIMARY KEY (session_id, model, billing_provider, billing_base_url, billing_mode, task) )aõINSERT INTO session_model_usage ( session_id, model, billing_provider, billing_base_url, billing_mode, task, api_call_count, input_tokens, output_tokens, cache_read_tokens, cache_write_tokens, reasoning_tokens, estimated_cost_usd, actual_cost_usd, cost_status, cost_source, first_seen, last_seen ) SELECT session_id, model, billing_provider, billing_base_url, billing_mode, '', api_call_count, input_tokens, output_tokens, cache_read_tokens, cache_write_tokens, reasoning_tokens, estimated_cost_usd, actual_cost_usd, cost_status, cost_source, first_seen, last_seen FROM session_model_usage_v21z"DROP TABLE session_model_usage_v21rrz+v22 session_model_usage rebuild skipped: %sÚfts_optimize_availabler|r}ézESELECT 1 FROM state_meta WHERE key = 'fts_rebuild_high_water' LIMIT 1Úfts_storage_versionz%UPDATE schema_version SET version = ?zfCREATE UNIQUE INDEX IF NOT EXISTS idx_sessions_title_unique ON sessions(title) WHERE title IS NOT NULLagUPDATE sessions AS older SET title = NULL WHERE title IS NOT NULL AND EXISTS ( SELECT 1 FROM sessions AS newer WHERE newer.title = older.title AND newer.rowid > older.rowid )zFCleared %d duplicate session title(s) while restoring the unique indexzICould not repair duplicate session titles; unique title index not created)r‘rjr‚rž)8r˜r/r—rrírrr4r6r7r;rrrHr rWrrMrKrr8r9rrorrÚ-_backfill_gateway_metadata_from_sessions_jsonrprlr€rDÚ_has_fts_trashÚ'_fts_external_index_empty_with_messagesrŽrÚIntegrityErrorr<Úrowcountršrrr¥reržrŸrrZrurr rr‰r r‡Úgetattrryr›) r=r/rCÚfts5_availableÚfts_migrations_completer?Úcurrent_versionÚ_fts_trigram_existsÚ legacy_pkÚtitle_index_sqlÚ legacy_ftsÚtriggers_need_repairÚtrigram_enableds r"Ú_init_schemazSessionSchemaMixin._init_schema-sï €ð”×"Ò"Ñ$Ô$ˆà×ÒZÑ(Ô(Ð(ð ×Ò Ñ'Ô'Ð'ð ×%Ò% fÑ-Ô-Ð-ð ×)Ò)¨&Ñ1Ô1Ð1ð QØNŠNð8ñ ô ð ð øõ Ô'ð Qð Qð QÝLŠLÐJÈCÑPÔPÐPÐPÐPÐPÐPÐPøøøøð Qøøøð ×ÒÕ/Ñ0Ô0Ð0ð ØNŠNØEñ ô ð ð øõÔ'ð ð ð ØˆDð øøøð×3Ò3°FÑ;Ô;ˆØ"&ÐØ Ÿ.š.Ø<Ý Ðñ ô ÷Š(‰*Œ*˜Dð!ˆŒðŒ?ð 0ð ×'Ò'¨Ñ/Ô/Ð/Øð ,ð ×#Ò# FÑ+Ô+Ð+ð ŠÐCÑDÔDÐDØoŠoÑÔˆØˆ;ØNŠNØAÝÐ!ñ ô ð ñ õ 1;¸3ÅÄÑ0LÔ0LÐX˜c )œn˜nÐRUÐVWÔRXˆOð Ò#Ð#¸"Ò(<Ð(<ð"ð4Ø*.×*?Ò*?ØÐ 6ñ+ô+Ð'ð+¨eÐ3Ð3Ø×2Ò2Ø"Ð$:½Oñôð<ð#ŸNšNð!]ñôððð 7<Ð3Ð3Ø,Ð4Ø27Ð/øà.3Ð+Ø Ò#Ð#¸Ò(;Ð(;ðØ Ò#Ð#ðØ—N’NðBõ 4°JÑ?Ô?ð BðBñôðð—N’Nð TñôððøõÔ/ðððØDðøøøà Ò#Ð#ð SØ×FÒFÀvÑNÔNÐNÐNøÝ ðSðSðSõ —L’LÐ!LÈcÑRÔRÐRÐRÐRÐRÐRÐRøøøøðSøøøð Ò#Ð#ð!Ø—N’NðHñôððøõ>Ô/ðððØDðøøøà Ò#Ð#ð7UØ &§¢ð9ñ!ô!÷’h‘j”j ô!$Ið%ð0ØŸšÐ'jÑkÔkÐkØŸšð$ñôðð.Ÿšð?ñôððŸšÐ'KÑLÔLÐLØŸšðAñôððŸšð<ñôðøøõÔ/ðUðUðUÝ—L’LÐ!NÐPSÑTÔTÐTÐTÐTÐTÐTÐTøøøøðUøøøà Ò#Ð#ð:"ðP d×&DÒ&DÀVÑ&LÔ&LðPØ—M’MÐ":¸CÈMÑOÔOÐOà Ò#Ð#ð×2Ò2°6Ñ:Ô:Ð:ðð à×6Ò6°vÑ>Ô>ð ð—N’NðCñô÷’(‘*”*ð%ð×+Ò+¨FÑ3Ô3ð %ð ×DÒDÀVÑLÔLð%ð— ’ Ø)3Õ/BÑ+CÔ+CÈFðñôðð ¥.Ò0Ð0Ø+ð1à"ð1ð—’Ø;Ý#Ð%ñôðð 9ð ð ØNŠN˜?Ñ+Ô+Ð+Ð+øÝÔ%ð ð ð ð Ø—’ðñ ô ð õ—’Ø\Ø”Oñôðð—’˜Ñ/Ô/Ð/Ð/øÝ”=ð ð ð Ý× Ò ð5ñôðððð øøøøøõ Ô'ð ð ð ØˆDð øøøðñD @ð×7Ò7¸Ñ?Ô?ˆJØŒð1 8Ø×*Ò*¨6¸*Ð*ÑEÔEð4ð×/Ò/°Ñ7Ô7Ð7Ñ7à(-DÔ%Ø.3DÔ+Ø.3DÔ+Ñ+Øð' 8à×+Ò+¨FÑ3Ô3µc½-Ñ6HÔ6HÒHð%ð%)×$;Ò$;Ø˜NNñ%ô%Ô!ðÔ$ðØ&*×&=Ò&=ØÐ 6Õ8Nñ'ô'Oð/>DÔ+Ø+ðØ×8Ò8Ø"°Oð9ñôðøð ×+Ò+¨FÑ3Ô3µc½-Ñ6HÔ6HÒHð%ð%)×$;Ò$;Ø˜NGñ%ô%Ô!ðÔ$ð8Ø&*×&=Ò&=ØÐ 6½ñ'ô'Oð/>DÔ+Ø+ðØ×1Ò1Ø"Ø,;ð2ñôðð×/Ò/°Ñ7Ô7Ð7õt˜^¨UÑ3Ô3ð @Ø×7Ò7¸Ñ?Ô?Ð?àŒ ×ÒÑÔÐÐÐs¼Á4B Â B>ÂB9Â9B>ÃC2Ã2DÄDÉ;:J6Ê6KËKËK(Ë( LË2LÌLÌ!L7Ì7M ÍM ÍB-PÐP5ÐP0Ð0P5ÕUÕW;Õ.A V9Ö8W;Ö9)W%×"W;×$W%×%W;×*W;×:W;có,—t¦«dzdz}| ¦«sdSt|dd¬¦«5}tj|¦«}ddd¦«n#1swxYwYt|t¦«sdS| ¦«D]~\}}t|¦« d¦«st|t¦«sŒ>| d¦«}|sŒV| d ¦«}| d | d¦«p|t|t¦«r|pi d¦«nd| d ¦«t|t¦«r|pi d¦«nd| d¦«t|t¦«rtj|¦«nd| d¦«s| d¦«rdndt|¦«f¦«Œ€dS)uvOne-time v18 backfill of gateway metadata from sessions.json. Existing gateway sessions predate the display_name / origin_json / expiry_finalized columns; copy what sessions.json knows so consumers can switch to state.db without losing pre-migration sessions. Only fills NULL columns â€” never overwrites data written by newer code. rz sessions.jsonNr÷r§r©rUr@ÚoriginaiUPDATE sessions SET session_key = COALESCE(session_key, ?), chat_id = COALESCE(chat_id, ?), chat_type = COALESCE(chat_type, ?), thread_id = COALESCE(thread_id, ?), display_name = COALESCE(display_name, ?), origin_json = COALESCE(origin_json, ?), expiry_finalized = CASE WHEN COALESCE(expiry_finalized, 0) = 0 AND ? = 1 THEN 1 ELSE expiry_finalized END WHERE id = ?rþÚchat_idÚ chat_typeÚ thread_idÚdisplay_nameÚexpiry_finalizedÚmemory_flushedr3r) rÚexistsÚopenr¿Úloadr8r°r+rŽÚ startswithrÆr4Údumps) r=r/Ú sessions_fileÚfÚdatarüÚentryr@r's r"rz@SessionSchemaMixin._backfill_gateway_metadata_from_sessions_json sB€õ(Ñ)Ô)¨JÑ6¸ÑHˆ Ø×#Ò#Ñ%Ô%ð ØˆFÝ - ¨wÐ 7Ñ 7Ô 7ð ¸1Ý”9˜Q‘<”<ˆDð ð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð å˜$¥Ñ%Ô%ð ØˆFØŸ*š*™,œ,ð ñ ‰JˆCÝ3‰xŒx×"Ò" 3Ñ'Ô'ð z¸%ÅÑ/FÔ/Fð ØØŸš <Ñ0Ô0ˆJØð ØØ—Y’Y˜xÑ(Ô(ˆFØNŠNð#ð—I’I˜mÑ,Ô,Ð3°Ý5?ÀÍÑ5MÔ5MÐWV\˜r×&Ò& yÑ1Ô1Ð1ÐSWØ—I’I˜kÑ*Ô*Ý7AÀ&Í$Ñ7OÔ7OÐYV\˜r×&Ò& {Ñ3Ô3Ð3ÐUYØ—I’I˜nÑ-Ô-Ý*4°V½TÑ*BÔ*BÐL•D”J˜vÑ&Ô&Ð&ÈØŸšÐ#5Ñ6Ô6Ð\¸%¿)º)ÐDTÑ:UÔ:UÐ\AAÐ[\Ý˜ ‘O”Oð ñ ô ð ñ ð ð s½AÁA"Á%A")Ú__name__Ú __module__Ú__qualname__Ú__doc__r6ÚCursorrDÚboolrHrMÚstaticmethodrXrZrrŽraryrsrqr‡r‰rr¥rr(rírrr%rrSr$r"r'r'Usi€€€€€ØHÐHð'°G´Nð'Àtð'ð'ð'ð'ðR ¨G¬Nð ¸tð ð ð ð ð¨W¬^ðÀððððððK 7¤>ðK°cðKðKðKñ„\ðKðð -°¸#´ð -À4ð -ð -ð -ñ„\ð -ðS¸¼ðSÈCðSðSðSðSðj A°g´nð AÈð Að Að Að AðØ”nðà ððððð4ð!%ð ð ð Ø”ð ðð ð ð ð ð ñ„\ð ð,ð!%ð ð ð Ø”ð ðð ð ð ð ð ñ„\ð ðB w¤~ðÀ3ðÈ8ÐTXÌ>ððððð"[¨¬ð[ÀDð[ÈTð[ð[ð[ð[ðzðX¨#ðX°$°s¸DÀÀcÀ¼NÐ7JÔ2KðXðXðXñ„\ðXðtA¨¬ðA¸DðAðAðAðAðFG?¨w¬~ðG?À$ðG?ðG?ðG?ðG?ðRv5°7´>ðv5Àdðv5ðv5ðv5ðv5ðp^ð^ð^ð@/Ø”nð/à ð/ð/ð/ð/ð/ð/r$r')r:Úloggingr¿r6ÚtypingrrrÃrÚhermes_state_commonrrr r rrr rrrrrrÚ getLoggerr;rr)Ú__annotations__r-r'rSr$r"úrCstððððð€€€Ø€€€Ø€€€Ø!Ð!Ð!Ð!Ð!Ð!Ð!Ð!à,Ð,Ð,Ð,Ð,Ð,ððððððððððððððððððððððððððððððð$ ˆÔ ˜>Ñ *Ô *€ð+/Ð˜ œÐ.Ð.Ñ.ð(" eð("ð("ð("ð("ðVgðgðgðgðgñgôgðgðgðgr$