j|NdZddlmZddlZddlZddlZddlZddlmZddl Z ee jjjjZ ee ejvr!ejj!ee ejj#dee ddlmZmZmZmZmZmZmZmZmZmZmZmZmZm Z m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&ddl'm(Z(ddl)m*Z*ddl+m,Z,m-Z-dd l'm.Z.dd l/m0Z0dd l1m2Z2ee jd z d z Z3d.dZ4d/dZ5hdZ6dZ7dZ8dZ9dZ:dZ;dZdZ?dZ@dZAe jddZCdZDd ZEd!ZFd"ZGd#ZHd$ZId%ZJd&ZKd'ZLd(ZMd)ZNd*ZOd0d+ZPd,ZQeRd-k(rejePyy)1utask-2515 e2e auto-merge replay harness — 9 PR × 12 verifications. 회장 명시: 본 task = end-to-end 검증 + replay harness (신규 기능 X). ) annotationsN)Path)AUTO_MERGE_ALLOWEDAUTO_MERGE_SUCCESSBLOCKED_WITH_REASONDIFF_CONTAMINATION_REPLACEMENTGEMINI_UNRESOLVED_BLOCKCRITICAL_FORBIDDEN_PATH CRITICAL_DIFF_REPLACEMENT_FAILEDCRITICAL_GEMINI_SCOPE_EXPANSIONCRITICAL_BLOCK_OVERRIDECRITICAL_DEPENDENCY_CYCLECRITICAL_REPLACEMENT_FAILEDCRITICAL_POST_MERGE_SMOKEExecutorContextTaskSpec evaluate_prverify_head_lock_then_mergecompare_effective_diffdetect_forbidden_pathscheck_predecessor_mergedrecheck_following_prs)ReplacementResult) triage_pr)PostMergeSmokeRun SmokeStatus) SmokeResult) process_eventReplacementPRRunnerfixtureszauto_merge_replay_2515.jsoncTtjtjdS)Nutf-8encoding)jsonloads FIXTURE_PATH read_text@/home/jay/workspace/tests/e2e/test_auto_merge_e2e_replay_2515.py_load_fixturesr-.s ::l,,g,> ??r+c4tjg|||S)N)args returncodestdoutstderr) subprocessCompletedProcess)r0r1r2s r,_cpr52s  & &B:f]c ddr+>-f--admin--force --no-verify cherry-pick--force-with-leasec*gdfd }|_|S)uZ시나리오 fixture로부터 fake subprocess runner 합성. forbidden flag 호출 차단.c  jt||dtD]#tfdDsJdddvr!dvrt j ddd S j d xsg}|r4t fd |dd Drt j ddd S j dxsgD]}t|d}|vsdvs|j dd|j ddd|j dgDcgc]}d|ic}d}t dtj| cSt Scc}w)N)r/cwdtimeoutc3\K|]#}|k(xs|jdddk(%yw)=rN)split).0argtoks r, z4_make_fake_runner..runner..Bs:s 9ciiQ/2c99s),zFORBIDDEN_TOKEN detected: z in mergez--squashmerge_runner_returncodermerged)r0r1 smoke_commandc3&K|]}|v ywNr*)rDtr/s r,rGz4_make_fake_runner..runner..Ks0Aa4i0srBsmoke_runner_returncodez smoke outputfollowing_queue pr_numberz--jsonmergeStateStatusCLEAN headRefOidmaineffective_filespath)rRrT baseRefNamefiles) appendlistFORBIDDEN_TOKENSanyr5getallstrr&dumps) r/r>r?scfppnppayloadrFcallsscenarios ` @r,runnerz!_make_fake_runner..runner>st d4jIJ# ._FailRunnerNc pt|dd|rt|jngtdgddS)NTrWF9REPLACEMENT_PR_AUTO_CREATION_FAILED_FOR_CONTAMINATED_DIFF) source_prreplacement_proriginal_pr_preservedroeffective_diff_filesforbidden_pathssuccessfailure_reason)rr\ro)selfrQ task_specrys r,executez5_make_replacement_runner.._FailRunner.executewsB('*.EN4 (@(@#ATV)-a0A.B)C$&!#^r+rM)__name__ __module__ __qualname__rrxsr, _FailRunnerrvs r+rNr)ryrjsidrs` r,_make_replacement_runnerrlsD D'C .."&$?? >>  } r+cjddjdxsgrdjndfd}|S)utask-2514 W1 circular import으로 run_pm_smoke_v2 가 None이라 직접 envelope 합성 fn 주입. fixture 의 smoke_runner_returncode 에 따라 PASS/FAIL envelope 반환. rOrrK rUc $ dk(rDt ddddd}t|xsd dtj|dt ddd| St d dd d }t|xsd dtj |dt ddd| S) NrTrU)commandpassed exit_code stdout_tail stderr_tailrzfixture-merge-sharndF) merge_commitrnstatus smoke_result duration_msrKallow_continuation escalationstaler~zsmoke fail simulatedEXIT_)rrrPASSr\FAIL) task_filerr~rjrQskip_stale_check_kwsrcmdcmd_strrcris r, _envelope_fnz-_make_smoke_envelope_fn.._envelope_fns 7BtB%)@-@ +"''"3i#'  ER(>"2$<  !%<)<Y'##s)$  r+)r_join)rirrrrs` @@@r,_make_smoke_envelope_fnrsH / 3B ,, ' -2C"chhsmG" F r+c$gfd}|_|S)uctx.triage_fn 으로 주입할 spy. evaluate_pr W3 호출 여부를 외부에서 관찰 가능. 실제 triage_pr 을 위임 호출. wiring 활성화 검증용. c dj|t||dt||||||||S)N)rQ thread_countrn)r[lenr) rQthreads pr_head_sha fix_commitsrorapplyrnobserveds r,spyz_make_triage_spy..spysB"L   w [ OUG  r+rrirrs @r,_make_triage_spyrs H  CL Jr+c(gfd}|_|S)u ctx.reporter_hook 으로 주입할 spy. evaluate_pr emit_critical_escalation 활성 검증. 실제 process_event 호출 후 decision.escalations 에 결과를 직접 push. W1 circular import 으로 default report_critical_event=None 이지만, hook 명시 주입 시 작동. c$|j|j|tdd}tdd|d|ddd}j ||d t |d r |j g|_|j j |y) NrW)decisionreason critical_coderWrnrQe2e_reporter_hook_spyrnrQ event_typesourceevidenceTno_auditr~)coderesult escalations)rrr\rr[hasattrr)rrrrrris r,rz$_make_reporter_hook_spy..spys ))oo!#H->$?@   #I.%k2"1$     89x/83G3G3O#%H ##F+r+rrs` @r,_make_reporter_hook_spyrs H,,CL Jr+cb|jdr t|nd}|jddk(r t|nd}|jdr t|nd}t ||jdd|jddt ||||jdxsd|jdxsd|jd |jd rd nd|| }|t t|_|jd rt|d |_ ||_ ||_ |S)Ntriage_threadsexpected_classificationcriticalrKTfixture_main_shazfixture-main-sharrmain_log_grep_returns_truecyNTr*_ts r,z(_make_executor_context..r+) rjrKrrreplacement_runner triage_fnrtriage_fix_commitstriage_pr_head_sha main_log_grep reporter_hooksmoke_envelope_fnrP) r_rrrrrr__file__rr\rP triage_spy reporter_spy)ryrjrr smoke_env_fnctxs r,_make_executor_contextrs().>(?!!$TJ127P1QU_1_*1-eiL121G*1-TL eeO,13EF3Av>uu-.6$55/7455/+,551M+NTX"& CX uu "1%6#78CN#C Jr+c@tttttd|S)Nrrrrr rnames r,_resolve_expected_decisionr s%002*H#:      r+cZ|ytttttt t d|S)Nr r r r rrrrrs r,_resolve_critical_coders3 |#:,L+J#:%>'B%>    r+c $t}t}t|}td|dt dddd|}j dr)|j tk(rt|d|fd d }||||fS) u_evaluate_pr → (필요 시) verify_head_lock_then_merge 호출 → final QueueDecision 반환.rQrrW merge_stateci_state gemini_state)rQrrrWrrrr verify_mergecdS)Nrr*)_nris r,rz_run_pipeline..5s h}.Er+F)rrQrfetch_pr_head_at_merger~) rlrzrrr\r_rrr)rirjspecrrs` r, _run_pipeliner!s x (F 8 $D 6 2C;']+X&789]+*%n-  H||N#(9(9=O(O.{+#E   S&$ &&r+c |d}|jdrdnd}t|jdxsg||\}}|dur|gk(s J|d|t|d |d \} } } | t|d k(sJ|d | d | d| d|d  t |d |d } t | t |dk(sJ|d| d|d|jt|dk(sJ|d|jd|dt|dd} |jdrq| J|dt | jdk(sJ|dt | j| jdd|dk(s"J|d| j| J|d|jdxsg}|rt|d|dxsg|d |jd!xsgt|d gd"|d#$}|jDcgc]}|jj}}||k(sJ|d%|d||jd&}|jd'd"}|jd(d"}||jxs |j }|t|k(s&J|d)|jd*|j d||j"t|k(sJ|d+|j"d||rb|j t|k(sJJ|d,|j d||j"t|k(sJ|d-|j"d|t%|d.}|j&|k(sJ|d/|j&d|t)|jd0}|j*|k(sJ|d1|j*d||jd2}||j,|k(sJ|d3|j,d||j.J|d4|j,|j.jd5|k(s%J|d6|j.jd5|d7k(}|j.jd8|usYJ|d9|j.jd8d||j,d:k(s"|j.J|d;|j.|jd<xsg}|jd=xsg}|r@t1||}t |t |k(s!J|d>t |dt |t3||D]d\}}|j5D]L\}} |j|| k(rJ|d?|jdd@|dA|j|d| f|jdBr|j&t6k(r|j8}!|!rt |!dk\s J|dC|!|!D"chc]}"|"jd}#}"|D]}$|$d|#vr J|dD|$ddEn1|j8gk(s"|j8J|dF|j8|jdG}%|dH}&t|dId}'|&dJk(r|' J|dKt |'jdk\sJ|dLt |'j|'jd}(|(dMdNdJk(sJ|dO|(dMdN|(dMdP J|dQ|(dMdR|%k(sJ|dS|(dMdRd|%|j:rt |j:dk\sJ|dT|j:|'7t |'jdk(sJ|dUt |'jt=|d#|ddVdWidXddY})|)dNdZk(sJ|d[|)dN|)dP J|d\|&dZk(rE|j*J|d]|j*|j>J|d^|j>y|j*|j> J|d_yycc}wcc}"w)`u12 항목을 순서대로 검증. 모든 assertion이 PASS여야 함. ctx 는 spy(triage_spy/reporter_spy) 관찰 + smoke_envelope_fn 활성화 검증 시 사용. _spec 은 호출 측 signature 호환 (직접 참조 X). r|rcyrr*rs r,rz"_verify_12_items..Drr+Nrq)rTu §1 queue head failed: pending=rWroexpected_diff_equalu §2 diff mismatch: diff_ok=z extra=z missing=z expected_equal=expected_forbidden_countu §3 forbidden mismatch: got=z expected_count=expected_replacement_usedu$ §4 replacement_used mismatch: got=z expected=rru5 §5 triage_spy must be injected for triage scenariosrBu1 §5 triage_fn must be invoked exactly once, got rrQu# §5 triage_fn pr_number mismatch: u' §5 no triage scenario but spy presentexpected_triage_verdictsrrFrn)rQrrrrorrrnu §6 verdict mismatch: actual=expected_review_gate_passedfallback_review_used_expectedfallback_review_passed_expectedu& §7 review_gate_passed mismatch: got=z fallback=u( §7 fallback_review_used mismatch: got=u* §7 fallback_review_passed mismatch: got=u* §7 N/A path fallback_used mismatch: got=expected_decisionu §8 decision mismatch: got=expected_critical_codeu! §8 critical_code mismatch: got=expected_smoke_statusu §9 smoke_status mismatch: got=uK §9 smoke_envelope must be populated when verify_merge=true; smoke_status=ru# §9 envelope status mismatch: got=rru/ §9 envelope allow_continuation mismatch: got=rUuK §9 envelope must remain unpopulated for non-smoke scenario, got envelope=expected_following_statesrPu$ §10 following count mismatch: got=u §10 following PR#z field z: got=ruP §10 verify_head_lock_then_merge must populate decision.fixture_pr_replay, got u §10 PR#z( missing from decision.fixture_pr_replayu4 §10 N/A path expects empty fixture_pr_replay, got expected_escalation_typerrru( §11 reporter_hook spy must be injectedu> §11 reporter_hook must be called for critical scenario, got rclassificationu# §11 spy classification mismatch: packetu §11 packet must be setescalation_typeu$ §11 escalation_type mismatch: got=u> §11 decision.escalations must contain at least 1 entry, got u? §11 auto-handled scenario must not invoke reporter_hook, got AUTO_HANDLED_DUMMY_EVENT e2e_replayrr auto-handledu! §11 expected auto-handled, got u* §11 packet must be None for auto-handledu7 §12 critical_code must be None for auto-handled, got u= §12 critical_escalation must be None for auto-handled, got uE §12 critical scenario must set critical_code or critical_escalation) r_rrboolrrintreplacement_usedgetattrrrr\rverdictvaluereview_gate_passedfallback_review_passedfallback_review_usedrrrr smoke_statussmoke_enveloperzipitemsrfixture_pr_replayrrcritical_escalation)*rirrrj_specr main_grephead_okpendingdiff_okextramissing forbiddenrexpected_verdictsreportoactual expected_rgpexpected_fb_usedexpected_fb_passed actual_rgp expected_dec expected_critexpected_smokeexpected_allowexpected_statesfqstatess_actual s_expectedkv replay_statesryrecorded_pr_numbersef expected_esc expected_clsr first_obsrs* r,_verify_12_itemsr>;s 4.C&.\\2N%OUYI/ \"(b& GW d?w"}_5UV]U^.__ ,5"#X.>%?GUG d8$9:; ; %+G9GE7)G9TdemoDfEeF G ; '"#X.>%?I y>S*D!EF F %,YK7GQkHlGmn F  $ $X6Q-R(S S %3H4M4M3NjYab}Y~X A S lD1J||$%%d#.c'dd%:&&'1, eDSI\I\E]D^ _ ,""1%k2h{6KK e6z7J7J6K L K ! e: ; ! ! %?@FB{+-.4" / ]39r)9 :;Y'  ,2>>:a!))//::** e1&DUCV W * << =>L||$CUK!&GO00SH4S4S T,// e9(:U:U9VV`aibAbAaBBLMYLZ [ /,,5E0FF e;H[>[=\\fgwfx y F .h7J.KLL    , %+H,=,=+>jW ,+8<<8P+QRM  ! !] 2 %01G1G0H S`Rab 2 \\"9:N!$$6 e3H4I4I3J*UcTd e 6 &&2 e$112 4 2&&**84F e6x7N7N7R7RS[7\6] ^ F)F2&&**+?@NR e**../CDEZP^O_ a R $$*h.E.E.M e^_g_v_v^w x M ll#>?E2O ' ( .BB &r626{c/22 e7F }JsSbOcNd e 2%($@  Hj"((* 1||A!+e.x||K/H.IQRPSSYZbZfZfghZiYjjtuvtwx+   << 'H,=,=AS,S$66M S%71%< %ghugvw <@M"M!155#5"M "M +*==e9R _$55]^=  ))R/83M3M3U eGHbHbGc d U << :;L56L35Lz!'YC50X)YY'<(()Q. eQRUVbVkVkRlQm n .!))!, "#34 B e6y7JK[7\6] ^ B"8,8ZSEAY:ZZ8"#45E e7 (8KL]8^7__ijviw x E##H,@,@(AQ(F eQRZRfRfQg h F  #|,,-2 %VWZ[g[p[pWqVrs 2 +(;:O5 4   &'>9 e4VH 3-r+cZt|d}t|\}}}}t|||||y)NPR55_clean_auto_mergerFrr>rBryrrrjrs r,test_e2e_pr55_clean_auto_mergerK#s2 78A"/"2Hc64Q#vt4r+cZt|d}t|\}}}}t|||||y)NPR57_false_positive_triagerIrJs r,#test_e2e_pr57_false_positive_triagerN)2 <=A"/"2Hc64Q#vt4r+cZt|d}t|\}}}}t|||||y)NPR58_gemini_quota_fallbackrIrJs r,#test_e2e_pr58_gemini_quota_fallbackrR/rOr+cZt|d}t|\}}}}t|||||y)NPR64_smoke_passrIrJs r,test_e2e_pr64_smoke_passrU5s2 12A"/"2Hc64Q#vt4r+cZt|d}t|\}}}}t|||||y)Nr}rIrJs r,'test_e2e_pr57_contamination_replacementrW;s2 @AA"/"2Hc64Q#vt4r+cZt|d}t|\}}}}t|||||y)NPR61_review_thread_blockerrIrJs r,#test_e2e_pr61_review_thread_blockerrZArOr+cZt|d}t|\}}}}t|||||y)Ncritical_smoke_failurerIrJs r,test_e2e_critical_smoke_failurer]Gs2 89A"/"2Hc64Q#vt4r+cZt|d}t|\}}}}t|||||y)Ncritical_forbidden_pathrIrJs r, test_e2e_critical_forbidden_pathr`Ms2 9:A"/"2Hc64Q#vt4r+cZt|d}t|\}}}}t|||||y)NrrIrJs r,7test_e2e_critical_diff_contamination_replacement_failedrbSs2 PQA"/"2Hc64Q#vt4r+c|}tddddddgid|dd }|d d k(sJ|d d usJ|dz dz dz }|js Jd||jdj}|sJdt j |j d}|ddk(sJ|d d k(sJ|ddk(sJy)u_Critical 시나리오에서 process_event(no_audit=False) 호출 시 audit JSONL 실재 박제. task-2515i'FORBIDDEN_PATH_INTRUSIONtest_audit_appendrWz.github/workflows/foo.ymlrFTworkspace_rootrr~rraudit_appendedmemoryorchestration-auditcritical-escalations.jsonlaudit JSONL must exist at r#r$(audit JSONL must contain at least 1 linernr Nrexistsr)stripr&r' splitlinestmp_path audit_rootr audit_lograwlasts r,'test_audit_append_critical_writes_jsonlrz[sJ "4)*-H,IJ  " F " #z 11 1 " #t ++ +X%(==@\\I    G!;I;GG    w  / 5 5 7C :::3 ::cnn&r* +D  ?k )) )  !Z // / ! "&@ @@ @r+cx|}tddddid|dd}|d d k(sJ|d J|d dusJ|dz dz dz }|js Jd|d|jdj}|sJdt j |j d}|ddk(sJ|d d k(sJy )uaauto-handled 시나리오에서 process_event(no_audit=False) 호출 시 audit-only JSONL 박제.rdi'r rfrFTrgrr r Nrirjrkrlrmz (auto-handled append)r#r$rnrornrprts r,+test_audit_append_auto_handled_writes_jsonlr|vs J "4)  " F " #~ 55 5 (  ## # " #t ++ +X%(==@\\I    ]!;I;F\]]    w  / 5 5 7C :::3 ::cnn&r* +D  ?k )) )  !^ 33 3r+c tjd}|jdtd|jddd |j |}t }|j r0|d D]'}td |d d d|ddd|dd|d)y|jr|d D]{}|d |jk(st|\}}}}ttj|jddtt|||||td|ddytd|jdy|jy)Nztask-2515 e2e replay harness) descriptionz--pru단일 PR 번호 replay)typehelpz--list store_trueu9 시나리오 목록)actionrrDz PR#rQz>3z r|z<55z [categoryu] → rrF)indent ensure_asciidefaultz [PASS] u — 12/12 verificationszPR #z not found in fixtures)argparseArgumentParser add_argumentr parse_argsr-r\printprrr&rbto_dictrar> print_help) argvparserr/r!ryrrrjrs r, _cli_mainrsc  $ $1O PF S/HI +#vtdjj!1!1!3AE[^_` Hc64@ !D'*BCD   TWWI345  r+cddl}dD]&}|tjvstj|=(|jd}|jdusJd|j J|j J|jJ|jJy)utask-2516: ctx hook 미주입 상태에서 default runtime path가 W1 wiring chain (_WIRING_AVAILABLE=True 경로의 ReplacementPRRunner / triage_pr / run_pm_smoke_v2 등)을 실제로 사용하는지 검증. circular import fix 회귀 방지. rN)utils.merge_queue_executorzutils.replacement_pr_runnerrTu,W1 wiring 비활성 — task-2516 fix 회귀) importlibsysmodules import_module_WIRING_AVAILABLEr rrun_pm_smoke_v2report_critical_event)rmod_namemqes r,+test_default_runtime_path_no_ctx_hooks_2516rs Q& s{{ " H%&  ! !"> ?C  D (X*XX (  " " .. . == $$ $    ** *  $ $ 00 0r+__main__)returndict)rrUrUrM)T__doc__ __future__rrr&r3rpathlibrpytestrresolveparent WORKSPACErarXremoveinsertutils.merge_queue_executorrrrrr r r r r rrrrrrrrrrrutils.automation_contractsrutils.auto_gemini_triagerutils.post_merge_smoke_runnerrrr"utils.critical_escalation_reporterrutils.replacement_pr_runnerr r(r-r5r]rlrzrrrrrrrrr>fixturerBrFrKrNrRrUrWrZr]r`rbrzr|rrrexitr*r+r,rs#   N " " $ + + 2 2 9 9 y>SXXHHOOC N#3y>"      9=;H~$$z14QQ @e d!H 2,^,D:   '4W xh 5 5 5 5 5 5 5 5 5A64: 01( z CHHY[r+