vtcode-core 0.98.7

//! End-to-End MCP Integration Tests
//!
//! These tests verify that MCP integration works correctly with real MCP servers.
//! They test the complete flow from configuration loading to tool execution.

use hashbrown::HashMap;
use std::path::PathBuf;
use tempfile::TempDir;
use tokio::process::Command;
use vtcode_core::config::loader::VTCodeConfig;
use vtcode_core::config::mcp::{
    McpClientConfig, McpHttpServerConfig, McpProviderConfig, McpStdioServerConfig,
    McpTransportConfig,
};
use vtcode_core::mcp::McpClient;
use vtcode_core::tools::registry::ToolRegistry;

/// Check if the time MCP server is available for testing
async fn is_time_server_available() -> bool {
    match Command::new("uvx").arg("--help").output().await {
        Ok(_) => {
            // Try to check if mcp-server-time is available
            match Command::new("uvx")
                .arg("mcp-server-time")
                .arg("--help")
                .output()
                .await
            {
                Ok(output) => output.status.success(),
                Err(_) => false,
            }
        }
        Err(_) => false,
    }
}

async fn is_python_available() -> bool {
    match Command::new("python3").arg("--version").output().await {
        Ok(output) => output.status.success(),
        Err(_) => false,
    }
}

fn mock_mcp_server_path() -> PathBuf {
    PathBuf::from(env!("CARGO_MANIFEST_DIR"))
        .join("tests")
        .join("fixtures")
        .join("mock_mcp_server.py")
}

fn build_mock_mcp_config(script_path: &std::path::Path) -> McpClientConfig {
    let mut mcp_config = McpClientConfig {
        enabled: true,
        startup_timeout_seconds: Some(5),
        tool_timeout_seconds: Some(5),
        ..Default::default()
    };

    mcp_config.providers = vec![McpProviderConfig {
        name: "mock".to_string(),
        transport: McpTransportConfig::Stdio(McpStdioServerConfig {
            command: "python3".to_string(),
            args: vec![script_path.to_string_lossy().to_string()],
            working_directory: None,
        }),
        env: HashMap::new(),
        enabled: true,
        max_concurrent_requests: 1,
        startup_timeout_ms: Some(5_000),
    }];

    mcp_config
}

#[cfg(test)]
mod tests {
    use super::*;

    #[tokio::test]
    #[ignore] // This test requires the time MCP server to be installed
    async fn test_time_mcp_server_integration() {
        // Skip if time server is not available
        if !is_time_server_available().await {
            eprintln!("Time MCP server not available, skipping test");
            return;
        }

        // Create a temporary workspace
        let temp_dir = TempDir::new().unwrap();
        let workspace = temp_dir.path().to_path_buf();

        let time_provider = McpProviderConfig {
            name: "time".to_string(),
            transport: McpTransportConfig::Stdio(McpStdioServerConfig {
                command: "uvx".to_string(),
                args: vec!["mcp-server-time".to_string()],
                working_directory: Some(workspace.to_string_lossy().to_string()),
            }),
            env: HashMap::new(),
            enabled: true,
            max_concurrent_requests: 3,
            startup_timeout_ms: None,
        };

        // Create MCP configuration for time server
        let mcp_config = McpClientConfig {
            enabled: true,
            providers: vec![time_provider],
            ..Default::default()
        };

        // Create MCP client
        let mut mcp_client = McpClient::new(mcp_config);

        // Initialize the client
        assert!(mcp_client.initialize().await.is_ok());

        // Check that we can list tools
        let tools = mcp_client.list_tools().await.unwrap();
        assert!(!tools.is_empty(), "Time MCP server should provide tools");

        // Look for the get_current_time tool
        let time_tool = tools.iter().find(|tool| tool.name == "get_current_time");
        assert!(
            time_tool.is_some(),
            "get_current_time tool should be available"
        );

        // Execute the get_current_time tool
        let result = mcp_client
            .execute_tool("get_current_time", serde_json::json!({}))
            .await;
        assert!(
            result.is_ok(),
            "get_current_time tool should execute successfully"
        );

        let result_value = result.unwrap();
        assert!(
            result_value.get("time").is_some(),
            "Result should contain time field"
        );

        println!("MCP time server integration test passed!");
        println!(
            "Current time: {}",
            result_value["time"].as_str().unwrap_or("unknown")
        );
    }

