q0i&dZddlZddlZddlZddlZddlmZmZddlmZedZ edZ edZ edZ d Z d efd Zd Zd edededefdZdZedk(reyy)a) Genesis PreCompact CTM Hook (Layer 3 of Defense System - Enhanced) ================================================================= Fires before context compaction to backup transcript AND session state. This is the LAST CHANCE to preserve context before summarization. Enhanced after session 7e3fae84 crash: - Now also triggers a session heartbeat backup - Checks for active agents (danger condition for thinking block corruption) - Warns if compaction is happening during agent notification storm - Prunes old backups to prevent disk bloat N)datetimetimezone)Pathz*/mnt/e/genesis-system/data/context_backupsz(/mnt/e/genesis-system/data/context_statez+/mnt/e/genesis-system/hive/session_recoveryz(/mnt/e/genesis-system/data/observabilityreturnc tdz }|jr=t|d5}tj|}|j ddcdddS y#1swYyxYw#t $rYywxYw)z%Check if agents are currently active.z metrics.jsonr agents_activerN) EVENTS_DIRexistsopenjsonloadget Exception) metrics_filefmetricss 6/mnt/e/genesis-system/.claude/hooks/pre_compact_ctm.pyget_active_agent_countrs~ !N2    lC( 7A))A,{{?A6 7 7 !  7     s.%A&'A A&A#A&#A&& A21A2c ttjd}t|tkDr |dt D]}|j yy#t $rYywxYw)z=Remove old backups, keeping only the most recent MAX_BACKUPS.zpre_compact_*.jsonlN)sorted BACKUP_DIRgloblen MAX_BACKUPSunlinkr)backupsold_files rprune_old_backupsr +sb )>?@ w<+ %#Mk\2 "! " &    sAA AA session_idtrigger active_agents timestampc tjddtdz }d|d|d|d|d|d kDrd nd d } t|d 5}|j|dddy#1swYyxYw#t$rYywxYw)z*Write a compaction-specific recovery note.Tparentsexist_okz LATEST.mdzY# Session Recovery State ## Auto-generated by PreCompact CTM Hook **Compaction Event**: z **Session ID**: z **Trigger**: z" **Active Agents at Compaction**:  rzT**WARNING**: Agents were active during compaction -- thinking block corruption risk!z*No agents active during compaction (safe).a@ ## Recovery Instructions 1. If session crashed after this compaction, thinking blocks may have been corrupted 2. The pre-compaction transcript backup is in: `/mnt/e/genesis-system/data/context_backups/` 3. Read MEMORY.md for strategic context 4. Check `/mnt/e/genesis-system/hive/session_backups/` for heartbeat state wN) RECOVERY_DIRmkdirr writer)r!r"r#r$ recovery_filenoters rwrite_compaction_recoveryr06std3 ;.M!k" Y""/1[hkl[lWs_`` D - %  GGDM       s/ A.A"A."A+'A.+A.. A:9A:ct tjtjj }|jdd}|jdd}|jdd}tjtj}|jd}t}t j#dd|rFt$j&j)|r' t d |d |d z }t+j,||t.j#dd |j1d ||||d kDd}t.dz } t3| d5} | j5tj|dzdddt7||||j1t9i} |d kDr d|d| d<ttj| y#tj t f$r!ttjiYywxYw#t $rYwxYw#1swYxYw#t $rYwxYw)Ntranscript_pathr"unknownr!z %Y%m%d_%H%M%STr& pre_compact__z.jsonl pre_compactr)r$eventr"r!r#dangerzcompaction_log.jsonlar)zCOMPACTION DANGER: a agent(s) still active during compaction. Post-compaction thinking blocks may be corrupted if agent notifications arrive during the next API call. Consider killing agents or waiting for them to complete before continuing. This is the exact scenario that killed session 7e3fae84.additionalContext)rloadssysstdinreadJSONDecodeErrorrprintdumpsrrnowrutcstrftimerrr,ospathr shutilcopy2 STATE_DIR isoformatr r-r0r ) hook_inputr2r"r!rCr$r# backup_filer8log_filerresults rmainrPQsZZ  01 !nn%6;OnnY 2G i8J ,,x|| $C _-I*,MTD1277>>/: $gYa {&'QQK LL+ 6 OOD4O0  "$*#a'  55 (C  .A GGDJJu%, - . j'=#--/RFq!-1' ( "# $**V q  ) , djjn&    . .    sM1G &H/H+ (H5H+7H  H  HHH($H++ H76H7__main__)__doc__r=rrFrHrrpathlibrrrJr+r rintrr strr0rP__name__rrYs  ' > ? ; < AB < =        #  C \_ 6;| zFrX