+ iHjC Rt^RIHt^RIt^RIt^RIHtHtHtH t H t ^RI H t ^RI HtHtHtHtHt^RIHtHt^RIHtHt^RIHt]!R R R R R ]R04t];QJd.R]4FNK 5M !R]44t]!0R%m4t];QJd.R]4FNK 5M !R]44t R&t!R'],t"Rt#Rt$RRlt%RRlt&RRlt'RRlt(RRlt)RRlt*RR lt+R!R"lt,R#R$lt-R#)(zTranscript repair for SessionDB batch appends: reconcile in-memory rows with committed SQLite rows (in-place sanitizer rewrites, assistant blank-row repair, concurrent-winner adoption, watermark-compaction clone lookup) and sync markers after commit.) annotationsN)AnyCallableDictListMapping)_DB_PERSISTED_MARKER) CANONICAL_ROWDB_ROW_SNAPSHOT MESSAGE_UIDcopy_identity_fieldsmessage_uid_or_none) _id_chunks _placeholders)_fill_missing_tool_call_uids_restore_row_identity)_MESSAGE_WRITE_COLUMNS session_idrole timestampactivedisplay_identity tool_call_uidc#>"TFq\9gKVxK R#5iN)_NON_PAYLOAD_COLUMNS.0cs& r s[#9aFZ=Z#9  c#>"TFq\9gKVxK R#5ir)_METADATA_COLUMNSrs& rr r "sP/Q>O5Oqq/r!_metadata_only _content_onlyc V^8dQhRRRR/#)rowMapping[str, Any]returnstr)formats"r __annotate__r.-s!2sc.\P!^R7p\FpW,pVfVPR4K"\ V\ \ \34'dR\ V4rTM]\ V\4'dRVPRR4rTM3\ V\4'dRMR\V4PR 4rTVPV\V4P^R 4,V,4K VP4#) aFixed-size digest of the owned (non-metadata) columns (the CAS version) of a ``SELECT *`` messages row. Callers pass rows read back from SQLite, never Python bind values: column affinity rewrites values on storage (int ``platform_message_id`` -> TEXT, float ``token_count`` -> INTEGER), so hashing bind values would never match the stored version. A digest rather than a row copy: the value rides on live message dicts, so a full copy would double transcript memory and anything that prices dict bytes. ) digest_sizeNBSzutf-8 surrogatepassFIasciibig)hashlibblake2b_OWNED_COLUMNSupdate isinstancebytes bytearray memoryviewr+encodefloatreprlento_bytes hexdigest)r(digestcolumnvaluetagdatas& rtranscript_row_snapshotrM-s__ ,F   = MM$   eeY ; < <eEl s # #ell7OD!+E5!9!9td5kFXFXY`Fa cCI..q%884?@!    r/c(V^8dQhRRRRRRRR/#) r'connsqlite3.Connectionrr+messageslist[dict[str, Any]]r*Noner,)r-s"rr.r.Es1RR'9RsRVjRosRr/cvVUu/uF4p\VPR4\4'gK*VR,VbK6 pp\V4FdpVP R\ V4 R2V.VO54P 4F,p\V4V\VR,4,\&K. Kf R#uupi)ztStamp the stored-row digest on freshly inserted dicts (every ``_insert_message_rows`` caller; one SELECT per batch)._row_idz7SELECT * FROM messages WHERE session_id = ? AND id IN ()idN) r>getintrexecuterfetchallrMr )rOrrQmsgby_idchunkr(s&&& rstamp_inserted_row_snapshotsr_Es-5 \HS 3779CUWZ8[ S^S HE \E"<<EmTYFZE[[\ ]`j_smr_s (*C6MS5QE#c$i. !/ 2# ]s 'B6B6c V^8dQhRRRR/#)r'contentrr*boolr,)r-s"rr.r.Pscdr/cVfR#\V\4'dVP4'*#\V\4'd,RP RV44P4'*#R#)zYTrue when decoded message content is None, whitespace-only, or has no visible text parts.Tc3"TFGp\V\4'gKVPR4R8XgK3VPRR4xKI R#5i)typetextrdN)r>dictrX)rps& rr #is_content_blank..WsBqgAtAT,YZY^Y^_eYfjpYp,155,,gsAAAF)r>r+striplistjoin)ras&ris_content_blankrnPsW'3==?""'4  77qgqqwwyyy r/c ,V^8dQhRRRRRRRRRR /#) r'rOrPrr+r message_uidz str | Noner*zMapping[str, Any] | Noner,)r-s"rr.r.[s4 *-58GQr/cRVfR#VPRWV34P4#)aNewest active physical row for one durable logical message. A ``message_uid`` names a logical message, not a physical row: compaction/copy paths deliberately keep it while re-issuing row ids. The later active row is the current version. Callers use this only when the live dict also carries a stored-row snapshot, so a fresh message that merely resembles an older one can never be adopted here. NztSELECT * FROM messages WHERE session_id = ? AND active = 1 AND role = ? AND message_uid = ? ORDER BY id DESC LIMIT 1)rZfetchone)rOrrrps&&&&r_active_logical_message_rowrs[s4 << # ;' hj r/c8V^8dQhRRRRRRRRR RR R R R RR/#)r'rOrPrr+rQrRencode_content_fnzCallable[[Any], Any]decode_content_fnserialize_message_fnz4Callable[[dict[str, Any], float], Mapping[str, Any]] decode_row_fnz-Callable[[Mapping[str, Any]], dict[str, Any]]r*r,)r-s"rr.r.nsdYY YY#Y, Y , Y O YAYYr/c baa.pVEFp\V\4'dVPR4MRp \V\4'dVPRR4MRp \V\4'dVP\4MRp Ro\V \4'd\ WW4oM,\V \ 4'd\WV \V44oSfVPV4K\ SR,4p WR&\SV4Rp R;r\V \ 4'Ed`\S4V 8gpV'EgHV!V\SR,44oSR,f/SCRSR,/Co\;QJd$VV3R l\4F 'gK R M RM!VV3R l\44'd\WSS4R p\ Uu/uF"pVPV4eKVSV,bK$ pp\;QJd*R VP#44F 'gK R M RM!R VP#444'd4V!S4pVUu/uFpVV9gK VVV,bK p pR V \$&MV R 8Xd^\'V!SR ,44'd@VP)RV!VPR 44WSR ,34P*^8pMV R 8XdR V!SR ,4\,R /p V'd"VP)RW34P/4MSpVR,VR&\1VV4\V4V\&V'd V!V4p V 'd W\2&EKVP5\2R4EK V#uupiuupi)a:Resolve row-addressed rewrites without appending duplicates or replacing concurrent winners. A durable row snapshot is a compare-and-swap version for sanitizer rewrites. When a live replay loses its physical ``_row_id``, the pair (logical ``message_uid``, stored-row snapshot) recovers the newest active generation without matching mutable payload. Watermark-compaction clones are matched by their copied payload identity, not timestamp alone. Legacy blank assistant rows retain the narrow interrupted- stream content repair. Returns only rows that need fresh inserts. rUNrunknownrWFr token_countc3J<"TFpSV,SV,8gxK R#5irr,)rrI serialized target_rows& rr 6resolve_and_repair_transcript_batch..s ]nFz&)Z-??ns #Tc3("TFqRJxK R#5irr,)rrJs& rr rsG6FUD(6Fs assistantrazPUPDATE messages SET content = ? WHERE id = ? AND session_id = ? AND content IS ?6SELECT * FROM messages WHERE id = ? AND session_id = ?)r>rhrXr rY_active_message_rowr+rsr appendrrMrCanyr< _rewrite_row_LIVE_MISSING_METADATAvalues_METADATA_ONLYrnrZrowcount _CONTENT_ONLYrrrr pop)rOrrQrurvrwrx inserted_rowsr\existing_row_idrexpected target_id canonicaladoptwrotermissingdecoded final_rowr}r~s&&&&&&& @@r#resolve_and_repair_transcript_batchrns)"+-M0:30E0E#''),4-7T-B-Bswwvy) /9#t/D/D377?+$ os + +,TUJ # & &5TtM`adMefJ     %  4() "I$Z5  h $ $,J78CE51#uZ =T7UV m,4"ZJ!Y z-?X!YJ3]n]333]n]]] :zJ E5Kb5KswwWXz+1jm+5Kb3Ggnn6FG333Ggnn6FGGG+J7G8? P11<GAJI P04In- [ %56G S\H]6^%_%_LLb"3779#56 zZcOdehE{"&(9*Y:O(PR_aef LL DyF] (*: %[1K i-6yAO %i0I !*  GGM4 (MN Ec!QsN'6N'( N,6N,c ,V^8dQhRRRRRRRRRR /#) r'rOrPrr+r~r)r}r*rSr,)r-s"rr.r.sAaa aa"a" a  ar/caVR,pVeJVPRWR,V34P4Uu.uFp\VR,4NK upM.pRPR\44pVPRV R2.V3R l\4O\VR,4NVN4\ WVSWF4R#uupi) zXRewrite one durable payload whose digest matched the live dict's last committed version.rNztSELECT id FROM messages WHERE session_id = ? AND id != ? AND (active = 1 OR compacted = 1) AND display_identity IS ?rWz, c3*"TF q R2xK R#5i)z = ?Nr,rrIs& rr _rewrite_row..sI.hdO.zUPDATE messages SET z WHERE id = ? AND session_id = ?c36<"TFpSV,xK R#5irr,)rrIr}s& rr rs ;N&:f  N)rZr[rYrmr<_restore_display_index)rOrr~r} old_identityr( old_peer_ids assignmentss&&&f rrrs01L  ! << J D)< 8  (* C CI(*))I.IIKLL {m+KL_ ;N ;_SDAQ=R_T^_4Z\`sCc4V^8dQhRRRRRRRRRR R R R R /#)r'rOrPrr+r~r)r}rrrz list[int]r*rSr,)r-s"rr.r.sN- - - - "- " -  -  -  - r/c V'd2\V4p\V4pVPRV R2WGV.VO54\VR,4pVR,p \ VR,;'g VR,4p V 'gVPRWW34R#VPR WV 34P 4p \V.V U u.uF)p \V R ,e V R ,MV R,4NK+ up ,4p VPRWW34V 'd7TP R V U u.uFq\V R,4V3NK up 4R#R#uup iuup i) zLRestore display identities/orders invalidated by the payload-update trigger.z\UPDATE messages SET display_identity = ?, display_order = ? WHERE session_id = ? AND id IN (rVrWrr compactedz[UPDATE messages SET display_identity = ?, display_order = ? WHERE id = ? AND session_id = ?NzSELECT id, display_order FROM messages WHERE session_id = ? AND id != ? AND (active = 1 OR compacted = 1) AND display_identity IS ? display_orderzEUPDATE messages SET display_order = ? WHERE id = ? AND session_id = ?)rminrZrYrbr[ executemany)rOrr~r}rr placeholders old_orderr new_identityvisiblepeerspeer new_orders&&&&&& rrrsj$\2  %  //;nA ? j @< @ Jt$%I01L:h'BB:k+BCG  i i <   LL F  - hj    gl mgl_c3_(=(ItO$tTXz Zgl m nI LLe )8   SBG H%$T$Z* 5% H  n Is /E +E c(V^8dQhRRRRRRRR/#)r'rOrPrr+row_idrYrr,)r-s"rr.r.s*2202c232VY2r/c aVPRW!34P4oSeSR,V8wdR#\SR,;'g^4^8XdS#SR,fS#RPR\44pVPRV R 2VVSR,SR ,SR ,.V3R l\4O54P 4p\ V4^8Xd V^,#S#) z^The same-role active clone for ``row_id``, or the addressed inactive row when no clone exists.rNrrrz AND c3*"TF q R2xK R#5i)z IS ?Nr,rs& rr &_active_message_row.."s%U_6&6_rzSELECT * FROM messages WHERE session_id = ? AND active = 1 AND role = ? AND display_identity IS ? AND timestamp IS ? AND id != ? AND z ORDER BY id DESC LIMIT 2rrWc36<"TFpSV,xK R#5irr,)rrIr(s& rr r-s 8fc&kkr)rZrrrYrm_REPAIR_COLUMNSr[rE)rOrrrpayload_predicatesclonesr(s&&&& @rrrs ,,@6BV hj {c&kT) 3x=  A!#  &  %U_%UU \\ H  7 9   " #   I  9 8  hj F q(6!91c1r/c$V^8dQhRRRRRR/#)r' batch_msgsrR batch_rowsr*rSr,)r-s"rr.r.3s$++-A+Oc+hl+r/c\W4EFwr#RV\&\VPR4\4'd VR,VR&\ W24\VPR4\\ 34'd VR,VR&\VP\4\4'dV\,V\&VP\4p\V\4'd`VP\4'dE\F7pVPV4fKVPV4eK-WE,W%&K9 EKI\V\4'd+VP\4'dVR,VR&EK\V\4'gEK\F:pWT9dWE,e WE,W%&KVR9gK(VPVR4K< EK R#)zYStamp persistence markers and sync canonical durable fields onto live dicts after commit.TrUrNra)rra)ziprr>rXrYr rCr r+r rhrrr _SYNC_FIELDSr)rrwrittenr(rkeys&& rsync_flushed_message_markersr3saJ3 (,$% cggi(# . .!$YGI S* cggk*S%L 9 9#&{#3GK cggo. 4 4'*?';GO $GGM* i & &9==+H+H-==%1gkk#6F6N#,>GL. 4 ( (Y]]=-I-I!*9!5GI   4 ( (## (B#,>GL 33KKT* $%4r/> api_content display_kinddisplay_metadataplatform_message_idcodex_reasoning_items)rr)r).__doc__ __future__rr:sqlite3typingrrrrragent.context_compressorragent.message_metadatar r r r r hermes_state_commonrrhermes_state_identityrrhermes_state_messagesr frozensetrtuplerr#r<rrrrrMr_rnrsrrrrrr,r/rrs0#559\\9U8!6;2DkSbce%[#9[%%[#9[[gP/PP/PP=?* " 0R&Yxa4- `2>+r/