Function map_graph_to_input

atomic-cli/src/commands/provenance/mapping.rs:42–90

Map a loaded `ProvenanceGraph` into the plain projector input. `change_hash` is the change the user asked to trace (it names the subgraph and the projected activity). `person_did` is the real signer's `did:atomic`, resolved from the signing identity by the caller — it is NOT in the graph. `graph.previous` is a hash of the PREVIOUS PROVENANCE GRAPH (not an activity id): we load that graph and use

(
    repo: &Repository,
    graph: &ProvenanceGraph,
    change_hash: &Hash,
    person_did: &str,
)

/// id): we load that graph and use ITS activity id for `turnParent`. If it can't
/// be loaded, `turnParent` is omitted (best-effort) rather than fabricated.
pub fn map_graph_to_input(
    repo: &Repository,
    graph: &ProvenanceGraph,
    change_hash: &Hash,
    person_did: &str,
) -> ProvActivityInput {
    let change_id_base32 = change_hash.to_base32();
    let activity_id = activity_id_for(graph);

    let generated = graph
        .changes_explained
        .iter()
        .map(|h| change_urn(&h.to_base32()))
        .collect();

    // `previous` is a hash of the previous PROVENANCE GRAPH — load it and use
    // ITS own activity id (session_id # first-explained-change). Best-effort.
    let turn_parent = graph.previous.and_then(|prev_hash| {
        repo.load_provenance_graph(&prev_hash)
            .ok()
            // The parent activity is keyed the same graph-stable way as this one
            // (activity_id_for), so trace walks a consistent, joinable chain.
            .map(|prev| activity_urn(&activity_id_for(&prev)))
    });

    let agent_vendor = (!graph.agent_vendor.is_empty()).then(|| graph.agent_vendor.clone());

    ProvActivityInput {
        change_id_base32,
        activity_id,
        // Timestamp is Unix SECONDS on the graph but MILLISECONDS on nodes;
        // to avoid mixing units the thin slice leaves times as None (the shape
        // simply omits absent times).
        started_at: None,
        ended_at: None,
        agent_slug: normalize_agent_slug(&graph.agent_name),
        agent_display_name: graph.agent_display_name.clone(),
        agent_vendor,
        person_did: person_did.to_string(),
        generated,
        // The flywheel `used` edge (intents/memories the turn pulled). The current
        // `atomic_core::ProvenanceGraph` capture records no structured inputs —
        // only `nodes`/`edges`/`changes_explained` — so we supply an empty set
        // (the projection omits `used` rather than inventing edges). Populating it
        // is gated on the capture recording inputs (a separate capture-path change).
        used: Vec::new(),
        turn_parent,
    }
}