bpm-engine 0.1.0

Lightweight embeddable BPM runtime for long-running, stateful workflows with tokens, timers, Saga compensation, and crash recovery
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

//! In-memory ProcessDefinition store (design: Step 3).

use crate::model::ProcessDefinition;
use std::collections::HashMap;
use std::sync::RwLock;

use super::repo::ProcessDefinitionRepo;

/// In-memory store: register definitions by id, load by id.
pub struct ProcessDefStore {
    defs: RwLock<HashMap<String, ProcessDefinition>>,
}

impl ProcessDefStore {
    pub fn new() -> Self {
        ProcessDefStore {
            defs: RwLock::new(HashMap::new()),
        }
    }

    pub fn register(&self, def: ProcessDefinition) {
        self.defs
            .write()
            .unwrap()
            .insert(def.id.to_string(), def);
    }
}

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

impl ProcessDefinitionRepo for ProcessDefStore {
    fn load(&self, id: &str) -> Option<ProcessDefinition> {
        self.defs.read().unwrap().get(id).cloned()
    }
}