daa_rules/
engine.rs

1//! Rules engine implementation
2
3use std::collections::HashMap;
4use std::sync::Arc;
5
6use tokio::sync::RwLock;
7
8use crate::{Rule, RuleResult, RulesError, Result};
9use crate::context::ExecutionContext;
10use crate::conditions::ConditionEvaluator;
11use crate::actions::ActionExecutor;
12
13/// Main rules engine
14pub struct RuleEngine {
15    /// Stored rules
16    rules: Arc<RwLock<HashMap<String, Rule>>>,
17    
18    /// Condition evaluator
19    condition_evaluator: ConditionEvaluator,
20    
21    /// Action executor
22    action_executor: ActionExecutor,
23}
24
25impl RuleEngine {
26    /// Create a new rules engine
27    pub fn new() -> Self {
28        Self {
29            rules: Arc::new(RwLock::new(HashMap::new())),
30            condition_evaluator: ConditionEvaluator::new(),
31            action_executor: ActionExecutor::new(),
32        }
33    }
34
35    /// Add a rule to the engine
36    pub async fn add_rule(&mut self, rule: Rule) -> Result<()> {
37        rule.is_valid()?;
38        self.rules.write().await.insert(rule.id.clone(), rule);
39        Ok(())
40    }
41
42    /// Execute a rule
43    pub async fn execute_rule(&self, rule: &Rule, context: &mut ExecutionContext) -> Result<RuleResult> {
44        if !rule.enabled {
45            return Ok(RuleResult::Skipped);
46        }
47
48        // Evaluate conditions
49        for condition in &rule.conditions {
50            if !self.condition_evaluator.evaluate_condition(condition, context).await? {
51                return Ok(RuleResult::Skipped);
52            }
53        }
54
55        // Execute actions
56        for action in &rule.actions {
57            self.action_executor.execute_action(action, context).await?;
58        }
59
60        Ok(RuleResult::Allow)
61    }
62
63    /// Evaluate a condition
64    pub async fn evaluate_condition(&self, condition: &crate::RuleCondition, context: &ExecutionContext) -> Result<bool> {
65        self.condition_evaluator.evaluate_condition(condition, context).await
66    }
67
68    /// Execute an action
69    pub async fn execute_action(&self, action: &crate::RuleAction, context: &mut ExecutionContext) -> Result<()> {
70        self.action_executor.execute_action(action, context).await
71    }
72}
73
74impl Default for RuleEngine {
75    fn default() -> Self {
76        Self::new()
77    }
78}
daa_rules/engine.rs

daa_rules/
engine.rs
