Method load_content_chunks

atomic-repository/src/redb_change_store/queries.rs:172–205

Load all content chunks for a change, in order. Reads from CHANGE_CHUNKS (manifest) + CONTENT_CHUNKS (data). Decompresses each chunk and returns the raw content. # Returns A vector of decompressed content chunks, ordered by chunk index.

(&self, hash: &[u8; 32])

    ///
    /// A vector of decompressed content chunks, ordered by chunk index.
    pub fn load_content_chunks(&self, hash: &[u8; 32]) -> RedbStoreResult<Vec<StoredContentChunk>> {
        let meta = self.load_meta(hash)?;
        let txn = self.db().begin_read()?;
        let manifest_table = txn.open_table(tables::CHANGE_CHUNKS)?;
        let content_table = txn.open_table(tables::CONTENT_CHUNKS)?;

        let mut chunks = Vec::with_capacity(meta.content_chunk_count as usize);

        for idx in 0..meta.content_chunk_count {
            let manifest_key = tables::encode_change_file_key(hash, idx);

            if let Some(chunk_hash_value) = manifest_table.get(&manifest_key)? {
                let chunk_hash = *chunk_hash_value.value();

                if let Some(chunk_data_value) = content_table.get(&chunk_hash)? {
                    let compressed = chunk_data_value.value();
                    let decompressed = zstd::decode_all(compressed).map_err(|e| {
                        RedbStoreError::Corrupt(format!(
                            "content chunk {} decompression failed: {}",
                            idx, e
                        ))
                    })?;

                    chunks.push(StoredContentChunk {
                        index: idx,
                        hash: chunk_hash,
                        data: decompressed,
                    });
                }
            }
        }

        Ok(chunks)
    }

    /// Load the full content blob for a change by concatenating all chunks.
    ///