actrpc-orchestrator 0.1.0

Configuration and orchestration utilities 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

use actrpc_core::{
    DescribeValue,
    action::{ActionKind, RequestedActionRecord},
    interception::InterceptionPhase,
};
use serde::{Deserialize, Serialize};
use std::collections::HashSet;

#[derive(Debug, Clone, PartialEq, Serialize, Deserialize, DescribeValue)]
pub struct InterceptorPolicy {
    pub outbound: HashSet<ActionKind>,
    pub inbound: HashSet<ActionKind>,
}

impl InterceptorPolicy {
    fn allowed_for_phase(&self, phase: InterceptionPhase) -> &HashSet<ActionKind> {
        match phase {
            InterceptionPhase::Outbound => &self.outbound,
            InterceptionPhase::Inbound => &self.inbound,
        }
    }

    pub fn allows_all(&self, phase: InterceptionPhase, actions: &[RequestedActionRecord]) -> bool {
        let allowed = self.allowed_for_phase(phase);
        actions.iter().all(|action| allowed.contains(&action.kind))
    }

    pub fn conflicting_actions<'a>(
        &self,
        phase: InterceptionPhase,
        actions: &'a [RequestedActionRecord],
    ) -> Vec<&'a RequestedActionRecord> {
        let allowed = self.allowed_for_phase(phase);

        actions
            .iter()
            .filter(|action| !allowed.contains(&action.kind))
            .collect()
    }
}