Method vault_store_entry

atomic-repository/src/repository/vault.rs:197–227

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 mut txn = self
            .pristine
            .write_txn()
            .map_err(|e| RepositoryError::Database(e.to_string()))?;
        use atomic_core::pristine::{VaultMutTxnT, VaultTxnT};

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

        let now = chrono::Utc::now().to_rfc3339();
        let mut manifest = txn
            .get_vault_manifest()
            .map_err(|e| RepositoryError::Database(e.to_string()))?;
        update_manifest_for_store(&mut manifest, path, entry, &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);

        Ok(content_hash)
    }

    /// Automatically index a vault entry into the KG and embed it.
    ///