use crate::state::{Freeze, MakeRx, MakeUnrx};
use serde::{de::DeserializeOwned, Deserialize, Serialize};
use std::ops::Deref;
#[cfg(any(client, doc))]
use sycamore::prelude::Scope;
use sycamore::reactive::{create_rc_signal, RcSignal};
#[derive(Serialize, Deserialize, Clone, Debug, PartialEq, Eq)]
pub struct RxVec<T>(Vec<T>)
where
T: Clone + 'static;
#[derive(Clone, Debug, PartialEq, Eq)]
pub struct RxVecRx<T>(RcSignal<Vec<RcSignal<T>>>)
where
T: Clone + Serialize + DeserializeOwned + 'static;
impl<T> MakeRx for RxVec<T>
where
T: Clone + Serialize + DeserializeOwned + 'static,
{
type Rx = RxVecRx<T>;
fn make_rx(self) -> Self::Rx {
RxVecRx(create_rc_signal(
self.0.into_iter().map(|x| create_rc_signal(x)).collect(),
))
}
}
impl<T> MakeUnrx for RxVecRx<T>
where
T: Clone + Serialize + DeserializeOwned + 'static,
{
type Unrx = RxVec<T>;
fn make_unrx(self) -> Self::Unrx {
let vec = (*self.0.get_untracked()).clone();
RxVec(
vec.into_iter()
.map(|x| (*x.get_untracked()).clone())
.collect(),
)
}
#[cfg(any(client, doc))]
fn compute_suspense(&self, _cx: Scope) {}
}
impl<T> Deref for RxVec<T>
where
T: Clone + Serialize + DeserializeOwned + 'static,
{
type Target = Vec<T>;
fn deref(&self) -> &Self::Target {
&self.0
}
}
impl<T> Deref for RxVecRx<T>
where
T: Clone + Serialize + DeserializeOwned + 'static,
{
type Target = RcSignal<Vec<RcSignal<T>>>;
fn deref(&self) -> &Self::Target {
&self.0
}
}
impl<T> From<Vec<T>> for RxVec<T>
where
T: Clone + Serialize + DeserializeOwned + 'static,
{
fn from(value: Vec<T>) -> Self {
Self(value)
}
}
impl<T> Freeze for RxVecRx<T>
where
T: Clone + Serialize + DeserializeOwned + 'static,
{
fn freeze(&self) -> String {
let unrx = Self(self.0.clone()).make_unrx();
serde_json::to_string(&unrx).unwrap()
}
}