jP *UdZddlmZddlZddlZddlZddlZddlmZm Z ddl m Z m Z ddl m Z mZmZmZmZmZmZmZddlmZmZmZmZmZdZd Zd Zd d d ddddddd Zde d<Gdde!Z"eGddZ#eGddZ$d.dZ%ejLdd/d Z'd0d!Z( d1d"Z)d2d#Z*d3d$Z+ d4d%Z,dd& d5d'Z-d6d(Z.dd)dd* d7d+Z/ d8d,Z0d9d-Z1y):aANU v3.1 - ANU-Codex Micro Refinement Convergence Loop (Phase 1 Core). Reference: ANU v3 master spec section 5.4-5.8. Task: task-2662 (CHAIR-AUTH-V3-1-CODEX-MICRO-LOOP-20260525-JJONGS-START-001). Scope (allowed, per task-2662 md): - document / contract / fixture / test layer refinement only - GO_READY / HOLD_FOR_CHAIR packet generation - safe round repetition with NO hard cap (section 5.4) - safety_gates 8-flag enforcement (immediate HOLD on any trigger) - allowed_write_paths enforcement on changed_files Scope (forbidden, per task-2662 md 14-item ban list): 1. dev bot automatic dispatch 2. branch push without chair approval 3. automatic GitHub write 4. merge 5. auto-merge 6. production mutation 7. real write mode 8. OWNER PAT manipulation 9. credential change 10. Axis 1/2/3 runtime change 11. live settings.json change 12. dispatch.py change 13. HARNESS_ENFORCED full declaration 14. ANU-Work production deployment declaration This module is a pure-logic refinement loop driver. It does NOT perform any of the forbidden operations. It only: (a) accepts a `micro_refinement_target` payload + a sequence of round outcomes (each carrying a Codex verdict, proposed changes, and a safety probe); (b) enforces the 8 safety_gates and the allowed_write_paths boundary; (c) collapses the round history into a `micro_refinement_result`; (d) emits a GO_READY or HOLD_FOR_CHAIR packet shaped per sections 5.7/5.8. ) annotationsN) dataclassfield)datetimetimezone)AnyCallableDictIterableListMappingOptionalSequence) CODEX_FAIL CODEX_PASSCODEX_PASS_WITH_RECOMMENDATIONS CODEX_UNKNOWNevaluateGO_READYHOLD_FOR_CHAIR) critical_7security_high_or_criticalpermission_expansiongithub_write_requireddev_bot_reactivation_requiredreal_write_requiredforbidden_write_targetscope_expansion CRITICAL_7 SECURITY_HIGHPERMISSION_EXPANSIONGITHUB_WRITE_REQUIREDDEV_BOT_REACTIVATION_REQUIREDREAL_WRITE_REQUIREDFORBIDDEN_WRITE_TARGETSCOPE_EXPANSIONALLOWED_WRITE_PATH_VIOLATION) rrrrrrrrallowed_write_path_violationzDict[str, str]GATE_TO_HOLD_REASONceZdZdZy)MicroRefinementTargetErrorz;Raised when a micro_refinement_target payload is malformed.N)__name__ __module__ __qualname____doc__V/home/jay/workspace/.worktrees/task-2662-dev2/utils/anu_codex_micro_refinement_loop.pyr+r+TsEr1r+cpeZdZUdZded<eeZded<eeZ ded<eeZ ded <y ) RoundOutcomeapOne ANU-Codex refinement round. `codex_payload` carries the Codex verdict for this round. `proposed_changes` is the list of file paths the round wants to write to (allowed_write_paths boundary is enforced against this list). `safety_probe` is the 8-gate snapshot for this round. `actions` is a human-readable list of refinement actions taken. Mapping[str, Any] codex_payload)default_factory Sequence[str]proposed_changeszMapping[str, bool] safety_probeactionsN) r,r-r.r/__annotations__rtupler9dictr:r;r0r1r2r4r4Xs>%$&+E&BmB',T'BL$B"59G]9r1r4ceZdZUdZded<ded<ded<ded<ded <ded <ded <ded <ded <ded<ded<ded<ded<ded<ded<ded<ded<ded<ded<dZded<dZded<dZded<dZded<d!d Z y)"MicroRefinementResultz4Internal representation; serialize via `.as_dict()`.strtask_idintrounds final_verdictcodex_final_verdictboolrrrrrforbidden_write_target_touchedscope_expansion_detectedr List[str] changed_fileszList[Dict[str, Any]]remaining_findings round_historyevidence_pathstriggered_gatesoffending_pathsdecision_itemsN Optional[str] chair_command ready_forgo_ready_packet_pathhold_packet_pathc&iddd|jd|jd|jd|jd|jd|j d |j d |jd |jd |jd |jd|jdt|jdt|jdt|jdt|j |j"|j$dS)Nschemaz!anu_v3.micro_refinement_result.v1rBrDrErFrrrrrrHrIrrKrLrMrN)rUrV)rBrDrErFrrrrrrHrIrlistrKrLrMrNrUrV)selfs r2as_dictzMicroRefinementResult.as_dicts\ 9 t||  dkk  T//  "4#;#;  $//   #D$=$=  $T%?%?  ,T-O-O  "4#;#;  -d.Q.Q  '(E(E  ()G)G  T$"4"45  !$t'>'>"? T$"4"45! " d4#6#67# $%)$=$= $ 5 5'  r1)returnDict[str, Any]) r,r-r.r/r<rSrTrUrVr[r0r1r2r@r@is> L K#''$((""##,,''((#'M='#I}#*.-.&*m* r1r@c|jddk7r td|jd}t|tr|j ds td|jddk7r td |jd d k7r td |jd dvr td|jdxsi}t Dcgc] }||vs| }}|rtd||j D]\}}|dk7s td|d|dt|jdts tdt|jdts tdycc}w)zOLightweight schema check against schemas/anu_v3_1_micro_refinement_target.json.rXz!anu_v3.micro_refinement_target.v1zschema mismatchrBztask-z"task_id must look like 'task-XXXX'goal_condition'CODEX_PASS_OR_PASS_WITH_RECOMMENDATIONSz>goal_condition must be CODEX_PASS_OR_PASS_WITH_RECOMMENDATIONSround_limit_policy NO_HARD_CAP_FOR_MICRO_REFINEMENTzFround_limit_policy must be NO_HARD_CAP_FOR_MICRO_REFINEMENT (ANCHOR-3) max_rounds)Nrz>max_rounds must be null or 0 for micro refinement (hard cap 0) safety_gateszsafety_gates missing keys: holdz safety_gates[z] must be 'hold' (got )allowed_write_pathsz"allowed_write_paths must be a listforbidden_write_targetsz&forbidden_write_targets must be a listN)getr+ isinstancerA startswithSAFETY_GATE_KEYSitemsrY)targetrBgateskmissingkeyvals r2validate_targetrtszz(BB():;;jj#G gs #7+=+=g+F()MNN zz"#'PP()ijj zz&'+MM( T  zz,y0( L   JJ~ & ,"E*=Qaunq=G=(+Fwi)PQQKKMS &=,w&()MNN fjj!:;T B()QRR C>s  E: E:)maxsizectjdd|}d|vr|jdd}d|vrd}|jd|}g}|D]}||k(r|jd|dk(r|jd1|d k(r|jd H|d vr%|jtj|q|j|d d j |zdz}tj |S)uConvert a glob pattern to a compiled regex. Semantic rules (POSIX glob, ANCHOR-2): * → [^/]* (same-directory-only, does NOT cross path separators) ** → .* (recursive, crosses path separators) ? → [^/] (single char, does NOT cross path separator) other chars → re.escape'd literally Separator normalisation: both pattern and path use POSIX ``/``. z\\+/z//z**z.**z[^/]*?z[^/]z \.+^${}[]|()^$)resubreplaceappendescapejoincompile)patternDOUBLE_STAR_SENTINELpartsch regex_strs r2_glob_to_regexrsffVS'*G '///$, '/"ood$89GE  % % LL  3Y LL ! 3Y LL ? " LL2 ' LL  bggen$s*I ::i  r1ctjj|jtjd}|D]}t |j |syy)NrxTF)ospathnormpathrseprmatch)rpatterns norm_pathrs r2_path_matches_anyrsQ  &..rvvs;I ' " ( ( 3 r1cg}g}|D]>}t||r|j|!t||r.|j|@||dS)zAPer ANCHOR-4: changed_files must stay inside allowed_write_paths.) out_of_bounds forbidden_hit)rr)rKrgrhrrrs r2enforce_allowed_write_pathsrs_ "M!M' T#: ;   &  ':;   & ' +] KKr1czg}tD]/}t|j|ds|j|1|S)NF)rlrGrir)probe triggeredrrs r2_safety_probe_truthy_keysrs?I"  #u% &   S !" r1cftjtjj dS)Nz%Y-%m-%dT%H:%M:%SZ)rnowrutcstrftimer0r1r2_isoformat_nowr s! << % . ./C DDr1c|ttfvrtd||s tdd|||dddd||t|t|t d S)z0Section 5.7. ANCHOR-5: must carry chair_command.z9GO_READY requires PASS or PASS_WITH_RECOMMENDATIONS, got z*chair_command must be non-empty (ANCHOR-5)zanu_v3.go_ready_packet.v1F FINAL_GO_ONLY) rXrBrT codex_verdictrrforbidden_actionrequired_chair_decisionrSrDrKrN generated_at)rr ValueErrorrYrrBrrDrKrNrSrTs r2_build_go_ready_packetr syZ)HIIG GX Y   EFF-& %!#2&m,~.&( r1) hold_reasonc $|s | td||d}tj|d}d|vxs"t|jddxs|dk(} d||| t |t |ddd |t |t |t d S) zPSection 5.8. ANCHOR-5: must name trigger gate via hold_reason + triggered_gates.NuCHOLD packet requires ≥1 triggered_gate or an explicit hold_reasonrrrFzanu_v3.hold_for_chair_packet.v1 ASK_CHAIR) rXrBrrrOrQrecommended_next_actionrDrNrPr)rr)rirGrYr) rBrOrDrNrPrQr6rprimarycritical_7_flags r2_build_hold_packetr0s {2 Q  !!$)--g|D ' '  !!,6 7 ' , & 4"%0~.r2#.~.0&(  r1cH|tj|dt|dS)Nr)gatereasonrP)r)rirY)r offendings r2_decision_item_for_gaterXs&%))$ = ? r1DISPATCH)chair_command_builderrTrNc :t||s td|d}|d}|d}t|xsg}g} g} g} g} g} t}i}d}d}t |dD]\}}t |j xsi}t |jxsi}t|jxsg}t|||}g}|d r%|jd | j|d |d r%|jd | j|d t|D]}||vs|j|t|jd drd |vr|jd t||||Dcic]}|dc}}|j }|}| j||j t|j"t|d|s|D]}|| vs| j||rYd}|}|} t|d t|d d}|D]/}|j|g}| jt%||1n|j t&t(fvsn|s|t&t(fvrg} |s|t&t(fvrt*nt,}||n t/| } t0D!cic]}!|!|!| v }"}!|"d xst|jd d|"d <t3d+id|d| d|d|d |"d d|"dd|"dd|"dd|"dd|"d d|"dd|"dd| dt|jdgxsgd | d!|d"| d#| d$| }#|t,k(rX|xst4}$|$||}%t7||| | ||%|%}&|%|#_||#_d|#_d|#_|#jA}'|&|'d&<|'Sd}(t| })|)s|tBtfvrd'}(tE||)| || | xs|)rt%|)d(| gng||()}&|#jA}'|&|'d*<|'Scc}wcc}!w),zDrive a micro refinement convergence loop end-to-end. Returns a `micro_refinement_result.v1` dict that embeds the GO_READY or HOLD_FOR_CHAIR packet under `go_ready_packet` / `hold_for_chair_packet`. u-round_outcomes must contain ≥1 RoundOutcomerBrgrhFN)startrrrr(rT)rB review_roundr6 safety_signal)roundrr;safety_gates_triggered)rr(rDrErFrrrrrHrIrrrKrLrecommendationsrMrNrOrPrQrgo_ready_packetREPEATED_DISAGREEMENTr)rBrOrDrNrPrQr6rhold_for_chair_packetr0)#rtrrYr enumerater>r6r:r9rrextendrrGrievaluate_codex_decisionrFr;rrrVERDICT_HOLD_FOR_CHAIRVERDICT_GO_READYlenrlr@_default_chair_command_builderrrSrTrUrVr[rr)*rnround_outcomesrrTrNrBrgrh evidence_listrMaggregate_changedrOrPrQlast_codex_verdictlast_codex_payloadhold_triggeredhold_round_indexidxoutcomer6r:proposed path_check round_gatesrrpdecisionp gate_to_paths gate_pathsrErounds_executedrr gate_flagsresultbuilderrSpacket result_dictr packet_gatess* r2run_micro_refinementr`sF HIIYG)/0E)F-34M-N#N$8b9M*,M#%!#O!#O+-N+,.N&*!.:? WW228b9 G006B7 006B70 )+B "$ o &   7 8  " ":o#> ? o &   = >  " ":o#> ?-l; )D;&""4( )  !!,6 7LP[<[   | ,*',78q1d78   &99*!)!=!=0*.{*;    0--%,,Q/ 0 !N" )O+/z//J*K04Z5P0QM$ Q*..tR8 %%&=dJ&OP Q   ' 'J8W+X X ?B 0'9  / Dc7dd  -8c->P? ))@A'11P&Q''<=(22J'K",,=!>#--H"I( 2 6 67H" M SQST$ %!"(#$(%&&'F.(('I+I(:; ',"+('  -$&*#"&nn& )/ %&( %&* O,  2z=6Q Q1K#("(+)eO[(a/JKac,#  nn& /5 +, q9nMs 1 P) Pc|d}d|d|dS)uASection 5.7 + ANCHOR-5: chair_command is what 회장 copy-pastes.rBzAPPROVE FINAL_GO z verdict=zC policy=v3_1_codex_micro_refinement_loop_core_pr_only_no_auto_merger0)rnrrBs r2rrs, YG G9Im_=M Mr1c4tj|dddS)zFJSON-serialize a result dict deterministically for evidence writeback.FT) ensure_ascii sort_keysindent)jsondumps)rs r2serialize_resultr&s ::ka PPr1)rnr5r\None)rrAr\zre.Pattern[str])rrArz Iterable[str]r\rG)rKr8rgr8rhr8r\zDict[str, List[str]])rr5r\rJ)r\rA)rBrArrArDrCrKr8rNr8rSrArTrAr\r])rBrArOr8rDrCrNr8rPr8rQzSequence[Mapping[str, Any]]r6r5rrRr\r])rrArr8r\r]) rnr5rzSequence[RoundOutcome]rz1Optional[Callable[[Mapping[str, Any], str], str]]rTrArNzOptional[Sequence[str]]r\r])rnr5rrAr\rA)rr5r\rA)2r/ __future__r functoolsrrr dataclassesrrrrtypingrr r r r r rrutils.codex_cc_decision_looprrrrrrrrrlr)r<rr+r4r@rt lru_cacherrrrrrrrrrrr0r1r2rsS$L# ('SSS) !024%D06($B '^ FF  : :  :  0 0  0 fSBS!$!"$!NL L&L+L L$E       !  "    X"&% %#%  % " % # %0%%%%%PPT.2 w w+wM w  w , wwt   .1  Qr1