Method save_provenance_graph

atomic-repository/src/repository/changes.rs:1040–1112

Save a provenance graph to the repository. Serializes the graph to disk, registers it in the pristine database with `node_type::PROVENANCE`, and records dependencies on the changes this graph explains. # Returns The content hash of the saved provenance graph.

(
        &self,
        graph: &atomic_core::change::ProvenanceGraph,
    )

    ///
    /// The content hash of the saved provenance graph.
    pub fn save_provenance_graph(
        &self,
        graph: &atomic_core::change::ProvenanceGraph,
    ) -> Result<Hash, RepositoryError> {
        use atomic_core::pristine::MutTxnT;

        // Save to disk
        let hash = self
            .change_store
            .save_provenance_graph(graph)
            .map_err(|e| RepositoryError::Database(e.to_string()))?;

        // Register in the graph
        let mut txn = self
            .pristine
            .write_txn()
            .map_err(|e| RepositoryError::Database(e.to_string()))?;

        let prov_id = txn
            .register_provenance(&hash)
            .map_err(|e| RepositoryError::Database(e.to_string()))?;

        // Register dependencies: provenance → explained changes
        for change_hash in &graph.changes_explained {
            if let Ok(Some(change_id)) = txn.get_internal(change_hash) {
                txn.put_dep(prov_id, change_id)
                    .map_err(|e| RepositoryError::Database(e.to_string()))?;
            }
        }

        // If chained, register dependency on previous provenance graph too
        if let Some(ref prev_hash) = graph.previous {
            if let Ok(Some(prev_id)) = txn.get_internal(prev_hash) {
                txn.put_dep(prov_id, prev_id)
                    .map_err(|e| RepositoryError::Database(e.to_string()))?;
            }
        }

        // Populate session tables from the provenance graph, for any agent
        // (Sherpa, Claude Code, OpenCode, generic atomic-agent, ...). The
        // write transaction is still open, so this is atomic with the
        // provenance registration above.
        txn.populate_session_tables(prov_id.get(), graph)
            .map_err(|e| RepositoryError::Database(e.to_string()))?;

        // Maintain the Atomic-native session ledger alongside the provenance
        // registration. The JSON file is a mutable runtime cache; this index
        // connects the external session identity to immutable turn objects.
        let json_path = self
            .dot_dir
            .join("sessions")
            .join(format!("{}.json", graph.session_id))
            .to_string_lossy()
            .to_string();
        txn.index_session_turn(&graph.session_id, &json_path, &hash, graph)
            .map_err(|e| RepositoryError::Database(e.to_string()))?;

        txn.commit()