    #[tokio::test]
    async fn test_mcp_configuration_loading() {
        let toml_content = r#"
[mcp]
enabled = true
max_concurrent_connections = 3
request_timeout_seconds = 45
retry_attempts = 2

[mcp.ui]
mode = "compact"
max_events = 25
show_provider_names = false

[[mcp.providers]]
name = "time"
enabled = true
command = "uvx"
args = ["mcp-server-time"]
max_concurrent_requests = 2
        "#;

        let config: VTCodeConfig = toml::from_str(toml_content).unwrap();

        assert!(config.mcp.enabled);
        assert_eq!(config.mcp.ui.mode.to_string(), "compact");
        assert_eq!(config.mcp.ui.max_events, 25);
        assert!(!config.mcp.ui.show_provider_names);
        assert_eq!(config.mcp.max_concurrent_connections, 3);
        assert_eq!(config.mcp.request_timeout_seconds, 45);
        assert_eq!(config.mcp.retry_attempts, 2);
        assert!(config.mcp.startup_timeout_seconds.is_none());
        assert!(config.mcp.tool_timeout_seconds.is_none());
        assert!(config.mcp.experimental_use_rmcp_client);
        assert_eq!(config.mcp.providers.len(), 1);

        let provider = &config.mcp.providers[0];
        assert_eq!(provider.name, "time");
        assert!(provider.enabled);
        assert_eq!(provider.max_concurrent_requests, 2);
    }

    #[tokio::test]
    async fn test_tool_registry_with_mcp_client() {
        let temp_dir = TempDir::new().unwrap();

        // Create tool registry without MCP client
        let mut registry = ToolRegistry::new(temp_dir.path().to_path_buf()).await;

        // Initially should not have MCP tools
        assert!(registry.mcp_client().is_none());

        // Create a mock MCP client config
        let mcp_config = McpClientConfig {
            enabled: true,
            ..Default::default()
        };

        let mcp_client = McpClient::new(mcp_config);

        // Add MCP client to registry
        registry = registry
            .with_mcp_client(std::sync::Arc::new(mcp_client))
            .await;

        // Should now have MCP client
        assert!(registry.mcp_client().is_some());
    }

    #[tokio::test]
    async fn test_mcp_disabled_by_default() {
        // Create MCP client with default config (disabled)
        let config = McpClientConfig::default();
        let mut client = McpClient::new(config);

        // Initialize should succeed but do nothing
        assert!(client.initialize().await.is_ok());

        // Should have no providers
        let status = client.get_status();
        assert_eq!(status.provider_count, 0);

        // List tools should return empty
        let tools = client.list_tools().await.unwrap();
        assert!(tools.is_empty());
    }

    #[tokio::test]
    async fn test_mcp_client_status() {
        let config = McpClientConfig::default();
        let client = McpClient::new(config);

        let status = client.get_status();
        assert!(!status.enabled);
        assert_eq!(status.provider_count, 0);
        assert_eq!(status.active_connections, 0);
        assert!(status.configured_providers.is_empty());
    }

    #[tokio::test]
    async fn test_multiple_providers_config() {
        let toml_content = r#"
[mcp]
enabled = true

[[mcp.providers]]
name = "time"
enabled = true
command = "uvx"
args = ["mcp-server-time"]
max_concurrent_requests = 1

[[mcp.providers]]
name = "context7"
enabled = true
command = "npx"
args = ["-y", "@upstash/context7-mcp@latest"]
max_concurrent_requests = 2

[[mcp.providers]]
name = "disabled_provider"
enabled = false
command = "echo"
args = ["disabled"]
max_concurrent_requests = 1
        "#;

        let config: VTCodeConfig = toml::from_str(toml_content).unwrap();

        assert!(config.mcp.enabled);
        assert_eq!(config.mcp.providers.len(), 3);

        // Check first provider (time)
        let time_provider = &config.mcp.providers[0];
        assert_eq!(time_provider.name, "time");
        assert!(time_provider.enabled);
        assert_eq!(time_provider.max_concurrent_requests, 1);

        // Check second provider (context7)
        let context7_provider = &config.mcp.providers[1];
        assert_eq!(context7_provider.name, "context7");
        assert!(context7_provider.enabled);
        assert_eq!(context7_provider.max_concurrent_requests, 2);

        // Check third provider (disabled)
        let disabled_provider = &config.mcp.providers[2];
        assert_eq!(disabled_provider.name, "disabled_provider");
        assert!(!disabled_provider.enabled);
    }

