3j_vdZddlmZddlZddlZddlmZmZddlm Z m Z m Z m Z m Z ddlmZmZmZmZddlmZmZmZmZmZmZmZdZd Zd Zd Zd Zd Z dZ!e"ee e!hZ#dZ$dZ%dZ&dZ'dZ(dZ)dZ*e e+e e+e,fgdfZ-d"dZ.d#dZ/eGddZ0eGddZ1GddZ2dd d$d Z3gd!Z4y)%u anu_v3.runtime_event_enactor — bounded enactor for the +54 runtime-event loop proposal candidates (task-2553+55, 회장 결정). 회장 §1 verbatim: "자동 loop 가 proposal 생성까지 완성됐고, 다음 단계는 proposal candidate 를 안전 조건 안에서 enact 하는 bounded enactor." The +54 ``RuntimeEventLoop`` interprets the durable registry as progress events and emits *proposal candidates only* (zero authority). This module is the bounded enactor that consumes those candidates and, within strict safety conditions, enacts ONLY what it is authorized to (회장 §2 1~10): 1. input = a +54 runtime-event-loop result (envelope or inner result). 2. type = consolidated_summary · closeout_candidate · next_dispatch_candidate · hold_packet (``anu_v3.proposal_authorization_gate``). 3. enact = ONLY authorized actions. 4. else = the proposal is retained as a proposal (no enact). 5. closeout = an ADDITIVE artifact ONLY (a brand-new file; zero modification of any existing artifact; zero merge/PR/branch). 6. next dispatch = candidate->actual dispatch promotion ONLY on the §2.6 triple AND an explicit chair grant (verify-only here — Track B never promotes; 회장 §3.B/§8/§10). 7. merge / PR / credential / branch-write = BLOCKED by default. 8. every enact decision is recorded in an enactor-result JSON. 9. re-processing the same proposal is idempotent (``anu_v3.enactor_idempotency``). 10. using a dead-man / fixed-time / fallback source as the progress trigger is a hard FAIL. Track boundary (회장 §3): * Track A (final consolidated closeout) -> actually ENACTED here, as an ADDITIVE artifact only. * Track B (next_dispatch_candidate safety gate) -> verified ONLY. * Track C (hold_packet routing) -> verified ONLY. Authority boundary: the enactor performs ZERO merge / PR / branch / main write / credential op / cron register / dispatch / subprocess / cokacdir. The ONLY side effect it is permitted is an *additive* artifact create, and even that is delegated to an injected, allowlist-gated ``artifact_writer`` (the module never opens a file for write itself — pure core + injected sink, fully testable with a tmp writer). Layer A / NO-CRON. ) annotationsN) dataclassfield)CallableDictListOptionalSequence)IDEMPOTENT_BINDING_CONFLICTIDEMPOTENT_SKIPalready_enactedenact_id)ACTION_BLOCKEDACTION_DISPATCH_READYACTION_ENACT_ADDITIVEACTION_HOLD_ROUTEDPROPOSAL_CLOSEOUT_CANDIDATEPROPOSAL_CONSOLIDATED_SUMMARYauthorize_proposalzanu_v3.runtime_event_enactor.v1zruntime_event_enactor_result.v1z(task-2553.final-consolidated-closeout.v1registry_completed_eventfixed_time_gatedead_man_fallbackfallback_progressz?memory/events/task-2553.final-consolidated-closeout_260518.jsonnoneENACTEDr NO_ACTIONFORBIDDEN_TRIGGER_SOURCEHOLD_FOR_CHAIRctjtj|dddj dj S)NFT),:) ensure_ascii sort_keys separatorszutf-8)hashlibsha256jsondumpsencode hexdigest)values 3/home/jay/workspace/anu_v3/runtime_event_enactor.py_shar-gs: >> * &/ ik ct|jd}t|tr|jddk(r|S|S)zAccept either the +54 envelope (``...runtime-event-loop-result.v1`` with a nested ``result``) or the inner ``runtime_event_loop_result.v1``. resultschemazruntime_event_loop_result.v1)get isinstancedict) loop_resultinners r,_unwrap_loop_resultr7os< OOH %E%599X#6&$ r.ceZdZUded<ded<ded<ded<ded<ded<d ed <d ed <d ed <ded<eeZded<ddZy)EnactionRecordstr proposal_typeaction source_idbool authorizedenactedidempotent_skip Optional[str]artifact_targetrDict[str, object]decisionzOptional[Dict[str, object]] idempotencydefault_factory List[str]reasonsc  |j|j|j|j|j|j |j |j|j|jt|jd S)N r;r<r=r?r@rArCrrErFrJ) r;r<r=r?r@rArCrrErFlistrJselfs r,to_jsonzEnactionRecord.to_jsonsf!//kk//||#33#33  ++DLL)  r.NreturnrD)__name__ __module__ __qualname____annotations__rrMrJrPr.r,r9r9{sO KN M"",,t4GY4  r.r9ceZdZUded<ded<ded<ded<ded<ded <ded <ded <ded <d ed<d ed<d ed<d ed<d ed<d ed<ded<ded<ded<eeZded<eddZddZ y) EnactorResultr:r1generated_at_kstverdictrBprogress_triggerr>fixed_time_used dead_man_used fallback_used authorityloop_result_sha256intproposals_total enacted_countidempotent_skip_countdispatch_ready_count blocked_counthold_routed_countList[Dict[str, object]]recordsadditive_artifactshold_for_chairrGrIrJc2|jttfvSN)r[ENACTOR_FORBIDDEN_TRIGGERENACTOR_HOLD_FOR_CHAIRrNs r,okzEnactorResult.oks|| % "$   r.c,id|jd|jd|jd|jd|jd|j d|j d|jd d d d d |jd|jd|jd|jd|jd|jd|jt|j t|j"|j$t|j&dS)Nr1rZr[r\r]r^r_r` auto_executedFmerge_pr_branch_credentialblockedrarcrdrerfrgrh)rjrkrlrJ)r1rZr[r\r]r^r_r`rarcrdrerfrgrhrMrjrkrlrJrNs r,rPzEnactorResult.to_jsons^ dkk  5 5  t||   5 5  t33  T//   T//    U  ))  !$"9"9  t33  T//  $T%?%?  #D$=$= T//! " !7!7# $DLL)"&t'>'>"?"11DLL)+  r.N)rRr>rQ) rSrTrUrVrrMrJpropertyrqrPrWr.r,rYrYs K L##N $$//t4GY4    r.rYceZdZdZddd d dZ d dZ ddZedd edd  dd Z y )RuntimeEventEnactorzBounded enactor over +54 proposal candidates (read-mostly; the only side effect is an injected, allowlist-gated *additive* artifact write). z/home/jay/workspace)executor_self_keyworkspace_rootcNtd|D|_||_||_y)Nc3&K|] }|s| ywrnrW).0ks r, z/RuntimeEventEnactor.__init__..s7AQa7s)tupleanu_keysrzr{)rOrrzr{s r,__init__zRuntimeEventEnactor.__init__s&777 !2,r.cg}dD]M}|j|}t|ts%|D]$}t|ts|j |&O|S)N)consolidated_summary_candidatesdispatch_candidatesquarantined_events)r2r3rMr4append)rOr6outkeyseqitems r,_collect_candidatesz'RuntimeEventEnactor._collect_candidatess_(* )C ))C.C#t$)D!$- 4() ) r.c.t||tddddd|jd|jd|jd|jd |jd |jd d ||jd xsgdddddddddddS)u^Construct the ADDITIVE final-consolidated-closeout artifact. It is a brand-new, self-describing file: it carries the ``enact_id`` (for idempotency), the consolidated batch identity, the source loop sha, and an explicit authority boundary. It NEVER references or mutates any existing artifact (회장 §2.5/§3.A/§8).enacted_additive_artifact_onlyFruz task-2553z*task-2553+55 bounded runtime-event enactorr1statusbatch_id all_settledall_authoritative_passgenerated_basis)r1rrrrr track_statesFINAL_CONSOLIDATED_CLOSEOUTCLOSED_OUT_ADDITIVEz+54 runtime-event-loop consolidated_summary_candidate (all-settled & all-AUTHORITATIVE_PASS) enacted by the +55 bounded enactor as an additive artifact only.)kindrbasismergepr branch_write credential_opdispatchuADDITIVE ARTIFACT ONLY — this is a newly created closeout record. Zero existing artifact was modified; zero merge / PR / branch / main write / credential op / dispatch was performed (회장 §2.5/§3.A/§6/§8).)r1rrZr` action_modersrttask produced_bysource_proposalsource_loop_result_sha256consolidated_track_statescloseoutnote)CLOSEOUT_ARTIFACT_SCHEMAAUTHORITY_NONEr2)rOeidrZsummaryloop_shas r,_build_closeout_artifactz,RuntimeEventEnactor._build_closeout_artifacts/ 0';"*3G!++h/!++h/#KK 3&{{=9*1++,+$+;;/@#A *2)0^)D)J5/H %!&! :K* * r.FN)progress_trigger_sourceallow_actual_dispatchartifact_writercloseout_targetrZc\ g}t|}|tvr|jd|dtdt d6idt d|dt ddd |tk(d |tk(d |tk(d td |dddddddddddddgdgddd|St|} |j| } g} g} dx} x}x}x}}d}t}| D]}t||j|j |}|j#}t%|j&|j(|j*|j,dddd|dt/|j0 }|j(t2k(rP|j&t4t6fvr7|j9d}t;|t<r|ni}t?|j9dxs|j9dxsd}tA|j9d xstA|j9d }tCd!|||g|"}||_!||_"||vrJd#|_#|d$z }d%||d&d|d'gd(|_$|j0jd)| j||jK|tM|||jN*}|j#|_$|jPtRk(rd#}|j0jd+n|jPtTk(r)d#|_#|d$z }|j0jd,nI|jW||||-}|1|||d#|_,| d$z } |j0jd.n|j0jd/| j|||jX|jFs|ndd0n|j(tZk(r!|d$z }|j0jd1n|j(t\k(r!|d$z }|j0jd2nO|j(t^k(r!|d$z }|j0jd3n|j0jd4| j||rt`}n| rtb}n|rtd}ntf}|jd5t d6idt d|d|dtd dd dd dd td |dti| d| d|d|d|d|d| Dcgc]}|j#c}d| d|d|Scc}w)7uConsume +54 proposal candidates and enact only the authorized bounded actions (회장 §2 1~10). ``artifact_writer`` (optional) is the injected allowlist-gated additive sink. When omitted, the enactor still computes every decision + the would-be artifact + idempotency, but performs ZERO write (dry, fully deterministic). Track A actual enact requires the writer to be supplied by the allowlisted runner. zprogress_trigger_source=u is a dead-man / fixed-time / fallback class trigger — FORBIDDEN as a progress trigger; the bounded enactor refuses to enact. Only u_ (a durable-registry append/update consumed by +54) drives progress (회장 §2.10/§6, reg 6).r1rZr[r\Nr]r^r_r`rarcrrdrerfrgrhrjrkrlFrJ)rrzrrL gate_evidencerr=ryrfinal_consolidated_closeout)r;r=settle_identityrCTzanu_v3.enactor_idempotency.v1r usame closeout already enacted earlier in THIS run (consolidated_summary + closeout candidate of one batch) — idempotent skip, no second write (회장 §2.9, reg 2).)r1rrCclassification should_writeexisting_enact_idrJucin-run duplicate of the same final consolidated closeout — idempotent skip (회장 §2.9, reg 2).)rrCr{uadditive closeout path already bound to a DIFFERENT enact_id — never overwritten; escalated to HOLD (회장 §7 registry/binding mismatch).udsame proposal re-processed — idempotent skip; additive artifact left byte-0 (회장 §2.9, reg 2).)rrZrruTrack A — final consolidated closeout ENACTED as an ADDITIVE artifact (new file; zero modification of any existing artifact; zero merge/PR/branch; 회장 §2.5/§3.A/§8, reg 1/7).uTrack A authorized & deterministic artifact computed, but no allowlisted artifact_writer injected — DRY (zero write). The allowlisted runner supplies the writer for the real enact.)targetrwrittenartifactu{Track B — §2.6 triple PASSED -> DISPATCH-READY; verify-only, NO actual dispatch executed (회장 §3.B/§8/§10, reg 4).u_merge/PR/credential/branch target -> BLOCKED; retained as a proposal (회장 §2.7/§6, reg 5).ulTrack C — hold_packet routed to the independent-ANU HOLD lane; verify-only (회장 §3.C/§8, reg 8/9/10).uQunauthorized action -> retained as a proposal, NOT enacted (회장 §2.4, reg 3).ubounded enactor: Track A=additive closeout enact only · Track B/C=verify-only · merge/PR/credential/branch=blocked · zero auto-dispatch/merge/cron/subprocess · idempotent · executor self key never owns/operates a callback (회장 §2/§6/§8/§10).rW)5r-FORBIDDEN_PROGRESS_TRIGGERSrTRIGGER_REGISTRY_COMPLETEDrY RESULT_SCHEMAroTRIGGER_FIXED_TIMETRIGGER_DEAD_MANTRIGGER_FALLBACKrr7rsetrrrzrPr9r;r<r=r?rMrJrrrr2r3r4r:r>rrCrArFaddr r{rr r rr@rrrrpENACTOR_ENACTEDENACTOR_IDEMPOTENT_SKIPENACTOR_NO_ACTIONlen) rOr5rrrrrZrJrr6 candidatesrjrkr@ idem_skipdispatch_readyru hold_routedholdseen_enact_idscandrEdjrecge batch_keyall_apridemrr[rs r,enactzRuntimeEventEnactor.enact,sJ&  $ #&A A NN*+B*EF :<=.. !$!12"&  ,/AA ,/??,/??)$, !"!" #$'(%&&''( )*#$+,-.$&/0 %12 3 8$K0--e4 (*68GHHH)HnHw $'5] D)"&"8"8&; H !!#B &44",,#.. % $ X--. C"77&&1/XXo.%b$/RRHHZ(GDHH[,AGR dhh'?@ATFF34F"?'%.$7$3  # &5#.(*.C'NI"A$'+:*;(--0;$ 'COKK&&NNN3'""3'&$3#'#6#6 #',,.&&*EEDKK&&J ((O;*.C'NIKK&&O $<<)9 $!) = H '2'B&* 1  **Q **M '--&5(+'*{{##6)1!%  $99!# ""( N21  ""?$66q  ""M  ""5 NN3 {] ~ ,G %G -G'G Q    -  8  "      %  (  O " #, "0 " * +22QQYY[2! " 2# $ % &'  3sT))rz Sequence[str]rzr:r{r:rRNone)r6rDrRri) rr:rZr:rrDrr:rRrD)r5rDrr:rr>rzOptional[ArtifactWriter]rr:rZr:rRrY) rSrTrU__doc__rrrrCLOSEOUT_ARTIFACT_TARGETrrWr.r,rxrxs"$3 -  - -  -  -&  8 8  8 # 8  8  8 ~(B&+487 "K &K "% K $ K 2 K K K  K r.rxry)rZcTd|xs |jtdd|jdS)ugSerialize the enactor result as the standalone enactor-result artifact (회장 §4 expected_files).ztask-2553+55.enactor-result.v1 bounded_enactF)r1rZr`rrsr0)rZrrP)r0rZs r,enactor_result_enveloper:s2 3,G0G0G#&.."  r.)ENACTOR_SCHEMArrrrrrrrrrrrrorpr9rYrxr)r+objectrRr:)r5rDrRrD)r0rYrZr:rRrD)5r __future__rr%r' dataclassesrrtypingrrrr r anu_v3.enactor_idempotencyr r r r"anu_v3.proposal_authorization_gaterrrrrrrrrrrrrr frozensetrrrrrrrorpr:rArtifactWriterr-r7r9rYrxr__all__rWr.r,rs@,Z# (;; 31 E8&&&()+;< F+6)3S&[ 12D89      : 3 3  3 lg g V 79   03   r.