use core::{borrow::Borrow, marker::PhantomData};
use super::StorageMapper;
use crate::{
abi::{TypeAbi, TypeDescriptionContainer, TypeName},
api::{EndpointFinishApi, ManagedTypeApi, StorageMapperApi},
io::EndpointResult,
storage::{storage_clear, storage_get, storage_get_len, storage_set, StorageKey},
types::ManagedType,
};
use dharitri_codec::{TopDecode, TopEncode};
pub struct SingleValueMapper<SA, T>
where
SA: StorageMapperApi,
T: TopEncode + TopDecode + 'static,
{
key: StorageKey<SA>,
_phantom_api: PhantomData<SA>,
_phantom_item: PhantomData<T>,
}
impl<SA, T> StorageMapper<SA> for SingleValueMapper<SA, T>
where
SA: StorageMapperApi,
T: TopEncode + TopDecode,
{
#[inline]
fn new(base_key: StorageKey<SA>) -> Self {
SingleValueMapper {
key: base_key,
_phantom_api: PhantomData,
_phantom_item: PhantomData,
}
}
}
impl<SA, T> SingleValueMapper<SA, T>
where
SA: StorageMapperApi,
T: TopEncode + TopDecode,
{
pub fn get(&self) -> T {
storage_get(self.key.as_ref())
}
pub fn is_empty(&self) -> bool {
self.raw_byte_length() == 0
}
#[inline]
pub fn set<BT>(&self, new_value: BT)
where
BT: Borrow<T>,
{
storage_set(self.key.as_ref(), new_value.borrow());
}
pub fn set_if_empty(&self, value: &T) {
if self.is_empty() {
self.set(value);
}
}
pub fn clear(&self) {
storage_clear(self.key.as_ref());
}
pub fn update<R, F: FnOnce(&mut T) -> R>(&self, f: F) -> R {
let mut value = self.get();
let result = f(&mut value);
self.set(value);
result
}
pub fn raw_byte_length(&self) -> usize {
storage_get_len(self.key.as_ref())
}
}
impl<SA, T> EndpointResult for SingleValueMapper<SA, T>
where
SA: StorageMapperApi,
T: TopEncode + TopDecode + EndpointResult,
{
type DecodeAs = T::DecodeAs;
fn finish<FA>(&self)
where
FA: ManagedTypeApi + EndpointFinishApi,
{
self.get().finish::<FA>();
}
}
impl<SA, T> TypeAbi for SingleValueMapper<SA, T>
where
SA: StorageMapperApi,
T: TopEncode + TopDecode + TypeAbi,
{
fn type_name() -> TypeName {
T::type_name()
}
fn provide_type_descriptions<TDC: TypeDescriptionContainer>(accumulator: &mut TDC) {
T::provide_type_descriptions(accumulator)
}
}