Method vault_store_entry

atomic-repository/src/repository/vault.rs:231–295

Store a pre-built vault entry. Also updates the manifest. This is a lower-level method for internal use and tests where the caller has already constructed a `VaultEntry`. For the common case prefer [`vault_store`](Self::vault_store) which accepts raw parameters.

(
        &self,
        path: &str,
        entry: &VaultEntry,
    )

    /// caller has already constructed a `VaultEntry`. For the common case
    /// prefer [`vault_store`](Self::vault_store) which accepts raw parameters.
    pub fn vault_store_entry(
        &self,
        path: &str,
        entry: &VaultEntry,
    ) -> Result<Hash, RepositoryError> {
        let content_hash = Hash::from_bytes(entry.content_hash);
        let now = chrono::Utc::now().to_rfc3339();

        let mut txn = self
            .pristine
            .write_txn()
            .map_err(|e| RepositoryError::Database(e.to_string()))?;
        use atomic_core::pristine::{KgMutTxnT, VaultMutTxnT, VaultTxnT};

        let previous_entry = txn
            .get_vault_entry(path)
            .map_err(|e| RepositoryError::Database(e.to_string()))?;
        let cascade_updates = match previous_entry.as_ref() {
            Some(previous) if previous.entry_type != entry.entry_type => {
                unlink_goal_from_intent_entries(&mut txn, path, previous, &now)?
            }
            _ => Vec::new(),
        };
        if let Some(previous_entry_type) = previous_entry
            .as_ref()
            .map(|previous| previous.entry_type)
            .filter(|previous| *previous != entry.entry_type)
        {
            txn.init_kg()
                .map_err(|e| RepositoryError::Database(e.to_string()))?;
            txn.del_kg_node(&super::vault_triples::entry_subject(
                path,
                previous_entry_type,
            ))
            .map_err(|e| RepositoryError::Database(e.to_string()))?;
        }

        txn.put_vault_entry(path, entry)
            .map_err(|e| RepositoryError::Database(e.to_string()))?;

        let mut manifest = txn
            .get_vault_manifest()
            .map_err(|e| RepositoryError::Database(e.to_string()))?;
        update_manifest_for_store(&mut manifest, path, entry, previous_entry.as_ref(), &now);
        apply_cascaded_intent_manifest_updates(&mut manifest, &cascade_updates, &now);
        txn.put_vault_manifest(&manifest)
            .map_err(|e| RepositoryError::Database(e.to_string()))?;

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

        self.vault_auto_index(path);
        for update in cascade_updates {
            self.vault_auto_index(&update.path);
            if let Err(error) = self.vault_materialize(&update.path) {
                log::warn!(
                    "Failed to materialize Intent '{}' after Goal unlink: {}",
                    update.path,