dsntk-workspace 0.0.2

DSNTK | Workspace
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

//! # Container for decision model evaluators

use crate::builder::WorkspaceBuilder;
use crate::errors::*;
use dsntk_common::{ColorPalette, Result};
use dsntk_feel::context::FeelContext;
use dsntk_feel::values::Value;
use dsntk_model_evaluator::ModelEvaluator;
use std::collections::HashMap;
use std::path::Path;
use std::sync::Arc;

/// Container for decision model evaluators.
pub struct Workspaces {
  /// Map: invocable path -> (workspace name, model namespace, model name, invocable name)
  pub(crate) invocables: HashMap<String, (String, String, String, String)>,
  /// Map: workspace name -> model evaluator
  pub(crate) evaluators: HashMap<String, Arc<ModelEvaluator>>,
}

impl Workspaces {
  /// Creates a new [Workspaces] and loads decision models from specified directory.
  pub fn new(dir: &Path, colors: ColorPalette, verbose: bool) -> Self {
    let mut builder = WorkspaceBuilder::new(colors, verbose);
    builder.load_decision_models(dir);
    Self {
      invocables: builder.invocables,
      evaluators: builder.evaluators,
    }
  }

  /// Evaluates invocable identified by invocable path.
  pub fn evaluate(&self, invocable_path: &str, input_data: &FeelContext) -> Result<Value> {
    if let Some((workspace_name, model_namespace, model_name, invocable_name)) = self.invocables.get(invocable_path) {
      if let Some(evaluator) = self.evaluators.get(workspace_name) {
        return Ok(evaluator.evaluate_invocable(model_namespace, model_name, invocable_name, input_data));
      }
    }
    Err(err_invocable_not_found(invocable_path))
  }
}