Function resolve_paths

atomic-repository/src/query_plan.rs:396–425

Resolve a source path that may be a `$variable` reference. If it starts with `$`, extract vault paths from the bound nodes (using the node label or metadata path field).

(source: &str, bindings: &HashMap<String, Vec<KgNode>>)

/// If it starts with `$`, extract vault paths from the bound nodes
/// (using the node label or metadata path field).
fn resolve_paths(source: &str, bindings: &HashMap<String, Vec<KgNode>>) -> Vec<String> {
    if let Some(var_name) = source.strip_prefix('$') {
        bindings
            .get(var_name)
            .map(|nodes| {
                nodes
                    .iter()
                    .filter_map(|n| {
                        // Try metadata.path first (from vector search results)
                        n.metadata
                            .as_ref()
                            .and_then(|m| m.get("path"))
                            .and_then(|p| p.as_str())
                            .map(String::from)
                            .or_else(|| {
                                // Fall back to node label if it looks like a path
                                if n.label.contains('/') || n.label.contains('.') {
                                    Some(n.label.clone())
                                } else {
                                    None
                                }
                            })
                    })
                    .collect()
            })
            .unwrap_or_default()
    } else {
        vec![source.to_string()]
    }
}

/// Get a field value from a KgNode for filtering.
fn get_node_field(node: &KgNode, field: &str) -> Option<String> {