Method import_v3_bytes

atomic-repository/src/redb_change_store/mod.rs:245–379

Import V3 change data from a byte slice. This is the core import method — used by both `import_v3_file` and by the network layer when receiving change data during pull.

(&self, data: &[u8])

    /// This is the core import method — used by both `import_v3_file` and
    /// by the network layer when receiving change data during pull.
    pub fn import_v3_bytes(&self, data: &[u8]) -> RedbStoreResult<[u8; 32]> {
        let mut cursor = Cursor::new(data);
        let mut reader = ChangeReader::open(&mut cursor)?;

        let _file_header = *reader.file_header();
        let hash_table = reader.hash_table().clone();

        // Read all sections
        let mut meta_header: Option<ChangeHeader> = None;
        let mut meta_deps: Vec<u16> = Vec::new();
        let mut provenance_payload: Option<Vec<u8>> = None;
        let mut graph_sections: Vec<(u32, Vec<u8>)> = Vec::new();
        let mut semantic_sections: Vec<(u32, Vec<u8>)> = Vec::new();
        let mut content_chunks: Vec<(u32, [u8; 32], Vec<u8>)> = Vec::new();
        let mut unhashed_payload: Option<Vec<u8>> = None;

        let mut graph_idx = 0u32;
        let mut semantic_idx = 0u32;

        while let Some(section) = reader.next_section()? {
            match section.section_type {
                SectionType::Header => {
                    meta_header = Some(
                        postcard::from_bytes(&section.payload)
                            .map_err(|e| RedbStoreError::Serialization(e.to_string()))?,
                    );
                }
                SectionType::Dependencies => {
                    meta_deps = postcard::from_bytes(&section.payload)
                        .map_err(|e| RedbStoreError::Serialization(e.to_string()))?;
                }
                SectionType::Provenance => {
                    provenance_payload = Some(section.payload.clone());
                }
                SectionType::Graph => {
                    graph_sections.push((graph_idx, section.payload.clone()));
                    graph_idx += 1;
                }
                SectionType::Semantic => {
                    semantic_sections.push((semantic_idx, section.payload.clone()));
                    semantic_idx += 1;
                }
                SectionType::Content => {
                    if let Some(info) = &section.content_chunk_info {
                        content_chunks.push((
                            info.chunk_index,
                            info.chunk_hash,
                            section.payload.clone(),
                        ));
                    }
                }
                SectionType::Unhashed => {
                    unhashed_payload = Some(section.payload.clone());
                }
            }
        }

        // Verify hash