i)pdZddlmZddlZddlZddlmZejeZ dZ dZ GddZ y) u core/merge/merge_prompt_builder.py MergePromptBuilder — constructs the structured Opus conflict-resolution prompt for the SemanticMergeInterceptor. The output is deterministic: identical inputs always produce identical prompt strings (no randomness, no timestamps, no UUIDs in the body). # VERIFICATION_STAMP # Story: 7.03 # Verified By: parallel-builder # Verified At: 2026-02-25 # Tests: 9/9 # Coverage: 100% ) annotationsN)Anyiz... [truncated]cNeZdZdZ d d dZd dZd dZd dZd dZy)MergePromptBuilderu Constructs the exact Opus conflict-resolution prompt for the SemanticMergeInterceptor. Output is deterministic for the same inputs (no randomness). Usage:: builder = MergePromptBuilder() prompt = builder.build(deltas, conflict_report, current_state, version=3) # → pass prompt to Opus API call # VERIFICATION_STAMP # Story: 7.03 # Verified By: parallel-builder # Verified At: 2026-02-25 # Tests: 9/9 # Coverage: 100% c |j|}tj|jd}|j |}d|d|d|d|d }t j d|t|t||S) aa Build the Opus merge resolution prompt. Args: deltas: List of StateDelta objects (or dicts with a ``patch`` key). conflict_report: ConflictReport from ConflictDetector. current_state: Current master state dict. version: Current state version number. Returns: Formatted prompt string. Template:: You are the Genesis Semantic Reducer. Multiple swarm workers have produced conflicting outputs. CURRENT STATE (version {version}): {current_state} CONFLICT REPORT: Paths in conflict: {conflicting_paths} WORKER PROPOSALS: Worker {agent_id}: {delta.patch} ... Respond ONLY with valid JSON: {"resolved_patch": [...], "resolution_rationale": "..."} ,:) separatorszwYou are the Genesis Semantic Reducer. Multiple swarm workers have produced conflicting outputs. CURRENT STATE (version z): z% CONFLICT REPORT: Paths in conflict: z WORKER PROPOSALS: zVRespond ONLY with valid JSON: {"resolved_patch": [...], "resolution_rationale": "..."}z>MergePromptBuilder.build: version=%d, deltas=%d, prompt_len=%d)_truncate_statejsondumpsconflicting_paths_format_worker_proposalsloggerdebuglen) selfdeltasconflict_report current_stateversion state_strconflicting_paths_strworker_proposalsprompts 8/mnt/e/genesis-system/core/merge/merge_prompt_builder.pybuildzMergePromptBuilder.build7s8((7 $  - -*!  88@ &&-Yc)=33H2IJ"  G  G   L  K K   ctj|dd}t|tkr|Stttz }|d|tzS)z Serialise *state* to JSON and truncate to MAX_STATE_CHARS if longer. A truncation marker is appended when the string is cut so the LLM knows the state was abbreviated. rT)r sort_keysN)r rrMAX_STATE_CHARS_TRUNCATION_MARKER)rstate state_jsoncutoffs rr z"MergePromptBuilder._truncate_statepsKZZ*M z?o -  3'9#::'6"%777rcg}|D]T}|j|}|j|}tj|dd}|j d|d|dVdj ||rdzSdzS)z Format each worker's patch as a readable JSON block labelled by agent_id. Each worker's section ends with a newline so proposals are clearly separated in the final prompt. T)indentr!zWorker z:  )_extract_agent_id_extract_patchr rappendjoin)rrlinesdeltaagent_idpatch patch_jsons rrz+MergePromptBuilder._format_worker_proposals~s @E--e4H''.EE!tDJ LL78*C |2> ?  @ yy5499b99rct|drt|jSt|trt|j ddSy)z Extract agent_id from a StateDelta or plain dict. Falls back to ``"unknown"`` if the attribute / key is absent. r2unknown)hasattrstrr2 isinstancedictget)rr1s rr,z$MergePromptBuilder._extract_agent_ids@ 5* %u~~& & eT "uyyY78 8rct|dr |j}n%t|tr|j dg}ng}t|t r t |St|t r|SgS)z Extract the patch list from a StateDelta or plain dict. Mirrors the same logic used by ConflictDetector so the two classes stay in sync. r3)r7r3r9r:r;tuplelist)rr1r3s rr-z!MergePromptBuilder._extract_patchs` 5' "KKE t $IIgr*EE eU #;  eT "L rN)r) rr>rrrr:rintreturnr8)r$r:r@r8)rr>r@r8)r1rr@r8)r1rr@r>) __name__ __module__ __qualname____doc__rr rr,r-rrrrsV: 333 3  3 3r 8: rr) rD __future__rr loggingtypingr getLoggerrArr"r#rrErrrJsA"#    8 $&OOr