use core::{borrow::Borrow, marker::PhantomData};
use super::StorageMapper;
use crate::{
abi::{TypeAbi, TypeDescriptionContainer, TypeName},
api::StorageMapperApi,
storage::{storage_clear, storage_get, storage_get_len, storage_set, StorageKey},
types::ManagedType,
};
use dharitri_codec::{
multi_types::PlaceholderOutput, CodecFrom, CodecFromSelf, DecodeErrorHandler,
EncodeErrorHandler, TopDecode, TopDecodeInput, TopEncode, TopEncodeMulti, TopEncodeMultiOutput,
TopEncodeOutput,
};
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<BT>(&self, value: BT)
where
BT: Borrow<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> TopEncodeMulti for SingleValueMapper<SA, T>
where
SA: StorageMapperApi,
T: TopEncode + TopDecode,
{
fn multi_encode_or_handle_err<O, H>(&self, output: &mut O, h: H) -> Result<(), H::HandledErr>
where
O: TopEncodeMultiOutput,
H: EncodeErrorHandler,
{
output.push_single_value(&self.get(), h)
}
}
pub struct SingleValue<T: TopDecode>(T);
impl<T: TopEncode + TopDecode> TopEncode for SingleValue<T> {
fn top_encode_or_handle_err<O, H>(&self, output: O, h: H) -> Result<(), H::HandledErr>
where
O: TopEncodeOutput,
H: EncodeErrorHandler,
{
self.0.top_encode_or_handle_err(output, h)
}
}
impl<T: TopDecode> TopDecode for SingleValue<T> {
fn top_decode_or_handle_err<I, H>(input: I, h: H) -> Result<Self, H::HandledErr>
where
I: TopDecodeInput,
H: DecodeErrorHandler,
{
Ok(SingleValue(T::top_decode_or_handle_err(input, h)?))
}
}
impl<T: TopDecode> From<T> for SingleValue<T> {
fn from(value: T) -> Self {
SingleValue(value)
}
}
impl<T: TopDecode> SingleValue<T> {
#[inline]
pub fn into(self) -> T {
self.0
}
}
impl<SA, T> !CodecFromSelf for SingleValueMapper<SA, T>
where
SA: StorageMapperApi,
T: TopEncode + TopDecode,
{
}
impl<SA, T, R> CodecFrom<SingleValueMapper<SA, T>> for SingleValue<R>
where
SA: StorageMapperApi,
T: TopEncode + TopDecode,
R: TopDecode + CodecFrom<T>,
{
}
impl<SA, T> CodecFrom<SingleValueMapper<SA, T>> for PlaceholderOutput
where
SA: StorageMapperApi,
T: TopEncode + TopDecode,
{
}
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)
}
}