Ij pUdZddlmZddlZddlZddlmZmZddlmZddl m Z m Z m Z ddl mZmZmZddlmZmZmZdd lmZmZmZmZmZmZmZdd lmZdd l m!Z!m"Z"dd l#m$Z$d Z%de&d<dZ'de&d<dZ(de&d<dZ)de&d<dZ*de&d<dZ+de&d<d.dZ,d/dZ-d0dZ.d1dZ/ d2dZ0d3d Z1d4d!Z2ddddddd"d#d$ d5d%Z3 d6d&Z4dd#d"ddd' d7d(Z5ddd) d8d*Z6d"dd+ d9d,Z7gd-Z8y):uanu_v3.goal_activation_controller — GOAL_DRIVEN_ACTIVATION_CONTROLLER_V0 (task-2553+7). 회장 §명시 핵심 불변식 (verbatim 박제): chair 가 goal_execution_contract 만 제공 → controller 가 deriver→gate→activation 루프를 자동 구성 + 기계 결정. 회장 1~13 단계 수동 절차 불필요. ``--activate`` 는 더 이상 인간 첨부 옵션이 아님. 내부적으로 6 조건 전부 충족 시에만 activate=True 로 run_activation 호출: 1. goal_contract.allowed_actions 에 ``clean_replacement_pr_open`` 포함 2. pre_authorized_action_gate 가 DECISION_ALLOW 반환 (dry-run 결과 기준) 3. goal_boundary_validator PASS (planned actions ⊆ allowed; forbidden 충돌 0; effective_diff ⊆ 6 파일; forbidden_write_target 미포함) 4. binding preflight == DRY_RUN_PLAN_ONLY (provenance stamp 유효 + sha256 재해시 일치 + decision machine 4-field ok) 5. hold_conditions 트리거 수 == 0 (dry-run 결과로 평가) 6. callback collector 준비 완료 (normal + fallback contract 존재, collector-only 권한) 6 조건 전부 PASS → run_activation(activate=True). 그 외 → activate=False (dry-run) 또는 HOLD_FOR_CHAIR packet. 방어 심층 (9-R.1): run_activation 이 자체 gate ALLOW + binding + 4 조건을 재검증. controller 의 activate=True 통과는 필요조건이지 충분조건 아님. 9-R.4 정적 부재 (controller): merge / PR-merge / auto-merge / PR#102-mutation / same_branch_push / source_branch_push — 이 파일에 없음. ) annotationsN)datetimetimezone)Path)AnyFinalMapping)parse_hold_conditionsparse_success_conditionvalidate_boundary)GOAL_RESULT_SCHEMAGoalContractErrorparse_goal_contract)STATUS_ACTIVATED_PR_OPENSTATUS_DRY_RUN_VERIFIED STATUS_HOLDadjudication_hookcollector_handoffrun_activationwrite_hold_for_chair_packet)DECISION_ALLOW)TASK_2553P1_EFFECTIVE_DIFF_6#TASK_2553P6_FORBIDDEN_WRITE_TARGETS)STATUS_DRY_RUN_PLANz!anu_v3.goal_activation_controllerz Final[str]CONTROLLER_MODULEz1.0.0CONTROLLER_VERSION7memory/events/task-2553+7.goal-activation-decision.json_DEFAULT_DECISION_PATH%memory/events/task-2553+7.result.json_DEFAULT_RESULT_PATHclean_replacement_pr_open_GOAL_ACTION_ACTIVATE) clean_replacement_branch_createcommitpushr!result_marker_write report_writenormal_callback_registerfallback_callback_registercodex_post_result_auditanu_codex_adjudicationzFinal[tuple[str, ...]]_PLANNED_ACTIONScftjtjj dS)Nz%Y-%m-%dT%H:%M:%SZ)rnowrutcstrftime8/home/jay/workspace/anu_v3/goal_activation_controller.py_now_utcr4]s! << % . ./C DDr2ct|jjddt|jt j |dddzdy) NT)parentsexist_okF)indent ensure_ascii zutf-8)encoding)rparentmkdir write_textjsondumps)pathobjs r3 _write_jsonrDasNJD48J 3qu5<r2cht|}|j}||vryd|vrytd|d|d)u>Finding 4: output 파일명에 포함된 task id 가 controller_task_id 와 일치하는지 검증. 불일치 시 ValueError 를 발생시켜 controller 를 중단 (stale/mis-routed output 방지). 파일명에 task id 가 없거나 경로가 메모리/이벤트 경로가 아닌 경우는 검사 스킵. Nztask-z-output path task id mismatch: filename stem 'z'' does not contain controller_task_id='uF'. Stale/mis-routed output detected — aborting to prevent overwrite.)rstem ValueError)rBcontroller_task_idprFs r3_validate_output_path_task_idrJisW T A 66DT!d  7v>123N N r2c\t|}|jr|jyy)uRFinding 4: non-HOLD 결과 시 stale hold.json 삭제 (delete-on-non-HOLD 정책).N)rexistsunlink) hold_pathrIs r3_delete_stale_holdrOs" YAxxz  r2cn g}t|}jdd}jdd jdi jddjdg}d  fd }|D]}||s |j||tk(r|r|j |d d |S) ugoal_contract.hold_conditions 중 dry-run result 에서 트리거된 항목 반환. 빈 list = 0개 트리거 = Condition 5 PASS. status gate_decisionfour_conditionsall_four_conditions_metF hold_reasonsc|j}d|vr tk7Sd|vsd|vr tk7Sd|vsd|vr%jdi}|jdd Sd |vr Sd |vr Sd |vsd |vr Sd |vsd|vryd|vsd|vr Sd|vsd|vr Sd|vs d|vsd|vsd|vr Sd|vsd|vryd|vsd|vsd|vryd|vrjdd}| Sy)Nz critical 7zgate decision holdz gate decisionzexpected_files mismatchexpected_filesrT.provenance_and_sha_and_decision_machine_4fieldTzforbidden targetzsource pr mutationzsame branch pushzsame-branch pushzmerge requiredmergeFf2ztoken transportphase3mqe credentialapi real_writez real writezcodex unresolvedcodexz anu-codexu anu–codex disagreement provenance)lowerrget)condclprovprov_okall_fourdry_run_resultfourrSs r3_checkz)_evaluate_hold_conditions.._checks` ZZ\ 2  N2 2 2 %B)> N2 2 $ *.>".D!%%&7Ub[<  2 " 0BlVXFX<   #w"} "   3~7K 2 hh@%G; r2N)rfstrreturnbool)r reappendRUNNER_STATUS_HOLDextend) goal_contractrk triggered hold_conds result_statusrVrmrfrjrlrSs ` @@@r3_evaluate_hold_conditionsrysI&}5J"&&x4M"&&;M   / 4D!!";UCH!%%nb9L!!F# $<   T "# **    \"1- . r2c 0dtddddddddddd S)unormal + fallback callback 주입 contract (collector-only 권한). 실제 cron 등록 0. contract 객체만 생성. 9-R.5 강제. z anu_v3.goal_callback_contract.v1Tcollector_onlyz;dry-run contract injection (no cron registration performed)uicallback collector = 결과 회수 전용. write/재가동/dispatch/closeout/merge 권한 없음 (9-R.5).) schemats_utcnormalfallback authorityno_writeno_dev_reactivation no_dispatch no_closeoutno_mergeinjection_modenote)r4r1r2r3_build_callback_contractrs6 5*%#W 4 r2chg}|jddur|jd|jddur|jd|jddk7r#|jd|jdd D]+}|j|dus|jd |d -|S) u@callback contract 유효성 확인. 빈 list = Condition 6 PASS.r~Tzcallback.normal != truerzcallback.fallback != truerr{z(callback.authority != 'collector_only': )rrrrz callback.z != true)rerr)cbissueskeys r3_validate_callback_contractrsF vvht# /0 vvj% 12 vvk.. 6rvvk7J6M N Q5 66#;d " MMIcU(3 45 Mr2z task-2553+7F)evidence_bundle codex_auditdecision_out_pathresult_out_path hold_out_pathregression_resultrH_force_dry_runc  t} ttj} t |} |xs | t z } |xs | t z }|xs | d|dz }t| |t||t|| tt|}|j!d d }t"|j!d gv}|rgn d t"dg}t%| |d}|j!d}|t&k(}|rgnd|dg}|j!dxsi}t)|trt+|j!dxsgng}t-|t+t.|t+t0}t3|dk(}|s|ng}|j!d}|t4k(} | rgnd|dg}!t7||}"t3|"dk(}#|#rgndt3|"d|"ddg}$t9}%t;|%}&t3|&dk(}'|'rgnd|&g}(||z|z|!z|$z|(z})|xr|xr|xr | xr|#xr|'}*|*xr| }+|||| |#|'d},| rB|*r?t=|}-t?||}.t9}%|-j!dr|-j!d d!d"g}/t||/|d#|-d$d%&}0t|d|/|,t| d||| ' }1t| |1t|}2t@|2d(<tC| ||||||1|2|%|.|-|0d|| )}3t||3|3St|d$g|,t| d$||| ' }1d$|1d*<d$|1d+<d,|1d-<t| |1t|}4tD|4d(<tC| ||||||1|4|%|.|-dd|| )}3d|3d.<d$|3d/<t||3tG||3S|+s|)xsd0g}/|j!d(t@k(r|/|j!d1gddz }/t||/|d2|,| d3&}0t=|}-|-j!dr|/|-j!d d4gz }/t?||}.t|d|/|,t| d||| ' }1t| |1tC| ||||||1||%|.|-|0d|| )}3t||3|3St%| |d$}5t=|}-|-j!drR|5j!d(t@k7r:t||-j!d d!g|d5}0t|5}5t@|5d(<d$|5d6<n d}0tG|t?|5|}.|5j!d(tDtHfvxr|-j!d }6t||+g|,t| |6||| ' }1t| |1tC| ||||||1|5|%|.|-|0d|| )}3t||3|3S#t$ro}t|d|g|d}t| tddt|gt| || t|t| ||| t| ||| cYd}~Sd}~wwxYw)7ugoal_execution_contract 만으로 deriver→gate→activation 루프 자동 구성 + 기계 결정. Parameters ---------- goal_contract: chair 제공 goal_execution_contract (schema: anu_v3.goal_execution_contract.v1). repo_path: workspace root 경로. evidence_bundle: None 이면 run_activation 내부 builder 가 자동 구성. codex_audit: 선택적 Codex post-result audit mapping. HIGH/CRITICAL → HOLD 강제. decision_out_path: activation decision JSON 저장 경로 (None 이면 기본값). result_out_path: final goal result JSON 저장 경로 (None 이면 기본값). hold_out_path: HOLD packet 저장 경로 (None 이면 기본값). regression_result: pytest 결과 dict {"passed": N, "failed": M, "total": T, "ts_utc": ..., "command": ...}. 제공 시 field 11 = 실 결과. 없으면 {"status": "NOT_PROVIDED"}. controller_task_id: 이 controller 실행의 task ID (e.g. "task-2553+7"). 출력 파일명과 일치해야 함. _force_dry_run: True = 6 조건 전부 충족해도 activate=False 강제 (CLI --dry-run 안전 오버라이드). Returns ------- dict — 16-field final goal result packet. zmemory/events/z .hold.jsonugoal contract parse 실패: goal_contract_parse)out_pathstageNF)gcall_passreasonscontroller_versiontsrHrun_idrholdrHrtarget_task_idz task-2553+1allowed_actionszCondition 1 FAIL: 'z&' not in goal_contract.allowed_actions) repo_pathractivaterSz"Condition 2 FAIL: gate_decision = z != DECISION_ALLOWderived_contracteffective_diff_files)planned_effective_actionsrforbidden_write_targetsrbinding_preflight_statusz-Condition 4 FAIL: binding_preflight_status = z != DRY_RUN_PLAN_ONLYzCondition 5 FAIL: z hold condition(s) triggered: rnzCondition 6 FAIL: )0cond1_allowed_actions_contains_clean_replacementcond2_gate_decision_allowcond3_boundary_validator_pass$cond4_binding_preflight_dry_run_plancond5_hold_conditions_zerocond6_callback_collector_ready force_holdreasonzCodex unresolved HIGH/CRITICALz5force_hold=True overrides --dry-run all-six-pass pathcodex_audit_force_hold_dry_runT) codex_result force_dry_run)rrdetail) rrrsix_conditionsrr auto_continuerHrrrQ)rrHrrrrSactivation_decisionactivation_result cb_contractadjrhold_pktmerge_performedrractivation_permittedforce_dry_run_overrideuDRY_RUN_VERIFIED — 6 조건 전부 통과. --dry-run 안전 오버라이드로 activate=False 강제 (실 write 0). 회장 gated real activation 별도 실행 가능.rhold_for_chairrz6 conditions not all passedrVsix_conditions_check)rrzCodex HIGH/CRITICALcodex_post_auditcodex_forced_hold)%r4rouuiduuid4rrr rJrdictrrrD_activation_decisionr_empty_result_packetrer"rr isinstancelistr r,rlenrryrr_handle_codex_auditrrs_build_final_packetrrOr)7rurrrrrrrrHrrrrepodec_pathres_pathrNrerr cond1_pass cond1_reasonsrkgate_dec cond2_pass cond2_reasonsr eff_filesboundary_violations cond3_pass cond3_reasons bp_status cond4_pass cond4_reasonstriggered_holds cond5_pass cond5_reasonsr cb_issues cond6_pass cond6_reasonsall_six_reasons all_six_passrrrrrVr decision_json hold_result final_packetdry_run_verifiedrrs7 r3run_goal_activationrsMV B  F  ?D CT,B%BH?4*>#>H  23:>>"(,>?!(,>?!)-?@ m!4 54VV,mPQ R&))*<=C & -  ! !"8 9 ?R@  , "&'7"8& $%H I  ()Q.J:D2"M""#=>I11J  ,>=G%/)30:&0*4 N,+;7  <.0   L )  +KLGL3""6(4tL H1$-#5##5- M - 0~.K$6K !.#5-!1&$1"-')! %"3L" , / -)11)  15 ,-26 ./ f f Hm,/%<"*1)-" -.#%!/ $*/ %&(, _%Hl+9% &I+H*I   h '+= = N..~rB2AF FL.  ("0!/  +;7   L ) \--h8MNO OL  <- )11)   Hm,*1)-" -,#%!/ " Hl+'''{3L %*;*?*?+ +/    h(H I J$   !!23&8(#15-.9% -{ ;C&))(3 8-|, , ) %%- #-% M-(' -% ))+ !+L",' ]  * +A3 / 0'   H2ec!fX1b1   H21  $1  % s?U,, W$5A$WW$W$c |ddddSt|jddj}|jdg}|xsgDcgc]0}t|jddjdvs/|2}}t|jd d xsd }|d vr d d |d |ddS|rd d |t |dt |ddS|d kDr d d ||d|ddSd d|dScc}w)uCodex post-result audit 처리. force_hold=True 조건 (any of): 1. verdict ∈ {NEEDS_REFINEMENT, FAIL, HIGH, CRITICAL} 2. unresolved_findings[*].severity ∈ {HIGH, CRITICAL} 3. scalar unresolved_high_or_critical > 0 Only verdict ∈ {PASS, PASS_WITH_RECOMMENDATIONS} AND unresolved_high_or_critical == 0 AND no HIGH/CRITICAL findings → force_hold=False (auto-continue allowed). FNO_AUDIT_PROVIDED)attachedrverdictrrRunresolved_findingsseverity)HIGHCRITICALunresolved_high_or_criticalr)NEEDS_REFINEMENTFAILrrTzCodex verdict=z$ is not a pass (force_hold required))rrrrzCodex z$ unresolved HIGH/CRITICAL finding(s))rrrunresolved_high_critical_countrz"Codex unresolved_high_or_critical=z6 > 0 (scalar field indicates unresolved HIGH/CRITICAL))rrrrr)roreupperintr)rr unresolvedf high_critscalar_high_crits r3rrsZ*  +//)R01779G!6;J$"QUU:r-B)C)I)I)KOc)cI;??+H!LQPQRBB&wk1UV   .1)ns9~..RS   !+;45E4FGDD   Ks 0C(=C()rrrHrrc | t|ni} |xs|r|jdnd} idddtd|d|d| d|d| d |r|jd ndd |d |xsid |d |ddddd| d|rdSdS)Nrr|z"anu_v3.goal_activation_decision.v1controller_modulerr}rrHgoal_idrrrVrmerge_not_permittedTmerge_not_performedsuccess_condition_parsedruactivation_permitted=True 이면 controller 가 run_activation(activate=True) 호출. runner 의 fail-closed gate 가 최종 barrier.u;activation_permitted=False — HOLD_FOR_CHAIR. 실 write 0.)r rer) rrrrrrrrHrrsuccess_cond_parsed_tids r3rrs$:<1"5R  G"bff%56$D 6 .  0  "   &   0  $  266)$    ..B      t  t  #$7! "  F% *O+ r2)rrc|jd}|jd}t|trt|jdxsgng}t t }|r t t |t |k(nd}| t| }ndddd d }id td td td|d|d|d|d|d|xstdgdd|d|d|d|d|d|ddddt|txr7t|jdtxr|djd d!ud"d#d$dd%d&ddd'd(|| | |t|d!d!d!d!d!d!d)d| d*d+|tk(xs| du| |jd,d|jd-dd. S)/u회장 §명시 16-field final packet 생성. NOTE: activation_permitted removed — it was passed but never used inside this function (LOW unused-param cleanup). Callers updated accordingly. rQ pr_numberrFN=tests/regression/test_goal_activation_controller_2553plus7.py NOT_PROVIDEDuRpytest 결과 미제공 (--regression-result 없이 실행). 별도 실행 필요.) test_suiterequired_testsrQrr|rrr}rrHrtask_idimplementation_files) z!anu_v3/goal_execution_contract.pyz!anu_v3/goal_boundary_validator.pyz$anu_v3/goal_activation_controller.pyzanu_v3/goal_result_planner.pyz)scripts/run_goal_activation_controller.pyz+schemas/goal_execution_contract.schema.jsonz)schemas/goal_execution_result.schema.jsonz5memory/fixtures/task-2553+1.f1solo.goal-contract.jsonrrrzmemory/reports/task-2553+7.mdrurrSrclean_replacement_pr_numbereffective_diff_6_file_matchpr_102_preservation_evidencefztask/task-2553-dev5(bd5ad74f5d443b354319fc8b3cb006816b8a9025 source_pr preservedTuGPR #102 원본 변경 0. clean replacement PR 은 별도 신규 branch.)source_pr_number source_branchrecorded_head_sharrztoken_transport / owner_triggerufcontroller 는 F2 관련 파일 변경 0. effective diff = 6 파일만 (TASK_2553P1_EFFECTIVE_DIFF_6).)f2_scopecontroller_changed_f2ru*controller 는 phase3/mqe 파일 변경 0.)phase3_tests_changedmerge_queue_executor_changedr)contracthandoffr{rrrrrumerge NOT permitted / NOT performed. controller 설계상 merge 경로 부재 (9-R.4 정적 증명). activation = clean replacement PR open 만.)merge_permittedrrreal_write_performedgithub_mutation_performed) f2_byte_identical_evidencephase3_mqe_unchanged_evidencerr*r+callback_collector_resultmerge_possibility_judgmentr hold_packetrr ) rerrrsetrsortedr rrrsr)rrHrrrrSrrrrrrrrr act_statusrrexpected_6_seteffective_6_match_regression_fields r3rr!s.#&&x0J!%%k2I & -  ! !"8 9 ?R@  56NLUs9~.&2HH[`$ !23Z $h  d $d  .d  0 d  " d  & d  0d  .d  %d  *2 2d   ! d : ;d > ,?d B Cd F 2Gd J &yKd N &'8Od R ' #2!K+T2K/33K@$GK$[155kBdJ] ) Sd l:%*2 ' %*,1@* /#/"%$():;"#' &  %.U ' %(::Rhd>R 1 5 56Le T%6%:%: '& Cd dr2)rHrc idtdtdtd|d|d|ddd |d td dd dd ddddddddddidddiddid didddiidddd|ddgd S)u&parse 실패 시 최소 결과 패킷.r|rrr}rrHrNr rQrurrSrrrFrrr!rrNOT_RUN)rr)rrT) r"rr*r+r#r$rr%rr r )r rrrsrs r3rrs# $ .  0  "   &   0   $  %  $    D    t  &t  &u  'e(&F# $+A%)H& 205U#K"$%':?TY&Z %%* "9 r2)rrr)rpro)rB str | PathrCdict[str, Any]rpNone)rBr.rHrorpr0)rNr.rpr0)ruMapping[str, Any]rkr1rp list[str])rpr/)rr1rpr2)rur1rr.rMapping[str, Any] | Nonerr3rstr | Path | Nonerr4rr4rr3rHrorrqrpr/)rr3rpr/)rdict[str, Any] | Nonerrqrr2rzdict[str, bool] | NonerrorrorrqrHror str | Nonerr6rpr/) rrorHrorrorr/rr5rSr6rr/rr/rr/rr/rr/rr5rrqrr3rr6rpr/) rrorr/rHrorr6rpr/)9__doc__ __future__rr@rrrpathlibrtypingrrr anu_v3.goal_boundary_validatorr r r anu_v3.goal_execution_contractr rr'anu_v3.pre_authorized_activation_runnerrrrrsrrrr!anu_v3.pre_authorized_action_gater-anu_v3.pre_authorized_evidence_bundle_builderrr&anu_v3.pre_authorized_executor_bindingrr__annotations__rrr r"r,r4rDrJrOryrrrrrrr__all__r1r2r3rCs:# '&&  G C:C!(J(> $KjJ%@z? ,( E,>$>%>>H0015,0+/)-'+26+ p$pp. p * p ) p'p%p0ppppl ?)??T.2 +!%''' ' + '  ' '''' ''x37!Q QQ Q  Q , QQ(Q&Q Q Q!Q$QQ0Q !Q"#Qp, % % % %  %  %P r2