1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107

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};

/// A reactive version of [`Vec`] that uses nested reactivity on its elements.
/// That means the type inside the vector must implement [`MakeRx`] (usually
/// derived with the `ReactiveState` macro). If you want to store simple types
/// inside the vector, without nested reactivity (e.g. `String`s), you should
/// use [`super::RxVec`].
#[derive(Serialize, Deserialize, Clone, Debug, PartialEq, Eq)]
pub struct RxVecNested<T>(Vec<T>)
where
    // We get the `Deserialize` derive macro working by tricking Serde by not
    // including the actual bounds here
    T: MakeRx + 'static,
    T::Rx: MakeUnrx<Unrx = T> + Freeze + Clone;
/// The reactive version of [`RxVecNested`].
#[derive(Clone, Debug, PartialEq, Eq)]
pub struct RxVecNestedRx<T>(RcSignal<Vec<T::Rx>>)
where
    T: MakeRx + Serialize + DeserializeOwned + 'static,
    T::Rx: MakeUnrx<Unrx = T> + Freeze + Clone;

// --- Reactivity implementations ---
impl<T> MakeRx for RxVecNested<T>
where
    T: MakeRx + Serialize + DeserializeOwned + 'static,
    T::Rx: MakeUnrx<Unrx = T> + Freeze + Clone,
{
    type Rx = RxVecNestedRx<T>;

    fn make_rx(self) -> Self::Rx {
        RxVecNestedRx(create_rc_signal(
            self.0.into_iter().map(|x| x.make_rx()).collect(),
        ))
    }
}
impl<T> MakeUnrx for RxVecNestedRx<T>
where
    T: MakeRx + Serialize + DeserializeOwned + 'static,
    T::Rx: MakeUnrx<Unrx = T> + Freeze + Clone,
{
    type Unrx = RxVecNested<T>;

    fn make_unrx(self) -> Self::Unrx {
        let vec = (*self.0.get_untracked()).clone();
        RxVecNested(vec.into_iter().map(|x| x.make_unrx()).collect())
    }

    #[cfg(any(client, doc))]
    fn compute_suspense(&self, cx: Scope) {
        // We do *not* want to recompute this every time the user changes the state!
        // (There lie infinite loops.)
        for elem in self.0.get_untracked().iter() {
            elem.compute_suspense(cx);
        }
    }
}
// --- Dereferencing ---
impl<T> Deref for RxVecNested<T>
where
    T: MakeRx + Serialize + DeserializeOwned + 'static,
    T::Rx: MakeUnrx<Unrx = T> + Freeze + Clone,
{
    type Target = Vec<T>;

    fn deref(&self) -> &Self::Target {
        &self.0
    }
}
impl<T> Deref for RxVecNestedRx<T>
where
    T: MakeRx + Serialize + DeserializeOwned + 'static,
    T::Rx: MakeUnrx<Unrx = T> + Freeze + Clone,
{
    type Target = RcSignal<Vec<T::Rx>>;

    fn deref(&self) -> &Self::Target {
        &self.0
    }
}
// --- Conversion implementation ---
impl<T> From<Vec<T>> for RxVecNested<T>
where
    T: MakeRx + Serialize + DeserializeOwned + 'static,
    T::Rx: MakeUnrx<Unrx = T> + Freeze + Clone,
{
    fn from(value: Vec<T>) -> Self {
        Self(value)
    }
}

// --- Freezing implementation ---
impl<T> Freeze for RxVecNestedRx<T>
where
    T: MakeRx + Serialize + DeserializeOwned + 'static,
    T::Rx: MakeUnrx<Unrx = T> + Freeze + Clone,
{
    fn freeze(&self) -> String {
        let unrx = Self(self.0.clone()).make_unrx();
        // This should never panic, because we're dealing with a vector
        serde_json::to_string(&unrx).unwrap()
    }
}