Method save_provenance_graph

atomic-repository/src/repository/changes.rs:636–684

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 if this is a Sherpa provenance graph.
        // 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()))?;

        txn.commit()
            .map_err(|e| RepositoryError::Database(e.to_string()))?;

        Ok(hash)
    }

    /// Load a provenance graph from the repository by hash.
    pub fn load_provenance_graph(