openethereum/ethcore/src/account_db.rs

127 lines
2.5 KiB
Rust
Raw Normal View History

2016-02-05 01:49:17 +01:00
//! DB backend wrapper for Account trie
use util::*;
static NULL_RLP_STATIC: [u8; 1] = [0x80; 1];
// TODO: introduce HashDBMut?
/// DB backend wrapper for Account trie
/// Transforms trie node keys for the database
pub struct AccountDB<'db> {
db: &'db HashDB,
address: H256,
}
#[inline]
fn combine_key<'a>(address: &'a H256, key: &'a H256) -> H256 {
address ^ key
2016-02-05 01:49:17 +01:00
}
impl<'db> AccountDB<'db> {
pub fn new(db: &'db HashDB, address: &Address) -> AccountDB<'db> {
AccountDB {
db: db,
2016-05-31 16:59:01 +02:00
address: address.into(),
2016-02-05 01:49:17 +01:00
}
}
}
impl<'db> HashDB for AccountDB<'db>{
fn keys(&self) -> HashMap<H256, i32> {
unimplemented!()
}
fn get(&self, key: &H256) -> Option<&[u8]> {
2016-02-05 01:49:17 +01:00
if key == &SHA3_NULL_RLP {
return Some(&NULL_RLP_STATIC);
}
self.db.get(&combine_key(&self.address, key))
2016-02-05 01:49:17 +01:00
}
fn contains(&self, key: &H256) -> bool {
2016-02-05 01:49:17 +01:00
if key == &SHA3_NULL_RLP {
return true;
}
self.db.contains(&combine_key(&self.address, key))
2016-02-05 01:49:17 +01:00
}
fn insert(&mut self, _value: &[u8]) -> H256 {
unimplemented!()
}
fn emplace(&mut self, _key: H256, _value: Bytes) {
unimplemented!()
}
fn remove(&mut self, _key: &H256) {
2016-02-05 01:49:17 +01:00
unimplemented!()
}
}
/// DB backend wrapper for Account trie
pub struct AccountDBMut<'db> {
db: &'db mut HashDB,
address: H256,
}
impl<'db> AccountDBMut<'db> {
pub fn new(db: &'db mut HashDB, address: &Address) -> AccountDBMut<'db> {
AccountDBMut {
db: db,
2016-05-31 16:59:01 +02:00
address: address.into(),
2016-02-05 01:49:17 +01:00
}
}
#[allow(dead_code)]
pub fn immutable(&'db self) -> AccountDB<'db> {
AccountDB { db: self.db, address: self.address.clone() }
}
}
impl<'db> HashDB for AccountDBMut<'db>{
fn keys(&self) -> HashMap<H256, i32> {
unimplemented!()
}
fn get(&self, key: &H256) -> Option<&[u8]> {
2016-02-05 01:49:17 +01:00
if key == &SHA3_NULL_RLP {
return Some(&NULL_RLP_STATIC);
}
self.db.get(&combine_key(&self.address, key))
2016-02-05 01:49:17 +01:00
}
fn contains(&self, key: &H256) -> bool {
2016-02-05 01:49:17 +01:00
if key == &SHA3_NULL_RLP {
return true;
}
self.db.contains(&combine_key(&self.address, key))
2016-02-05 01:49:17 +01:00
}
fn insert(&mut self, value: &[u8]) -> H256 {
2016-03-13 21:28:57 +01:00
if value == &NULL_RLP {
return SHA3_NULL_RLP.clone();
}
2016-02-05 01:49:17 +01:00
let k = value.sha3();
let ak = combine_key(&self.address, &k);
self.db.emplace(ak, value.to_vec());
k
}
fn emplace(&mut self, key: H256, value: Bytes) {
2016-03-13 21:28:57 +01:00
if key == SHA3_NULL_RLP {
return;
}
2016-02-05 01:49:17 +01:00
let key = combine_key(&self.address, &key);
self.db.emplace(key, value.to_vec())
}
fn remove(&mut self, key: &H256) {
2016-03-13 21:28:57 +01:00
if key == &SHA3_NULL_RLP {
return;
}
2016-02-05 01:49:17 +01:00
let key = combine_key(&self.address, key);
self.db.remove(&key)
2016-02-05 01:49:17 +01:00
}
}