Method load_change

atomic-repository/src/changestore/mod.rs:360–404

Load a change from disk. If the change is in the cache, it's returned directly. Otherwise, it's loaded from disk, verified, and added to the cache. # Arguments `hash` - The hash of the change to load # Errors Returns an error if: - The change doesn't exist (`NotFound`) - The file is corrupted (`HashMismatch`) - Deserialization fails (`Serialization`) - An I/O error occurs (`Io`) # Example `

(&self, hash: &Hash)

    /// println!("Message: {}", change.hashed.header.message);
    /// ```
    pub fn load_change(&self, hash: &Hash) -> ChangeStoreResult<Change> {
        // Check cache first
        {
            if let Ok(mut cache) = self.cache.write() {
                if let Some(change) = cache.get(hash) {
                    log::trace!("Cache hit for change {}", hash.to_base32());
                    return Ok(change.clone());
                }
            }
        }

        // Load from disk
        let path = self.change_path(hash);
        log::debug!(
            "Loading change {} from {}",
            hash.to_base32(),
            path.display()
        );

        if !path.exists() {
            return Err(ChangeStoreError::NotFound {
                hash: hash.to_base32(),
            });
        }

        let file = File::open(&path)?;
        let mut reader = BufReader::new(file);

        let (change, computed_hash) = Change::deserialize(&mut reader)?;

        // Verify the hash
        if computed_hash != *hash {
            return Err(ChangeStoreError::HashMismatch {
                expected: hash.to_base32(),
                computed: computed_hash.to_base32(),
            });
        }

        // Add to cache
        if let Ok(mut cache) = self.cache.write() {
            cache.insert(*hash, change.clone());
        }

        Ok(change)
    }

    /// Copy a content span from a change without cloning the full `Change`.
    ///