3jdZddlmZddlZddlZddlmZmZddlm Z ddl m Z m Z m Z mZdZdZd Zd Zdd Z dd ZeGd dZ ddZgdZy)uanu_v3.enactor_idempotency — deterministic enact-id + idempotent-skip ledger for the bounded runtime-event enactor (task-2553+55 §2.9). 회장 §2.9 verbatim: "같은 proposal 재처리 시 idempotent." The bounded enactor must be a pure deterministic function of the proposal candidate: re-processing the *same* proposal must NOT produce a second additive artifact, a duplicate decision, or a re-write. This module supplies: * ``enact_id(...)`` — a deterministic content hash over the *normative* fields of a proposal (proposal_type · source_id · settle identity · additive artifact target). Free-form note text is deliberately excluded so a cosmetic note change never forces a duplicate enact. * ``already_enacted(...)`` — reads an existing additive artifact (if any) READ-ONLY and reports whether it already carries this exact ``enact_id`` (idempotent skip) or a *different* one at the same path (a binding conflict — never silently overwritten). The module performs ZERO writes itself — it only *decides* idempotency. The caller (the enactor) performs the allowlisted additive write only when this module reports ``should_write is True``. Layer A / NO-CRON: pure. ZERO cron / dispatch / subprocess / cokacdir / merge / PR / branch / credential. ) annotationsN) dataclassfield)Path)DictListOptionalSequencezanu_v3.enactor_idempotency.v1 FIRST_WRITEIDEMPOTENT_SKIPENACT_BINDING_CONFLICTc4tj|dddS)z@Stable JSON canonicalisation (sorted keys, no whitespace drift).FT),:) ensure_ascii sort_keys separators)jsondumps)values 1/home/jay/workspace/anu_v3/enactor_idempotency.py _canonicalr)s :: ETj ct||t||d}tj|j dj S)aIDeterministic enact identity. ``settle_identity`` = the normative tuple that makes this enact unique (e.g. batch_id + sorted track task_ids + all_authoritative_pass). It is canonicalised so element ordering / dict key ordering never perturbs the hash. The same proposal -> the same id -> an idempotent skip. ) proposal_type source_idsettle_identityartifact_targetutf-8)rlisthashlibsha256encode hexdigest)rrrrpayloads renact_idr&0sG*"#O4.  G >>'..1 2 < < >>rceZdZUded<ded<ded<ded<ded<ded <ee Zd ed <edd ZddZ y)IdempotencyDecisionstrschemar&rclassificationbool should_writez Optional[str]existing_enact_id)default_factoryz List[str]reasonsc(|jtk(S)N)r+r selfs ridempotent_skipz#IdempotencyDecision.idempotent_skipSs""o55rc |j|j|j|j|j|j t |jdS)Nr*r&rr+r-r.r0)r*r&rr+r-r.r r0r2s rto_jsonzIdempotencyDecision.to_jsonWsJkk #33"11 --!%!7!7DLL)  rN)returnr,)r8zDict[str, object]) __name__ __module__ __qualname____annotations__rr r0propertyr4r7rrr(r(IsJ KM$$t4GY4 66  rr(c tt||z }|jstt||t dddgS t j|jd}t|tr+|jdrt|jdnd}||k(rtt||td|d gStt||td|d |d |d gS#ttf$rd}YUwxYw) uREAD-ONLY idempotency probe over an existing additive artifact. * absent target -> FIRST_WRITE (should_write=True) * present & embedded id == eid -> IDEMPOTENT_SKIP (should_write=False, byte-0 — never re-written) * present & embedded id != eid -> ENACT_BINDING_CONFLICT (should_write =False — a different enact already owns this path; never silently overwritten, escalated by the caller) * present but unreadable/no id -> ENACT_BINDING_CONFLICT (fail-closed — an opaque pre-existing file at the additive path is never clobbered) TNuhadditive artifact absent — first deterministic enact (additive create only; no existing file touched).r6r)encodingr&Fuadditive artifact already carries this exact enact_id — idempotent skip; the file is left byte-0 (no re-write, no duplicate decision; 회장 §2.9).z"%+1"D  ::dnngn>?(D)hll:.F  Z( ) c"%+*)5   !'2% $tC73; ;   ! Z  sA"C((C<;C<)rBrCr rKr&r(rQ)robjectr8r)) rr)rr)rzSequence[object]rr)r8r))rLr)rr)rMrRr8r()__doc__ __future__rr!r dataclassesrrpathlibrtypingrrr r rBrCr rKrr&r(rQ__all__r>rrrYs0# (114&#6???& ?  ?  ?2     2E EE E  EP r