dex-sdk 1.26.0

Strongly typed Rust SDK for Dex
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
57
58
59
60
61
62
63
64
65
66

// Portions of this file are derived from indeedeng/iwf-java-sdk.
// Those portions are licensed under the Apache License, Version 2.0.
// See LICENSES/Apache-2.0.txt and LEGACY_NOTICES.md.
//
// Modifications Copyright (c) 2026 Super Durable, Inc.
//
// Modifications are licensed under the Sustainable Use License 1.0.
// Third-Party Materials remain under the Apache License, Version 2.0.
// See LICENSE and LEGACY_NOTICES.md.

use std::time::{Duration, Instant};

use dex_sdk::{Client, Registry, SdkResult, StepExecutionId, WaitForStepCompletionOptions};

use crate::support::{DexDevTestEnvironment, flow_id};
use crate::timer_workflow::TimerWorkflow;

#[test]
#[ignore = "requires dexcli dev"]
fn test_basic_timer_workflow() {
    let environment = DexDevTestEnvironment::start(Registry::new().register(TimerWorkflow::new()));
    let workflow = TimerWorkflow::new();
    let flow_id = flow_id("basic-timer");
    let started_at = Instant::now();
    environment
        .client
        .start_flow(&workflow, &flow_id, 5)
        .expect("start timer Flow");
    environment
        .client
        .wait_for_step_completion(
            &flow_id,
            StepExecutionId::of(&workflow.start),
            WaitForStepCompletionOptions::new()
                .request_id(format!("{flow_id}-wait-timer"))
                .request_timeout(Duration::from_secs(10)),
        )
        .expect("wait for Timer Step");
    environment
        .client
        .wait_for_flow_with_timeout(&flow_id, Duration::from_secs(30))
        .expect("complete timer Flow");
    let elapsed = started_at.elapsed();
    assert!(
        (Duration::from_secs(4)..=Duration::from_secs(7)).contains(&elapsed),
        "actual duration: {elapsed:?}"
    );
}

#[expect(
    dead_code,
    reason = "Integration fixtures implement schema variants exercised by selected test targets."
)]
fn compile_timer_and_step_wait(client: &Client) -> SdkResult<()> {
    let workflow = TimerWorkflow::new();
    client.start_flow(&workflow, "timer", 1)?;
    client.wait_for_step_completion(
        "timer",
        StepExecutionId::of(&workflow.start),
        WaitForStepCompletionOptions::new()
            .request_id("wait-timer-step")
            .request_timeout(Duration::from_secs(10)),
    )?;
    let _ = client.wait_for_flow("timer")?;
    Ok(())
}