Function initialize

src/apps/server/src/bootstrap.rs:33–233

Initialize all core services and return the shared server state. The optional `workspace` path, when provided, is opened automatically.

(workspace: Option<String>)

///
/// The optional `workspace` path, when provided, is opened automatically.
pub async fn initialize(workspace: Option<String>) -> anyhow::Result<Arc<ServerAppState>> {
    log::info!("Initializing BitFun server core services");

    // 1. Global config
    config::initialize_global_config().await?;
    let config_service = config::get_global_config_service().await?;

    // Initialize the global I18nService so server-mode bot/remote-connect
    // consumers observe the same runtime locale lifecycle as Desktop.
    if let Err(e) =
        bitfun_core::service::i18n::initialize_global_i18n_service(Some(config_service.clone()))
            .await
    {
        log::warn!(
            "Failed to initialize global I18nService in server mode: {}",
            e
        );
    }

    // 2. AI client factory
    AIClientFactory::initialize_global().await?;
    let ai_client_factory = AIClientFactory::get_global().await?;

    // 3. Agentic system
    let path_manager = try_get_path_manager_arc()?;

    let event_queue = Arc::new(events::EventQueue::new(Default::default()));
    let event_router = Arc::new(events::EventRouter::new());

    let persistence_manager = Arc::new(persistence::PersistenceManager::new(path_manager.clone())?);

    let context_store = Arc::new(session::SessionContextStore::new());
    let context_compressor = Arc::new(session::ContextCompressor::new(Default::default()));

    let session_manager = Arc::new(session::SessionManager::new(
        context_store,
        persistence_manager,
        Default::default(),
    ));

    let tool_registry = tools::registry::get_global_tool_registry();
    let tool_state_manager = Arc::new(tools::pipeline::ToolStateManager::new(event_queue.clone()));

    let tool_pipeline = Arc::new(tools::pipeline::ToolPipeline::new(
        tool_registry.clone(),
        tool_state_manager,
        None,
    ));

    let stream_processor = Arc::new(execution::StreamProcessor::new(event_queue.clone()));
    let round_executor = Arc::new(execution::RoundExecutor::new(
        stream_processor,
        event_queue.clone(),
        tool_pipeline.clone(),
    ));

    let execution_engine = Arc::new(execution::ExecutionEngine::new(
        round_executor,