+ Wj9nRt^RIHt^RIHtHtHtHtHtH t ^RI H t ^RI H t ^RIHt!RR4tR#) aHeld-row coverage resolution for in-place compaction: which durable rows the compressor actually held. Names carried-forward dicts, id-less held dicts and the rows an alternation repair merged, dropped or folded, so ``archive_and_compact`` archives exactly those (or falls back to the watermark when a durable held row cannot be named). Mixin bound via the MRO next to SessionMessagesMixin, which owns the writes. ) annotations)AnyDictListOptionalSetTuple) coerce_epoch) _placeholders)_parse_tool_callsc]tRt^tRtRRltRRltRRRlltRR R lltRR R llt ] R Rl4t ] RRl4t Rt R#)SessionCoverageMixinzXCoverage helpers for SessionDB; relies on SessionMessagesMixin's codec/identity helpers.c$V^8dQhRRRRRR/#) session_idstrcarried_messageslist[dict[str, Any]]return list[int])formats"IC:\Users\johnn\AppData\Local\hermes\hermes-agent\hermes_state_coverage.py __annotate__!SessionCoverageMixin.__annotate__s$<-<- #<-7K<- <-c  aaaaV'g.#.pVFp\V\4'gKSPVPRR4VPR4VPR4\ VPR444pVPR4p\V\ 4'd\V\ 4'gV^8gRpVPWgVPR434K R VVV3R llpVU Uu.uF wrqfK VNK p p pT!\V 4\V48XdT MR4wop \V 4\V48XdL\;QJdV3R lV4F 'gK R M R M!V3R lV44'd V!R4wop .p VFwrgp Ve*SPV4V8XdV PV4K3\V RR7pVfKFV P.VOVN5.4p\V4^8XgKoV PV^,4K \\PV 44#uupp i)aResolve byte-identical carried-forward live dicts to their ACTIVE durable originals. _row_id is authoritative when the message carries it and the stored identity still matches. Resume surfaces that intentionally omit row ids fall back to a UNIQUE (role/content/tool identity, timestamp) match. Ambiguous or timestamp-less fallbacks are left as compacted history rather than risking a false rewind classification. roleunknowncontent tool_call_id tool_calls_row_idN timestampcV^8dQhRR/#)ridsOptional[list[int]]r)rs"rrCSessionCoverageMixin._resolve_carried_row_ids..__annotate__,s ! !+ !rc </p/pV'dR\V4 R2MRpSPRV R2S .T;'gR O54P4Fp\VR,4pSP VR,SP VR,4VR,\ VR ,44W&\VR ,R R 7pVfKyVP.W,OVN5.4PV4K W3#)z AND id IN ()zoSELECT id, role, content, tool_call_id, tool_calls, timestamp FROM messages WHERE session_id = ? AND active = 1 ORDER BY ididrrr r!r#message timestampfieldr) r executefetchallint _row_identity_decode_contentr r setdefaultappend) r%by_idby_keynarrowrowridtsconnselfrs & r_index=SessionCoverageMixin._resolve_carried_row_ids.._index,s02E79F=@|M#$6#7q9bF||66GZ%c,&78: "#k"2:MN>%%&7 &7B&7<CCCH= rc3R<"TFwrpSPV4V8gxK R#5iN)get).0identr;_r7s& r @SessionCoverageMixin._resolve_carried_row_ids..Bs%/e]dMEXY #%0G]ds$'TFr-r.) isinstancedictr3rCr r2boolr6lenanyr listfromkeys)r>r=rrcarriedmessageidentityrow_idr?rFrow_idsr8resolved raw_timestampr#matchesr7sfff& @r_resolve_carried_row_ids-SessionCoverageMixin._resolve_carried_row_idss I:<'Ggt,,)) FI. I0F TbHc!'++l";<>H[[+Fvs++Jvt4L4LQWZ[Q[ NNHgkk+.FG H( ! !(/6Lgla66gL#g,#g,*FwDQ v w<3w< 'CC/e]d/eCCC/e]d/e,e,e"4LME6 /6 +Hm!eii&78&C'$]:MNI jj!78!7Y!7CV_Crc bVPR4p\V\4'g.#VPVP VPRR4V44pVP RW#PR4V34P 4Uu.uFp\VR,4NK up#uupi)z`Active row ids whose stored role and content equal *message*. Empty when it was never persisted.rrrzXSELECT id FROM messages WHERE session_id = ? AND active = 1 AND role = ? AND content = ?r,)rCrIr_encode_content_loaded_view_contentr0r1r2)r>r=rrQrstoredr:s&&&& r_matching_active_ids)SessionCoverageMixin._matching_active_idsRs++i('3''I%%d&?&? FT]@^`g&hi*.,, f V,f 5+77?xz+BC+B3CI+BC CCsB,Nc(V^8dQhRRRRRRRR/#) rrrretiredr[ watermark Optional[int]rrr)rs"rrr\s, #.<IV rc \VPR4;'gR4pVRJpTPRV'dRMR R2W%.V'd \V43MR O54P 4p\ VPR4;'gR 4p.p VEF p VP WPPV R,44p T ;'gRVPR4;'gR8wdKWV R ,;'gRVPR 4;'gR8wdK\V R ,4;'g.p \V \ 4'd:V U u.uF,p \V \4'gKV PR 4NK. up M.pW8wdKV P\V R ,44EK# V #uup i) aTActive rows equal to a row the alternation repair retired without an id. Matched on role, loaded-view content (an empty assistant stores ``None`` or ``""``), tool_call_id and the ids of its tool calls. Only rows at or below *watermark*: the repair ran on a load taken before the snapshot, so a later equal row is another surface's append. rr*NzkSELECT id, content, tool_call_id, tool_calls FROM messages WHERE session_id = ? AND active = 1 AND role = ? AND id <= ?r+ tool_call_idsrr r!r,r) rrCr0r2r1rNr^r4r rIrJr6)r>r=rrcrdrboundrows want_callsrWr:rcallscallr%s&&&&& r_matching_retired_ids*SessionCoverageMixin._matching_retired_ids\s7;;v&,,"-%|| -2>;< I  Ee#i.!2 EGHPxz '++o6<<"= C//6J6J3y>6Z[G4W[[%;%C%CtDN#++t^1L1T1TPTU%c,&78>>BER\]bdhRiRieNedz$7M>488D>eNoqC  NN3s4y> * Os F>4F>c(V^8dQhRRRRRRRR/#) rrrrQr[rdrerr&r)rs"rrrzs,7'7' #7'.<7'IV7' 7'rc  ^RIHpHpHpVP R4VP V4rVP R4R8wg1\ V\ 4'd\V 4\JgV ^8d.#^RI H p V !V4wrVRJp TPRV 'dRMR R 2V.V 'd \V43MR O54P4U u.uFLp \V R ,4V R,VPV R,VPV R,443NKN pp \4pVP V4;'gR FSpVP V4'dKVP!WVV4p\#V4^8wdR#VP%V4KU VU u.uFq^,V9gKV NK pp .p\'\#V44FpR p\'V\#V44FpVV,wpppVR8wg\ V\ 4'gKJV'dV'dV R V 2M T;'gTpVP)V4'gKVV, ^,V 8XgKVV8XdATP+\'VV^,4Uu.uFpVV,^,NK up4K K \#V4^8dR#V'd V^,#.#uup iuup iuupi)aActive rows an alternation repair merged into *message*: ``[]`` for none, None when ambiguous. A reload without row ids turns a durable ``user;user`` pair (a prompt that never got its reply) into one dict equal to neither row. Read as an unpersisted turn, its rows would be re-sequenced after the compacted set like concurrent appends, behind the turn that is running. Only a dict the repair stamped: a prompt that was never persisted can carry the same text as rows another surface appended, and those were never held. Only rows at or below *watermark*: the repair ran on a load taken before the snapshot, so a run appended later that joins to the same text is another surface's, not the merged one. )MERGED_DURABLE_ROWSOWN_ROWRETIRED_DURABLE_ROWSrruser) strip_leading_message_timestampsNzJSELECT id, role, content FROM messages WHERE session_id = ? AND active = 1rgr*r+r,z r)&agent.conversation_compression_archiverrrsrtrCrIrtyper2gateway.message_timestampsrvr0r1r^r4setrnrLupdaterange startswithr6)r>r=rrQrdrrrsrtrwidthrvrFrir:rj retired_idsrcrWrunsstartmergedendr"rpartis&&&&& r_merged_user_run%SessionCoverageMixin._merged_user_runzs nm Y/=P1Q ;;v & ( 7C0H0HDQVK_bLbfknofoIO5g> %||\%*>3<ACEI0rCEFNXZPQPT^S[$*C*CCKQUQeQefijsftQu*v wP Qe {{#78>>B>G{{7##007IVG7|q    w ' ? $At1v['@tA "3t9%EFUCI.&*3i#t6>D#)>)>28TF84v.RV))&11;?e+( ucAg9N$O9NAT!WQZZ9N$OP/& t9q=tAw&B&CQ B%PsAK)$K.8K.K3 c ,V^8dQhRRRRRRRRR R /#) rrr covered_idsr&unresolved_heldzOptional[list[dict[str, Any]]]rdrerz$Optional[tuple[list[int], set[int]]]r)rs"rrrs65858 #582E58758DQ58 .58rc  ,aVfR#^RIHp^RIHpHpHoHp Hp VU u.uF/p \V \4'gKV ^8gK$\V 4NK1 p p \4p T;'gREFp\V\4'gKVPV 4'daVPWW4p\V4^8wdR#V PV4VPS4'gV P!V4K\";QJd8V3RlVPV 4;'gR4F 'gK RM- RM)!V3RlVPV 4;'gR44'dEKVP%WW4pVPV4'd V'gR#V'd.MVP'WV4p\V4^8g0VPV4'd\V4^8wd V'gR#T PT;'gT4T P!\VR,4\VPV4;'gR4, 4EK \)\P+V 44V 3#uup i) a``(ids safe to archive as summarized, ids merged into another held dict)``, or None when a durable held row cannot be named. An unresolved dict that still carries the persist marker was loaded from the DB. Failing to name it means the watermark path, which archives the rows the compressor saw, including ones whose ids were stripped. A marker-less miss is an unpersisted turn: it names nothing, and it is not a reason to abandon the ids we do have. Several active rows with the same content are ambiguous, so that also abandons, and so does a merged dict whose run cannot be named. The second set holds only merges the caller could not count: a dict that lists its own ``_absorbed_row_ids`` is already counted in ``tail_count``. N)_DB_PERSISTED_MARKER)ABSORBED_ROW_IDSrrrsrt RETIRED_ROWc3v<"TF.p\V\4;'dVPS4xK0 R#5irB)rIrJrC)rDr:rss& rrG8SessionCoverageMixin._proved_coverage..s.qIp#:c4(==SWWW-==Ips99TF:NNr)agent.context_compressorrrwrrrrsrtrrIr2rzrJrCrnrLextendr{rMrr`rNrO)r>r=rrrrdrrrrrtrrSproved merged_awayrQrWrunrss&&&&&& @r_proved_coverage%SessionCoverageMixin._proved_coverages  A _ _-8bK&:fc;R+W]`aWa+#f+Kb # &,,",Ggt,,{{;''44TwZw<1$ g&{{7++&&w/sqUiIjIpIpnpIpqsssqUiIjIpIpnpIpqqq'''MC{{.//bT%>%>tQX%YG7|aKK 455#g,!:KTW MM'..S )   s3r7|c'++>N2O2U2USU.VV W9-:DMM&)*K77?csJJJc V^8dQhRRRR/#)rtailrrr2r)rs"rrrsZZ%9ZcZrc ^aaaa^RIHoHoHoRVVV3Rllo\ V3RlV44#)aDurable rows behind the carried *tail* beyond one per dict, for the positional rewind. The watermark path cannot name a merged dict's run, so it widens by the stamp, less the rows the dict lists in ``_absorbed_row_ids``: those are already counted in ``tail_count``. Rows the repair dropped behind a dict, or folded into an assistant turn, on a reload without ids are in neither, so their count is added. A dict that holds a ``_row_id`` was written back as a single row by an earlier compaction. )rrrUNNAMED_DURABLE_ROWSc V^8dQhRRRR/#)rrQr[rr2r)rs"rrASessionCoverageMixin._uncounted_merged_rows..__annotate__s O ON Os Orc0<VPS4VPS4r!\V4\Jd3V^, \VPS4;'gR4, M^p\ ^V4\V4\Jd V,#^,#)rr)rCrxr2rLmax)rQrunnamedunlistedrrrrs& rbehind;SessionCoverageMixin._uncounted_merged_rows..behindsy%kk*=> L`@aGPTU[P\`cPcvzC 4D(E(K(K$LLijHq(#$w-32FwN NAN Nrc3<"TFLp\V\4'gK\VPR4\4'dKBS!V4xKN R#5i)r"N)rIrJrCr2)rDrQrs& rrG>SessionCoverageMixin._uncounted_merged_rows..sCZ+/'4( 1;GKK .s(Yv[CXs )r2rrL)rrrr~windowneeds&&f r_tail_originals$SessionCoverageMixin._tail_originalssQJ#FG,Fz?S(Y(Y%YYD}^)< < ErrrB)__name__ __module__ __qualname____firstlineno____doc__rXr`rnrr staticmethodrr__static_attributes__rrrr r sLb<-|C<7'r58nZZ(rr N)r __future__rtypingrrrrrrhermes_cli.timefmtr hermes_state_commonr hermes_state_messagesr r rrrrs*#88+-3wwr