bpm_engine_storage/
history.rs

1//! Execution history for Trace UI: append events, list by instance with optional filters.
2
3use async_trait::async_trait;
4use serde::{Deserialize, Serialize};
5
6#[derive(Debug, Clone, Serialize, Deserialize)]
7pub struct HistoryEvent {
8    pub id: String,
9    pub instance_id: String,
10    pub event_type: String,
11    pub payload: serde_json::Value,
12    pub occurred_at: String,
13}
14
15#[async_trait]
16pub trait HistoryRepo: Send + Sync {
17    /// Append one event (called when engine applies an event).
18    async fn append(
19        &self,
20        instance_id: &str,
21        event_type: &str,
22        payload: &serde_json::Value,
23        occurred_at: &str,
24    ) -> anyhow::Result<String>;
25
26    /// List events for an instance, optionally filtered by token_id (from payload) or event_type.
27    /// Returns events sorted by occurred_at ascending.
28    async fn list_by_instance(
29        &self,
30        instance_id: &str,
31        token_id_filter: Option<&str>,
32        event_type_filter: Option<&str>,
33    ) -> anyhow::Result<Vec<HistoryEvent>>;
34}
bpm_engine_storage/history.rs

bpm_engine_storage/
history.rs
