use crate::account::{AccessKey, Account};
use crate::hash::{hash, CryptoHash};
use crate::receipt::{Receipt, ReceivedData};
use crate::trie_key::trie_key_parsers::{
parse_account_id_from_access_key_key, parse_account_id_from_account_key,
parse_account_id_from_contract_code_key, parse_account_id_from_contract_data_key,
parse_account_id_from_received_data_key, parse_data_id_from_received_data_key,
parse_data_key_from_contract_data_key, parse_public_key_from_access_key_key,
};
use crate::trie_key::{col, TrieKey};
use crate::types::{AccountId, StoreKey, StoreValue};
use borsh::BorshDeserialize;
use serde_with::base64::Base64;
use serde_with::serde_as;
use std::fmt::{Display, Formatter};
use unc_crypto::PublicKey;
#[serde_as]
#[derive(serde::Serialize, serde::Deserialize, Clone, Debug, Eq, PartialEq)]
pub enum StateRecord {
Account { account_id: AccountId, account: Account },
Data { account_id: AccountId, data_key: StoreKey, value: StoreValue },
Contract {
account_id: AccountId,
#[serde_as(as = "Base64")]
code: Vec<u8>,
},
AccessKey { account_id: AccountId, public_key: PublicKey, access_key: AccessKey },
PostponedReceipt(Box<Receipt>),
ReceivedData {
account_id: AccountId,
data_id: CryptoHash,
#[serde_as(as = "Option<Base64>")]
data: Option<Vec<u8>>,
},
DelayedReceipt(Box<Receipt>),
}
impl StateRecord {
pub fn from_raw_key_value(key: Vec<u8>, value: Vec<u8>) -> Option<StateRecord> {
Self::from_raw_key_value_impl(key, value).unwrap_or(None)
}
pub fn from_raw_key_value_impl(
key: Vec<u8>,
value: Vec<u8>,
) -> Result<Option<StateRecord>, std::io::Error> {
Ok(match key[0] {
col::ACCOUNT => Some(StateRecord::Account {
account_id: parse_account_id_from_account_key(&key)?,
account: Account::try_from_slice(&value)?,
}),
col::CONTRACT_DATA => {
let account_id = parse_account_id_from_contract_data_key(&key)?;
let data_key = parse_data_key_from_contract_data_key(&key, &account_id)?;
Some(StateRecord::Data {
account_id,
data_key: data_key.to_vec().into(),
value: value.into(),
})
}
col::CONTRACT_CODE => Some(StateRecord::Contract {
account_id: parse_account_id_from_contract_code_key(&key)?,
code: value,
}),
col::ACCESS_KEY => {
let access_key = AccessKey::try_from_slice(&value)?;
let account_id = parse_account_id_from_access_key_key(&key)?;
let public_key = parse_public_key_from_access_key_key(&key, &account_id)?;
Some(StateRecord::AccessKey { account_id, public_key, access_key })
}
col::RECEIVED_DATA => {
let data = ReceivedData::try_from_slice(&value)?.data;
let account_id = parse_account_id_from_received_data_key(&key)?;
let data_id = parse_data_id_from_received_data_key(&key, &account_id)?;
Some(StateRecord::ReceivedData { account_id, data_id, data })
}
col::POSTPONED_RECEIPT_ID => None,
col::PENDING_DATA_COUNT => None,
col::POSTPONED_RECEIPT => {
let receipt = Receipt::try_from_slice(&value)?;
Some(StateRecord::PostponedReceipt(Box::new(receipt)))
}
col::DELAYED_RECEIPT_OR_INDICES
if key.len() == TrieKey::DelayedReceiptIndices.len() =>
{
None
}
col::DELAYED_RECEIPT_OR_INDICES => {
let receipt = Receipt::try_from_slice(&value)?;
Some(StateRecord::DelayedReceipt(Box::new(receipt)))
}
_ => {
println!("key[0]: {} is unreachable", key[0]);
None
}
})
}
pub fn get_type_string(&self) -> String {
match self {
StateRecord::Account { .. } => "Account",
StateRecord::Data { .. } => "Data",
StateRecord::Contract { .. } => "Contract",
StateRecord::AccessKey { .. } => "AccessKey",
StateRecord::PostponedReceipt { .. } => "PostponedReceipt",
StateRecord::ReceivedData { .. } => "ReceivedData",
StateRecord::DelayedReceipt { .. } => "DelayedReceipt",
}
.to_string()
}
}
impl Display for StateRecord {
fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), std::fmt::Error> {
match self {
StateRecord::Account { account_id, account } => {
write!(f, "Account {:?}: {:?}", account_id, account)
}
StateRecord::Data { account_id, data_key, value } => write!(
f,
"Storage {:?},{:?}: {:?}",
account_id,
to_printable(data_key.as_ref()),
to_printable(value.as_ref())
),
StateRecord::Contract { account_id, code: _ } => {
write!(f, "Code for {:?}: ...", account_id)
}
StateRecord::AccessKey { account_id, public_key, access_key } => {
write!(f, "Access key {:?},{:?}: {:?}", account_id, public_key, access_key)
}
StateRecord::ReceivedData { account_id, data_id, data } => write!(
f,
"Received data {:?},{:?}: {:?}",
account_id,
data_id,
data.as_ref().map(|v| to_printable(v))
),
StateRecord::PostponedReceipt(receipt) => write!(f, "Postponed receipt {:?}", receipt),
StateRecord::DelayedReceipt(receipt) => write!(f, "Delayed receipt {:?}", receipt),
}
}
}
fn to_printable(blob: &[u8]) -> String {
if blob.len() > 60 {
format!("{} bytes, hash: {}", blob.len(), hash(blob))
} else {
let ugly = blob.iter().any(|&x| x < b' ');
if ugly {
return format!("0x{}", hex::encode(blob));
}
match String::from_utf8(blob.to_vec()) {
Ok(v) => v,
Err(_e) => format!("0x{}", hex::encode(blob)),
}
}
}
pub fn state_record_to_account_id(state_record: &StateRecord) -> &AccountId {
match state_record {
StateRecord::Account { account_id, .. }
| StateRecord::AccessKey { account_id, .. }
| StateRecord::Contract { account_id, .. }
| StateRecord::ReceivedData { account_id, .. }
| StateRecord::Data { account_id, .. } => account_id,
StateRecord::PostponedReceipt(receipt) | StateRecord::DelayedReceipt(receipt) => {
&receipt.receiver_id
}
}
}
pub fn is_contract_code_key(key: &[u8]) -> bool {
debug_assert!(!key.is_empty());
key[0] == col::CONTRACT_CODE
}