floria 0.0.5

Floria data system for cloud orchestration
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 super::{
    super::super::{errors::*, plugins, store::*},
    call::*,
    expression::*,
};

use {kutil::std::error::*, std::collections::*};

impl Expression {
    /// Evaluate the expression.
    ///
    /// Eager calls will be dispatched here.
    pub fn evaluate<StoreT, ErrorReceiverT>(
        self,
        call_site: &plugins::CallSite,
        library: &mut plugins::Library<StoreT>,
        errors: &mut ErrorReceiverT,
    ) -> Result<Option<Expression>, FloriaError>
    where
        StoreT: Clone + Send + Store,
        ErrorReceiverT: ErrorReceiver<FloriaError>,
    {
        match self {
            Self::List(list) => {
                let mut expressions = Vec::with_capacity(list.len());
                for item in list {
                    expressions.push(item.evaluate(call_site, library, errors)?.unwrap_or_default());
                }
                Ok(Some(expressions.into()))
            }

            Self::Map(map) => {
                let mut expressions = BTreeMap::default();
                for (key, value) in map {
                    if let Some(key) = key.evaluate(call_site, library, errors)? {
                        expressions.insert(key, value.evaluate(call_site, library, errors)?.unwrap_or_default());
                    }
                }
                Ok(Some(expressions.into()))
            }

            Self::Call(call) => {
                if matches!(call.kind, CallKind::Eager) {
                    call.dispatch(call_site, library, errors)
                } else {
                    Ok(Some(Self::Call(call)))
                }
            }

            _ => Ok(Some(self)),
        }
    }
}