actrpc-core 0.1.0

Core types and traits for ActRPC.
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

use crate::{
    action::{ActionSpec, RequestedActionRecord},
    error::ActionCodecError,
};

/// A request from an interceptor for the orchestrator to consider executing.
#[derive(Debug, Clone, PartialEq)]
pub struct RequestedAction<A: ActionSpec> {
    pub params: A::Params,
}

impl<A> RequestedAction<A>
where
    A: ActionSpec,
{
    fn decode_from_record(value: &RequestedActionRecord) -> Result<Self, ActionCodecError> {
        let expected = A::action_kind();

        if value.kind != expected {
            return Err(ActionCodecError::KindMismatch {
                expected,
                actual: value.kind.clone(),
            });
        }

        let raw_params = value
            .params
            .clone()
            .ok_or_else(|| ActionCodecError::MissingParams {
                action: value.kind.clone(),
            })?;

        let params = serde_json::from_value(raw_params).map_err(|source| {
            ActionCodecError::InvalidParams {
                action: value.kind.clone(),
                source,
            }
        })?;

        Ok(Self { params })
    }
}

impl<A> TryFrom<RequestedActionRecord> for RequestedAction<A>
where
    A: ActionSpec,
{
    type Error = ActionCodecError;

    fn try_from(value: RequestedActionRecord) -> Result<Self, Self::Error> {
        Self::decode_from_record(&value)
    }
}