bamboo-agent 2026.4.12

A fully self-contained AI agent backend framework with built-in web services, multi-LLM provider support, and comprehensive tool execution
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
96
97
98
99
100
101
102
103
104
105

use actix_web::web;

use crate::agent::core::Session;
use crate::server::app_state::AppState;

fn should_prefer_storage(memory_session: &Session, storage_session: &Session) -> bool {
    if memory_session.pending_question.is_none() && storage_session.pending_question.is_some() {
        return true;
    }

    storage_session.updated_at > memory_session.updated_at
}

pub(super) async fn load_session_from_memory_or_storage(
    state: &web::Data<AppState>,
    session_id: &str,
) -> Option<Session> {
    let memory_session = {
        let sessions = state.sessions.read().await;
        sessions.get(session_id).cloned()
    };

    let storage_session = match state.storage.load_session(session_id).await {
        Ok(session) => session,
        Err(_) => None,
    };

    match (memory_session, storage_session) {
        (Some(memory_session), Some(storage_session)) => {
            let chosen = if should_prefer_storage(&memory_session, &storage_session) {
                storage_session
            } else {
                memory_session
            };

            let mut sessions = state.sessions.write().await;
            sessions.insert(session_id.to_string(), chosen.clone());
            Some(chosen)
        }
        (Some(memory_session), None) => Some(memory_session),
        (None, Some(storage_session)) => {
            let mut sessions = state.sessions.write().await;
            sessions.insert(session_id.to_string(), storage_session.clone());
            Some(storage_session)
        }
        (None, None) => None,
    }
}

#[cfg(test)]
mod tests {
    use super::*;
    use crate::server::app_state::AppState;

    #[tokio::test]
    async fn prefers_storage_when_memory_lacks_pending_question() {
        let temp_dir = tempfile::tempdir().expect("temp dir");
        let state = AppState::new(temp_dir.path().to_path_buf())
            .await
            .expect("app state should initialize");
        let state = web::Data::new(state);

        let session_id = "session-stale-memory";
        let memory_session = Session::new(session_id, "test-model");
        let mut storage_session = memory_session.clone();
        storage_session.set_pending_question(
            "tool-call-1".to_string(),
            "Need confirmation?".to_string(),
            vec!["OK".to_string()],
            true,
        );

        {
            let mut sessions = state.sessions.write().await;
            sessions.insert(session_id.to_string(), memory_session);
        }
        state
            .storage
            .save_session(&storage_session)
            .await
            .expect("storage save should succeed");

        let loaded = load_session_from_memory_or_storage(&state, session_id)
            .await
            .expect("session should load");

        assert!(loaded.pending_question.is_some());
        assert_eq!(
            loaded
                .pending_question
                .as_ref()
                .map(|pending| pending.tool_call_id.as_str()),
            Some("tool-call-1")
        );

        let cached = {
            let sessions = state.sessions.read().await;
            sessions
                .get(session_id)
                .cloned()
                .expect("cache should be warmed")
        };
        assert!(cached.pending_question.is_some());
    }
}