Function anchor_to_graph

atomic-agent/src/transcript/reasoning.rs:307–356

Anchor code learnings to the CRDT graph using FileOps from the recorded change. This is a post-processing step called after the LLM returns human-readable findings. For each `CodeLearning`, it looks up the file path and line number in the change's `FileOps` to find the corresponding TrunkId, BranchId, and LeafId references. # Arguments `learnings` — The code learnings to anchor (modified in pla

(learnings: &mut [CodeLearning], file_ops: &[atomic_core::change::FileOps])

/// - If no match is found, the anchor is left as `None` (the learning still
///   works, just without auto-tracking through renames/refactors)
pub fn anchor_to_graph(learnings: &mut [CodeLearning], file_ops: &[atomic_core::change::FileOps]) {
    for learning in learnings.iter_mut() {
        let mut anchor = GraphAnchor::empty();

        // Find the matching file in FileOps
        for fop in file_ops {
            if fop.path() != learning.path {
                continue;
            }

            // Set trunk anchor (file level)
            let tid = fop.trunk_id();
            anchor.trunk = Some((tid.change_id().get(), tid.file_idx()));

            // If we have a line number, try to match line operations
            if let Some(target_line) = learning.line {
                for line_op in fop.line_ops() {
                    // Check both old and new line numbers — deletes have old,
                    // inserts have new, some ops have both
                    let op_line = line_op.new_line_num().or_else(|| line_op.old_line_num());
                    let matches = match (op_line, learning.end_line) {
                        (Some(l), Some(end)) => l as u32 >= target_line && (l as u32) <= end,
                        (Some(l), None) => l as u32 == target_line,
                        (None, _) => false,
                    };

                    if matches {
                        let bid = line_op.branch_id();
                        anchor
                            .branches
                            .push((bid.change_id().get(), bid.branch_idx()));

                        // Collect leaf IDs from the line's operations
                        for leaf_op in line_op.leaf_ops() {
                            if let Some(lid) = leaf_op_id(leaf_op) {
                                anchor.leaves.push(lid);
                            }
                        }
                    }
                }
            }

            break; // Found the file, done
        }

        if anchor.is_populated() {
            learning._anchor = Some(anchor);
        }
    }
}

// CRDT Anchor Helpers