j/UdZddlmZddlZddlZddlZddlZddlZddlm Z m Z ddl m Z m Z ddl mZddlmZmZmZmZdZd ed <d Zd ed <d Zd ed<dZd ed<dZd ed<dZd ed<dZd ed<dZd ed<dZd ed<dZd ed<dZd ed<dZ d ed <d!Z!d ed"<eee"ee"e"fgejFfZ$eee"efgdfZ%eee"efegdfZ&ege"fZ'e d#$Gd%d&Z(e d#$Gd'd(Z)d@d)Z*dAd*Z+dBd+Z,dCd,Z-efdDd-Z.dEd.Z/dFd/Z0dGd0Z1dHd1Z2dId2Z3dJd3Z4dKd4Z5dLd5Z6dMd6Z7dNd7Z8d8Z9d9ed:<dOd;Z:Gd<d=Z;dPd>Z>%,,w/ 0 : : /..dedupe..marker` 형식으로 audit 파일과 동일 디렉토리에 위치시켜 같은 fs 의 atomic create 성질을 활용한다. .z.dedupe.z.marker)r r}rlstem)audit_log_pathr0 audit_pathsafe_keys r:_dedupe_marker_pathrs= n%J$Z0H   :??"38H:WM MMr9cX |jy#t$rYyt$rYywxYw)udedupe 선점 마커를 best-effort 로 제거 (실패해도 silent). 회장 Codex G1 round 2 High — gh 실패 후 marker 가 남으면 같은 PR/head 의 재시도가 영구 차단된다. trigger 실패 경로에서만 호출되어 marker 를 정리, 다음 사이클이 자유롭게 재시도하도록 한다. 마커 미존재나 race 로 사라진 경우는 무시 (FileNotFoundError) — 본 의도는 "있다면 지운다". OSError 외 예외는 trigger 흐름과 무관하므로 silent (예: permission denied 시에도 trigger 실패 흐름은 계속). 보안 경계 위반 가능성 0 — 마커 정리는 어떤 endpoint/token 도 건드리지 않는다. N)unlinkFileNotFoundErrorOSError) marker_paths r:_safe_remove_markerrs0  s )))c t|}t||}|jry|jsy |jdd5}|D]~}|j }|s t j |}t|ts=|jd|k7rR|jd}|tk(s |tk(svdddy dddy#t j$rYwxYw#1swYyxYw#t$rYywxYw) uaudit jsonl 또는 dedupe 마커 파일에서 같은 dedupe_key 선점 상태 검사. 회장 §명시: PR/head 단위 1회 only. 새 head_sha 면 다른 dedupe_key 가 되어 자동 stale. TOCTOU 보강 (회장 Codex G1 Medium 3): - 1차 검사: jsonl 에 outcome == "ok"/"pending" 엔트리 존재 여부. - 2차 검사: 같은 디렉토리에 dedupe 마커 파일이 존재하는지 (gh runner 호출 직전에 O_EXCL 로 박제되는 파일). 둘 중 하나라도 발견되면 중복으로 판정. 설계: - jsonl append-only — 한 줄씩 파싱. - 깨진 라인은 skip (안전 fallback). 단, 정상 라인이 1개라도 매칭되면 True. - 파일 미존재 = 첫 trigger = False. TFrrJrjr0r=N)r rexistsopenr[rploadsJSONDecodeError isinstancer`rZrrr)rr0rtrflinerecordr=s r:is_duplicate_triggerrs  D%dJ7K ;;=  YYsWY -  zz|!ZZ-F"&$/::l+z9 **Y/j(G,F    $ ++ $  sfDC5(C=A C5C5DC5DC2/C51C22C55C>:D>D D  D c8d|d|d|d}ddd|dd tgS) u허용되는 단 1 가지 gh api 호출 인자 — 정확히 이것만 통과시킨다. 회장 §명시: comment trigger 1 endpoint only. 다른 endpoint 호출 0. /repos///issues/ /commentsapiz-XPOSTz-fbody=)r)ownerrepor*endpoints r:_build_allowed_gh_argsrsA qhykCH  f *+,  r9ct|||}t|}||k(ry|D]@}t|ts|j ds&|dt k7s3t tt t)uOgh args 가 허용 list 와 **정확히 일치**하는지 검증. 불일치 시 fail-fast. - endpoint path 가 다른 경우 → ENDPOINT_NOT_ALLOWED. - body 가 정확히 `/gemini review` 가 아닌 경우 → BODY_NOT_ALLOWED. - 다른 어떤 추가 인자도 허용되지 않는다 (예: --silent, --paginate 등). Nr) rlistrr startswithrr\r!r#)argsrrr*expected args_listrPs r:_assert_args_allowlistrsx&eT9=HT IH5 eS !e&6&6w&?EuUiTjMkDk34 45 / 00r9c4|tk7rtty)ucomment body 가 strict equality `/gemini review` 인지 검증. fail-fast. 회장 §명시 6 허용 1: comment body 정확히 `/gemini review` only. - 앞뒤 공백 / 대소문자 변형 / suffix 추가 등 모두 BODY_NOT_ALLOWED. N)rr\r!)bodys r:assert_body_allowedr2s  ##/00$r9cDd|d|d|d}||k7rtty)uendpoint path 가 허용된 issue comments POST 1 endpoint 인지 검증. 회장 §명시 15 금지 1~5: merge/approve/push/close/reopen 호출 0. 본 함수가 엔드포인트 정적 allowlist 의 단일 진입점. rrrrN)r\r#)rrrr*expected_endpoints r:assert_endpoint_allowedr<s9 "%$x {)L$$344%r9)z/mergesz/reviewsz/pulls/z /branches/z /git/refsztuple[str, ...]_FORBIDDEN_ENDPOINT_FRAGMENTScp|D]1}t|tstD]}||vstt3y)u,방어적 2차 차단: args 안에 금지 endpoint fragment 가 섞여 있는지 추가 검사. `_assert_args_allowlist` 가 이미 strict equality 로 차단하지만, 호출부가 내부 헬퍼를 우회해 직접 gh_runner 를 호출하더라도 본 함수가 raise 하도록 한다. N)rrrr\r#)rrPfrags r: _validate_no_forbidden_fragmentsrSsB =%% 1 =Du}"#;<< ==r9ceZdZdZeed d dZ d dZd dZ d dZ d dZ y)OwnerTriggerPatuFine-grained OWNER PAT trigger-only comment writer. 회장 §명시 (2026-05-11 dec_1) 1:1 강제: - OWNER PAT 은 `/gemini review` 댓글 작성 1 endpoint 에서만 사용. - merge/approve/push/close/reopen 호출 0 (정적 차단). - audit 에 token value 0, token_present + token_hash 만. - dedupe by (pr_number, head_sha) — update-branch 후 새 head 는 새 trigger 허용. 외부 부수효과는 생성자 주입 callable (gh_runner / audit_writer / decision_writer / clock) 로 분리되어 테스트에서 mock 으로 교체 가능. 본 모듈은 anu_v2/* 외 어떤 외부 모듈도 import 하지 않는다 (one-way isolation). )clockr]c|rt|ts td|rt|ts tdtjd|s tdtjd|s td|t k7rtdt d|||_||_||_||_ ||_ ||_ ||_ y)Nzowner must be non-empty strzrepo must be non-empty strz[A-Za-z0-9._-]+z!owner contains invalid charactersz repo contains invalid charactersztoken_env must be z; got ) rr ValueErrorr{ fullmatchr_gh_audit _decision_owner_repo_clock _token_env)self gh_runner audit_writerdecision_writerrrrr]s r:__init__zOwnerTriggerPat.__init__psJuc2:; ;:dC09: :||.6@A A||.5?@ @ * *$%7$:& N " (  " #r9c Xt||||||t|||jS)N)r*r+r,r-r.r/r0r1)r(rHr)rr*r+r,r-r.r/s r:_make_decisionzOwnerTriggerPat._make_decisions6$"7)&y(;{{}  r9c:|jt||y)u]decision_writer 콜백 호출 — REJECT 도 박제하여 회장 §명시 audit trail 유지.N)rra)rr,rts r:_persist_decisionz!OwnerTriggerPat._persist_decisions )(3T:r9c l|||t||||tt||d }|j|y)N) r1r*r+r0r=r-actor token_present token_hash)rHr$boolr) rr*r+r=r-rrr1rs r: _append_auditzOwnerTriggerPat._append_audits@" ))X>,!-0$   Fr9c  tt|j}t|}t|} |dk7rid|} |j ||t | ||} |j | ||j||t| dd|tt| t|S|tk7rid|} |j ||t | ||} |j | ||j||t| dd|tt| t|St||} t| | rid | } |j ||t | ||} |j | ||j||t| dd|tt| t|S t|j} t#| }|j ||t$d ||}|j ||t'| | } t)j*t|t(j,t(j.zt(j0zd } t)j2|t5j6| ||t8|dddj;dt)j<| tA|jB|jD|}tG||jB|jD|tI|t(jJjM}| |d<| |d< |jO||}t]t_|dd }tU|| }|j`dk7rWtS|d|j`d|d d} |j||tZ| d||ttZ| t|S|j||tbdd||ttbdt|S#t $rs}d |} |j ||t | ||} |j | ||j||t| dd|tt| t|cYd }~Sd }~wwxYw#t)j<|wxYw#t>$r?d| } |j||t| d||tt| t|cYSwxYw#tP$rv}tS|tUtW|jXd|| }|j||tZd|d||ttZd|t|cYd }~Sd }~wwxYw)ufqueue-head + evidence missing + dedupe + token 검증 후 `/gemini review` 댓글 1회 작성. 회장 §명시 6 허용 1:1: 1. body 정확히 `/gemini review` (내부 상수, 사용자 입력 받지 않음) 2. queue_position == 0 (queue-head only) 3. gemini_evidence_state == "missing_for_current_head" 4. dedupe 검증 — (pr, head) 1회 only 5. token 로딩 성공 (없으면 REJECT) 6. owner_trigger_decision.json 박제 PASS 후에만 실제 호출 모든 REJECT 케이스도 audit + decision 박제 — 추적성 유지. rznot_queue_head:queue_position=)r*r+r,r-r.r/FrS)r*r+r=r-rrr1)r=r-r>zevidence_not_missing:state=zduplicate_trigger:dedupe_key=ztoken_missing:NzDall_gates_pass:queue_head+evidence_missing+dedupe_clean+token_loadedi)r0r*r+r=r1TrgrhrJz$duplicate_trigger_marker:dedupe_key=GH_TOKEN GITHUB_TOKENz: zgh_runner_exception:stderrzgh_api_failed:rc=z:stderr=zcomment_posted:/gemini reviewcomment_posted)2rrrr rrrrrr<rrrHrr^rr\rQrrrXrO_CREATO_EXCLO_WRONLYwriterprqrrNcloseFileExistsErrorrrrrrrYcopyr ExceptionrrVtyper3r_coerce_streamgetattr returncoder)rr*r+r/r.rdecision_json_pathr1r>rr-r,r0rPexcr pass_decisiondedupe_marker_pathfdrenvcp sanitized stderr_rawstderr_redacteds r:trigger_gemini_reviewz%OwnerTriggerPat.trigger_gemini_reviews. 01 [[]/0 .)  Q 5n5EFF**#!(&;- +H  " "8] ;   #!(#  "(!-0  !$E E23H2IJF**#!(&;- +H  " "8] ;   #!(#  "(!-0 %Y9  J 74ZLAF**#!(&;- +H  " "8] ;   #!(#  "(!-0  "4??3E<!' ++"Y"7) ,  }m<1ZH) &' RYY&4B  JJ*4)2(0'6"$ &+"& fWo  .&dkk4::yItT[[$**iH(.jjooJ#N $$B0$GB$$?@ ' E: ==A   2 3(xPTQT@U?VWF   #!&"%  "&!-0  2!  #m,  C &cU+F**#!(&;- +H  " "8] ;   #!(#  "(!-0 - L  U U N)rGhRunnerr AuditWriterrDecisionWriterrrrrrClockr]rreturnNone)r*r)r+rr,rr-rr.rr/r)rr()r,r(rtr rr)r*r)r+rr=rr-rrrrrr1rrr)r*r)r+rr/r)r.rrr rr rr<) r3r4r5r6rErrrrrrr8r9r:rrbs[ * +$$$$" $$ ( $$  $$$$$$$$ $$N         #    *;        6W W W  W # W W !W  W r9rcd|yt|tr|jddSt|S)usubprocess stdout/stderr 정규화 (merge_queue_executor 동일 패턴). None → "", bytes → utf-8 decode, str → 그대로. 직렬화 시점에 bytes 가 dict 에 박히지 않게 한다. rSrJrT)errors)rbytesdecoder)values r:rrs3  }%||GI|66 u:r9c*t|dfd }|S)u기본 audit writer factory — jsonl 1줄 append. 호출부가 명시적으로 path 를 묶어 callable 을 만들 수 있도록 closure 반환. 테스트에서는 list-collector callable 로 대체. cjjddtjt |dd}j dd5}|j |dzdddy#1swYyxYw) NTrcFrarJrj )rlrmrprqr`rr)rrfprus r:_writerz%default_audit_writer.._writersg D48zz$v,UdK [[w[ / "2 HHTD[ ! " " "s A11A:)rMapping[str, Any]rrr)rrrus @r:default_audit_writerrs . !F" Nr9)rr)r*r)r+rrr)rPrrr)rUz str | NonerPrrr)r]rrr)r,r(rzdict[str, Any])rsrrtr rr)r0rrr)rr r0rrr )rr rr)rr r0rrr)rrrrr*r)rz list[str]) r Sequence[str]rrrrr*r)rr)rrrr) rrrrrrr*r)rr)rrrr)rr rr)rr rr)>r6 __future__rrLrprXr{ subprocess dataclassesrrrrpathlibr typingr r r r rr7rrrrrrrrr!r#r$r%rCompletedProcessrrrrr(r<rErHrQrVr^rarxr}rrrrrrrrrrrrr8r9r:rs,# )'33 5C4-c, s*D!3C C"#"! /c. 6#6 :9-c, Xc]GCH$56 8S8SS TS)*D01 738,d3T9:S $   " $D %B:"%7 " 7N*.d 1(152 =A A J r9