jTUdZddlmZddlZddlmZmZddlmZddlZdZ dZ dZ d Z d Z d Zd Zd ed<ddZGddZy)u[anu_v2.pr_open_gemini_trigger_prevention — ANU v2 PR open Gemini trigger miss 예방 + 조기 분류 (task-2544). 회장 §명시 (2026-05-10): 목표: PR open 시점에서 Gemini trigger miss를 예방하고 조기 분류한다. 사고 배경: task-2537 PR #86 — Gemini Code Assist 미수신 → 25분 polling 재발 → 회장 직접 kill 2회. 설계 원칙: - one-way isolation: anu_v2/ 외부 import 금지. 외부 모듈(utils/dispatch/scripts/dashboard)은 anu_v2를 import 가능하나, anu_v2 내부에서 이들을 직접 import 하는 것은 엄격히 금지. - token raw 0: raw 토큰/secret 값 (Personal Access Token, Bot Token 등) 어떤 형태로도 (string literal, env read, print 등) 본 모듈 내 노출 금지. - chat 격리: chat_id=6937032012 기준으로 외부 chat record 노출 차단. - 25분 polling 부재: poll_first_gemini_evidence는 grace_seconds(기본 180초) hard limit. 무한 루프/self-register/60초×N chain 패턴 절대 금지. 초과 호출 시 raise 보장. 5 분류 코드 + 우선순위 (회장 §명시 priority): 1. INTERNAL_HEAD_MISMATCH — pushed_sha != github headRefOid (auto_retry=True, repush_head) 2. INTERNAL_FETCH_128 — git exit 128 (broken ref fetch 실패, auto_retry=True, refetch) 3. INTERNAL_BEHIND_BASE — behind_count>0 AND head_diverged AND evidence_arrived=False 4. EXTERNAL_TRIGGER_REQUIRED — evidence_arrived=False, head_match=True, fetchable=True (human_only=True, 25분 polling 재발 금지) 5. PR_OPEN_GEMINI_TRIGGER_OK — evidence_arrived=True (정상 진행) ) annotationsN)datetimetimezone)CallablePR_OPEN_GEMINI_TRIGGER_OK4PR_OPEN_GEMINI_TRIGGER_MISSED_INTERNAL_HEAD_MISMATCH0PR_OPEN_GEMINI_TRIGGER_MISSED_INTERNAL_FETCH_1282PR_OPEN_GEMINI_TRIGGER_MISSED_INTERNAL_BEHIND_BASEEXTERNAL_TRIGGER_REQUIRED 6937032012int_POLL_INTERVAL_SECONDSchtjtjj dS)Nseconds)timespec)rnowrutc isoformat?/home/jay/workspace/anu_v2/pr_open_gemini_trigger_prevention.py_now_isor.s# << % / / / CCrceZdZdZddddded ddZddZddZddZddZ dd Z dd Z dd Z d dd Z d dd Z ddZ d ddZy)PROpenGeminiTriggerPreventionuJANU v2 PR open Gemini trigger miss 예방 + 조기 분류 모듈. PR open 직전 preflight (base/head freshness, ref fetch) → PR open 직후 검증 (headRefOid match, gemini-review-gate 진입) → grace window 내 first evidence polling → 미도착 시 외부/내부 원인 분리 → 즉시 분류. one-way isolation: anu_v2/ 외부 import 금지. 외부 모듈은 anu_v2 import 가능하나 anu_v2 내부에서 utils/dispatch/scripts/dashboard 직접 import 금지. token raw 0: 토큰/secret raw value는 어디에도 노출하지 않는다. chat 격리: DEFAULT_CHAT_ID 기준으로 다른 chat record 노출 차단. 25분 polling 부재: 모든 polling은 grace_seconds hard limit 준수. 모든 외부 부수효과는 주입 가능 callable로 추상화. None이면 NotImplementedError. N) gh_runner git_runnerevidence_pollerclock audit_writerchat_idcj||_||_||_||_||_t ||_y)N) _gh_runner _git_runner_evidence_poller_clock _audit_writerstr_chat_id)selfrrrrr r!s r__init__z&PROpenGeminiTriggerPrevention.__init__Cs5$% / )G  rcH|j td|jS)Nzgh_runner must be injected)r#NotImplementedErrorr*s r_require_gh_runnerz0PROpenGeminiTriggerPrevention._require_gh_runnerVs" ?? "%&BC CrcH|j td|jS)Nzgit_runner must be injected)r$r-r.s r_require_git_runnerz1PROpenGeminiTriggerPrevention._require_git_runner[s&    #%&CD DrcH|j td|jS)Nz evidence_poller must be injected)r%r-r.s r_require_evidence_pollerz6PROpenGeminiTriggerPrevention._require_evidence_poller`s&  (%&HI I$$$rcH|j td|jS)Nzclock must be injected)r&r-r.s r_require_clockz,PROpenGeminiTriggerPrevention._require_clockes" ;; %&>? ?{{rc|j}g}|ddg}|jdddk(r|jdddd |d S|d d |d |g} t|jddj }|d|g}|dd|g} |jddj } | jddj } t| xr | xr| | k7} |dkDr|jd|| r|jd|dk(xr| } | || |d S#t t f$rd}YwxYw)ubase origin/main fetch + head 로컬 == origin/head 검증. git_runner를 사용해 다음을 수행: - git fetch origin (base_branch 최신 취득) - git rev-list --count {head_branch}..origin/{base_branch} → behind_count (head가 origin/base_branch 대비 얼마나 뒤쳐졌나) - git rev-parse {head_branch} vs git rev-parse origin/{head_branch} SHA 직접 비교 → head_diverged (SHA 불일치 시 True) fresh = True iff behind_count == 0 AND head_diverged == False. Returns: {"fresh": bool, "behind_count": int, "head_diverged": bool, "reasons": list[str]} fetchorigin exit_codergit_fetch_exit_128FT)fresh behind_count head_divergedreasonszrev-listz--countz ..origin/stdout0z rev-parsezorigin/ behind_count=head_diverged=True)r1getappendrstrip ValueError TypeErrorbool)r* base_branch head_branchgitr@ fetch_result behind_resultr>local_sha_resultremote_sha_result local_sha remote_shar?r=s rpreflight_base_head_freshnessz;PROpenGeminiTriggerPrevention.preflight_base_head_freshnessls&&(GX./   K +s 2 NN/ 0 "!%"  Z{m9[M4Z[\  }003?EEGHL  [9: }.E FG$((26<<> &**8R8>>@ YQ:Q)z:QR !  NN]<.9 :  NN/ 0";]):(*   #I& L s)D..EEc|j}|dd|g}|jdd}|dk(rddddS|dk(}|dd |g}|jdd}|dk(}|||dk7r|dSd dS) uhead SHA가 GitHub에서 fetch 가능한지 + base merge-base resolvable 검증. git_runner를 사용해 다음을 수행: - git fetch origin {head_sha} → exit_code 128이면 fetchable=False - git merge-base HEAD {head_sha} → exit_code 0이면 merge_base_resolvable=True Returns: {"fetchable": bool, "merge_base_resolvable": bool, "git_exit_code": int|None} r7r8r9rr:F) fetchablemerge_base_resolvable git_exit_codez merge-baseHEADN)r1rF) r*head_sharNrO fetch_exitrW merge_result merge_exitrXs rpreflight_ref_fetchabilityz8PROpenGeminiTriggerPrevention.preflight_ref_fetchabilitys&&(GXx89 !%%k15  ").!$   1_ L&(;< !%%k15 !+q#%:+5?Z  AE  rc|j}|d|g}|jdd}t|xr||k(}|||dS)ugh api pulls/.headRefOid == pushed_sha 검증. gh_runner("pulls/{pr_number}", []) → headRefOid 필드를 비교. Returns: {"match": bool, "github_head_sha": str, "pushed_sha": str} zpulls/ headRefOidrC)matchgithub_head_sha pushed_sha)r/rFrK)r* pr_numberrdghresultrcrbs rverify_pr_head_sha_matchz6PROpenGeminiTriggerPrevention.verify_pr_head_sha_matchs^ $ $ &fYK("-%zz,;_%I?j+H.$  rc,|}|j}|d|dg}|jdg}g}d}d} d} |D]} | jddk(sd}| jd } d } t| jd tr| d jd d xsd } n$t| jd tr| d } | d k(rd| vsd| vrd} |j dn|s|j d| r|j d|| | |dS)uFgemini-review-gate check_run이 head_sha에 존재하는지 + git exit 128 여부. gh_runner("commits/{sha}/check-runs", []) → check_runs 목록에서 name == "gemini-review-gate" 존재 여부 확인. conclusion이 failure이고 출력에 "exit 128" 또는 "fatal: " 포함 시 git_exit_128=True. internal_cause_candidate는 ["check_missing", "git_exit_128", "ref_fetch_failure"] 등. Returns: {"check_present": bool, "git_exit_128": bool, "conclusion": str|None, "internal_cause_candidate": list[str]} zcommits/z /check-runs check_runsFNnamezgemini-review-gateT conclusionrCoutputtextfailurezexit 128zfatal: git_exit_128 check_missingref_fetch_failure) check_presentrprlinternal_cause_candidate)r/rF isinstancedictr(rG) r*r[max_wait_seconds_rfrgrjinternal_causersrlrprun output_texts r'verify_gemini_review_gate_check_presentzEPROpenGeminiTriggerPrevention.verify_gemini_review_gate_check_presents@   $ $ &hxj 4b9!'L"!= $& !%   Cwwv"66 $  WW\2 ! cggh/6"%h-"3"3FB"?"E2K 137"%h-K*+-k1I#'L")).9# &  ! !/ 2   ! !"5 6+($(6   rc `|j}|j}tj|tz }d}|} ||z } | |k\rn|dz }||kDrt d|d|d|d|||} | D]h} | j dxsi} | j d d } | d k(s0t||z }d|| j d | j d dcStjt||z } | |k\rnt||z }d|dddS)uPR open 후 grace_seconds 내 Gemini 첫 evidence polling. 무한 polling/self-register 금지. grace 만료 즉시 종료. poller 호출 횟수 hard limit: ceil(grace_seconds / _POLL_INTERVAL_SECONDS). 초과 시 RuntimeError (사고 방지). Returns: {"evidence_arrived": bool, "elapsed_seconds": int, "review_id": int|None, "review_commit_id": str|None} rTz.poll_first_gemini_evidence: poller call count z exceeded hard limit z (grace_seconds=u1). 무한 polling 방지를 위한 안전 종료.userloginrCzgemini-code-assist[bot]id commit_id)evidence_arrivedelapsed_seconds review_idreview_commit_idFN) r3r5mathceilr RuntimeErrorrFrtimesleep)r*rer[ grace_secondspollerr max_calls call_count start_timeelapsedreviewsreviewrr elapsed_finals rpoll_first_gemini_evidencez8PROpenGeminiTriggerPrevention.poll_first_gemini_evidencesv..0##%IIm.DDE  W g *G-' !OJI%"DZLQ++4+5Em_UEE #)H"=G! zz&)/R"-55$'*(<$=M,0+8%+ZZ%5,2JJ{,C   JJ- .g *G-'ADEGj01 %, $   rcg}|jdds|jdtdddd|dS|jdd}|jdd}|r|r3|s|jd |r|jdtdddd |dS|jd d }|jd d} |jdd} |d kDr6| r4| s2|jd||jdtdddd|dS| sA|jd|jdds|jdt dddd|dSt dddd|dS)uc4 input dict → 분류 → 후속 액션. 분류 우선순위 (회장 §명시 높음→낮음): 1. head_match["match"] is False → INTERNAL_HEAD_MISMATCH (auto_retry=True, action=repush_head_and_retry) 2. preflight["fetchable"] is False OR (gate_present["git_exit_128"] is True) → INTERNAL_FETCH_128 (auto_retry=True, action=refetch_refs_and_retry) 3. preflight["behind_count"] > 0 AND preflight["head_diverged"] AND evidence["evidence_arrived"] is False → INTERNAL_BEHIND_BASE (auto_retry=True, action=merge_base_and_reopen) 4. evidence["evidence_arrived"] is False AND head_match["match"] is True AND preflight.get("fetchable", True) is True → EXTERNAL_TRIGGER_REQUIRED (auto_retry=False, human_only=True) 5. evidence["evidence_arrived"] is True → PR_OPEN_GEMINI_TRIGGER_OK Returns: {"classification": str, "is_internal": bool, "auto_retry_allowed": bool, "human_only": bool, "next_action": str, "reasons": list[str]} rbThead_sha_mismatchFrepush_head_and_retry)classification is_internalauto_retry_allowed human_only next_actionr@rWrpref_fetch_failure_exit_128refetch_refs_and_retryr>rr?rrDrEmerge_base_and_reopenexternal_trigger_missingrsrqz3wait_for_owner_/gemini_review_or_chairman_directiveproceed_to_merge_gates)rFrG%CLASSIFICATION_INTERNAL_HEAD_MISMATCH!CLASSIFICATION_INTERNAL_FETCH_128#CLASSIFICATION_INTERNAL_BEHIND_BASE(CLASSIFICATION_EXTERNAL_TRIGGER_REQUIREDCLASSIFICATION_OK) r* preflight head_match gate_presentevidencer@rWrpr>r?rs rclassify_trigger_missz3PROpenGeminiTriggerPrevention.classify_trigger_missYs6 ~~gt, NN. /"G#&*#6"  MM+t4 #''> l;<~."C#&*#7"  !}}^Q7 ! ou= #<<(:EB !  6F NN]<.9 : NN/ 0"E#&*#6"   NN5 6##OT:/"J$&+"T"  0 "'3   rc |j||}|j|}i||}|j||} |j|d} |j |||} |j || | | } | d|| | | | d| d| d| d| d |j td } |j|j| | S) uppreflight → verify → poll → classify 한 번에 실행. 순서: 1. preflight_base_head_freshness 2. preflight_ref_fetchability 3. verify_pr_head_sha_match 4. verify_gemini_review_gate_check_present (max_wait_seconds=60) 5. poll_first_gemini_evidence (grace_seconds) 6. classify_trigger_miss audit_writer가 주입돼 있으면 결과를 호출 (token raw 0 보장). Returns: {"classification": str, "preflight": dict, "head_match": dict, "gate_present": dict, "evidence": dict, "next_action": str} <)rw)rrrrrrr@) rrrrrrrrrr@r!run_at) rUr_rhr|rrr)rr')r*rerLrMr[r freshness fetchabilityrrrrclassification_resultrgs rrzz!PROpenGeminiTriggerPrevention.runs 266{KP 66x@ 8Y7,7 229hG CCH_aCb 229hVc2d!% : :9jR^`h i44DE"$( 0?0?"78L"M/ =,Y7}}j      )   v & r)rz'Callable[[str, list[str]], dict] | Nonerz"Callable[[list[str]], dict] | Nonerz'Callable[[int, str], list[dict]] | NonerzCallable[[], float] | Noner zCallable[[dict], None] | Noner!r(returnNone)rz Callable[[str, list[str]], dict])rzCallable[[list[str]], dict])rz Callable[[int, str], list[dict]])rzCallable[[], float])rLr(rMr(rrv)r[r(rrv)rerrdr(rrv)r)r[r(rwrrrv))rerr[r(rrrrv) rrvrrvrrvrrvrrv) rerrLr(rMr(r[r(rrrrv)__name__ __module__ __qualname____doc__DEFAULT_CHAT_IDr+r/r1r3r5rUr_rhr|rrrzrrrrr2s]&>B9=CG,06:&%;%7 % A % * %4%% %&  % 6 p" L (688 8 /28 8 zCF< < (+< >> >  >  > >rr)rr()r __future__rrrrtypingrrrrrrrrr__annotations__rrrrrrs_0# ' 0(^%$V!&Z#+F(! DIIr