Method next

atomic-repository/src/history/iter.rs:74–111

(&mut self)

    type Item = HistoryResult<HistoryEntry>;

    fn next(&mut self) -> Option<Self::Item> {
        // Check limit
        if let Some(limit) = self.limit {
            if self.count >= limit {
                return None;
            }
        }

        // Get next from inner iterator
        let result = self.inner.next()?;

        self.count += 1;

        match result {
            Ok((seq, node_id, merkle)) => {
                // Get the external hash
                let hash = match self.txn.get_external(node_id) {
                    Ok(Some(h)) => h,
                    Ok(None) => {
                        return Some(Err(HistoryError::ChangeNotFound {
                            hash: format!("{:?}", node_id),
                        }));
                    }
                    Err(e) => {
                        return Some(Err(HistoryError::Database(e.to_string())));
                    }
                };

                let entry = HistoryEntry::new(seq, node_id, hash, merkle);

                // Note: Header loading would be done by the Repository layer
                // since it requires access to the ChangeStore

                Some(Ok(entry))
            }
            Err(e) => Some(Err(HistoryError::Database(e.to_string()))),
        }
    }
}

// Log Functions