Function find_sequences

atomic-agent/src/provenance/consolidate.rs:127–182

Indices of unclassified tool-derived nodes grouped into sequences separated by structural boundaries (goals, patches, human gates, errors).

(nodes: &[GraphNode])

/// Indices of unclassified tool-derived nodes grouped into sequences
/// separated by structural boundaries (goals, patches, human gates, errors).
fn find_sequences(nodes: &[GraphNode]) -> Vec<Vec<usize>> {
    let mut sequences = Vec::new();
    let mut current = Vec::new();

    for (i, node) in nodes.iter().enumerate() {
        if node.classified {
            if current.len() >= 2 {
                sequences.push(std::mem::take(&mut current));
            } else {
                current.clear();
            }
            continue;
        }

        match node.kind {
            // Structural boundaries break sequences
            NodeKind::Goal
            | NodeKind::PatchProposal
            | NodeKind::HumanGate
            | NodeKind::Todo
            | NodeKind::TodoStatusChange
            | NodeKind::PhaseTransition
            | NodeKind::Lesson
            | NodeKind::LlmResponse
            | NodeKind::HumanGateResolution => {
                if current.len() >= 2 {
                    sequences.push(std::mem::take(&mut current));
                } else {
                    current.clear();
                }
            }
            // Decision nodes are already consolidated
            NodeKind::Decision => {
                if current.len() >= 2 {
                    sequences.push(std::mem::take(&mut current));
                } else {
                    current.clear();
                }
            }
            // Tool-derived nodes accumulate into the current sequence
            NodeKind::Exploration
            | NodeKind::Commitment
            | NodeKind::Verification
            | NodeKind::Execution
            | NodeKind::Error => {
                current.push(i);
            }
        }
    }

    if current.len() >= 2 {
        sequences.push(current);
    }

    sequences
}

// =============================================================================