Function serve_resolved_project

src/serve.rs:458–485

Serves a startup-resolved project: proxy to the daemon when one owns the socket, otherwise run the in-process MCP engine.

(
    cg: TraceDecay,
    original_cwd: Option<std::path::PathBuf>,
    timings: bool,
    peeked_line: Option<String>,
    allow_initialize_root_routing: bool,
)

/// Serves a startup-resolved project: proxy to the daemon when one owns the
/// socket, otherwise run the in-process MCP engine.
async fn serve_resolved_project(
    cg: TraceDecay,
    original_cwd: Option<std::path::PathBuf>,
    timings: bool,
    peeked_line: Option<String>,
    allow_initialize_root_routing: bool,
) -> Result<()> {
    let scope_prefix = serve_scope_prefix(original_cwd.as_deref(), cg.project_root());
    let mut handshake = crate::daemon::DaemonHandshake::for_current_client(
        Some(cg.project_root().to_path_buf()),
        scope_prefix,
        timings,
        false,
    )?;
    handshake.allow_initialize_root_routing = allow_initialize_root_routing;
    let socket_path = crate::daemon::default_socket_path()?;
    if crate::daemon::should_proxy_serve_to_daemon(&socket_path).await {
        crate::daemon::proxy_stdio_to_daemon(&socket_path, &handshake, peeked_line).await
    } else {
        let server = crate::mcp::McpServer::new(cg, handshake.scope_prefix.clone()).await;
        server.set_initialize_root_routing_enabled(allow_initialize_root_routing);
        let mut transport = ReplayTransport::new(StdioTransport::new());
        if let Some(line) = peeked_line {
            transport.push_replay(line);
        }
        Box::pin(server.run(&mut transport)).await
    }
}

/// The scope prefix for a serve session: the relative path from the project
/// root to the directory serve was launched from, when the latter is inside