distributed 4.0.0

CQRS/ES framework for Rust using Plain Old Rust Structs — append-only events, replay, snapshots, outbox, service bus, and pluggable infrastructure
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

use super::*;

#[derive(Clone, Debug, PartialEq, Eq, Serialize, Deserialize)]
pub struct ClientExecutionLimits {
    pub max_depth: u64,
    pub max_complexity: u64,
    pub max_bool_width: u64,
    pub max_in_list: u64,
    pub complexity: ClientComplexityWeights,
}

impl Default for ClientExecutionLimits {
    fn default() -> Self {
        Self {
            max_depth: DEFAULT_MAX_DEPTH as u64,
            max_complexity: DEFAULT_MAX_COMPLEXITY as u64,
            max_bool_width: DEFAULT_MAX_BOOL_WIDTH,
            max_in_list: DEFAULT_MAX_IN_LIST,
            complexity: ClientComplexityWeights::current(),
        }
    }
}

impl ClientExecutionLimits {
    #[cfg(feature = "graphql")]
    pub(crate) fn from_runtime(
        max_depth: usize,
        max_complexity: usize,
        max_bool_width: usize,
        max_in_list: usize,
    ) -> Result<Self, ClientManifestError> {
        Ok(Self {
            max_depth: u64::try_from(max_depth).map_err(|_| {
                ClientManifestError("GraphQL max_depth exceeds the client manifest range".into())
            })?,
            max_complexity: u64::try_from(max_complexity).map_err(|_| {
                ClientManifestError(
                    "GraphQL max_complexity exceeds the client manifest range".into(),
                )
            })?,
            max_bool_width: u64::try_from(max_bool_width).map_err(|_| {
                ClientManifestError(
                    "GraphQL max_bool_width exceeds the client manifest range".into(),
                )
            })?,
            max_in_list: u64::try_from(max_in_list).map_err(|_| {
                ClientManifestError("GraphQL max_in_list exceeds the client manifest range".into())
            })?,
            complexity: ClientComplexityWeights::current(),
        })
    }
}

#[derive(Clone, Debug, PartialEq, Eq, Serialize, Deserialize)]
pub struct ClientComplexityWeights {
    pub version: u32,
    pub scalar: u64,
    pub belongs_to: u64,
    pub has_many: u64,
    pub m2m: u64,
    pub aggregate: u64,
    pub list_root: u64,
    pub by_pk: u64,
    pub list_fanout: u64,
}

impl ClientComplexityWeights {
    pub(super) fn current() -> Self {
        let weights = default_weights();
        Self {
            version: QUERY_COMPLEXITY_VERSION,
            scalar: weights.scalar as u64,
            belongs_to: weights.belongs_to as u64,
            has_many: weights.has_many as u64,
            m2m: weights.m2m as u64,
            aggregate: weights.aggregate as u64,
            list_root: weights.list_root as u64,
            by_pk: weights.by_pk as u64,
            list_fanout: weights.list_fanout as u64,
        }
    }
}