Method vault_store

atomic-repository/src/repository/vault.rs:156–190

Store content in the vault. Creates a `VaultEntry` from the given parameters, stores it in the database, and updates the manifest atomically. Returns the content hash (Blake3) of the stored entry. If an entry already exists at this path, it is replaced and the manifest is updated accordingly.

(
        &self,
        path: &str,
        entry_type: VaultEntryType,
        content: Vec<u8>,
        frontmatter_json: String,
    )

    /// If an entry already exists at this path, it is replaced and the
    /// manifest is updated accordingly.
    pub fn vault_store(
        &self,
        path: &str,
        entry_type: VaultEntryType,
        content: Vec<u8>,
        frontmatter_json: String,
    ) -> Result<Hash, RepositoryError> {
        let now = chrono::Utc::now().to_rfc3339();
        let entry = VaultEntry::new(entry_type, content, frontmatter_json, now.clone());
        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()))?;

        // Update manifest
        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)
    }

    /// Store a pre-built vault entry. Also updates the manifest.
    ///