runkon-flow 0.6.1-alpha

Portable workflow execution engine — DSL, traits, and in-memory reference implementations
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

use crate::engine_error::EngineError;
use crate::status::WorkflowStepStatus;

/// Current approval state of a gate step.
#[derive(Debug, Clone)]
pub enum GateApprovalState {
    Pending,
    Approved {
        feedback: Option<String>,
        selections: Option<Vec<String>>,
    },
    Rejected {
        feedback: Option<String>,
    },
}

pub fn gate_approval_state_from_fields(
    approved_at: Option<&str>,
    status: WorkflowStepStatus,
    feedback: Option<String>,
    selections: Option<Vec<String>>,
) -> GateApprovalState {
    if approved_at.is_some() || status == WorkflowStepStatus::Completed {
        return GateApprovalState::Approved {
            feedback,
            selections,
        };
    }
    if status == WorkflowStepStatus::Failed {
        return GateApprovalState::Rejected { feedback };
    }
    GateApprovalState::Pending
}

/// Abstracts human-approval gate reads and writes for a persistence backend.
///
/// Extracted from `WorkflowPersistence` as a supertrait so the engine's gate
/// executor can call `state.persistence.get_gate_approval()` without any
/// structural changes to `ExecutionState` — any `dyn WorkflowPersistence` is
/// also a `dyn GateApprovalStore` through the supertrait bound.
pub trait GateApprovalStore: Send + Sync {
    fn get_gate_approval(&self, step_id: &str) -> Result<GateApprovalState, EngineError>;
    fn approve_gate(
        &self,
        step_id: &str,
        approved_by: &str,
        feedback: Option<&str>,
        selections: Option<&[String]>,
    ) -> Result<(), EngineError>;
    fn reject_gate(
        &self,
        step_id: &str,
        rejected_by: &str,
        feedback: Option<&str>,
    ) -> Result<(), EngineError>;
}