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
28
29
30
31

//! EventHandler trait and EngineContext (design: handler.md §5, §6).
//! Context holds async storage store references.

use async_trait::async_trait;
use bpm_engine_core::EngineEvent;
use bpm_engine_storage::{
    CompensationRecordRepo, ExternalTaskStore, HistoryRepo, OutboxRepo, ParallelJoinRepo,
    ProcessDefinitionStore, ProcessInstanceStore, TimerStore, TokenStore,
};
use std::sync::Arc;

/// Design: handler.md §5 — handle(event, ctx) -> Vec<EngineEvent>. Async for storage access.
#[async_trait]
pub trait EventHandler: Send + Sync {
    async fn handle(&self, event: &EngineEvent, ctx: &mut EngineContext) -> Vec<EngineEvent>;
}

/// Design: handler.md §6 — execution environment for handlers (stores from storage).
#[derive(Default)]
pub struct EngineContext {
    pub process_store: Option<Arc<dyn ProcessInstanceStore>>,
    pub token_store: Option<Arc<dyn TokenStore>>,
    pub process_def_store: Option<Arc<dyn ProcessDefinitionStore>>,
    pub parallel_join_repo: Option<Arc<dyn ParallelJoinRepo>>,
    pub timer_store: Option<Arc<dyn TimerStore>>,
    pub compensation_repo: Option<Arc<dyn CompensationRecordRepo>>,
    pub outbox_repo: Option<Arc<dyn OutboxRepo>>,
    pub external_task_store: Option<Arc<dyn ExternalTaskStore>>,
    pub history_repo: Option<Arc<dyn HistoryRepo>>,
    pub tenant_id: Option<String>,
}