bamboo-server 2026.5.2

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

use tokio_util::sync::CancellationToken;

use crate::app_state::{AgentRunner, AgentStatus, AppState};
use bamboo_agent_core::AgentEvent;

pub(in crate::handlers::agent::execute) enum RunnerReservation {
    Started(CancellationToken),
    AlreadyRunning,
}

pub(in crate::handlers::agent::execute) async fn reserve_runner(
    state: &AppState,
    session_id: &str,
    session_tx: &tokio::sync::broadcast::Sender<AgentEvent>,
) -> RunnerReservation {
    let mut runners = state.agent_runners.write().await;

    // Check if there's already a running runner for this session.
    if let Some(runner) = runners.get(session_id) {
        if matches!(runner.status, AgentStatus::Running) {
            tracing::debug!(
                "[{}] Runner already running, returning status: already_running",
                session_id
            );
            return RunnerReservation::AlreadyRunning;
        }
        tracing::debug!(
            "[{}] Existing runner with status {:?}, will restart",
            session_id,
            runner.status
        );
    }

    // Remove stale runner and insert new one atomically.
    runners.remove(session_id);

    let mut runner = AgentRunner::new();
    runner.status = AgentStatus::Running;
    runner.event_sender = session_tx.clone();
    let cancel_token = runner.cancel_token.clone();

    runners.insert(session_id.to_string(), runner);
    RunnerReservation::Started(cancel_token)
}