Workflows — `nestrs-workflows`

[dependencies]
nestrs = { version = "1.7.1", features = ["workflows"] } # pulls outbox + locks

use nestrs::workflows::{WorkflowsModule, WorkflowsOptions, WorkflowsService, WorkflowStatus};
use serde_json::json;
use std::sync::Arc;

#[injectable]
struct Orders {
    wf: Arc<WorkflowsService>,
}

impl Orders {
    async fn start_order(&self) -> String {
        let inst = self.wf.start("order", json!({ "id": 1 })).await;
        self.wf
            .complete_step(&inst.id, "charge", json!({ "ok": true }))
            .await
            .unwrap();
        self.wf.wait_for_approval(&inst.id).await.unwrap();
        // … later, after human action …
        self.wf.approve(&inst.id).await.unwrap();
        inst.id
    }

    async fn resume_after_restart(&self, id: &str) {
        let loaded = self.wf.get(id).await.expect("persisted");
        assert!(loaded.steps.contains_key("charge"));
        assert_eq!(loaded.status, WorkflowStatus::WaitingApproval);
    }
}

#[module(
    imports = [WorkflowsModule::register(WorkflowsOptions::default())],
    providers = [Orders],
)]
struct AppModule;