bamboo-server 2026.4.28

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
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95

use actix_web::{web, HttpResponse, Result};

use super::shared::{
    clear_derived_context_state, ensure_session_not_running, load_session_or_404,
    save_and_cache_session,
};
use super::types::RestoreSessionRequest;
use crate::app_state::AppState;

mod files;
mod models;
mod planning;

#[cfg(test)]
mod tests;

use files::apply_restore_plan;
use models::FileRestoreOutcome;
use planning::{build_restore_plan, find_target_message_index};

/// `POST /api/v1/sessions/{session_id}/restore`
///
/// Restore session history to `target_message_id`.
/// When `restore_files` is true, file changes after the target message are reverted
/// by replaying tool checkpoints in reverse order.
pub async fn restore_session_state(
    state: web::Data<AppState>,
    path: web::Path<String>,
    req: web::Json<RestoreSessionRequest>,
) -> Result<HttpResponse> {
    let session_id = path.into_inner();
    let target_message_id = req.target_message_id.trim().to_string();
    let restore_files = req.restore_files;

    if target_message_id.is_empty() {
        return Ok(HttpResponse::BadRequest().json(serde_json::json!({
            "error": "target_message_id is required",
            "session_id": session_id,
        })));
    }

    if let Some(response) = ensure_session_not_running(&state, &session_id).await {
        return Ok(response);
    }

    let Some(mut session) = load_session_or_404(&state, &session_id).await? else {
        return Ok(HttpResponse::NotFound().json(serde_json::json!({
            "error": "Session not found",
            "session_id": session_id
        })));
    };

    let Some(target_index) = find_target_message_index(&session.messages, &target_message_id)
    else {
        return Ok(HttpResponse::NotFound().json(serde_json::json!({
            "error": "Target message not found",
            "session_id": session_id,
            "target_message_id": target_message_id,
        })));
    };

    let messages_to_remove = session
        .messages
        .len()
        .saturating_sub(target_index.saturating_add(1));
    let messages_after_target = session.messages[target_index + 1..].to_vec();

    let restore_outcome = if restore_files {
        let plan = build_restore_plan(&messages_after_target);
        apply_restore_plan(plan).await
    } else {
        FileRestoreOutcome::default()
    };
    let FileRestoreOutcome {
        restored_files,
        deleted_files,
        file_errors,
    } = restore_outcome;

    session.messages.truncate(target_index + 1);
    clear_derived_context_state(&mut session);
    save_and_cache_session(&state, &session_id, session).await?;

    Ok(HttpResponse::Ok().json(serde_json::json!({
        "success": true,
        "session_id": session_id,
        "target_message_id": target_message_id,
        "restore_files": restore_files,
        "messages_removed": messages_to_remove,
        "message_count": target_index + 1,
        "restored_files": restored_files,
        "deleted_files": deleted_files,
        "file_errors": file_errors,
    })))
}