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

//! ProcessCompletedHandler: ProcessCompleted -> mark instance completed, persist (design: handler.md).

use crate::engine::events::EngineEvent;
use crate::engine::handler::{EngineContext, EventHandler};

pub struct ProcessCompletedHandler;

impl EventHandler for ProcessCompletedHandler {
    fn handle(&self, event: &EngineEvent, ctx: &mut EngineContext) -> Vec<EngineEvent> {
        let EngineEvent::ProcessCompleted(p) = event else {
            return vec![];
        };
        let instance_id = &p.instance_id;
        if let Some(process_repo) = ctx.process_repo.as_ref() {
            if let Some(mut instance) = process_repo.load(instance_id) {
                instance.state = crate::model::InstanceState::Completed;
                process_repo.save(&instance);
            }
        }
        println!("✅ Process completed: {}", instance_id);
        vec![]
    }
}