assay-workflow 0.3.0

Durable workflow engine with REST+SSE API on PostgreSQL 18 and SQLite backends. Embeddable library or standalone server (via assay-engine).
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

pub mod activities;
pub mod events;
pub mod namespaces;
pub mod openapi;
pub mod public;
pub mod queues;
pub mod schedules;
pub mod tasks;
pub mod workers;
pub mod workflow_tasks;
pub mod workflows;

use std::sync::Arc;

use axum::Router;

use crate::ctx::WorkflowCtx;
use crate::store::WorkflowStore;

/// Build the workflow HTTP API router.
///
/// Three tiers, all under `/api/v1/engine/workflow/*`:
///
/// 1. **Authenticated** — workflows, schedules, namespaces, activities,
///    tasks, workers, queues, events. Authentication + authorization
///    happens at the engine layer (via [`assay_auth::gate`] in
///    `assay_engine::server`); the workflow router itself carries no
///    gate. (The `workflow.api_keys` surface was retired in plan-15
///    slice 3 — auth tokens come from the auth module now.)
/// 2. **Public** — health, version. Always unauthenticated so
///    Kubernetes probes, load balancers, and third-party monitors can
///    reach them without a bearer token.
/// 3. **OpenAPI** — `openapi.json` + `docs` HTML. Always public.
///
/// The standalone `serve*` entry points were removed in plan-15
/// slice 2 — workflow now only runs inside `assay-engine`, which owns
/// the listener, the auth gate, and the surrounding state.
pub fn router<S: WorkflowStore>(state: Arc<WorkflowCtx<S>>) -> Router {
    let authed_api = Router::new()
        .nest("/api/v1/engine/workflow", api_v1_router::<S>())
        .nest("/api/v1/engine/workflow", events::router::<S>());

    let public_api = Router::new().nest("/api/v1/engine/workflow", public::router::<S>());

    let app = authed_api.merge(public_api).merge(openapi::router::<S>());

    app.with_state(state)
}

fn api_v1_router<S: WorkflowStore>() -> Router<Arc<WorkflowCtx<S>>> {
    Router::new()
        .merge(workflows::router::<S>())
        .merge(activities::router::<S>())
        .merge(workflow_tasks::router::<S>())
        .merge(tasks::router::<S>())
        .merge(schedules::router::<S>())
        .merge(workers::router::<S>())
        .merge(namespaces::router::<S>())
        .merge(queues::router::<S>())
}