bamboo-server 2026.7.6

HTTP server and API layer for the Bamboo agent framework
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

//! HTTP-facing thin wrappers over the shared [`bamboo_server_tools::FabricDeployer`].
//!
//! All deploy/stop/test/logs orchestration (and the worker registry) lives in
//! the engine on `AppState`, shared with the `cluster` agent tool so both
//! surfaces manage the SAME workers. These wrappers only adapt the engine's
//! [`FabricError`] to the HTTP [`AppError`].

use bamboo_config::cluster_fabric::NodeState;
use bamboo_server_tools::FabricError;

use crate::app_state::AppState;
use crate::error::AppError;

fn map_err(e: FabricError) -> AppError {
    match e {
        FabricError::NotFound(m) => AppError::NotFound(m),
        FabricError::BadRequest(m) => AppError::BadRequest(m),
        FabricError::Internal(m) => AppError::InternalError(anyhow::anyhow!(m)),
    }
}

pub async fn deploy_node(
    app_state: &AppState,
    node_id: &str,
    echo: bool,
) -> Result<NodeState, AppError> {
    app_state
        .fabric_deployer
        .deploy(node_id, echo)
        .await
        .map_err(map_err)
}

pub async fn stop_node(app_state: &AppState, node_id: &str) -> Result<NodeState, AppError> {
    app_state.fabric_deployer.stop(node_id).await.map_err(map_err)
}

pub async fn test_node(app_state: &AppState, node_id: &str) -> Result<String, AppError> {
    app_state.fabric_deployer.test(node_id).await.map_err(map_err)
}

pub async fn read_logs(
    app_state: &AppState,
    node_id: &str,
    lines: usize,
) -> Result<String, AppError> {
    app_state
        .fabric_deployer
        .read_logs(node_id, lines)
        .await
        .map_err(map_err)
}