Struct TestWorkflowContext 

pub struct TestWorkflowContext {
    pub run_id: Uuid,
    pub workflow_name: String,
    pub started_at: DateTime<Utc>,
    pub auth: AuthContext,
    /* private fields */
}

Test context for workflow functions.

Fields

run_id: Uuid

workflow_name: String

started_at: DateTime<Utc>

auth: AuthContext

Implementations

impl TestWorkflowContext

pub fn builder(workflow_name: impl Into<String>) -> TestWorkflowContextBuilder

Create a new builder.

pub fn db(&self) -> Option<&PgPool>

Get the database pool (if available).

pub fn http(&self) -> &MockHttp

Get the mock HTTP client.

pub fn is_resumed(&self) -> bool

Check if this is a resumed execution.

pub fn workflow_time(&self) -> DateTime<Utc>

Get the deterministic workflow time.

pub fn tenant_id(&self) -> Option<Uuid>

Get the tenant ID.

pub fn is_step_completed(&self, name: &str) -> bool

Check if a step is completed.

pub fn is_step_started(&self, name: &str) -> bool

Check if a step has been started (exists in step states).

pub fn get_step_result<T: DeserializeOwned>(&self, name: &str) -> Option<T>

Get the result of a completed step.

pub async fn record_step_start(&self, name: &str) -> Result<()>

Record step start.

Mirrors WorkflowContext::record_step_start so workflow code that uses ? on the call compiles unchanged in tests. The in-memory test implementation can never fail, but the signature must match.

pub async fn record_step_complete( &self, name: &str, result: Value, ) -> Result<()>

Record step completion.

pub async fn record_step_failure( &self, name: &str, _error: impl Into<String>, ) -> Result<()>

Record step failure.

pub fn completed_step_names(&self) -> Vec<String>

Get completed step names in order.

pub async fn sleep(&self, _duration: Duration) -> Result<()>

Durable sleep (no-op in tests, but records the intent).

pub fn sleep_called(&self) -> bool

Check if sleep was called.

pub fn elapsed(&self) -> Duration

Get elapsed time since workflow started.

pub fn env_mock(&self) -> &MockEnvProvider

Get the mock env provider for verification.

pub fn save_state(&self, key: &str, value: impl Serialize) -> Result<()>

Save arbitrary state that persists across suspension points.

pub fn load_state<T: DeserializeOwned>(&self, key: &str) -> Result<Option<T>>

Load previously saved state. Returns None if the key doesn’t exist.

pub fn take_saved_state(&self) -> HashMap<String, Value>

Get a snapshot of all saved state.

Trait Implementations

impl EnvAccess for TestWorkflowContext

fn env_provider(&self) -> &dyn EnvProvider

fn env(&self, key: &str) -> Option<String>

fn env_or(&self, key: &str, default: &str) -> String

fn env_require(&self, key: &str) -> Result<String>

fn env_parse<T: FromStr>(&self, key: &str) -> Result<T>

where T::Err: Display,

fn env_parse_or<T: FromStr>(&self, key: &str, default: T) -> Result<T>

where T::Err: Display,

Returns the default when unset; errors only if the variable is set but unparseable.

fn env_contains(&self, key: &str) -> bool