3 Commits

Author SHA1 Message Date
6c16c89379 fix: add version + registry to wfe-server path deps for publishing 2026-04-05 12:01:02 +01:00
e515ffbe0c chore: bump version to 1.6.1, update CHANGELOG 2026-04-05 11:55:42 +01:00
978109d3fc feat(wfe-core): add step config API for attaching runtime JSON config
Adds StepBuilder::config() to attach arbitrary JSON configuration to
individual steps, readable at runtime via context.step.step_config.
Bumps version to 1.6.1.
2026-04-05 11:52:40 +01:00
7 changed files with 74 additions and 15 deletions

View File

@@ -2,6 +2,12 @@
All notable changes to this project will be documented in this file.
## [1.6.1] - 2026-04-05
### Added
- **wfe-core**: `StepBuilder::config()` for attaching arbitrary JSON configuration to individual steps, readable at runtime via `context.step.step_config`
## [1.6.0] - 2026-04-01
### Added

View File

@@ -3,7 +3,7 @@ members = ["wfe-core", "wfe-sqlite", "wfe-postgres", "wfe-opensearch", "wfe-valk
resolver = "2"
[workspace.package]
version = "1.6.0"
version = "1.6.1"
edition = "2024"
license = "MIT"
repository = "https://src.sunbeam.pt/studio/wfe"
@@ -38,15 +38,15 @@ redis = { version = "0.27", features = ["tokio-comp", "connection-manager"] }
opensearch = "2"
# Internal crates
wfe-core = { version = "1.6.0", path = "wfe-core", registry = "sunbeam" }
wfe-sqlite = { version = "1.6.0", path = "wfe-sqlite", registry = "sunbeam" }
wfe-postgres = { version = "1.6.0", path = "wfe-postgres", registry = "sunbeam" }
wfe-opensearch = { version = "1.6.0", path = "wfe-opensearch", registry = "sunbeam" }
wfe-valkey = { version = "1.6.0", path = "wfe-valkey", registry = "sunbeam" }
wfe-yaml = { version = "1.6.0", path = "wfe-yaml", registry = "sunbeam" }
wfe-buildkit = { version = "1.6.0", path = "wfe-buildkit", registry = "sunbeam" }
wfe-containerd = { version = "1.6.0", path = "wfe-containerd", registry = "sunbeam" }
wfe-rustlang = { version = "1.6.0", path = "wfe-rustlang", registry = "sunbeam" }
wfe-core = { version = "1.6.1", path = "wfe-core", registry = "sunbeam" }
wfe-sqlite = { version = "1.6.1", path = "wfe-sqlite", registry = "sunbeam" }
wfe-postgres = { version = "1.6.1", path = "wfe-postgres", registry = "sunbeam" }
wfe-opensearch = { version = "1.6.1", path = "wfe-opensearch", registry = "sunbeam" }
wfe-valkey = { version = "1.6.1", path = "wfe-valkey", registry = "sunbeam" }
wfe-yaml = { version = "1.6.1", path = "wfe-yaml", registry = "sunbeam" }
wfe-buildkit = { version = "1.6.1", path = "wfe-buildkit", registry = "sunbeam" }
wfe-containerd = { version = "1.6.1", path = "wfe-containerd", registry = "sunbeam" }
wfe-rustlang = { version = "1.6.1", path = "wfe-rustlang", registry = "sunbeam" }
# YAML
serde_yaml = "0.9"

View File

@@ -16,7 +16,7 @@ async-trait = { workspace = true }
tracing = { workspace = true }
thiserror = { workspace = true }
regex = { workspace = true }
wfe-buildkit-protos = { version = "1.6.0", path = "../wfe-buildkit-protos", registry = "sunbeam" }
wfe-buildkit-protos = { version = "1.6.1", path = "../wfe-buildkit-protos", registry = "sunbeam" }
tonic = "0.14"
tower = { version = "0.4", features = ["util"] }
hyper-util = { version = "0.1", features = ["tokio"] }

View File

@@ -9,7 +9,7 @@ description = "containerd container runner executor for WFE"
[dependencies]
wfe-core = { workspace = true }
wfe-containerd-protos = { version = "1.6.0", path = "../wfe-containerd-protos", registry = "sunbeam" }
wfe-containerd-protos = { version = "1.6.1", path = "../wfe-containerd-protos", registry = "sunbeam" }
tokio = { workspace = true }
serde = { workspace = true }
serde_json = { workspace = true }

View File

@@ -43,6 +43,14 @@ impl<D: WorkflowData> StepBuilder<D> {
self
}
/// Attach arbitrary JSON configuration to this step.
///
/// The step can read it at runtime via `context.step.step_config`.
pub fn config(mut self, config: serde_json::Value) -> Self {
self.builder.steps[self.step_id].step_config = Some(config);
self
}
/// Add a compensation step for saga rollback.
pub fn compensate_with<C: StepBody + Default + 'static>(mut self) -> Self {
let comp_id = self.builder.add_step(std::any::type_name::<C>());

View File

@@ -341,6 +341,51 @@ mod tests {
assert!(def.steps[1].step_type.contains("StepB"));
}
#[test]
fn config_sets_step_config() {
let cfg = serde_json::json!({"namespace": "ory", "timeout": 30});
let def = WorkflowBuilder::<TestData>::new()
.start_with::<StepA>()
.config(cfg.clone())
.end_workflow()
.build("test", 1);
assert_eq!(def.steps[0].step_config, Some(cfg));
}
#[test]
fn config_chains_with_name() {
let cfg = serde_json::json!({"namespace": "data"});
let def = WorkflowBuilder::<TestData>::new()
.start_with::<StepA>()
.name("apply-data")
.config(cfg.clone())
.then::<StepB>()
.end_workflow()
.build("test", 1);
assert_eq!(def.steps[0].name, Some("apply-data".into()));
assert_eq!(def.steps[0].step_config, Some(cfg));
assert_eq!(def.steps[0].outcomes[0].next_step, 1);
}
#[test]
fn config_on_multiple_steps_of_same_type() {
let cfg_a = serde_json::json!({"namespace": "ory"});
let cfg_b = serde_json::json!({"namespace": "data"});
let def = WorkflowBuilder::<TestData>::new()
.start_with::<StepA>()
.name("apply-ory")
.config(cfg_a.clone())
.then::<StepA>()
.name("apply-data")
.config(cfg_b.clone())
.end_workflow()
.build("test", 1);
assert_eq!(def.steps[0].step_config, Some(cfg_a));
assert_eq!(def.steps[1].step_config, Some(cfg_b));
// Both are StepA
assert_eq!(def.steps[0].step_type, def.steps[1].step_type);
}
#[test]
fn inline_step_via_then_fn() {
let def = WorkflowBuilder::<TestData>::new()

View File

@@ -14,9 +14,9 @@ path = "src/main.rs"
[dependencies]
# Internal
wfe-core = { workspace = true, features = ["test-support"] }
wfe = { path = "../wfe" }
wfe-yaml = { path = "../wfe-yaml", features = ["rustlang", "buildkit", "containerd"] }
wfe-server-protos = { path = "../wfe-server-protos" }
wfe = { version = "1.6.1", path = "../wfe", registry = "sunbeam" }
wfe-yaml = { version = "1.6.1", path = "../wfe-yaml", registry = "sunbeam", features = ["rustlang", "buildkit", "containerd"] }
wfe-server-protos = { version = "1.6.1", path = "../wfe-server-protos", registry = "sunbeam" }
wfe-sqlite = { workspace = true }
wfe-postgres = { workspace = true }
wfe-valkey = { workspace = true }