spacetimedb-schema 2.1.0

Schema library for SpacetimeDB
Documentation 
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
108
109
110
111
112
113

//! Helpers to allow deserializing data using a ReducerDef.

use crate::{
    def::{ProcedureDef, ReducerDef, ViewDef},
    identifier::Identifier,
};
use spacetimedb_lib::{
    sats::{self, de, impl_serialize, ser, ProductValue},
    ProductType,
};

/// Wrapper around a function def that allows deserializing to a [`ProductValue`] at the type of the def's parameter [`ProductType`].
///
/// Sensible instantiations for `Def` are [`ProcedureDef`], [`ReducerDef`] and [`ViewDef`].
pub struct ArgsSeed<'a, Def>(pub sats::WithTypespace<'a, Def>);

// Manual impls of traits rather than derives,
// 'cause derives are always constrained on all type parameters,
// even though `ArgsSeed<Def: ?Copy>: Copy` in our case.
impl<Def> Clone for ArgsSeed<'_, Def> {
    fn clone(&self) -> Self {
        *self
    }
}
impl<Def> Copy for ArgsSeed<'_, Def> {}

pub trait FunctionDef {
    fn params(&self) -> &ProductType;
    fn name(&self) -> &Identifier;
}

impl FunctionDef for ReducerDef {
    fn params(&self) -> &ProductType {
        &self.params
    }
    fn name(&self) -> &Identifier {
        self.name.as_identifier()
    }
}

impl FunctionDef for ProcedureDef {
    fn params(&self) -> &ProductType {
        &self.params
    }
    fn name(&self) -> &Identifier {
        &self.name
    }
}

impl FunctionDef for ViewDef {
    fn params(&self) -> &ProductType {
        &self.params
    }
    fn name(&self) -> &Identifier {
        &self.name
    }
}

impl<Def: FunctionDef> ArgsSeed<'_, Def> {
    pub fn name(&self) -> &Identifier {
        self.0.ty().name()
    }

    pub fn params(&self) -> &ProductType {
        self.0.ty().params()
    }
}

impl<'de, Def: FunctionDef> de::DeserializeSeed<'de> for ArgsSeed<'_, Def> {
    type Output = ProductValue;

    fn deserialize<D: de::Deserializer<'de>>(self, deserializer: D) -> Result<Self::Output, D::Error> {
        deserializer.deserialize_product(self)
    }
}

impl<'de, Def: FunctionDef> de::ProductVisitor<'de> for ArgsSeed<'_, Def> {
    type Output = ProductValue;

    fn product_name(&self) -> Option<&str> {
        Some(self.0.ty().name())
    }

    fn product_len(&self) -> usize {
        self.0.ty().params().elements.len()
    }

    fn product_kind(&self) -> de::ProductKind {
        de::ProductKind::ReducerArgs
    }

    fn visit_seq_product<A: de::SeqProductAccess<'de>>(self, tup: A) -> Result<Self::Output, A::Error> {
        de::visit_seq_product(self.0.map(|r| &*r.params().elements), &self, tup)
    }

    fn visit_named_product<A: de::NamedProductAccess<'de>>(self, tup: A) -> Result<Self::Output, A::Error> {
        de::visit_named_product(self.0.map(|r| &*r.params().elements), &self, tup)
    }
}

pub struct ReducerArgsWithSchema<'a> {
    value: &'a ProductValue,
    ty: sats::WithTypespace<'a, ReducerDef>,
}
impl_serialize!([] ReducerArgsWithSchema<'_>, (self, ser) => {
    use itertools::Itertools;
    use ser::SerializeSeqProduct;
    let mut seq = ser.serialize_seq_product(self.value.elements.len())?;
    for (value, elem) in self.value.elements.iter().zip_eq(&*self.ty.ty().params.elements) {
        seq.serialize_element(&self.ty.with(&elem.algebraic_type).with_value(value))?;
    }
    seq.end()
});