Method vault_store

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

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::{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_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_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()))?;

        // 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, 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);