bpmn-engine 0.1.0

BPMN 2.0 execution engine for Rust with JSON and XML format support
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
62
63
64
65
66
67
68
69
70
71

//! Simple Process Example
//!
//! Example demonstrating basic BPMN process execution.

use bpmn_engine::{Engine, ProcessDefinition};
use std::collections::HashMap;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    // Create engine
    let engine = Engine::new();

    // Define a simple process: Start -> Task -> End
    let process_json = r#"
    {
        "id": "simple_process",
        "name": "Simple Process",
        "isExecutable": true,
        "elements": [
            {
                "type": "startEvent",
                "id": "start1",
                "name": "Start"
            },
            {
                "type": "serviceTask",
                "id": "task1",
                "name": "Process Task"
            },
            {
                "type": "endEvent",
                "id": "end1",
                "name": "End"
            },
            {
                "type": "sequenceFlow",
                "id": "flow1",
                "sourceRef": "start1",
                "targetRef": "task1"
            },
            {
                "type": "sequenceFlow",
                "id": "flow2",
                "sourceRef": "task1",
                "targetRef": "end1"
            }
        ],
        "variables": {}
    }
    "#;

    // Parse process definition
    let definition = ProcessDefinition::from_json(process_json)?;

    // Set initial variables
    let mut initial_variables = HashMap::new();
    initial_variables.insert("input".to_string(), serde_json::json!("test"));

    // Start process
    let instance = engine.start_process(definition, Some(initial_variables)).await?;

    println!("Process instance created: {}", instance.id());

    // Get instance state
    let context = instance.context().await;
    println!("Process state: {:?}", context.state);
    println!("Execution steps: {}", context.execution_history.len());

    Ok(())
}