durable-actors 0.7.10

Standalone regional durable-actors control plane, host, and durability runtime
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

use anyhow::{Result, ensure};
use serde::Deserialize;

use super::{RequestOutcome, TRACE_CAPACITY};

#[derive(Clone, Deserialize)]
#[serde(rename_all = "camelCase", deny_unknown_fields)]
pub(crate) struct HistoryQuery {
    pub request_id: Option<String>,
    pub connection_id: Option<String>,
    pub actor_name: Option<String>,
    pub actor_id: Option<String>,
    pub outcome: Option<RequestOutcome>,
    pub from_ms: Option<u64>,
    pub to_ms: Option<u64>,
    #[serde(default = "page_size")]
    pub limit: usize,
    pub cursor: Option<String>,
}

impl Default for HistoryQuery {
    fn default() -> Self {
        Self {
            request_id: None,
            connection_id: None,
            actor_name: None,
            actor_id: None,
            outcome: None,
            from_ms: None,
            to_ms: None,
            limit: page_size(),
            cursor: None,
        }
    }
}

impl HistoryQuery {
    pub(crate) fn validate(&self) -> Result<()> {
        ensure!(
            self.request_id
                .iter()
                .chain(self.connection_id.iter())
                .all(|id| !id.is_empty() && id.len() <= 256),
            "invalid request or connection ID"
        );
        ensure!(
            (1..=TRACE_CAPACITY).contains(&self.limit),
            "limit must be between 1 and 500"
        );
        ensure!(
            self.cursor
                .as_ref()
                .is_none_or(|c| !c.is_empty() && c.len() <= 4096),
            "invalid history cursor"
        );
        ensure!(
            self.from_ms
                .into_iter()
                .chain(self.to_ms)
                .all(|ms| ms <= 9_007_199_254_740_991),
            "invalid timestamp"
        );
        ensure!(
            self.from_ms
                .zip(self.to_ms)
                .is_none_or(|(from, to)| from <= to),
            "fromMs must not exceed toMs"
        );
        crate::actor::ActorKey {
            project_id: "history".into(),
            actor_name: self.actor_name.clone().unwrap_or_else(|| "Actor".into()),
            actor_id: self.actor_id.clone().unwrap_or_else(|| "actor".into()),
        }
        .validate()
    }

    pub(super) fn filter_key(&self) -> Result<String> {
        Ok(serde_json::to_string(&(
            &self.request_id,
            &self.connection_id,
            &self.actor_name,
            &self.actor_id,
            self.outcome,
            self.from_ms,
            self.to_ms,
        ))?)
    }
}

fn page_size() -> usize {
    100
}