AjQUdZddlmZddlZddlZddlZddlmZddlmZm Z m Z ddl m Z ddl mZdZd ed <e e d Zej$d ej&ZdZej$ddj-deDzdzZddZeGddZeGddZeGddZGddZy)uanu_v2.worktree_cleanup — 6대 안전조건 기반 worktree cleanup helper (task-2550). 회장 §명시 (2026-05-11 C방안 승인): - 81개 누적 .worktrees 정리 — dry-run 우선, --apply는 별도 승인 - 6대 안전조건 AND 게이트 — 어느 하나라도 FAIL 시 skip + log - main worktree 절대 보호 (workspace_root path 차단) - one-way isolation: anu_v2 외부 import 금지 6대 안전조건: 1. task .done.acked 마커 존재 2. PR state = MERGED (gh API) 3. task .merge-done 마커 존재 4. branch가 main에 ancestor (git merge-base --is-ancestor) 5. worktree 사용 중 X (pgrep + git worktree list lock) 6. dry-run default; --apply 명시 시에만 실제 삭제 dirty worktree skip + log (memory/events/worktree-cleanup-skipped-.json) ) annotationsN) dataclass)datetime timedeltatimezone)Path)CallablelL5:intDEFAULT_CHAT_ID )hoursz((?:ghp_|ghs_|github_pat_)[A-Za-z0-9_\-]+) github_tokenbot_github_tokengh_token owner_patz x-api-key authorizationsecretpasswordz(?i)(|c#FK|]}tj|ywN)reescape).0hs H/home/jay/workspace/.worktrees/task-2550-dev5/anu_v2/worktree_cleanup.py r,s> ! >s!z)([=:\s]+[^\s,;\"']{1,200})ct|tr|n t|}tjd|}tjd|}|S)uraw token / API key 마스킹. ***MASKED***cT|jd|jddzdzS)Nrr)group)ms rz _sanitize_text..5s$AGGAJA$>$O) isinstancestr_TOKEN_PREFIX_REsub _KEY_VALUE_RE)textss r_sanitize_textr.1sA4%3t9A^Q/AOQRSA Hr&c:eZdZUdZded<ded<ded<ded<y) WorktreeCandidateuworktree 후보 1개.r(pathbranch str | Nonetask_idhead_shaN__name__ __module__ __qualname____doc____annotations__r&rr0r09s I K Mr&r0c:eZdZUdZded<ded<ded<ded<y ) SafetyConditionResultu6대 안전조건 결과.r conditionr(nameboolpasseddetailNr6r<r&rr>r>Bs#N I L Kr&r>cveZdZUdZded<ded<ded<ded <ded <ded <ded <ded <ded<ded<y) CleanupResultuworktree 1개 cleanup 결과.r( worktree_pathr3r4zlist[SafetyConditionResult]safety_resultsrAall_safedirtyis_mainappliedskipped skip_reasontsNr6r<r&rrErEKs;' //N K M M M Gr&rEceZdZdZdddd ddZddZdddZddZddZdd Z dd Z dd Z dd Z dd Z eddZdddZdddZddZy) WorktreeCleanupuq6대 안전조건 기반 worktree cleanup helper. 외부 부수효과는 모두 Callable 주입 가능. N)subprocess_runnerclockworkspace_rootc||ntj|_||nd|_|||_yt d|_y)Nc6tjtS)N)tz)rnow_KSTr<r&rr%z*WorktreeCleanup.__init__..hsx||t?Tr&z/home/jay/workspace) subprocessrun_subprocess_runner_clockr_workspace_root)selfrQrRrSs r__init__zWorktreeCleanup.__init__`sF8I7T"3ZdZhZh$0e7T 1?1K~QUVkQlr&c|jdz dz |dz }|j}tdd||rdSd|S) u:안전조건 1: memory/events/.done.acked 존재.memoryeventsz .done.ackedr! done_ackedok missing: r?r@rBrCr]existsr>r^r4markerrBs rcheck_safety_1_done_ackedz)WorktreeCleanup.check_safety_1_done_ackedm[%%08; >UU$l6"D  *3F8(<  r&c d}|r!|jdr|tddn|} gd}|r|jd|gn|jd|g|j|dddt |j d }|j d k7r(td d dd t|jddStj|jxsd}|std d ddS|Dcgc]"}|t |jddvs!|$}}|std d dd|dS|D]:}|jddk(std d dd|jddcStd d dd|D cgc]} | jdc} Scc}wcc} w#tjtj t"f$r1} td d ddtt | ddcYd} ~ Sd} ~ wwxYw)u안전조건 2: gh API로 task의 PR state == MERGED 확인. gh API 호출 전략: 1. branch가 주어지면 `--head ` 정확 매칭 시도 2. branch가 None이거나 1번 실패 시 head 없이 전체 검색 후 headRefName에서 task_id 매칭 gh API 실패 시 FAIL (보수적). 어느 dev 팀(dev1~dev7)이든 매칭 가능. Nz refs/heads/)ghprlistz--stateallz--jsonznumber,state,headRefNamez--headz--searchTFcapture_outputr,checkcwdtimeoutrr" pr_mergedzgh api failed: rfz[]z no PR found headRefNamezno PR with task_id=z' in headRefName (unrelated PR rejected)stateMERGEDzPR #numberz MERGEDz PR state: error: d) startswithlenextendr[r(r] returncoder>r.stderrjsonloadsstdoutgetrYTimeoutExpiredJSONDecodeErrorOSError) r^r4r2head_refcmdprocprsro candidatespes rcheck_safety_2_pr_mergedz(WorktreeCleanup.check_safety_2_pr_mergedvst $ 6<6G6G 6Vvc-012\bH GiC Hh/0 J01**3t$V[adeieyeyazEG*HD!#,k%,^DKK-H#-N,OP**T[[0D1C,q{SXanoo(+XgRVVMSU=V9W.W"XJX,k%0 9`a! F66'?h.01;W[fjkmkqkqrzk{j|}DeEFF F)1;u_iDNkO~klkpkpqxkykOjP^QR RYkO))4+?+?I G(1;u_fguvyz{v|g}C@ChDgE^FG G Gs`B F#53F#)F#-"FFF#+F##F#)F#7F F# F##(G< &G71G<7G<c|jdz dz |dz }|j}tdd||rdSd|S) u:안전조건 3: memory/events/.merge-done 존재.rarbz .merge-done merge_donerdrerfrgris rcheck_safety_3_merge_donez)WorktreeCleanup.check_safety_3_merge_donerlr&c X ddd|dg}|j|dddt|jd}|jd k(}t d d ||rd Sd |jdS#t j tf$r(}t d d ddt|ddcYd}~Sd}~wwxYw)u안전조건 4: git merge-base --is-ancestor origin/main → 0 (PASS). branch가 main에 머지되었으면 ancestor. gitz merge-basez --is-ancestorz origin/mainTFrsrbranch_in_mainzancestor of mainzNOT ancestor (rc=)rfrNr)r[r(r]rr>rYrr)r^r2rrrBrs rcheck_safety_4_branch_in_mainz-WorktreeCleanup.check_safety_4_branch_in_mains |,OC**3t$V[adeieyeyazEG*HDoo*F("26.4* : 다른 봇 process가 path를 사용 중이 아닌지 확인 둘 다 PASS여야 안전 (AND 게이트). 한쪽이라도 FAIL이면 사용 중으로 판정. rworktreerp --porcelainTFrrsr not_in_usezgit worktree list failed: rc=rf worktree N)lockedprunable)zlocked z prunable z4worktree is locked or prunable per git worktree listzgit worktree list error: rpgrepz-frtr,rurwr!z#git list OK + no process using pathz process(es) using pathz pgrep rc=z pgrep error: ) r[r(r]rr>r splitlinesrrstriprYrr) r^rFcmd_aproc_alocked_or_prunablein_target_blocklinercmd_bproc_b pid_counts rcheck_safety_5_not_in_usez)WorktreeCleanup.check_safety_5_not_in_uses J>E,,dU,,-r-F  A%,l5:6;L;L:MN "' #O 002 ??;/&*3{+;+<&=&C&C&E&VO$9O)O)-&$9Q)R)-& ",l5Q" ~dM2E,,U4dZ_ik,lF  A%,q|TXbGHH""a' 3 3 5 @ @ BC ,q|TYendopGcHII,q|TYdmntnnnAcBCC))73 J(1)r^ apply_flags rcheck_safety_6_apply_explicitz-WorktreeCleanup.check_safety_6_apply_explicits,%.z+5'  ;W  r&c dd|ddg}|j|dddd}t|jjS#tj t f$rYywxYw) uuuncommitted changes 존재 여부. `git status --porcelain` 결과가 비어있지 않으면 dirty. rz-CstatusrTFrr)r[rArrrYrr)r^rFrrs ris_dirty_worktreez!WorktreeCleanup.is_dirty_worktreesi  $ xGC**3t$V[eg*hD ))+, ,))73  s?AAAc t|j}|jj}||k(S#t$rYywxYw)uI★ workspace_root와 동일 경로면 main worktree → 절대 삭제 X.T)rresolver]r)r^rFwpwrs ris_main_worktreez WorktreeCleanup.is_main_worktree sI m$,,.B%%--/B8O  s7: AAc  gd}|j|dddt|jd}|jdk7rgSg}|jj j d}|D]}|j j}|s$d}d}d} |D]} | jd r| td d j }1| jd r| td d j }_| jd sq| td d j } |s|j| xs|} |jt|| | | |S#tjtf$rgcYSwxYw)ugit worktree list로 모든 worktree 열거. main worktree는 결과에 포함되지만, cleanup_worktree에서 차단. rTFrrsrz r{rNzHEAD zbranch )r1r2r4r5)r[r(r]rrrsplitrrr_extract_task_idappendr0rYrr) r^rrrblocksblklinesr1headr2rr4s renumerate_worktreesz#WorktreeCleanup.enumerate_worktreess  1#CLM288:3!%c)no!6! ?"33FNdCG%%&7T&Zalp&qr! s" ))73 I s$>E#C E# E#,6E##FFc^tjd|}|rd|jdSdS)uLbranch / path에서 task_id 추출 (예: task/task-2474-dev2 → task-2474).ztask-(\d+(?:\.\d+)?)ztask-r!N)rsearchr#)r-r$s rrz WorktreeCleanup._extract_task_id5s1 II-q 1'(qwwqzl#2d2r&c |jj}|j|jr<|j |d|t |j|j gdddddd| S|j|j}|r<|j |d|t |j|j gdddddd| S|j st |jdgdddddd | S|j|j |j|j |j |j|j |j|j|j|j|j|g}td |D}d}d}d} |s`d}|D cgc]} | j r| j"} } d | } t%| } | d hz } | r|j |dt'| |nq|sd}d} nj ddd|jg}|j)|dddt+|j,d}|j.dk(rd}nd}dt1|j2dd} t |j|j ||dd||| | Scc} w#t4j6t8f$r&}d}dt1t+|dd} Yd}~hd}~wwxYw)uH단일 worktree cleanup 시도. 6대 안전조건 AND 검증 후 실행.main_worktree_protectedFTu0main worktree (workspace_root) — never deleted) rFr4rGrHrIrJrKrLrMrNrIz$dirty worktree (uncommitted changes)Nztask_id cannot be extracted)r2c34K|]}|jywr)rB)rrs rrz3WorktreeCleanup.cleanup_worktree..hs1Aqxx1szsafety failed: rzsafety_failed:zdry-run mode (apply=False)rrremoverrrsrzgit worktree remove failed: ryrr)r\ isoformatrr1 _log_skippedrEr4rrkrr2rrrrrqrBr@setsortedr[r(r]rr.rrYrr)r^ candidateapplyrNrIresultsrHrKrLrMrfailed failed_setnon_apply_failuresrrrs rcleanup_worktreez WorktreeCleanup.cleanup_worktree=s [[] $ $ &   0   i)BB G 'nni6G6G!Et9k  &&y~~6    i" 5 'nni6G6G!Eut9_     'nnd!Et9V    * *9+<+< =  ) ))*;*;IDTDT ) U  * *9+<+< =  . .y/?/? @  * *9>> :  . .u 5  111"& G&->QXXaff>F>+F84KVJ!+/?.@!@ !!!)~fEW>X=Y-Z\^_G6K Gj(INNC..s4dZ_ehimi}i}e~IK.L??a'"G"G$@PTP[P[A\]a^aAb@c"dK #..)2C2C"XUEW+   3?*--w7 G 's1v(>t(D'EF  Gs%:J. J.A)J33K2 K--K2cxg}|jD]$}|j|j||&|S)u/모든 worktree 후보 검사. dry-run default.)r)rrr)r^rrcands rcleanup_all_dry_runz#WorktreeCleanup.cleanup_all_dry_runsB'),,. ED NN400U0C D Er&c< |jddjdd}tt|jdz}|jdz dz d|d|dz }|j j d d ||jrt|jnd t|jt|j|td }t|d d5}tj||ddd d d y #1swYy xYw#t$rYy wxYw)uskip log 박제 → memory/events/worktree-cleanup-skipped--.json. ts + path hash로 파일명 유일성 확보 (동시 실행 시 덮어쓰기 방지). branch / worktree_path 필드는 _sanitize_text로 token-like 노출 방어. :-.irarbzworktree-cleanup-skipped-z.jsonT)parentsexist_okN)rNr4rFr2reasonchat_idwzutf-8)encodingFr") ensure_asciiindent)replaceabshashr1r]parentmkdirr4r.r2r openrdumpr) r^rrrN ts_compact path_hashlog_pathpayloadfs rrzWorktreeCleanup._log_skippeds  C-55c3?JD01U;I++h6AF_`j_kklmvlww|D}}H OO ! !$ ! >@I@Q@Q>)*;*;r)r4r(r2r3rr>)r2r(rr>)rFr(rr>)rrArr>)rFr(rrA)rzlist[WorktreeCandidate])r-r(rr3)F)rr0rrArrE)rrArzlist[CleanupResult])rr0rr(rNr(rr)r7r8r9r:r_rkrrrrrrrr staticmethodrrrrr<r&rrPrPZsPT/3&* mM m- m $ m  m (GT | 6~p  B33Q fr&rP)r,objectrr()r: __future__rrrrY dataclassesrrrrpathlibrtypingr r r;rXcompile IGNORECASEr)TOKEN_KEY_HINTSjoinr+r.r0r>rErPr<r&rrs&# !22"! "#2::/MM  sxx>o>>>B""             VVr&