    #[tokio::test]
    async fn test_provider_environment_variables() {
        let mut env_vars = HashMap::new();
        env_vars.insert("API_KEY".to_string(), "secret_key".to_string());
        env_vars.insert("DEBUG".to_string(), "true".to_string());

        let provider_config = McpProviderConfig {
            name: "test_provider".to_string(),
            transport: McpTransportConfig::Stdio(McpStdioServerConfig {
                command: "test_command".to_string(),
                args: vec![],
                working_directory: None,
            }),
            env: env_vars,
            enabled: true,
            max_concurrent_requests: 1,
            startup_timeout_ms: None,
        };

        assert_eq!(provider_config.env.len(), 2);
        assert_eq!(
            provider_config.env.get("API_KEY"),
            Some(&"secret_key".to_string())
        );
        assert_eq!(provider_config.env.get("DEBUG"), Some(&"true".to_string()));
    }

    #[tokio::test]
    async fn test_mock_mcp_provider_lifecycle() {
        if !is_python_available().await {
            eprintln!("python3 not available, skipping mock MCP lifecycle test");
            return;
        }

        let script_path = mock_mcp_server_path();
        assert!(script_path.exists(), "mock MCP server script should exist");

        let mut mcp_config = McpClientConfig {
            enabled: true,
            startup_timeout_seconds: Some(5),
            tool_timeout_seconds: Some(5),
            ..Default::default()
        };

        mcp_config.providers = vec![McpProviderConfig {
            name: "mock".to_string(),
            transport: McpTransportConfig::Stdio(McpStdioServerConfig {
                command: "python3".to_string(),
                args: vec![script_path.to_string_lossy().to_string()],
                working_directory: None,
            }),
            env: HashMap::new(),
            enabled: true,
            max_concurrent_requests: 1,
            startup_timeout_ms: Some(5_000),
        }];

        let mut mcp_client = McpClient::new(mcp_config);
        assert!(mcp_client.initialize().await.is_ok());

        let status = mcp_client.get_status();
        assert!(status.enabled);
        assert_eq!(status.provider_count, 1);
        assert_eq!(status.active_connections, 1);
        assert_eq!(status.configured_providers.len(), 1);
        assert_eq!(status.configured_providers[0], "mock");

        let tools = mcp_client.list_tools().await.unwrap();
        assert_eq!(tools.len(), 1);
        assert_eq!(tools[0].name, "echo");
        assert_eq!(
            mcp_client.provider_for_tool("echo").as_deref(),
            Some("mock")
        );

        let result = mcp_client
            .execute_tool("echo", serde_json::json!({ "message": "hello" }))
            .await
            .unwrap();

        assert_eq!(
            result.get("provider").and_then(|v| v.as_str()),
            Some("mock")
        );
        assert_eq!(result.get("tool").and_then(|v| v.as_str()), Some("echo"));
        let content = result
            .get("content")
            .and_then(|v| v.as_array())
            .expect("tool result should contain content");
        let first_text = content
            .first()
            .and_then(|v| v.get("text"))
            .and_then(|v| v.as_str());
        assert_eq!(first_text, Some("echo:hello"));

        assert!(mcp_client.shutdown().await.is_ok());

        let shutdown_status = mcp_client.get_status();
        assert_eq!(shutdown_status.provider_count, 0);
        assert_eq!(shutdown_status.active_connections, 0);
        assert!(shutdown_status.configured_providers.is_empty());
        assert!(mcp_client.provider_for_tool("echo").is_none());
    }

