j7UdZddlmZddlZddlZddlZddlmZmZddl m Z m Z m Z ddl m Z mZmZmZmZmZdZdZd Zd Zd ZeeeeefZd ed <ehdZded<dZdZdZej>jAddZ!dZ"eGddZ#d&dZ$d'dZ%dddedd d(dZ&ddd d)dZ'e"fd*d Z(eGd!d"Z)dde"e!ddd# d+d$Z*gd%Z+y),uutils.pr_watcher_terminal_state_classifier — PR watcher 5-enum classifier. task-2673 — PR watcher terminal/callback fix implementation (RCA task-2670 follow-up). chair_authorization_id: CHAIR-AUTH-PR-WATCHER-TERMINAL-CALLBACK-FIX-20260526-JJONGS-IMPLEMENT-001 본 모듈은 dev7 watcher.py (`/home/jay/.cokacdir/workspace/29C74592/watcher.py`) 에서 관측된 4 결함을 재발 방지하기 위한 순수함수 classifier + envelope helper + ANU normal callback registrar 로 구성된다. 회장 verbatim 5 enum (terminal_states): - MERGE_READY — CI 11/11 + Gemini fresh + 0 unresolved + CLEAN - HOLD_FOR_CHAIR — 자동수렴 불가 · 회장 판정 필요 (head drift / fresh evidence + new unresolved / loop_boundary residual) - GEMINI_EXTERNAL_TRIGGER_STALE — OWNER nudge 후에도 fresh review 미도착 - CI_FAILED_NON_REMEDIABLE — Critical7 FAILURE 등 자동수렴 불가 - LOOP_BOUNDARY — max_watch 도과 (residual 없을 때만) 수정 목표 6 (회장 verbatim · task md): 1. fresh unresolved 발생 시 HOLD_FOR_CHAIR 조기 전환 2. terminal_state 5 enum evaluation 보강 3. ANU normal callback registrar 호출 보장 4. max_watch_minutes 도달 전 HOLD 조건 보강 5. LOOP_BOUNDARY elapsed-only 우선순위 보정 6. regression 추가 ) annotationsN) dataclassfield)datetime timedeltatimezone)AnyCallableDictListOptionalTuple MERGE_READYHOLD_FOR_CHAIRGEMINI_EXTERNAL_TRIGGER_STALECI_FAILED_NON_REMEDIABLE LOOP_BOUNDARYzTuple[str, ...]TERMINAL_STATES>ci/guardqc-check lock-in-checkhidden-path-auditcancel-kill-switchmerge-safety-checkguard frozensetDEFAULT_CRITICAL_CHECKSi<c119085addb0f8b7lL5: COKACDIR_BINz/usr/local/bin/cokacdirceZdZUdZdZded<dZded<dZded<ee Z ded <ee Z ded <d Z d ed <e ddZy) PRSnapshotz/PR watcher poll snapshot (test fixture parity).str head_ref_oidmerge_state_statusreview_decision)default_factoryzList[Dict[str, Any]]status_check_rollupreviewsrintunresolved_thread_countc |xsijdxsi}|jdxsi}|jdxsi}|jdxsi}|jdxsg}td|D}||xsijdxsd|xsijd xsd|xsijd xsd|xsijd xsg|xsijd xsg| S)Ndata repository pullRequest reviewThreadsnodesc3JK|]}|s|jdrdyw) isResolvedNget).0ns A/home/jay/workspace/utils/pr_watcher_terminal_state_classifier.py z%PRSnapshot.from_gh..XsKqQquu\7JKs ### headRefOidr#mergeStateStatusreviewDecisionstatusCheckRollupr*)r%r&r'r)r*r,)r7sum) clspr_datath_datar.repoprthreadsr2 unresolveds r:from_ghzPRSnapshot.from_ghQs 2""6*0bxx %+ XXm $ *&&)/R G$*KEKK !-R,,\:@b ' 2223EFL"$]//0@AGR!(B 3 34G H NB]'' 28b$.   N)rBDict[str, Any]rCrJreturnz 'PRSnapshot')__name__ __module__ __qualname____doc__r%__annotations__r&r'rlistr)r*r, classmethodrHrIr:r"r"Fsb9L#  OS05d0K-K$)$$?G !?#$S$  rIr"c|sy|Dcgc]-}|r)|jdxsijddk(r|/}}|syt|dScc}w)Nauthorloginzgemini-code-assistc,|jdxsdS)N submittedAtr#r6)rs r:z&latest_gemini_review..lsQUU=%9%?RrI)key)r7max)r*rYgeminis r:latest_gemini_reviewr^csc  !%%/'R,,W59MM F  v? @@ s2A ct|j}|sy|jdxsijdd|k(S)NFcommitoidr#)r^r*r7)snap expected_headlgs r:_is_gemini_freshreos< dll +B  FF8  " ' 'r 2m CCrIi)max_watch_secondshead_committed_utcgemini_stale_threshold_seccritical_checks now_utc_seccj|jDcic]}|s|jdd|} }|D cgc],} | j| xsijdddk(r| .} } | rtdt| fS|jr(|j|k7rt d|jd|dfSt ||} |j} |j}| r| d kDr|d k(r t d | d fSt|jxrtd |jD}|dk(r|jdvr|r| r | d k(rtdfS|9||nttj}||z }||kDr| s td|dfS||k\r(| d kDs|d k(rt d| d|d|dfSt d|dfSycc}wcc} w)u`5-enum decision tree (task md 수정 목표 1·2·4·5). 우선순위: 1) CI_FAILED_NON_REMEDIABLE (Critical7 FAILURE) 2) HOLD_FOR_CHAIR — head drift (목표 2 · spec admin override) 3) HOLD_FOR_CHAIR — fresh evidence + new unresolved (목표 1 · 4 · 사고 박제) 4) MERGE_READY (목표 2) 5) GEMINI_EXTERNAL_TRIGGER_STALE (목표 2) 6) HOLD_FOR_CHAIR — loop_boundary residual (목표 5) 7) LOOP_BOUNDARY (residual 없을 때만) 8) None / continue namer# conclusionFAILUREzcritical_failure: zhead_drift to z (expected u; spec §5 admin override)rBLOCKEDz%fresh_gemini_head_match + unresolved=u< + mss=BLOCKED (자동수렴 불가 · 회장 판정 필요)c3NK|]}|xr|jdddk(yw)rmr#SUCCESSNr6)r8cs r:r;zclassify..s-;782aeeL"%22;s#%CLEAN)APPROVEDr#z&>,!"!fb1,I, # MM!  " ' ' b 9Y F  $ (9!: ; <   T..-? T../0&'A C  $D-8L--J  ! !C Q3)+; 3J<@< =  112s;<@SI-(\se4./0@A  2345 6  Y,sF+F+1F0) last_snapshotextrasc |tvrtd||xsi}t|jdd} |jdd} t |jddxsd} |jdxsi} t | t r| jd d nd } d |d |d d|d|d|d|dd| d| d| d| dg }|r7t|jD]}|j|d||dj|}|jd}t|tkDrg}d}|D]C}t|jddz}||ztkDrn|j|||z }Edj|}|s2|r0|d}|jddt}|jdd}|S)uANU normal callback envelope (UTF-8 ≤ ENVELOPE_MAX_BYTES). body 는 ANU 가 consolidated report 를 작성할 때 필요한 최소 evidence 만 박제한다. zinvalid terminal_state: head_match_expectedFr=r#r,rr^rX-z[task-z PR #z watcher terminal]zterminal_state: zreason: zpolls: z elapsed: sz head_match: zmss: z unresolved: zlatest_gemini: u;action: ANU consolidated report (handoff policy §6 step 5):  utf-8r5Nignore)errors)r ValueErrorrwr7r+ isinstancedictrvkeysappendjoinencodelenENVELOPE_MAX_BYTESdecode)task_id pr_numberterminal_statereasonpolls_completed elapsed_secrrlast head_matchr~rGrdlg_atlineskbodyencoded out_linesrunninglnln_bytesheader truncateds r:build_callback_envelopers_,3N3EFGG  BDdhh4e<=J ((%r *CTXX7;@qAJ ( ) /RB*4R*>BFF=# &CE  yk);< >*+ 6( /"+k]!< zl# u zl# %!E E & .A LLA3b , - . 99U Dkk'"G 7|((!  B299W-.2H!$66   R x G  yy#U1XF g./B0BCI##GH#=D KrIctjtjt |z}|j dS)u9spec §11 + task-2661 Phase 2b absolute timestamp policy.)secondsz%Y-%m-%d %H:%M:%S)rrrutcrstrftime) delay_secondsfires r:_absolute_fire_atrs. << % -(H HD ==, --rIcleZdZUded<dZded<dZded<dZded <d Zd ed <dZded <dZ ded<y )CallbackRegisterResultrwfiredr#r$skipped_reasonrr+envelope_bytesfire_atN Optional[int] returncodestdoutstderr) rLrMrNrPrrrrrrrSrIr:rrsC KNCNCGS $J $FCFCrIr)anu_keychat_idr cokacdir_binrunner timeout_secc |jd}|stdddSt|tkDr*tddt|dtt|S|xs'tj j dxst}||} n8tj j d d xsd } | r t| nt} |stdd t|St|} |d |d| dt| d|dg } |xstj} | | dd|d}tt%|dddk(t%|dddk(rd ndt|| t%|dd t%|dd xsd t%|dd xsd S#t$r t} YwxYw#t$r<}tdd|j j"d|t|| cYd }~Sd }~wwxYw)uANU normal callback registrar (수정 목표 3 · spec §6 step 4). - envelope UTF-8 ≤ ENVELOPE_MAX_BYTES (invariant) - absolute timestamp now+delay_seconds (★ relative `30s` 형식 금지) - ANU key 단일출처 (env ANU_KEY → fallback ANU_KEY_DEFAULT; self-key 차단) - subprocess timeout 30s · retry 0 - 호출 실패는 silent (watcher 본체 정상 종료 보장) rFempty_enveloper)rrrzenvelope_oversize: z > ANU_KEYN ANU_CHAT_IDr#anu_key_missingz--cronz--atz--chatz--keyz--onceT)capture_outputtexttimeoutcheckzsubprocess_exception: r)rrrrrr5 non_zero_exitrr)rrrrrrr)rrrrosenvironr7ANU_KEY_DEFAULTr+ANU_CHAT_ID_DEFAULTrrr$ subprocessrun Exception __class__rLgetattr)enveloperrrrrrrr[chatraw_chatrcmdrprocexcs r:register_terminal_callbackr*s$oog&G %(8   7|((%0WcBTAUVw<   ARZZ^^I. A/C::>>-4: '$,3x=2ED %,w<   .G D   C  "JNNC 3t$ SXY "t\1-2$T<;q@ro7|4t4tXr*0btXr*0b C '&D '2  %3CMM4J4J3K2cUSw<    s03F FFF G#1GGG)rrrrrrrrrrrCALLBACK_DELAY_SECr"rr^rrr)r*zOptional[List[Dict[str, Any]]]rKOptional[Dict[str, Any]])rbr"rcr$rKrw)rbr"rzr+rcr$rfr+rgrrhr+rirrjrrKzTuple[str, str])rr$rr+rr$rr$rr+rr+rrrrrKr$)rr+rKr$)rr$rz Optional[str]rrrr+rr$rz4Optional[Callable[..., subprocess.CompletedProcess]]rr+rKr),rO __future__rrrry dataclassesrrrrrtypingr r r r r rrrrrrrrPrrrrrrr7rrr"r^rerrrrr__all__rSrIr:rsJ4#  (22== ! ?5 ! $&/0&$ zz~~n.GH      8 AD%(,&-!8!%c cc c  c & c!$cccc\/3'+: :: :  :  ::,: %: :z,>.   "!+$CGOOO O  O  O AOOOd rI