bamboo-engine 2026.10.13

Execution engine and orchestration 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

use crate::runtime::config::AgentLoopConfig;
use bamboo_agent_core::Session;

#[cfg(windows)]
use super::super::super::image_fallback::ensure_session_image_ocr_cached;

/// Populate OCR-derived message state without persisting it independently.
///
/// Retrieval-window uses this on its staged Session so the cache and archive
/// boundary become durable in one fail-closed checkpoint.
pub(super) async fn cache_ocr_results_in_session(
    session: &mut Session,
    config: &AgentLoopConfig,
) -> bool {
    #[cfg(not(windows))]
    {
        let _ = (session, config);
        false
    }

    #[cfg(windows)]
    {
        if matches!(
            config.image_fallback,
            Some(ref cfg) if cfg.mode == crate::runtime::config::ImageFallbackMode::Ocr
        ) {
            ensure_session_image_ocr_cached(session, config.attachment_reader.as_deref()).await
        } else {
            false
        }
    }
}

pub(super) async fn maybe_cache_ocr_results(
    session: &mut Session,
    config: &AgentLoopConfig,
    session_id: &str,
) {
    // If OCR fallback is enabled, compute + cache OCR results into the persisted session
    // (but do NOT rewrite message parts). This keeps OCR available for the UI while
    // also allowing the LLM request to be built from text-only projections.
    let changed = cache_ocr_results_in_session(session, config).await;
    if changed {
        if let Some(ref persistence) = config.persistence {
            if let Err(error) = persistence.save_runtime_session(session).await {
                tracing::warn!(
                    "[{}] Failed to save session after OCR caching: {}",
                    session_id,
                    error
                );
            }
        }
    }
}