Function check_deleted_context

atomic-core/src/apply/insertion.rs:237–282

Check if a context span was deleted by an unknown change. If the context has DELETED edges from changes not in our dependencies, we have a zombie conflict. The workspace tracks these for later resolution. # Arguments `txn` - Transaction for graph queries `workspace` - Workspace to record conflicts `change` - Current change for dependency checking `node` - GraphNode to check for deleted context

(
    txn: &T,
    workspace: &mut Workspace,
    change: &Change,
    node: GraphNode<NodeId>,
)

/// * `change` - Current change for dependency checking
/// * `node` - GraphNode to check for deleted context
fn check_deleted_context<T: GraphTxnT>(
    txn: &T,
    workspace: &mut Workspace,
    change: &Change,
    node: GraphNode<NodeId>,
) -> Result<(), LocalApplyError> {
    // Skip ROOT span
    if node.is_root() {
        return Ok(());
    }

    // Look for parent edges with DELETED flag
    let min_flag = EdgeFlags::PARENT | EdgeFlags::BLOCK;
    let max_flag = EdgeFlags::PARENT | EdgeFlags::BLOCK | EdgeFlags::DELETED | EdgeFlags::FOLDER;

    let edges =
        txn.iter_adjacent(node, min_flag, max_flag)
            .map_err(|e| LocalApplyError::Internal {
                message: format!("Failed to iterate adjacent edges: {}", e),
            })?;

    for edge_result in edges {
        let edge = edge_result.map_err(|e| LocalApplyError::Internal {
            message: format!("Edge iteration error: {}", e),
        })?;

        // Check if edge is deleted
        if edge.flag().contains(EdgeFlags::DELETED) {
            // Get the change that introduced the deletion
            let introduced_by = edge.introduced_by();
            if !introduced_by.is_root() {
                // Look up the external hash
                if let Ok(Some(hash)) = txn.get_external(introduced_by) {
                    // Check if this change knows about the deletion
                    if !change.knows(&hash) {
                        // Unknown deletion - mark as zombie
                        workspace.add_zombie_vertex(node);
                        break;
                    }
                }
            }
        }
    }

    Ok(())
}

// Tests