    #[tokio::test]
    async fn test_http_provider_missing_api_key_env_is_not_initialized() {
        const MISSING_API_KEY_ENV: &str = "MCP_TEST_MISSING_API_KEY_9A3F65";
        assert!(std::env::var(MISSING_API_KEY_ENV).is_err());

        let mcp_config = McpClientConfig {
            enabled: true,
            experimental_use_rmcp_client: true,
            providers: vec![McpProviderConfig {
                name: "http-auth".to_string(),
                transport: McpTransportConfig::Http(McpHttpServerConfig {
                    endpoint: "https://example.invalid/mcp".to_string(),
                    api_key_env: Some(MISSING_API_KEY_ENV.to_string()),
                    oauth: None,
                    protocol_version: "2024-11-05".to_string(),
                    http_headers: HashMap::new(),
                    env_http_headers: HashMap::new(),
                }),
                env: HashMap::new(),
                enabled: true,
                max_concurrent_requests: 1,
                startup_timeout_ms: Some(1_000),
            }],
            ..Default::default()
        };

        let mut mcp_client = McpClient::new(mcp_config);
        assert!(mcp_client.initialize().await.is_ok());

        let status = mcp_client.get_status();
        assert_eq!(status.provider_count, 0);
        assert_eq!(status.active_connections, 0);
        assert!(status.configured_providers.is_empty());
    }

    #[tokio::test]
    async fn test_mock_mcp_provider_reinitialize_after_shutdown() {
        if !is_python_available().await {
            eprintln!("python3 not available, skipping mock MCP reinitialize test");
            return;
        }

        let script_path = mock_mcp_server_path();
        assert!(script_path.exists(), "mock MCP server script should exist");

        let mut mcp_client = McpClient::new(build_mock_mcp_config(&script_path));
        assert!(mcp_client.initialize().await.is_ok());
        assert_eq!(mcp_client.list_tools().await.unwrap().len(), 1);
        assert!(mcp_client.shutdown().await.is_ok());

        // A fresh initialize after shutdown should reconnect and rebuild indices.
        assert!(mcp_client.initialize().await.is_ok());
        let tools = mcp_client.list_tools().await.unwrap();
        assert_eq!(tools.len(), 1);
        assert_eq!(tools[0].name, "echo");

        let result = mcp_client
            .execute_tool("echo", serde_json::json!({ "message": "again" }))
            .await
            .unwrap();
        let content = result
            .get("content")
            .and_then(|v| v.as_array())
            .expect("tool result should contain content");
        let first_text = content
            .first()
            .and_then(|v| v.get("text"))
            .and_then(|v| v.as_str());
        assert_eq!(first_text, Some("echo:again"));
    }

    #[tokio::test]
    async fn test_mock_mcp_shutdown_is_idempotent() {
        if !is_python_available().await {
            eprintln!("python3 not available, skipping mock MCP shutdown idempotency test");
            return;
        }

        let script_path = mock_mcp_server_path();
        assert!(script_path.exists(), "mock MCP server script should exist");

        let mut mcp_client = McpClient::new(build_mock_mcp_config(&script_path));
        assert!(mcp_client.initialize().await.is_ok());
        assert!(mcp_client.shutdown().await.is_ok());
        assert!(mcp_client.shutdown().await.is_ok());

        let status = mcp_client.get_status();
        assert_eq!(status.provider_count, 0);
        assert_eq!(status.active_connections, 0);
        assert!(status.configured_providers.is_empty());
    }

    #[test]
    fn test_mcp_ui_modes() {
        use vtcode_core::config::mcp::McpUiMode;

        let compact_config = vtcode_core::config::mcp::McpUiConfig {
            mode: McpUiMode::Compact,
            max_events: 25,
            show_provider_names: false,
            renderers: HashMap::new(),
        };

        let full_config = vtcode_core::config::mcp::McpUiConfig {
            mode: McpUiMode::Full,
            max_events: 100,
            show_provider_names: true,
            renderers: HashMap::new(),
        };

        assert_eq!(compact_config.mode, McpUiMode::Compact);
        assert_eq!(full_config.mode, McpUiMode::Full);
        assert!(!compact_config.show_provider_names);
        assert!(full_config.show_provider_names);
        assert_eq!(compact_config.max_events, 25);
        assert_eq!(full_config.max_events, 100);
    }
}