bamboo-server 2026.7.10

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

use bytes::Bytes;

use bamboo_llm::types::LLMChunk;

use super::super::super::helpers::convert_chunk_to_openai;

pub(super) fn openai_chunk_bytes(chunk: LLMChunk, model: &str) -> Option<Bytes> {
    convert_chunk_to_openai(chunk, model)
        .map(|openai_chunk| serde_json::to_string(&openai_chunk).unwrap_or_default())
        .map(Bytes::from)
}

pub(super) fn done_marker_bytes() -> Bytes {
    Bytes::from_static(b"[DONE]")
}

/// Raw payload for an OpenAI-style streaming error frame, emitted before
/// `[DONE]` when the upstream stream errors mid-response. Without it a client
/// sees a clean `[DONE]` and mistakes a **truncated** response for a complete
/// one. Wrapped as `data: {…}\n\n` downstream like every other frame.
pub(super) fn error_chunk_bytes(message: &str) -> Bytes {
    let payload = serde_json::json!({
        "error": { "message": message, "type": "api_error" }
    });
    Bytes::from(serde_json::to_string(&payload).unwrap_or_default())
}

pub(super) fn wrap_sse_data(bytes: Bytes) -> Bytes {
    let data = format!("data: {}\n\n", String::from_utf8_lossy(&bytes));
    Bytes::from(data)
}