cala-ledger 0.15.7

An embeddable double sided accounting ledger built on PG/SQLx
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

pub mod definition;
pub mod error;

use cel_interpreter::{CelContext, CelMap, CelValue};
use es_entity::clock::ClockHandle;
use std::collections::HashMap;
use tracing::instrument;

pub use cala_types::param::*;

use error::*;

#[derive(Clone, Debug)]
pub struct Params {
    values: HashMap<String, CelValue>,
}

impl Params {
    pub fn new() -> Self {
        Self {
            values: HashMap::new(),
        }
    }

    pub fn insert(&mut self, k: impl Into<String>, v: impl Into<CelValue>) {
        self.values.insert(k.into(), v.into());
    }

    #[instrument(name = "params.into_context", skip(self, clock, defs), fields(params_count = self.values.len()), err(level = tracing::Level::WARN))]
    pub(crate) fn into_context(
        mut self,
        clock: &ClockHandle,
        defs: Option<&Vec<ParamDefinition>>,
    ) -> Result<CelContext, ParamError> {
        let mut ctx = crate::cel_context::initialize(clock.clone());
        if let Some(defs) = defs {
            let mut cel_map = CelMap::new();
            for d in defs {
                if let Some(v) = self.values.remove(&d.name) {
                    cel_map.insert(
                        d.name.clone(),
                        d.r#type
                            .coerce_value(v)
                            .map_err(ParamError::ParamTypeMismatch)?,
                    );
                } else if let Some(expr) = d.default.as_ref() {
                    cel_map.insert(d.name.clone(), expr.evaluate(&ctx)?);
                }
            }
            ctx.add_variable("params", cel_map);
        }

        Ok(ctx)
    }
}

impl Default for Params {
    fn default() -> Self {
        Self::new()
    }
}