use super::{
CError, DBValue, Query, Result, Trie, TrieDB, TrieDBIterator, TrieDBKeyIterator, TrieHash,
TrieItem, TrieIterator, TrieKeyItem, TrieLayout,
};
use hash_db::{HashDBRef, Hasher};
use crate::{rstd::boxed::Box, triedb::TrieDBDoubleEndedIterator, MerkleValue, TrieDBBuilder};
pub struct FatDB<'db, 'cache, L>
where
L: TrieLayout,
{
raw: TrieDB<'db, 'cache, L>,
}
impl<'db, 'cache, L> FatDB<'db, 'cache, L>
where
L: TrieLayout,
{
pub fn new(db: &'db dyn HashDBRef<L::Hash, DBValue>, root: &'db TrieHash<L>) -> Self {
FatDB { raw: TrieDBBuilder::new(db, root).build() }
}
pub fn db(&self) -> &dyn HashDBRef<L::Hash, DBValue> {
self.raw.db()
}
}
impl<'db, 'cache, L> Trie<L> for FatDB<'db, 'cache, L>
where
L: TrieLayout,
{
fn root(&self) -> &TrieHash<L> {
self.raw.root()
}
fn contains(&self, key: &[u8]) -> Result<bool, TrieHash<L>, CError<L>> {
self.raw.contains(L::Hash::hash(key).as_ref())
}
fn get_hash(&self, key: &[u8]) -> Result<Option<TrieHash<L>>, TrieHash<L>, CError<L>> {
self.raw.get_hash(key)
}
fn get_with<Q: Query<L::Hash>>(
&self,
key: &[u8],
query: Q,
) -> Result<Option<Q::Item>, TrieHash<L>, CError<L>> {
self.raw.get_with(L::Hash::hash(key).as_ref(), query)
}
fn lookup_first_descendant(
&self,
key: &[u8],
) -> Result<Option<MerkleValue<TrieHash<L>>>, TrieHash<L>, CError<L>> {
self.raw.lookup_first_descendant(key)
}
fn iter<'a>(
&'a self,
) -> Result<
Box<dyn TrieIterator<L, Item = TrieItem<TrieHash<L>, CError<L>>> + 'a>,
TrieHash<L>,
CError<L>,
> {
FatDBIterator::<L>::new(&self.raw).map(|iter| Box::new(iter) as Box<_>)
}
fn key_iter<'a>(
&'a self,
) -> Result<
Box<dyn TrieIterator<L, Item = TrieKeyItem<TrieHash<L>, CError<L>>> + 'a>,
TrieHash<L>,
CError<L>,
> {
FatDBKeyIterator::<L>::new(&self.raw).map(|iter| Box::new(iter) as Box<_>)
}
}
pub struct FatDBIterator<'db, 'cache, L>
where
L: TrieLayout,
{
trie_iterator: TrieDBIterator<'db, 'cache, L>,
trie: &'db TrieDB<'db, 'cache, L>,
}
pub struct FatDBDoubleEndedIterator<'db, 'cache, L>
where
L: TrieLayout,
{
trie_iterator: TrieDBDoubleEndedIterator<'db, 'cache, L>,
trie: &'db TrieDB<'db, 'cache, L>,
}
impl<'a, 'cache, L: TrieLayout> FatDBDoubleEndedIterator<'a, 'cache, L> {
pub fn new(db: &'a TrieDB<'a, 'cache, L>) -> Result<Self, TrieHash<L>, CError<L>> {
Ok(Self { trie_iterator: TrieDBDoubleEndedIterator::new(db)?, trie: db })
}
}
impl<'db, 'cache, L> FatDBIterator<'db, 'cache, L>
where
L: TrieLayout,
{
pub fn new(trie: &'db TrieDB<'db, 'cache, L>) -> Result<Self, TrieHash<L>, CError<L>> {
Ok(FatDBIterator { trie_iterator: TrieDBIterator::new(trie)?, trie })
}
}
impl<'db, 'cache, L> TrieIterator<L> for FatDBIterator<'db, 'cache, L>
where
L: TrieLayout,
{
fn seek(&mut self, key: &[u8]) -> Result<(), TrieHash<L>, CError<L>> {
let hashed_key = L::Hash::hash(key);
self.trie_iterator.seek(hashed_key.as_ref())
}
}
impl<'db, 'cache, L> Iterator for FatDBIterator<'db, 'cache, L>
where
L: TrieLayout,
{
type Item = TrieItem<TrieHash<L>, CError<L>>;
fn next(&mut self) -> Option<Self::Item> {
self.trie_iterator.next().map(|res| {
res.map(|(hash, value)| {
let aux_hash = L::Hash::hash(&hash);
(
self.trie.db().get(&aux_hash, Default::default()).expect("Missing fatdb hash"),
value,
)
})
})
}
}
impl<'db, 'cache, L> TrieIterator<L> for FatDBDoubleEndedIterator<'db, 'cache, L>
where
L: TrieLayout,
{
fn seek(&mut self, key: &[u8]) -> Result<(), TrieHash<L>, CError<L>> {
let hashed_key = L::Hash::hash(key);
self.trie_iterator.seek(hashed_key.as_ref())
}
}
impl<'db, 'cache, L> Iterator for FatDBDoubleEndedIterator<'db, 'cache, L>
where
L: TrieLayout,
{
type Item = TrieItem<TrieHash<L>, CError<L>>;
fn next(&mut self) -> Option<Self::Item> {
self.trie_iterator.next().map(|res| {
res.map(|(hash, value)| {
let aux_hash = L::Hash::hash(&hash);
(
self.trie.db().get(&aux_hash, Default::default()).expect("Missing fatdb hash"),
value,
)
})
})
}
}
impl<'db, 'cache, L> DoubleEndedIterator for FatDBDoubleEndedIterator<'db, 'cache, L>
where
L: TrieLayout,
{
fn next_back(&mut self) -> Option<Self::Item> {
self.trie_iterator.next_back().map(|res| {
res.map(|(hash, value)| {
let aux_hash = L::Hash::hash(&hash);
(
self.trie.db().get(&aux_hash, Default::default()).expect("Missing fatdb hash"),
value,
)
})
})
}
}
pub struct FatDBKeyIterator<'db, 'cache, L>
where
L: TrieLayout,
{
trie_iterator: TrieDBKeyIterator<'db, 'cache, L>,
trie: &'db TrieDB<'db, 'cache, L>,
}
impl<'db, 'cache, L> FatDBKeyIterator<'db, 'cache, L>
where
L: TrieLayout,
{
pub fn new(trie: &'db TrieDB<'db, 'cache, L>) -> Result<Self, TrieHash<L>, CError<L>> {
Ok(FatDBKeyIterator { trie_iterator: TrieDBKeyIterator::new(trie)?, trie })
}
}
impl<'db, 'cache, L> TrieIterator<L> for FatDBKeyIterator<'db, 'cache, L>
where
L: TrieLayout,
{
fn seek(&mut self, key: &[u8]) -> Result<(), TrieHash<L>, CError<L>> {
let hashed_key = L::Hash::hash(key);
self.trie_iterator.seek(hashed_key.as_ref())
}
}
impl<'db, 'cache, L> Iterator for FatDBKeyIterator<'db, 'cache, L>
where
L: TrieLayout,
{
type Item = TrieKeyItem<TrieHash<L>, CError<L>>;
fn next(&mut self) -> Option<Self::Item> {
self.trie_iterator.next().map(|res| {
res.map(|hash| {
let aux_hash = L::Hash::hash(&hash);
self.trie.db().get(&aux_hash, Default::default()).expect("Missing fatdb hash")
})
})
}
}