IjYUdZddlmZddlZddlmZddlmZmZddlm Z ddl m Z m Z m Z mZdZd Zd ZeeeehZd ed <d ZdZdZdZdZdZdZdZdZdZeeeehZd ed<eeehZ d ed<dZ!dZ"dZ#dZ$ehdZ%d ed<dZ&d Z'd!Z(e d"e e)e ffZ*e d"e e)e ffZ+e e e)e fgdfZ,e ge)fZ-d+d#Z.ed$%Gd&d'Z/Gd(d)Z0gd*Z1y),uanu_v2.gemini_stale_prevention_runner — ANU v2 Gemini stale prevention runner v0 (task-2545). 회장 §명시 (2026-05-10): - Gemini evidence 가 도착한 PR 에 대해, 코드 변경이 필요한 Gemini real bug 를 같은 PR 에 push 하지 않는다. - same-PR push 는 Gemini evidence 를 stale 로 만들고 human trigger 를 강제하는 구조이므로 기본 금지. - expected_files 내부 real bug 수정이 필요한 경우 replacement_pr_runner 를 호출해 clean replacement PR 을 생성한다. - replacement PR 은 pull_request.opened 이벤트로 Gemini 자동 리뷰를 새로 받게 한다. - original PR 은 보존. close / reopen / force / rebase / empty commit 사용 금지. 핵심 5원칙 (회장 §명시): 1) Gemini evidence 도착 PR 에 code-changing fix same-PR push 금지 2) same-PR push 는 stale 강제 → human trigger 유발 구조이므로 기본 차단 3) expected_files 내부 real bug 는 replacement_pr_runner 호출 → clean replacement PR 4) replacement PR opened 이벤트 → Gemini 새 리뷰 자동 트리거 5) original PR 보존 (close / reopen / force / rebase / empty commit 절대 금지) 설계 원칙: - one-way isolation: anu_v2/* 만 import. utils / dispatch / scripts / dashboard 의존성 0. 표준 라이브러리만 보조 사용. - 외부 부수효과 (replacement PR runner / pr open health gate / audit writer / 시간) 는 모두 callable 주입 (DI). 미주입 시 메서드 호출 시점에 명시적 ValueError. - 단, audit_writer 는 jsonl 파일 append fallback 허용. - md / report fallback 분기 금지 (runner decision + check_run + PR diff 기준만). - bot `/gemini review` 코멘트 작성 금지 (코드 문자열 등장 0). - subprocess / git / gh 직접 호출 절대 금지. 모두 callable 주입 경로. - chat_id != 6937032012 audit record 금지 (default chat 이외 record 차단). ) annotationsN) dataclass)datetimetimezone)Path)AnyCallableMappingSequence SAME_PR_SAFE$SAME_PR_BLOCKED_REPLACEMENT_REQUIREDSAME_PR_BLOCKED_SCOPE_EXPANSIONzfrozenset[str] DECISIONSSAME_PR_RESOLVEDREPLACEMENT_PR_OPENEDSCOPE_EXPANSION_REPORTEDEMPTY_COMMIT_BLOCKEDfalse_positive style_onlyno_code_changeminor_fix_in_scopereal_bug_in_scopescope_expansion!NON_CODE_CHANGING_CLASSIFICATIONSCODE_CHANGING_CLASSIFICATIONSEXPECTED_FILES_SCOPE_EXPANSIONCREPLACEMENT_PR_CONTRACT_FRAMING_INCONSISTENT_WITH_ORIGIN_MAIN_STATE>OPENCLOSED ESCALATEDORIGINAL_PR_UNMERGED_STATES$EMPTY_COMMIT_TRIGGER_ATTEMPT_BLOCKEDzFPR #76 fixture proof: empty commit does not trigger Gemini App webhooklL5:.chtjtjj dS)uHUTC ISO-8601 (seconds 정밀도) — now_factory 미주입 시 fallback.seconds)timespec)rnowrutc isoformatr?r@rArBrCs r-__init__z$GeminiStalePreventionRunner.__init__s20N,-I* +G  (3(G7G  #.:D !%!A!AD  ==O +}}o'  ,r,c"|jS)u6주입된 now_factory 호출 (또는 default UTC ISO).)rJ)rOs r-_nowz GeminiStalePreventionRunner._nows  ""r,c|jdxs|jdxsd}djdt|D}|j|dz } |jj dd|j d d 5}|j tjt|d d dzdddy#1swYyxYw#t$rYywxYw)u?audit_writer 미주입 시 fallback — jsonl 파일에 append. audit_kindkindauditc3NK|]}|js|dk(r|ndyw)_N)isalnum).0cs r- zJGeminiStalePreventionRunner._default_jsonl_audit_writer..s#W!))+cACWs#%z.jsonlT)parentsexist_okazutf-8)encodingF) ensure_ascii sort_keys N) getjoinstrrHmkdiropenwritejsondumpsdictOSError)rOrecordrU safe_kindpathfps r-rLz7GeminiStalePreventionRunner._default_jsonl_audit_writerszz,'H6::f+=HGGWSQUYWW YKv"66     " "4$ " ?31 ^RDLuPTUX\\] ^ ^ ^   s00C 4C C CCC C"!C"cn|jd} | t|SdS#ttf$rYywxYw)u3thread dict 에서 thread_id 추출 (없으면 -1). thread_id)rer< TypeErrorrN)threadtids r- _thread_id_ofz)GeminiStalePreventionRunner._thread_id_ofsAjj% "3s8 6B 6:&  s ""44c|jd}t|tsy|jj S)uFthread dict 의 classification 문자열 추출 (lowercase normalize).classificationrW)re isinstancergstriplower)rwclss r-_classification_ofz.GeminiStalePreventionRunner._classification_ofs5jj)*#s#yy{  ""r,c|jd}t|tr|S||ntj |}|t vry|t vry|tk(ryy)u!thread dict 에서 code_change_required 추출. 명시되지 않으면 classification 기반. classification 인자가 주어지면 _classification_of 재호출 없이 그 값을 사용한다 (호출부에서 이미 cls 를 계산한 경우 중복 연산 회피). code_change_requiredFT)rer|boolr:rrrCLASSIFICATION_SCOPE_EXPANSION)rwr{explicitrs r-_is_code_change_requiredz4GeminiStalePreventionRunner._is_code_change_requiredsk::45 h %O) ,??G 3 3 / / 0 0r,cg}g}g}|D]}|j|}|j|}t|jdd}|tk(s|r|j |]|t vr|j |w|tvr|j ||j||r|j ||j |tt|t|t|S)utriage_classifications 를 3 버킷으로 분류. scope_expansion 판단은 classification 문자열 OR outside_expected_files=True 둘 중 하나라도 만족하면 scope_expansion 버킷으로 분리한다 (Critical 7종 #3 보고 누락 방지). outside_expected_filesFr{)r2r3r) ryrrrerappendrrrr1tuple) rOtriage_classificationsr2r3rrwrxr is_outsides r- _bucketizez&GeminiStalePreventionRunner._bucketize s$& ')%', .F$$V,C))&1Cfjj)A5IJJ44 &&s+77!((-33$$S),,VC,H$$S)!((-% .&  .#$56!/2  r,c d|j|}d}|d}nt|t|k7rd}|jr%t}dt |jdg}d} d} n>|j r%t }dt |j dg}d } d} n t}d g}d } d} |r|jd |d j|t |j t |jt |j| | t|t||dn t|t|d S)uGemini review 후 새 commit push 가 필요한지 + same-PR 안전 여부 판단. 분기 로직 (회장 §명시): - 모든 thread 가 비-코드변경 (false_positive / style_only / no_code_change) → SAME_PR_SAFE (same PR resolve 허용) - 코드변경 thread 1개 이상 + scope_expansion 0건 → SAME_PR_BLOCKED_REPLACEMENT_REQUIRED (replacement_pr_runner 호출 필요) - scope_expansion 1건 이상 → SAME_PR_BLOCKED_SCOPE_EXPANSION (Critical 7종 #3 보고 필요) gemini_review_commit_id != current_head_sha 일 때는 reason 에 "evidence_already_stale" 을 포함시키되 분류 자체는 동일 로직 적용. Args: pr_number: PR 번호. current_head_sha: 현재 PR HEAD SHA. gemini_review_commit_id: Gemini review 가 평가한 commit SHA (없으면 None). triage_classifications: auto_gemini_triage.classify_thread() 결과 list. Returns: dict: decision / reason / code_changing_threads / non_code_changing_threads / auto_retry_allowed / next_action / pr_number / current_head_sha / gemini_review_commit_id / evidence_stale. FNTz"scope_expansion threads detected: u# — Critical 7종 #3 보고 필요uqclassify_scope_expansion_as_critical_three 호출 후 회장 보고 (replacement PR 도 회장 승인 후 진행)z code-changing threads detected: u= — same-PR push 금지, replacement_pr_runner 호출 필요upivot_to_replacement_pr 호출 → clean replacement PR 생성 → pull_request.opened 이벤트로 Gemini 새 리뷰 자동 트리거ugall threads non-code-changing (false_positive / style_only / no_code_change) — same PR resolve 허용u:comments / threads resolve only — no new commit requiredevidence_already_stalez | ) decisionreasoncode_changing_threadsnon_code_changing_threadsscope_expansion_threadsauto_retry_allowed next_action pr_numbercurrent_head_shagemini_review_commit_idevidence_stale) rrgrrlistr2r r rrfr3r<r) rOrrrrbucketsrr reason_partsrrs r-evaluate_push_safetyz0GeminiStalePreventionRunner.evaluate_push_safety1so>//"89 " *!N ( )S1A-B B!N  " "6H4//011TVL @ "'   " ";H2--./066L V "' #H)L WK!%      8 9!jj.%)'*?*?%@)-g.G.G)H'+G,C,C'D"4&Y #$4 5/7SAX=Y">2  r,ct|tk7rtd||j td|jt|t |t ||Dcgc] }t |c}t|}t |ts!tdt|j|jdxs$|jdxs|jd}|jdxs$|jd xs|jd } |jd xs$|jd xs|jd } || | %tdt|j|jt|t | } t| jddt| jddt | jddd} | dj} d| vxs| d }|j!}d||j"t|t |t |dt|t | t | t|| d| dd }|j%|t|t | t | dt|t | t | t||d Scc}w)uhreplacement_pr_runner 호출하여 clean replacement PR 생성. 절대 금지 (회장 §명시): - original PR close / reopen - force / rebase / empty commit on original - bot `/gemini review` 코멘트 작성 original PR 보존 + replacement PR opened 이벤트로 Gemini 새 리뷰 트리거 기대. 본 메서드 자체는 git / gh 직접 호출 0 — 모두 주입된 callable 경유. Args: original_pr: 보존할 original PR 번호. original_branch: original PR branch 이름. original_head_sha: original PR HEAD SHA (audit 박제용). proposed_fixes: expected_files 내부 fix 명세 list. chat_id: 회장 §명시 default chat (6937032012). Returns: dict: replacement_pr_number / replacement_branch / replacement_head_sha / original_pr_preserved=True / pr_open_health_gate / gemini_first_evidence / trigger_missed. Raises: ValueError: replacement_pr_runner_callable 미주입 시 / chat_id mismatch 시. rEulreplacement_pr_runner_callable required for pivot_to_replacement_pr (회장 §명시 silent fallback 금지) original_proriginal_branchoriginal_head_shaproposed_fixesrBz?replacement_pr_runner_callable must return a Mapping. got type=replacement_pr_numberreplacement_prrreplacement_branch clean_branchbranchreplacement_head_sha clean_shahead_shazreplacement_pr_runner_callable result missing required keys (replacement_pr_number / replacement_branch / replacement_head_sha). got_keys=)rrevidence_arrivedFelapsed_secondsrr{rW)rrr{TRIGGER_MISSEDreplacement_pr_pivotT) rTtsrBrrroriginal_pr_preservedrrrtrigger_missedrr{) rrrrrpr_open_health_gategemini_first_evidencerr)r<rMrNrFrgrmr|r typer4resortedkeysrun_pr_open_health_gaterupperrRrIrK)rOrrrrrBf runner_resultrrrhealth_gate_resultrclassification_strrr audit_records r-pivot_to_replacement_prz3GeminiStalePreventionRunner.pivot_to_replacement_prsEB w,FJ^Jf"=#5#5#789; "9945!$%9!:: !%%7%;%;%?"%&8"9$'(<$=">2 56H I34DE  <(&))>%?"%&8"9$'(<$=%){+#'(:#;%)*?%@">2  M=s%K*c `|j td|jt|t|t|}t |t s!tdt |jt|jdd}|r tdt|jdd}|jdd } t|}t|jd d } ||| dt|t|t|d S#ttf$rd }YSwxYw) utask-2544 PROpenGeminiTriggerPrevention 호출. Gemini opened evidence 3분 watch. evidence 미도착 시 PR_OPEN_GEMINI_TRIGGER_MISSED 로 즉시 분류. long polling / self-register cron 절대 금지. Args: replacement_pr: replacement PR 번호. replacement_head_sha: replacement PR HEAD SHA. grace_seconds: grace window (기본 GRACE_SECONDS_PR_OPEN_HEALTH=180). Returns: dict: evidence_arrived / elapsed_seconds / classification / long_polling_invoked=False (강제 어설션). Raises: ValueError: pr_open_health_gate_callable 미주입 시 / callable 결과에 long_polling_invoked=True 포함 시. ujpr_open_health_gate_callable required for run_pr_open_health_gate (회장 §명시 silent fallback 금지))rr grace_secondsz=pr_open_health_gate_callable must return a Mapping. got type=long_polling_invokedFupr_open_health_gate_callable returned long_polling_invoked=True — 회장 §명시: long polling / self-register cron 절대 금지 (3분 grace 만 허용)rrrr{rW)rrr{rrrr) rGrNr<rgr|r rr4rrerv) rOrrr gate_result long_pollingrelapsed_seconds_rawrr{s r-rz3GeminiStalePreventionRunner.run_pr_open_health_gatesS0  - - 5;  88~.!$%9!:m,9 +w/ -6679  KOO,BEJK k   0BE JK)oo.?C !"56O[__-=rBC!1.,$)!.1$'(<$= /  :& O s DD-,D-c|jdz }dt||jt|dtt d}|j |dtt t|t|t|dS)u"empty commit 으로 Gemini webhook re-trigger 시도 차단. PR #76 사고 fixture 재현: empty commit 으로도 Gemini 도착 X 입증됨. 본 메서드 호출은 audit jsonl 박제만 수행 — 실제 empty commit 은 절대 수행 X. 본 클래스 어디에서도 git / gh / subprocess 직접 호출 없음. Args: pr_number: PR 번호. ts: 시도 시각 (ISO-8601 권장). Returns: dict: blocked=True / kind / reason / audit_jsonl_path / ts / pr_number. zempty_commit_block.jsonlempty_commit_blockT)rTrrBrblockedrUr)rrUraudit_jsonl_pathrr)rHrgrIr<EMPTY_COMMIT_BLOCKED_KINDEMPTY_COMMIT_BLOCKED_REASONrK)rOrrrros r-block_empty_commit_attemptz6GeminiStalePreventionRunner.block_empty_commit_attemptXsz ++.HH.b'}}Y-1  6"-1 #$4 5b'Y   r,c |Dchc] }t|}}t}|D]}t|jdd}|jdxs$|jdxs|jd} |r| r|j t| t| swt| |vs|j t| t |} t |Dchc] }t|c}} |j } d| |jt|tt| | dd } |j| ttt|| | d| d Scc}wcc}w) uexpected_files 외 수정 필요 시 Critical 7종 #3 (scope expansion) 분류. proposed_fixes 의 각 항목에서 다음 중 하나라도 해당하면 outside 로 분류: - outside_expected_files=True 명시 - target_file 이 expected_files_original 에 없음 Args: pr_number: PR 번호. proposed_fixes: expected_files 외부 후보 포함 fix 명세 list. expected_files_original: 원래 task 의 expected_files list. Returns: dict: critical_seven_kind=3 / kind_name / pr_number / expected_files_original (정렬) / proposed_outside_files (정렬) / report_to_chairman_required=True. rF target_filefilerqcritical_seven_scope_expansionT) rTrrBrcritical_seven_kind kind_nameexpected_files_originalproposed_outside_filesreport_to_chairman_required)rrrrrrr) rgsetrreaddrrRrIr<#CRITICAL_SEVEN_KIND_SCOPE_EXPANSION(CRITICAL_SEVEN_KIND_SCOPE_EXPANSION_NAMErK)rOrrrp expected_set outside_filesfix outside_flagrsorted_outsidesorted_expectedrrs r-*classify_scope_expansion_as_critical_threezFGeminiStalePreventionRunner.classify_scope_expansion_as_critical_three|sJ,)@@1A@ @"%% ! 4C(@% HIL''-0VCGGFOVswwvK !!#k"23s;/|C!!#k"23 4 . 2I!JQ#a&!JK YY[:}}Y#FA'6&4+/   <($GAY'6&4+/  ;A"Ks EEcFt|j}|tvxr|dv}|D chc] } t| } } |D chc] } t| } } t| | z } t |xr| } |j }d||j t|t||||ttt| t| | | | d}|j|| ttt|t|||t| t| | | |d Scc} wcc} w)uREPLACEMENT_PR_CONTRACT_FRAMING_INCONSISTENT_WITH_ORIGIN_MAIN_STATE 회귀 박제. 조건 (회장 §명시 2026-05-11, task-2545+2 corrected replacement): 1) original PR 이 OPEN / ESCALATED / CLOSED-without-merge 상태 (즉 origin/main 에 미반영) 2) replacement task expected_files 가 origin/main 실 상태 기준 effective diff 와 불일치 (특히 축소된 경우) 원칙: replacement expected_files 는 반드시 origin/main 실제 상태 기준 전체 effective diff 로 산정한다. original PR 머지 여부와 무관. Args: replacement_task_id: replacement task id (예: "task-2545+1"). original_pr_number: original PR 번호. original_pr_state: original PR 상태 ("OPEN" / "MERGED" / "CLOSED" / "ESCALATED"). original_pr_merged_at: original PR mergedAt (None 이면 미머지). replacement_expected_files: replacement task 가 선언한 expected_files. origin_main_effective_diff_files: origin/main 기준 실제 effective diff 파일 list. Returns: dict: contract_framing_inconsistent (bool) / critical_seven_kind=6 / kind_name / replacement_task_id / original_pr / original_pr_state / original_pr_unmerged (bool) / replacement_expected_files (정렬) / origin_main_effective_diff_files (정렬) / missing_from_replacement (정렬) — effective diff 에는 있는데 replacement expected_files 에는 없는 파일 list / report_to_chairman_required / ts. )NrWnull+critical_seven_replacement_contract_framing)rTrrBreplacement_task_idroriginal_pr_stateoriginal_pr_merged_atoriginal_pr_unmergedrrreplacement_expected_files origin_main_effective_diff_filesmissing_from_replacementcontract_framing_inconsistentr) rrrrrrrrrrrr) rgrr#rrrRrIr<0CRITICAL_SEVEN_KIND_REPLACEMENT_CONTRACT_FRAMING5CRITICAL_SEVEN_KIND_REPLACEMENT_CONTRACT_FRAMING_NAMErK)rOroriginal_pr_numberrrrroriginal_state_normrrreplacement_set effective_setrrrrs r-%classify_replacement_contract_framingzAGeminiStalePreventionRunner.classify_replacement_contract_framingsHP""34::< #> > <%);;  ,FFa3q6FF)IJAQJ J#)-/*I#J )- =%=) %YY[G}}#&':#;12!4%:$8#SN*0*A06}0E(@-J+H " <(.K#SN#&':#;12!4$8*0*A06}0E(@+H  =GJs DDc ,t|tk7rtd||j}|j t|t |||}|d} d} d} d} | t k(rt} n| tk(rPg}g}t}|D]v}|jdxs|jd}t|ttfs>|D]4}t |}||vs|j||j|6x|D]}|j!|}t#|jdd}|t$k7r|s;|j|j'||jd xs$|jd xs|jd d t$d |j)t|||}|d} t*} n5| t,k(r|j. tdg}|D]}|j!|}|t$k(r|j1||s2|j|j'|||jd xs$|jd xs|jd |jdxs|jdd|j3t|t |t ||t|} | jd} t4} ntd| | || | | t||dS)uevaluate → pivot (필요 시) → pr_open_health_gate → 결정 통합 entry point. 흐름 (회장 §명시): 1) evaluate_push_safety 호출 2) decision == SAME_PR_SAFE → outcome=SAME_PR_RESOLVED (pivot/health 호출 X) 3) decision == SAME_PR_BLOCKED_SCOPE_EXPANSION → classify_scope_expansion_as_critical_three 호출 → outcome=SCOPE_EXPANSION_REPORTED 4) decision == SAME_PR_BLOCKED_REPLACEMENT_REQUIRED → triage_classifications 중 code_change_required=True 항목을 proposed_fixes 로 변환 → pivot_to_replacement_pr 호출 → outcome=REPLACEMENT_PR_OPENED (replacement_pr_runner_callable 미주입 시 ValueError) Args: pr_number: PR 번호. current_head_sha: 현재 PR HEAD SHA. gemini_review_commit_id: Gemini review 가 평가한 commit SHA (없으면 None). triage_classifications: auto_gemini_triage.classify_thread() 결과 list. original_branch: original PR branch (replacement 시 audit 박제용). chat_id: 회장 §명시 default chat (6937032012). Returns: dict: outcome / evaluate_result / pivot_result | None / health_gate_result | None / critical_seven_classification | None / pr_number / ts. rE)rrrrrNrexpected_filesrFrrrqT)rtrrr{)rrrrureplacement_pr_runner_callable required for SAME_PR_BLOCKED_REPLACEMENT_REQUIRED outcome (회장 §명시 silent fallback 금지)rsummarybody)rtr{rrrrz,unknown decision from evaluate_push_safety: )outcomeevaluate_result pivot_resultrcritical_seven_classificationrr)r<rMrNrRrrgr OUTCOME_SAME_PR_RESOLVEDrrrer|rrrrrrrryr OUTCOME_SCOPE_EXPANSION_REPORTEDr rFrrOUTCOME_REPLACEMENT_PR_OPENED)rOrrrrrrBrrrrrrrproposed_fixes_for_criticalrexpected_files_seenrwefrsrrcritical_resultrs r-runzGeminiStalePreventionRunner.runsmH wZZ 9:ZfjjIY>Zb4-0>F$77/33A63::1= > >1 --f5!&**-Eu"MN 88+22!%!3!3F!;  =1.!::f-.!::f-.2&D 4  (#MMi.:(?NO -<xlK  .("4-JY  r,)r>z"ReplacementPrRunnerCallable | Noner?zPrOpenHealthGateCallable | Noner@zAuditWriter | NonerArrBr<rCzNowFactory | NonereturnNonerrg)roMapping[str, Any]rr)rwr rr<)rwr rrg)N)rwr r{ str | Nonerr)rSequence[Mapping[str, Any]]rr1) rr<rrgrr rr rdict[str, Any]) rr<rrgrrgrr rBr<rr )rr<rrgrr<rr )rr<rrgrr )rr<rr r Sequence[str]rr )rrgrr<rrgrr rrrrrr )rr<rrgrr rr rrgrBr<rr )r4r5r6r7r=r8rrMrPrRrL staticmethodryrrrrrrrrrrr+r,r-r:r:s ), #+ NRHL+/ <=&)-))K)'F ) ) )  ))') )X# ##&*!" 4# &A# # L[ [ [ ", [ !< [  [ H' B B B  B 4 B  B  B R: A A "A  A  A H! H; ; 4; "/ ;  ; |Y  Y  Y  Y * Y %2 Y +8Y  Y F'Y Y Y ", Y !< Y  Y Y  Y r,r:)r:r r rrrrrOUTCOME_EMPTY_COMMIT_BLOCKEDCLASSIFICATION_FALSE_POSITIVECLASSIFICATION_STYLE_ONLYCLASSIFICATION_NO_CODE_CHANGE!CLASSIFICATION_MINOR_FIX_IN_SCOPE CLASSIFICATION_REAL_BUG_IN_SCOPErrrrrrrr#rrrMr )2r7 __future__rrk dataclassesrrrpathlibrtypingrr r r r r r frozensetrr8rrrrrrrrrrrrrrrrr#rrrMrgReplacementPrRunnerCallablePrOpenHealthGateCallable AuditWriter NowFactoryr.r1r:__all__r+r,r-r s># !'33 'M$"C%(#' >. 7#= 5!1( 0$8!#6 !24=!!?5!> 1:%$;1~'(#+K(450I6/89/^CL 'sGCH,='=>#Cc):$:;S)*D01 b#g  D  $%%%a  a  H! r,