bpm-engine-runtime 0.2.0

BPM engine runtime: dispatcher, executor, timers, and event handling
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

//! ProcessCompletedHandler: ProcessCompleted -> mark instance completed, persist.

use async_trait::async_trait;
use bpm_engine_core::{EngineEvent, InstanceState};
use tracing::info;

use super::handler::{EngineContext, EventHandler};

pub struct ProcessCompletedHandler;

#[async_trait]
impl EventHandler for ProcessCompletedHandler {
    async 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_store) = ctx.process_store.as_ref() {
            if let Ok(Some(mut instance)) = process_store.load(instance_id).await {
                instance.state = InstanceState::Completed;
                let _ = process_store.save(&instance).await;
            }
        }
        info!(instance_id = %instance_id, "process completed");
        vec![]
    }
}